messaging

Documentation

Index

• func NewNatsWithOpt(opts ...natsOpt) *natsClientOpt
• func WithJetStream(jetstream bool) natsOpt
• func WithServer(server string) natsOpt
• func WithServers(servers ...string) natsOpt
• type Message
• type NatsWarp
  • func (n *NatsWarp) Close()
  • func (n *NatsWarp) JetStream(opts ...nats.JSOpt) (nats.JetStreamContext, error)

Functions

func NewNatsWithOpt

func NewNatsWithOpt(opts ...natsOpt) *natsClientOpt

func WithJetStream

func WithJetStream(jetstream bool) natsOpt

func WithServer

func WithServer(server string) natsOpt

func WithServers

func WithServers(servers ...string) natsOpt

Types

type Message

type Message interface {
	Publish(subject string, msg []byte)
	Subscribe(subject string, callback func(msg []byte))
	SubscribeGroup(subject string, callback func(msg []byte))
}

type NatsWarp

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

func (*NatsWarp) Close

func (n *NatsWarp) Close()

func (*NatsWarp) JetStream

func (n *NatsWarp) JetStream(opts ...nats.JSOpt) (nats.JetStreamContext, error)