kubebench

Documentation

Index

• func NewSubscriber(log logrus.FieldLogger, client kubernetes.Interface, castaiNamespace string, ...) controller.ObjectSubscriber
• type Subscriber
  • func (s *Subscriber) OnAdd(obj controller.Object)
  • func (s *Subscriber) OnDelete(obj controller.Object)
  • func (s *Subscriber) OnUpdate(obj controller.Object)
  • func (s *Subscriber) RequiredInformers() []reflect.Type
  • func (s *Subscriber) Run(ctx context.Context) error

Functions

func NewSubscriber

func NewSubscriber(
	log logrus.FieldLogger,
	client kubernetes.Interface,
	castaiNamespace string,
	provider string,
	scanInterval time.Duration,
	castClient castai.Client,
	logsReader log.PodLogProvider,
	scannedNodes []string,
) controller.ObjectSubscriber

Types

type Subscriber

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

func (*Subscriber) OnAdd

func (s *Subscriber) OnAdd(obj controller.Object)

func (*Subscriber) OnDelete

func (s *Subscriber) OnDelete(obj controller.Object)

func (*Subscriber) OnUpdate

func (s *Subscriber) OnUpdate(obj controller.Object)

func (*Subscriber) RequiredInformers

func (s *Subscriber) RequiredInformers() []reflect.Type

func (*Subscriber) Run

func (s *Subscriber) Run(ctx context.Context) error