eventsource

Documentation

Index

• type STANSourceConn
  • func (n *STANSourceConn) Publish(ctx context.Context, msg eventbuscommon.Message) error
• type SourceSTAN
  • func NewSourceSTAN(url, clusterID, eventSourceName string, subject string, ...) *SourceSTAN
  • func (n *SourceSTAN) Connect(clientID string) (eventbuscommon.EventSourceConnection, error)
  • func (n *SourceSTAN) Initialize() error

Types

type STANSourceConn

type STANSourceConn struct {
	*stanbase.STANConnection
	// contains filtered or unexported fields
}

func (*STANSourceConn) Publish

func (n *STANSourceConn) Publish(ctx context.Context,
	msg eventbuscommon.Message) error

type SourceSTAN

type SourceSTAN struct {
	*stanbase.STAN
	// contains filtered or unexported fields
}

func NewSourceSTAN

func NewSourceSTAN(url, clusterID, eventSourceName string, subject string, auth *eventbuscommon.Auth, logger *zap.SugaredLogger) *SourceSTAN

func (*SourceSTAN) Connect

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

func (*SourceSTAN) Initialize

func (n *SourceSTAN) Initialize() error