k8sevents

Documentation

Index

• type EventsCollector
  • func NewEventsCollector(clientset *kubernetes.Clientset, logger Logger) *EventsCollector
  • func (m *EventsCollector) RegisterSubscriber(aggregatorID, svcName, svcNamespace, port, namespace string)
  • func (m *EventsCollector) UnregisterByAggregatorID(aggregatorID string)
  • func (m *EventsCollector) UnregisterSubscriber(aggregatorID, svcName, svcNamespace string)
• type Logger

Types

type EventsCollector

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

func NewEventsCollector

func NewEventsCollector(clientset *kubernetes.Clientset, logger Logger) *EventsCollector

func (*EventsCollector) RegisterSubscriber

func (m *EventsCollector) RegisterSubscriber(aggregatorID, svcName, svcNamespace, port, namespace string)

func (*EventsCollector) UnregisterByAggregatorID

func (m *EventsCollector) UnregisterByAggregatorID(aggregatorID string)

func (*EventsCollector) UnregisterSubscriber

func (m *EventsCollector) UnregisterSubscriber(aggregatorID, svcName, svcNamespace string)

type Logger

type Logger interface {
	Info(msg string, keysAndValues ...any)
	Error(err error, msg string, keysAndValues ...any)
}