liteclient

Documentation

Index

• Constants
• Variables
• type Client
  • func NewClient() *Client
  • func (c *Client) Connect(ctx context.Context, addr, serverKey string) error
  • func (c *Client) DefaultReconnect(waitBeforeReconnect time.Duration, maxTries int) OnDisconnectCallback
  • func (c *Client) Do(ctx context.Context, typeID int32, payload []byte) (*LiteResponse, error)
  • func (c *Client) SetOnDisconnect(cb OnDisconnectCallback)
• type LiteRequest
• type LiteResponse
• type OnDisconnectCallback

Constants

const ADNLQuery int32 = -1265895046

const ADNLQueryResponse int32 = 262964246

const LiteServerQuery int32 = 2039219935

const TCPPing int32 = 1292381082

const TCPPong int32 = -597034237

Variables

var ErrNoActiveConnections = errors.New("no active connections")

Types

type Client

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

func NewClient

func NewClient() *Client

func (*Client) Connect

func (c *Client) Connect(ctx context.Context, addr, serverKey string) error

func (*Client) DefaultReconnect

func (c *Client) DefaultReconnect(waitBeforeReconnect time.Duration, maxTries int) OnDisconnectCallback

func (*Client) Do

func (c *Client) Do(ctx context.Context, typeID int32, payload []byte) (*LiteResponse, error)

func (*Client) SetOnDisconnect

func (c *Client) SetOnDisconnect(cb OnDisconnectCallback)

type LiteRequest

type LiteRequest struct {
	TypeID   int32
	QueryID  []byte
	Data     []byte
	RespChan chan *LiteResponse
}

type LiteResponse

type LiteResponse struct {
	TypeID int32
	Data   []byte
	// contains filtered or unexported fields
}

type OnDisconnectCallback

type OnDisconnectCallback func(addr, key string)