eventRouter

Documentation

Index

• func StreamEventMatch(stream *model.StreamStateRecord, event *model.EventRecord) bool
• type EventRouter
  • func NewRouter(provider dbProviders.DbProviderInterface) EventRouter

Functions

func StreamEventMatch

func StreamEventMatch(stream *model.StreamStateRecord, event *model.EventRecord) bool

StreamEventMatch checks provided event to see if it should be routed to the selected stream. If the aud or iss value is not specified for the stream is will be considered a wildcard. If the event has no value for aud or iss, they too will be considered a wildcard leading to the event being a match.

Types

type EventRouter

type EventRouter interface {
	UpdateStreamState(stream *model.StreamStateRecord)
	RemoveStream(sid string)
	HandleEvent(eventToken *goSet.SecurityEventToken, rawEvent string, sid string) error
	//	PushStreamHandler(stream *model.StreamStateRecord, eventBuf *buffer.EventPushBuffer)
	PollStreamHandler(sid string, params model.PollParameters) (map[string]string, bool, int)
	Shutdown()
	SetEventCounter(inCounter, outCounter *prometheus.CounterVec)
	GetPushStreamCnt() float64
	GetPollStreamCnt() float64
	IncrementCounter(stream *model.StreamStateRecord, token *goSet.SecurityEventToken, inBound bool)
}

func NewRouter

func NewRouter(provider dbProviders.DbProviderInterface) EventRouter