sources

Documentation

Index

• type EventsSourceManager
  • func NewEventSourceManager(log logr.Logger) *EventsSourceManager
  • func (mgr *EventsSourceManager) AddEventSource(source api.EventsSource)
  • func (mgr *EventsSourceManager) Events() <-chan *proto.Event
  • func (mgr *EventsSourceManager) Load() error
  • func (mgr *EventsSourceManager) RegisterContainer(nsId uint32, id *proto.SourceId) error
  • func (mgr *EventsSourceManager) Unload()

Types

type EventsSourceManager

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

func NewEventSourceManager

func NewEventSourceManager(log logr.Logger) *EventsSourceManager

func (*EventsSourceManager) AddEventSource

func (mgr *EventsSourceManager) AddEventSource(source api.EventsSource)

func (*EventsSourceManager) Events

func (mgr *EventsSourceManager) Events() <-chan *proto.Event

func (*EventsSourceManager) Load

func (mgr *EventsSourceManager) Load() error

func (*EventsSourceManager) RegisterContainer

func (mgr *EventsSourceManager) RegisterContainer(nsId uint32, id *proto.SourceId) error

func (*EventsSourceManager) Unload

func (mgr *EventsSourceManager) Unload()