core

Documentation

Index

• type Client
  • func NewClient(host string, port int) *Client
  • func (cli *Client) Close() error
  • func (cli *Client) Do(request proto.Marshaler, response proto.Unmarshaler) error
• type Hub
  • func (hub *Hub) Do() error

Types

type Client

type Client struct {
	Host          string
	Port          int
	Timeout       time.Duration
	MaxRetryTimes int
	RetryDuration time.Duration
	// contains filtered or unexported fields
}

func NewClient

func NewClient(host string, port int) *Client

https://www.sohamkamani.com/golang/options-pattern/ https://lingchao.xin/post/functional-options-pattern-in-go.html NewBaseClient 创建BaseClient实例

func (*Client) Close

func (cli *Client) Close() error

func (*Client) Do

func (cli *Client) Do(request proto.Marshaler, response proto.Unmarshaler) error

type Hub

type Hub struct {
	Clients []Client
	// contains filtered or unexported fields
}

todo: 链接池，无感切换

func (*Hub) Do

func (hub *Hub) Do() error