()
| 52 | } |
| 53 | |
| 54 | func (s *StatsdMonitor) initStatsdClient() error { |
| 55 | if dfStatsdClient == nil { |
| 56 | var err error |
| 57 | dfStatsdClient, err = stats.NewUDPClient(stats.UDPConfig{ |
| 58 | Addr: net.JoinHostPort(s.host, strconv.Itoa(s.port)), |
| 59 | PayloadSize: 1400, |
| 60 | }) |
| 61 | if err != nil { |
| 62 | return fmt.Errorf("connect (%s:%d) stats udp server failed: %s", s.host, s.port, err.Error()) |
| 63 | } |
| 64 | } |
| 65 | return nil |
| 66 | } |
| 67 | |
| 68 | func (s *StatsdMonitor) RegisterStatsdTable(stable Statsdtable) { |
| 69 | if !s.enable { |
no test coverage detected