vulinboxagentclient

Documentation

Index

• Constants
• type Client
  • func Connect(addr string, options ...Option) (*Client, error)
  • func (c *Client) Disconnect()
  • func (c *Client) MessageMux(bytes []byte)
  • func (c *Client) Msg() *MsgPrepare
  • func (c *Client) RegisterDataback(kind string, f func(any))
  • func (c *Client) Send(data any)
• type MsgPrepare
  • func (m *MsgPrepare) Callback(f func([]byte) error) *MsgPrepare
  • func (m *MsgPrepare) Send(data any)
• type Option
  • func WithOnClose(f func()) Option

Constants

const Expire = 10 * time.Second

Types

type Client

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

func Connect

func Connect(addr string, options ...Option) (*Client, error)

func (*Client) Disconnect

func (c *Client) Disconnect()

func (*Client) MessageMux

func (c *Client) MessageMux(bytes []byte)

func (*Client) Msg

func (c *Client) Msg() *MsgPrepare

func (*Client) RegisterDataback

func (c *Client) RegisterDataback(kind string, f func(any))

RegisterDataback register databack handler attention that no racing protect here, so you should register databack handler before connect

func (*Client) Send

func (c *Client) Send(data any)

type MsgPrepare

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

func (*MsgPrepare) Callback

func (m *MsgPrepare) Callback(f func([]byte) error) *MsgPrepare

func (*MsgPrepare) Send

func (m *MsgPrepare) Send(data any)

Send wants a pointer

type Option

type Option func(c *Client)

func WithOnClose

func WithOnClose(f func()) Option