clients

Documentation

Index

• type NATSContext
  • func NewNATSContext(conf *config.Config) (*NATSContext, error)
  • func (n *NATSContext) Close()
  • func (n *NATSContext) CreateStream() (nats.JetStreamContext, error)
  • func (n *NATSContext) Publish(event []byte, repo string) error

Types

type NATSContext

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

func NewNATSContext

func NewNATSContext(conf *config.Config) (*NATSContext, error)

func (*NATSContext) Close

func (n *NATSContext) Close()

func (*NATSContext) CreateStream

func (n *NATSContext) CreateStream() (nats.JetStreamContext, error)

func (*NATSContext) Publish

func (n *NATSContext) Publish(event []byte, repo string) error