code: func statsdConnector(metrics []producers.MetricsMessage, c *cli.Context) error {
  	once.Do(func() {
  		statsdHost := c.String("statsd-udp-host")
  		statsdPort := c.Int("statsd-udp-port")
  
  		log.Infof("Setting up new statsd client %s:%d", statsdHost, statsdPort)
  		statsdClient = statsd.New(statsdHost, statsdPort)
  	})
  
  	if len(metrics) == 0 {
  		log.Info("No messages received from metrics service")
  		return nil
  	}
  	for _, message := range metrics {
  		log.Debugf("Sending %d datapoints to statsd server...", len(message.Datapoints))
  		emitDatapointsOverStatsd(message.Datapoints, statsdClient)
  	}
  
  	return nil
  }
docs: // statsdConnector is the method called by the plugin every time it retrieves
  // metrics from the API.