code: func newSink(c influxdb_common.InfluxdbConfig) core.DataSink {
  	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,
  		conChan: make(chan struct{}, c.Concurrency),
  	}
  }
docs: // Returns a thread-compatible implementation of influxdb interactions.