Versions in this module Expand all Collapse all v0 v0.7.0 Nov 17, 2023 Changes in this version + func StreamEventMatch(stream *model.StreamStateRecord, event *model.EventRecord) bool + type EventRouter interface + GetPollStreamCnt func() float64 + GetPushStreamCnt func() float64 + HandleEvent func(eventToken *goSet.SecurityEventToken, rawEvent string, sid string) error + IncrementCounter func(stream *model.StreamStateRecord, token *goSet.SecurityEventToken, inBound bool) + PollStreamHandler func(sid string, params model.PollParameters) (map[string]string, bool, int) + RemoveStream func(sid string) + SetEventCounter func(inCounter, outCounter *prometheus.CounterVec) + Shutdown func() + UpdateStreamState func(stream *model.StreamStateRecord) + func NewRouter(provider dbProviders.DbProviderInterface) EventRouter
Go to main page