delta

Documentation

Index

• func ResyncObserver(ctx context.Context, log logrus.FieldLogger, snaphotProvider SnapshotProvider, ...) telemetry.Observer
• type Config
• type Controller
  • func NewController(log logrus.FieldLogger, logLevel logrus.Level, cfg Config, client castaiClient, ...) *Controller
  • func (s *Controller) OnAdd(obj kube.Object)
  • func (s *Controller) OnDelete(obj kube.Object)
  • func (s *Controller) OnUpdate(obj kube.Object)
  • func (s *Controller) RequiredInformers() []reflect.Type
  • func (s *Controller) Run(ctx context.Context) error
• type SnapshotProvider
  • func NewSnapshotProvider() SnapshotProvider

Functions

func ResyncObserver

func ResyncObserver(
	ctx context.Context,
	log logrus.FieldLogger,
	snaphotProvider SnapshotProvider,
	client castai.Client,
) telemetry.Observer

Types

type Config

type Config struct {
	DeltaSyncInterval time.Duration
}

type Controller

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

func NewController

func NewController(
	log logrus.FieldLogger,
	logLevel logrus.Level,
	cfg Config, client castaiClient,
	stateProvider SnapshotProvider,
	k8sVersionMinor int,
	podOwnerGetter podOwnerGetter,
) *Controller

func (*Controller) OnAdd

func (s *Controller) OnAdd(obj kube.Object)

func (*Controller) OnDelete

func (s *Controller) OnDelete(obj kube.Object)

func (*Controller) OnUpdate

func (s *Controller) OnUpdate(obj kube.Object)

func (*Controller) RequiredInformers

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

func (*Controller) Run

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

type SnapshotProvider

type SnapshotProvider interface {
	// contains filtered or unexported methods
}

func NewSnapshotProvider

func NewSnapshotProvider() SnapshotProvider