delta

Documentation

Index

• type Config
• type Controller
  • func NewController(log *logging.Logger, cfg Config, castaiClient castaiClient, ...) *Controller
  • func (c *Controller) OnAdd(obj kube.Object)
  • func (c *Controller) OnDelete(obj kube.Object)
  • func (c *Controller) OnUpdate(obj kube.Object)
  • func (c *Controller) RequiredTypes() []reflect.Type
  • func (c *Controller) Run(ctx context.Context) error

Types

type Config

type Config struct {
	Enabled        bool          `json:"enabled"`
	Interval       time.Duration `validate:"required" json:"interval"`
	InitialDeltay  time.Duration `json:"initialDeltay"`
	SendTimeout    time.Duration `validate:"required" json:"sendTimeout"`
	UseCompression bool          `json:"useCompression"`
	BatchSize      int           `validate:"required" json:"batchSize"`
}

type Controller

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

func NewController

func NewController(
	log *logging.Logger,
	cfg Config,
	castaiClient castaiClient,
	kubeClient kubeClient,
) *Controller

func (*Controller) OnAdd

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

func (*Controller) OnDelete

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

func (*Controller) OnUpdate

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

func (*Controller) RequiredTypes

func (c *Controller) RequiredTypes() []reflect.Type

func (*Controller) Run

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