client

type Cfg struct {
	// dial
	DialAddrs          []string      `toml:"addrs"`
	DialServerName     string        `toml:"server_name"` // default `Server`
	DialDiscovery      string        `toml:"discovery"`
	DialFailMode       string        `toml:"fail_mode"`
	DialSelectMode     string        `toml:"select_mode"`
	DialConnectTimeout time.Duration `toml:"dial_timeout"`

	// discovery, only support zookeeper
	DiscoveryBasePath string `toml:"discovery_base_path"` // only discovery

	// pool
	PoolMaxActive int `toml:"pool_max_active"` // 最大活跃连接数
}

type Message interface {
	proto.Message
	GetHeader() *pb.Header
}