eventstore

Documentation

Index

• type Lister
• type Store
  • func NewStore(apiClient apiClient, gracePeriod time.Duration, logger *zap.Logger) Store

Types

type Lister

type Lister interface {
	// List gives back the not-handled event list which is sorted by newest.
	ListNotHandled(name string, labels map[string]string, minCreatedAt int64, limit int) []*model.Event
}

type Store

type Store interface {
	// Run starts syncing the event list with the control-plane.
	Run(ctx context.Context) error
	Lister() Lister
}

func NewStore

func NewStore(apiClient apiClient, gracePeriod time.Duration, logger *zap.Logger) Store

NewStore creates a new event store instance. This syncs with the control plane to keep the list of events for this runner up-to-date.