code: func newSink(c influxdb_common.InfluxdbConfig) core.EventSink {
  	client, err := influxdb_common.NewClient(c)
  	if err != nil {
  		glog.Errorf("issues while creating an InfluxDB sink: %v, will retry on use", err)
  	}
  	return &influxdbSink{
  		client: client, // can be nil
  		c:      c,
  	}
  }
docs: // Returns a thread-safe implementation of core.EventSink for InfluxDB.