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, tls *v1alpha1.TLSConfig) (*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
Source Files
Click to show internal directories.
Click to hide internal directories.