k8scontroller

Documentation

Index

• Constants
• func NewDeploymentController(name string, k8sConfig *rest.Config, configLoader k8s_utils.ClientConfigLoader, ...) error
• func NewRolloutsController(name string, k8sConfig *rest.Config, configLoader k8s_utils.ClientConfigLoader, ...) error
• func NewSecretController(name string, k8sConfig *rest.Config, configLoader k8s_utils.ClientConfigLoader, ...) error
• func NewServiceController(name string, k8sConfig *rest.Config, configLoader k8s_utils.ClientConfigLoader, ...) error
• type DeploymentController
  • func (s *DeploymentController) Added(ctx context.Context, obj interface{}, ...)
  • func (s *DeploymentController) Deleted(ctx context.Context, obj interface{}, ...)
  • func (s *DeploymentController) GetInformer() cache.SharedIndexInformer
  • func (s *DeploymentController) Status(ctx context.Context, eventStatus controller.EventProcessStatus)
  • func (s *DeploymentController) Updated(ctx context.Context, newObj interface{}, oldObj interface{}, ...)
• type RolloutsController
  • func (rc *RolloutsController) Added(ctx context.Context, obj interface{}, ...)
  • func (rc *RolloutsController) Deleted(ctx context.Context, obj interface{}, ...)
  • func (rc *RolloutsController) GetInformer() cache.SharedIndexInformer
  • func (rc *RolloutsController) Status(ctx context.Context, eventStatus controller.EventProcessStatus)
  • func (rc *RolloutsController) Updated(ctx context.Context, newObj interface{}, oldObj interface{}, ...)
• type SecretController
  • func (s *SecretController) Added(ctx context.Context, obj interface{}, ...)
  • func (s *SecretController) Deleted(ctx context.Context, obj interface{}, ...)
  • func (s *SecretController) GetInformer() cache.SharedIndexInformer
  • func (s *SecretController) Status(ctx context.Context, eventStatus controller.EventProcessStatus)
  • func (s *SecretController) Updated(ctx context.Context, newObj interface{}, oldObj interface{}, ...)
• type ServiceController
  • func (s *ServiceController) Added(ctx context.Context, obj interface{}, ...)
  • func (s *ServiceController) Deleted(ctx context.Context, obj interface{}, ...)
  • func (s *ServiceController) GetInformer() cache.SharedIndexInformer
  • func (s *ServiceController) Status(ctx context.Context, eventStatus controller.EventProcessStatus)
  • func (s *ServiceController) Updated(ctx context.Context, newObj interface{}, oldObj interface{}, ...)

Constants

const SecretControllerNameValue = "secret-controller"

Functions

func NewDeploymentController

func NewDeploymentController(
	name string,
	k8sConfig *rest.Config,
	configLoader k8s_utils.ClientConfigLoader,
	namespace string,
	listOpts metav1.ListOptions,
	resync time.Duration,
	handler handler.Handler,
) error

func NewRolloutsController

func NewRolloutsController(
	name string,
	k8sConfig *rest.Config,
	configLoader k8s_utils.ClientConfigLoader,
	namespace string,
	listOpts metav1.ListOptions,
	resync time.Duration,
	handler handler.Handler,
) error

func NewSecretController

func NewSecretController(
	name string,
	k8sConfig *rest.Config,
	configLoader k8s_utils.ClientConfigLoader,
	namespace string,
	listOpts metav1.ListOptions,
	resync time.Duration,
	handler handler.Handler,
) error

func NewServiceController

func NewServiceController(
	name string,
	k8sConfig *rest.Config,
	configLoader k8s_utils.ClientConfigLoader,
	namespace string,
	listOpts metav1.ListOptions,
	resync time.Duration,
	handler handler.Handler,
) error

Types

type DeploymentController

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

func (*DeploymentController) Added

func (s *DeploymentController) Added(ctx context.Context, obj interface{}, statusChan chan controller.EventProcessStatus)

func (*DeploymentController) Deleted

func (s *DeploymentController) Deleted(ctx context.Context, obj interface{}, statusChan chan controller.EventProcessStatus)

func (*DeploymentController) GetInformer

func (s *DeploymentController) GetInformer() cache.SharedIndexInformer

func (*DeploymentController) Status

func (s *DeploymentController) Status(ctx context.Context, eventStatus controller.EventProcessStatus)

func (*DeploymentController) Updated

func (s *DeploymentController) Updated(ctx context.Context, newObj interface{}, oldObj interface{}, statusChan chan controller.EventProcessStatus)

type RolloutsController

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

func (*RolloutsController) Added

func (rc *RolloutsController) Added(ctx context.Context, obj interface{}, statusChan chan controller.EventProcessStatus)

func (*RolloutsController) Deleted

func (rc *RolloutsController) Deleted(ctx context.Context, obj interface{}, statusChan chan controller.EventProcessStatus)

func (*RolloutsController) GetInformer

func (rc *RolloutsController) GetInformer() cache.SharedIndexInformer

func (*RolloutsController) Status

func (rc *RolloutsController) Status(ctx context.Context, eventStatus controller.EventProcessStatus)

func (*RolloutsController) Updated

func (rc *RolloutsController) Updated(ctx context.Context, newObj interface{}, oldObj interface{}, statusChan chan controller.EventProcessStatus)

type SecretController

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

func (*SecretController) Added

func (s *SecretController) Added(ctx context.Context, obj interface{}, statusChan chan controller.EventProcessStatus)

func (*SecretController) Deleted

func (s *SecretController) Deleted(ctx context.Context, obj interface{}, statusChan chan controller.EventProcessStatus)

func (*SecretController) GetInformer

func (s *SecretController) GetInformer() cache.SharedIndexInformer

func (*SecretController) Status

func (s *SecretController) Status(ctx context.Context, eventStatus controller.EventProcessStatus)

func (*SecretController) Updated

func (s *SecretController) Updated(ctx context.Context, newObj interface{}, oldObj interface{}, statusChan chan controller.EventProcessStatus)

type ServiceController

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

func (*ServiceController) Added

func (s *ServiceController) Added(ctx context.Context, obj interface{}, statusChan chan controller.EventProcessStatus)

func (*ServiceController) Deleted

func (s *ServiceController) Deleted(ctx context.Context, obj interface{}, statusChan chan controller.EventProcessStatus)

func (*ServiceController) GetInformer

func (s *ServiceController) GetInformer() cache.SharedIndexInformer

func (*ServiceController) Status

func (s *ServiceController) Status(ctx context.Context, eventStatus controller.EventProcessStatus)

func (*ServiceController) Updated

func (s *ServiceController) Updated(ctx context.Context, newObj interface{}, oldObj interface{}, statusChan chan controller.EventProcessStatus)