client

Documentation

Index

• type Client
  • func NewClient(opts *Options) *Client
  • func (c *Client) Call(ctx context.Context, seq uint64, buf buffer.Buffer, idx ...int64) ([]byte, error)
  • func (c *Client) Send(ctx context.Context, buf buffer.Buffer, idx ...int64) error
• type Conn
• type Options

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(opts *Options) *Client

func (*Client) Call

func (c *Client) Call(ctx context.Context, seq uint64, buf buffer.Buffer, idx ...int64) ([]byte, error)

Call 调用

func (*Client) Send

func (c *Client) Send(ctx context.Context, buf buffer.Buffer, idx ...int64) error

Send 发送

type Conn

type Conn struct {
	// contains filtered or unexported fields
}

type Options

type Options struct {
	Addr         string       // 连接地址
	InsID        string       // 实例ID
	InsKind      cluster.Kind // 实例类型
	CloseHandler func()       // 关闭处理器
}