comm

Documentation

Index

• type HandlerContext
• type NatsClient
  • func Dial(opts *NatsClientOpts) (*NatsClient, error)
  • func (c *NatsClient) Broadcast(channel string) error
  • func (c *NatsClient) Call(channel string, device string, data []byte) error
  • func (c *NatsClient) Close() error
  • func (c *NatsClient) HandleBroadcast(channel string, handler nats.MsgHandler) error
  • func (c *NatsClient) IsConnected() bool
  • func (c *NatsClient) Request(channel string, device string, data []byte) ([]byte, error)
• type NatsClientOpts

Types

type HandlerContext

type HandlerContext struct {
	JetStream nats.JetStreamContext
}

type NatsClient

type NatsClient struct {
	JetStream nats.JetStreamContext
	// contains filtered or unexported fields
}

func Dial

func Dial(opts *NatsClientOpts) (*NatsClient, error)

func (*NatsClient) Broadcast

func (c *NatsClient) Broadcast(channel string) error

func (*NatsClient) Call

func (c *NatsClient) Call(channel string, device string, data []byte) error

func (*NatsClient) Close

func (c *NatsClient) Close() error

func (*NatsClient) HandleBroadcast

func (c *NatsClient) HandleBroadcast(channel string, handler nats.MsgHandler) error

func (*NatsClient) IsConnected

func (c *NatsClient) IsConnected() bool

func (*NatsClient) Request

func (c *NatsClient) Request(channel string, device string, data []byte) ([]byte, error)

type NatsClientOpts

type NatsClientOpts struct {
	Root             string
	NatsUrl          string
	NatsOptions      []nats.Option
	JetStreamOptions []nats.JSOpt
}