Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) 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
Click to show internal directories.
Click to hide internal directories.