Documentation
¶
Index ¶
- func NewSubscriber(log logrus.FieldLogger, logLevel logrus.Level, cfg Config, client castaiClient, ...) controller.ObjectSubscriber
- func ResyncObserver(ctx context.Context, log logrus.FieldLogger, snaphotProvider SnapshotProvider, ...) telemetry.Observer
- type Config
- type SnapshotProvider
- type Subscriber
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewSubscriber ¶
func NewSubscriber( log logrus.FieldLogger, logLevel logrus.Level, cfg Config, client castaiClient, stateProvider SnapshotProvider, k8sVersionMinor int, ) controller.ObjectSubscriber
func ResyncObserver ¶
func ResyncObserver( ctx context.Context, log logrus.FieldLogger, snaphotProvider SnapshotProvider, client castai.Client, ) telemetry.Observer
Types ¶
type SnapshotProvider ¶
type SnapshotProvider interface {
// contains filtered or unexported methods
}
func NewSnapshotProvider ¶
func NewSnapshotProvider() SnapshotProvider
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
Source Files
Click to show internal directories.
Click to hide internal directories.