code: func (f *Fluent) connect() (err error) {
  
  	switch f.Config.FluentNetwork {
  	case "tcp":
  		f.conn, err = net.DialTimeout(f.Config.FluentNetwork, f.Config.FluentHost+":"+strconv.Itoa(f.Config.FluentPort), f.Config.Timeout)
  	case "unix":
  		f.conn, err = net.DialTimeout(f.Config.FluentNetwork, f.Config.FluentSocketPath, f.Config.Timeout)
  	default:
  		err = net.UnknownNetworkError(f.Config.FluentNetwork)
  	}
  	return err
  }
docs: // connect establishes a new connection using the specified transport.