recorder

type Event ¶

type Event struct {
	InvolvedObjectMeta api.Metadata
	Type               string
	Reason             string
	Action             string
	Message            string
	EventTime          int64
}

type EventRecorder ¶

type EventRecorder interface {
	Eventf(apiMetadata api.Metadata, eventType, reason, action, messageFormat string, args ...any)
}

EventRecorder defines an interface for recording events.

The action argument names the operation the reporter performed (e.g. "Destroy", "AttachVolume", "Pull") and is distinct from reason, which names the outcome. It must be non-empty: downstream consumers publish events into the events.k8s.io/v1 API where action is a required field.

type EventStore ¶

type EventStore interface {
	ListEvents() []*Event
}

EventStore defines an interface for listing events

type EventStoreOptions ¶

type EventStoreOptions struct {
	MaxEvents      int
	TTL            time.Duration
	ResyncInterval time.Duration
}

EventStoreOptions defines options to initialize the machine event store

func (o *EventStoreOptions) Defaults()

type Store ¶

type Store struct {
	// contains filtered or unexported fields
}

Store implements the EventRecorder and EventStore interface and represents an in-memory event store with TTL for events.

func NewEventStore(log logr.Logger, opts EventStoreOptions) *Store

func (es *Store) Eventf(apiMetadata api.Metadata, eventType, reason, action, messageFormat string, args ...any)

func (es *Store) ListEvents() []*Event

func (es *Store) Start(ctx context.Context)