nats

Documentation

Index

• func WithoutJetstream(nc *NatsConnection)
• type NatsConnection
  • func DefaultNatsConnection() *NatsConnection
  • func New(optFuncs ...NatsConnectionOption) *NatsConnection
  • func (n *NatsConnection) Close()
  • func (n *NatsConnection) Connect() error
  • func (n *NatsConnection) GenericCommandSubscriber(logger *slog.Logger, commandName string, handler func([]byte) error)
  • func (n *NatsConnection) GenericNfcSubscriber(logger *slog.Logger, tagId string, handler func([]byte) error)
  • func (n *NatsConnection) GenericScheduleSubscriber(logger *slog.Logger, scheduleName string, handler func() error)
  • func (n *NatsConnection) GenericStateSubscriber(logger *slog.Logger, entityId string, handler func(ha.StateData) error)
  • func (n *NatsConnection) GenericTimerSubscriber(logger *slog.Logger, timerName string, handler func() error)
  • func (n *NatsConnection) GenericZhaSubscriber(logger *slog.Logger, deviceIeee string, handler func(ha.EventData) error)
  • func (n *NatsConnection) GenericZwaveLSubscriber(logger *slog.Logger, deviceId string, scene bool, ...)
  • func (n *NatsConnection) Publish(ctx context.Context, subject string, payload []byte, ...)
  • func (n *NatsConnection) Stream(ctx context.Context, subject string) (stream jetstream.Stream, consumer jetstream.Consumer, err error)
  • func (n *NatsConnection) Subscribe(subject string) (sub *nats.Subscription, ch chan *nats.Msg, err error)
• type NatsConnectionOption
  • func WithClientName(name string) NatsConnectionOption
  • func WithConnectionOption(opt nats.Option) NatsConnectionOption
  • func WithHostName(hostname string) NatsConnectionOption
  • func WithJetstreamnOption(opt jetstream.JetStreamOpt) NatsConnectionOption
  • func WithPort(port string) NatsConnectionOption
  • func WithToken(token string) NatsConnectionOption

Functions

func WithoutJetstream

func WithoutJetstream(nc *NatsConnection)

Types

type NatsConnection

type NatsConnection struct {
	HostName     string
	Port         string
	UseJetstream bool

	Conn *nats.Conn
	JS   jetstream.JetStream
	// contains filtered or unexported fields
}

func DefaultNatsConnection

func DefaultNatsConnection() *NatsConnection

func New

func New(optFuncs ...NatsConnectionOption) *NatsConnection

func (*NatsConnection) Close

func (n *NatsConnection) Close()

func (*NatsConnection) Connect

func (n *NatsConnection) Connect() error

func (*NatsConnection) GenericCommandSubscriber

func (n *NatsConnection) GenericCommandSubscriber(logger *slog.Logger, commandName string, handler func([]byte) error)

func (*NatsConnection) GenericNfcSubscriber

func (n *NatsConnection) GenericNfcSubscriber(logger *slog.Logger, tagId string, handler func([]byte) error)

func (*NatsConnection) GenericScheduleSubscriber

func (n *NatsConnection) GenericScheduleSubscriber(logger *slog.Logger, scheduleName string, handler func() error)

func (*NatsConnection) GenericStateSubscriber

func (n *NatsConnection) GenericStateSubscriber(logger *slog.Logger, entityId string, handler func(ha.StateData) error)

func (*NatsConnection) GenericTimerSubscriber

func (n *NatsConnection) GenericTimerSubscriber(logger *slog.Logger, timerName string, handler func() error)

func (*NatsConnection) GenericZhaSubscriber

func (n *NatsConnection) GenericZhaSubscriber(logger *slog.Logger, deviceIeee string, handler func(ha.EventData) error)

func (*NatsConnection) GenericZwaveLSubscriber

func (n *NatsConnection) GenericZwaveLSubscriber(logger *slog.Logger, deviceId string, scene bool, handler func(ha.EventData) error)

func (*NatsConnection) Publish

func (n *NatsConnection) Publish(ctx context.Context, subject string, payload []byte, opts ...jetstream.PublishOpt)

func (*NatsConnection) Stream

func (n *NatsConnection) Stream(ctx context.Context, subject string) (stream jetstream.Stream, consumer jetstream.Consumer, err error)

func (*NatsConnection) Subscribe

func (n *NatsConnection) Subscribe(subject string) (sub *nats.Subscription, ch chan *nats.Msg, err error)

type NatsConnectionOption

type NatsConnectionOption func(*NatsConnection)

func WithClientName

func WithClientName(name string) NatsConnectionOption

func WithConnectionOption

func WithConnectionOption(opt nats.Option) NatsConnectionOption

func WithHostName

func WithHostName(hostname string) NatsConnectionOption

func WithJetstreamnOption

func WithJetstreamnOption(opt jetstream.JetStreamOpt) NatsConnectionOption

func WithPort

func WithPort(port string) NatsConnectionOption

func WithToken

func WithToken(token string) NatsConnectionOption