events

Mar 5, 2024

Changes in this version

+ func CreateUserGroupEventRecord(objectID, message, referenceID string, changeType si.EventRecord_ChangeType, ...) *si.EventRecord

+ type EventStream struct

+ Events <-chan *si.EventRecord

+ type EventStreamData struct

+ CreatedAt time.Time

+ Name string

+ type EventStreaming struct

+ func NewEventStreaming(eventBuffer *eventRingBuffer) *EventStreaming

+ func (e *EventStreaming) Close()

+ func (e *EventStreaming) CreateEventStream(name string, count uint64) *EventStream

+ func (e *EventStreaming) GetEventStreams() []EventStreamData

+ func (e *EventStreaming) PublishEvent(event *si.EventRecord)

+ func (e *EventStreaming) RemoveEventStream(consumer *EventStream)

type EventSystem

+ CreateEventStream func(name string, count uint64) *EventStream

+ GetEventStreams func() []EventStreamData

+ RemoveStream func(*EventStream)

type EventSystemImpl

+ func (ec *EventSystemImpl) CloseAllStreams()

+ func (ec *EventSystemImpl) CreateEventStream(name string, count uint64) *EventStream

+ func (ec *EventSystemImpl) GetEventStreams() []EventStreamData

+ func (ec *EventSystemImpl) RemoveStream(consumer *EventStream)

Nov 14, 2023

Changes in this version

+ func Init()

+ type EventSystem interface

+ AddEvent func(event *si.EventRecord)

+ GetEventsFromID func(uint64, uint64) ([]*si.EventRecord, uint64, uint64)

+ IsEventTrackingEnabled func() bool

+ StartService func()

+ Stop func()

+ func GetEventSystem() EventSystem

+ type EventSystemImpl struct

+ Store *EventStore

+ func (ec *EventSystemImpl) AddEvent(event *si.EventRecord)

+ func (ec *EventSystemImpl) GetEventsFromID(id, count uint64) ([]*si.EventRecord, uint64, uint64)

+ func (ec *EventSystemImpl) GetRequestCapacity() int

+ func (ec *EventSystemImpl) GetRingBufferCapacity() uint64

+ func (ec *EventSystemImpl) IsEventTrackingEnabled() bool

+ func (ec *EventSystemImpl) Restart()

+ func (ec *EventSystemImpl) StartService()

+ func (ec *EventSystemImpl) StartServiceWithPublisher(withPublisher bool)

+ func (ec *EventSystemImpl) Stop()

Apr 26, 2022

Changes in this version

+ func CreateAndSetEventCache()

+ func CreateAppEventRecord(objectID, reason, message string) (*si.EventRecord, error)

+ func CreateNodeEventRecord(objectID, reason, message string) (*si.EventRecord, error)

+ func CreateQueueEventRecord(objectID, groupID, reason, message string) (*si.EventRecord, error)

+ func CreateRequestEventRecord(objectID, groupID, reason, message string) (*si.EventRecord, error)

+ type EventCache struct

+ Store EventStore

+ func GetEventCache() *EventCache

+ func (ec *EventCache) AddEvent(event *si.EventRecord)

+ func (ec *EventCache) StartService()

+ func (ec *EventCache) Stop()

+ type EventPublisher interface

+ StartService func()

+ Stop func()

+ func CreateShimPublisher(store EventStore) EventPublisher

+ type EventStore interface

+ CollectEvents func() []*si.EventRecord

+ CountStoredEvents func() int

+ Store func(event *si.EventRecord)