code: func GetRiemannClient(config RiemannConfig) (riemanngo.Client, error) {
  	glog.Infof("Connect Riemann client...")
  	client := riemanngo.NewTcpClient(config.Host)
  	runtime.SetFinalizer(client, func(c riemanngo.Client) { c.Close() })
  	// 5 seconds timeout
  	err := client.Connect(5)
  	if err != nil {
  		return nil, err
  	}
  	return client, nil
  }
docs: // Receives a sink, connect the riemann client.