client

Sep 3, 2021

Changes in this version

+ type AddressFetcher func() (string, error)

type Client

+ func (c *Client) FetchAddress() (err error)

type Options

+ AddressFetcher AddressFetcher

Aug 29, 2021

Changes in this version

+ type Client struct

+ func NewClient(opts *Options) (c *Client, err error)

+ func (c *Client) Ack(event string, v interface{}, r interface{}) (err error)

+ func (c *Client) Close()

+ func (c *Client) Emit(event string, v interface{}) (err error)

+ func (c *Client) IsClosed() bool

+ func (c *Client) MustStart()

+ func (c *Client) On(e string, fn EventHandler)

+ func (c *Client) RemoteAddr() string

+ func (c *Client) Start() error

+ type Context interface

+ Ack func(event string, v interface{}, r interface{}) error

+ Bind func(v interface{}) error

+ Close func()

+ Content func() []byte

+ Emit func(event string, v interface{}) error

+ IsClosed func() bool

+ Logger func() air.Logger

+ Packet func() air.Packet

+ Reply func(v interface{}) error

+ type EventHandler func(c Context) error

+ type Options struct

+ Address string

+ Codec air.Codec

+ HeartbeatInterval time.Duration

+ Logger air.Logger

+ MessageTimeout time.Duration

+ PacketReceiveChanLimit uint32

+ PacketSendChanLimit uint32

+ Reconnect bool

+ ReconnectInterval time.Duration

+ ReconnectLimit uint32

+ WorkId uint16

+ func DefaultOptions() *Options