events

Documentation

Index

• func InitDefaults()
• type Stream
  • func NewAPIManagedEventStream(bgCtx context.Context, persistedSpec *apitypes.EventStream, ...) (ees Stream, err error)
  • func NewEventStream(bgCtx context.Context, persistedSpec *apitypes.EventStream, ...) (ees Stream, err error)

Functions

func InitDefaults

func InitDefaults()

Types

type Stream

type Stream = eventapi.EventStream

func NewAPIManagedEventStream

func NewAPIManagedEventStream(
	bgCtx context.Context,
	persistedSpec *apitypes.EventStream,
	connector ffcapi.API,
	listeners []*apitypes.Listener,
	eme metrics.EventMetricsEmitter,
) (ees Stream, err error)

func NewEventStream

func NewEventStream(
	bgCtx context.Context,
	persistedSpec *apitypes.EventStream,
	connector ffcapi.API,
	checkpointsDB persistence.CheckpointPersistence,
	wsChannels ws.WebSocketChannels,
	initialListeners []*apitypes.Listener,
	eme metrics.EventMetricsEmitter,
) (ees Stream, err error)