kcc

Documentation

Overview

Package kcc is the package that is responsible to maintain the configuration of dynamic config for agents including katalyst-agent/qrm/sys-advisor and so on.

Index

• type CustomNodeConfigController
  • func NewCustomNodeConfigController(ctx context.Context, genericConf *generic.GenericConfiguration, ...) (*CustomNodeConfigController, error)
  • func (c *CustomNodeConfigController) Run()
• type KatalystCustomConfigController
  • func NewKatalystCustomConfigController(ctx context.Context, genericConf *generic.GenericConfiguration, ...) (*KatalystCustomConfigController, error)
  • func (k *KatalystCustomConfigController) Run()
• type KatalystCustomConfigTargetController
  • func NewKatalystCustomConfigTargetController(ctx context.Context, genericConf *generic.GenericConfiguration, ...) (*KatalystCustomConfigTargetController, error)
  • func (k *KatalystCustomConfigTargetController) Run()

Types

type CustomNodeConfigController

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

func NewCustomNodeConfigController

func NewCustomNodeConfigController(
	ctx context.Context,
	genericConf *generic.GenericConfiguration,
	_ *controller.GenericControllerConfiguration,
	kccConfig *controller.KCCConfig,
	client *kcclient.GenericClientSet,
	customNodeConfigInformer configinformers.CustomNodeConfigInformer,
	metricsEmitter metrics.MetricEmitter,
	targetHandler *kcctarget.KatalystCustomConfigTargetHandler,
) (*CustomNodeConfigController, error)

func (*CustomNodeConfigController) Run

func (c *CustomNodeConfigController) Run()

type KatalystCustomConfigController

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

func NewKatalystCustomConfigController

func NewKatalystCustomConfigController(
	ctx context.Context,
	genericConf *generic.GenericConfiguration,
	_ *controller.GenericControllerConfiguration,
	kccConfig *controller.KCCConfig,
	client *kcclient.GenericClientSet,
	katalystCustomConfigInformer configinformers.KatalystCustomConfigInformer,
	metricsEmitter metrics.MetricEmitter,
	targetHandler *kcctarget.KatalystCustomConfigTargetHandler,
) (*KatalystCustomConfigController, error)

func (*KatalystCustomConfigController) Run

func (k *KatalystCustomConfigController) Run()

type KatalystCustomConfigTargetController

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

func NewKatalystCustomConfigTargetController

func NewKatalystCustomConfigTargetController(
	ctx context.Context,
	genericConf *generic.GenericConfiguration,
	_ *controller.GenericControllerConfiguration,
	kccConfig *controller.KCCConfig,
	client *kcclient.GenericClientSet,
	katalystCustomConfigInformer configinformers.KatalystCustomConfigInformer,
	metricsEmitter metrics.MetricEmitter,
	targetHandler *kcctarget.KatalystCustomConfigTargetHandler,
) (*KatalystCustomConfigTargetController, error)

func (*KatalystCustomConfigTargetController) Run

func (k *KatalystCustomConfigTargetController) Run()

Run don't need to trigger reconcile logic.