base

Documentation

Index

• type Jetstream
  • func NewJetstream(url string, streamSettings string, auth *eventbuscommon.Auth, ...) (*Jetstream, error)
  • func (stream *Jetstream) CreateStream(conn *JetstreamConnection) error
  • func (stream *Jetstream) Init() error
  • func (stream *Jetstream) MakeConnection() (*JetstreamConnection, error)
• type JetstreamConnection
  • func (jsc *JetstreamConnection) Close() error
  • func (jsc *JetstreamConnection) IsClosed() bool

Types

type Jetstream

type Jetstream struct {
	MgmtConnection JetstreamConnection

	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

func NewJetstream

func NewJetstream(url string, streamSettings string, auth *eventbuscommon.Auth, logger *zap.SugaredLogger) (*Jetstream, error)

func (*Jetstream) CreateStream

func (stream *Jetstream) CreateStream(conn *JetstreamConnection) error

func (*Jetstream) Init

func (stream *Jetstream) Init() error

func (*Jetstream) MakeConnection

func (stream *Jetstream) MakeConnection() (*JetstreamConnection, error)

type JetstreamConnection

type JetstreamConnection struct {
	NATSConn  *nats.Conn
	JSContext nats.JetStreamContext

	NATSConnected bool

	Logger *zap.SugaredLogger
}

func (*JetstreamConnection) Close

func (jsc *JetstreamConnection) Close() error

func (*JetstreamConnection) IsClosed

func (jsc *JetstreamConnection) IsClosed() bool