Versions in this module Expand all Collapse all v0 v0.7.0 Nov 17, 2023 Changes in this version + type EventBuf interface + Close func() + Cnt func() int + IsClosed func() bool + SubmitEvent func(jti string) + type EventPollBuffer struct + func CreateEventPollBuffer(initialJtis []string) *EventPollBuffer + func (b *EventPollBuffer) Close() + func (b *EventPollBuffer) Cnt() float64 + func (b *EventPollBuffer) GetEvents(params model.PollParameters) (*[]string, bool) + func (b *EventPollBuffer) IsClosed() bool + func (b *EventPollBuffer) SubmitEvent(jti string) + type EventPushBuffer struct + Out chan interface{} + func CreateEventPushBuffer(initialJtis []string) *EventPushBuffer + func (b *EventPushBuffer) Close() + func (b *EventPushBuffer) Cnt() float64 + func (b *EventPushBuffer) IsClosed() bool + func (b *EventPushBuffer) SubmitEvent(jti string)
Go to main page