eventsource

Documentation

Index

• type JetstreamSourceConn
  • func CreateJetstreamSourceConn(conn *jetstreambase.JetstreamConnection, eventSourceName string) *JetstreamSourceConn
  • func (conn *JetstreamSourceConn) Close() error
  • func (conn *JetstreamSourceConn) IsClosed() bool
  • func (jsc *JetstreamSourceConn) Publish(ctx context.Context, msg eventbuscommon.Message) error
• type SourceJetstream
  • func NewSourceJetstream(url, eventSourceName string, streamConfig string, auth *eventbuscommon.Auth, ...) (*SourceJetstream, error)
  • func (n *SourceJetstream) Connect(clientID string) (eventbuscommon.EventSourceConnection, error)
  • func (n *SourceJetstream) Initialize() error

Types

type JetstreamSourceConn

type JetstreamSourceConn struct {
	*jetstreambase.JetstreamConnection
	// contains filtered or unexported fields
}

func CreateJetstreamSourceConn

func CreateJetstreamSourceConn(conn *jetstreambase.JetstreamConnection, eventSourceName string) *JetstreamSourceConn

func (*JetstreamSourceConn) Close

func (conn *JetstreamSourceConn) Close() error

func (*JetstreamSourceConn) IsClosed

func (conn *JetstreamSourceConn) IsClosed() bool

func (*JetstreamSourceConn) Publish

func (jsc *JetstreamSourceConn) Publish(ctx context.Context,
	msg eventbuscommon.Message) error

type SourceJetstream

type SourceJetstream struct {
	*jetstreambase.Jetstream
	// contains filtered or unexported fields
}

func NewSourceJetstream

func NewSourceJetstream(url, eventSourceName string, streamConfig string, auth *eventbuscommon.Auth, logger *zap.SugaredLogger) (*SourceJetstream, error)

func (*SourceJetstream) Connect

func (n *SourceJetstream) Connect(clientID string) (eventbuscommon.EventSourceConnection, error)

func (*SourceJetstream) Initialize

func (n *SourceJetstream) Initialize() error