events

package

v1.3.0 Latest Latest Go to latest Published: May 31, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

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 // storing eventChannel

	sync.Mutex
	// contains filtered or unexported fields
}

func GetEventCache() *EventCache

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

func (ec *EventCache) StartService()

func (ec *EventCache) Stop()

type EventPublisher interface {
	StartService()
	Stop()
}

func CreateShimPublisher(store EventStore) EventPublisher

type EventStore interface {
	Store(event *si.EventRecord)
	CollectEvents() []*si.EventRecord
	CountStoredEvents() int
}

The EventStore operates under the following assumptions:

there is a cap for the number of events stored
the CollectEvents() function clears the currently stored events in the EventStore

Assuming the rate of events generated by the scheduler component in a given time period is high, calling CollectEvents() periodically should be fine.