client

Documentation

Index

• type Client
  • func NewClient(url *url.URL, log *zerolog.Logger) *Client
  • func (c *Client) Handshake(ctx context.Context) error
  • func (c *Client) SubscribeWithExt(ctx context.Context, channel string, ext map[string]any, ...) error
• type Subscriptions
  • func NewSubscriptions() *Subscriptions
  • func (s *Subscriptions) Add(channel string, callback func(*message.Message))

Types

type Client

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

func NewClient

func NewClient(url *url.URL, log *zerolog.Logger) *Client

func (*Client) Handshake

func (c *Client) Handshake(ctx context.Context) error

func (*Client) SubscribeWithExt

func (c *Client) SubscribeWithExt(ctx context.Context, channel string, ext map[string]any, callback func(*message.Message)) error

type Subscriptions

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

func NewSubscriptions

func NewSubscriptions() *Subscriptions

func (*Subscriptions) Add

func (s *Subscriptions) Add(channel string, callback func(*message.Message))