(data *pb.Stats)
| 139 | } |
| 140 | |
| 141 | func (s *StatsdMonitor) Send(data *pb.Stats) error { |
| 142 | if !s.enable { |
| 143 | return fmt.Errorf("statsd monitor diable") |
| 144 | } |
| 145 | |
| 146 | if err := s.initStatsdClient(); err != nil { |
| 147 | return err |
| 148 | } |
| 149 | |
| 150 | encoder := new(codec.SimpleEncoder) |
| 151 | data.Encode(encoder) |
| 152 | defer encoder.Reset() |
| 153 | if err := dfStatsdClient.Write(encoder.Bytes()); err != nil { |
| 154 | return err |
| 155 | } |
| 156 | return nil |
| 157 | } |