controller

Documentation

Index

• func SetupRedisClusterController(mgr ctrl.Manager, redisClusterController *Controller) error
• type Config
  • func NewConfig(nbWorker int, redis config.Redis) *Config
• type Controller
  • func NewController(cfg *Config, mgr manager.Manager, kubeClient kclient.Client, ...) *Controller
  • func (c *Controller) Reconcile(ctx context.Context, namespacedName ctrl.Request) (ctrl.Result, error)
• type PodDisruptionBudgetsControl
  • func NewPodDisruptionBudgetsControl(client client.Client, rec record.EventRecorder) *PodDisruptionBudgetsControl
  • func (s *PodDisruptionBudgetsControl) CreateRedisClusterPodDisruptionBudget(redisCluster *rapi.RedisCluster) (*policyv1.PodDisruptionBudget, error)
  • func (s *PodDisruptionBudgetsControl) DeleteRedisClusterPodDisruptionBudget(redisCluster *rapi.RedisCluster) error
  • func (s *PodDisruptionBudgetsControl) GetRedisClusterPodDisruptionBudget(redisCluster *rapi.RedisCluster) (*policyv1.PodDisruptionBudget, error)
• type PodDisruptionBudgetsControlInterface
• type ServicesControl
  • func NewServicesControl(client client.Client, rec record.EventRecorder) *ServicesControl
  • func (s *ServicesControl) CreateRedisClusterService(redisCluster *rapi.RedisCluster) (*v1.Service, error)
  • func (s *ServicesControl) DeleteRedisClusterService(redisCluster *rapi.RedisCluster) error
  • func (s *ServicesControl) GetRedisClusterService(redisCluster *rapi.RedisCluster) (*v1.Service, error)
• type ServicesControlInterface

Functions

func SetupRedisClusterController

func SetupRedisClusterController(mgr ctrl.Manager, redisClusterController *Controller) error

Types

type Config

type Config struct {
	NbWorker int
	// contains filtered or unexported fields
}

Config contains the Controller settings

func NewConfig

func NewConfig(nbWorker int, redis config.Redis) *Config

NewConfig builds and returns new Config instance

type Controller

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

Controller contains all controller fields

func NewController

func NewController(cfg *Config, mgr manager.Manager, kubeClient kclient.Client, recorder record.EventRecorder) *Controller

NewController builds and return new controller instance

func (*Controller) Reconcile

func (c *Controller) Reconcile(ctx context.Context, namespacedName ctrl.Request) (ctrl.Result, error)

type PodDisruptionBudgetsControl

type PodDisruptionBudgetsControl struct {
	KubeClient client.Client
	Recorder   record.EventRecorder
}

PodDisruptionBudgetsControl contains all information for managing Kube PodDisruptionBudgets

func NewPodDisruptionBudgetsControl

func NewPodDisruptionBudgetsControl(client client.Client, rec record.EventRecorder) *PodDisruptionBudgetsControl

NewPodDisruptionBudgetsControl builds and returns new PodDisruptionBudgetsControl instance

func (*PodDisruptionBudgetsControl) CreateRedisClusterPodDisruptionBudget

func (s *PodDisruptionBudgetsControl) CreateRedisClusterPodDisruptionBudget(redisCluster *rapi.RedisCluster) (*policyv1.PodDisruptionBudget, error)

CreateRedisClusterPodDisruptionBudget used to create the Kubernetes PodDisruptionBudget needed to access the Redis Cluster

func (*PodDisruptionBudgetsControl) DeleteRedisClusterPodDisruptionBudget

func (s *PodDisruptionBudgetsControl) DeleteRedisClusterPodDisruptionBudget(redisCluster *rapi.RedisCluster) error

DeleteRedisClusterPodDisruptionBudget used to delete the Kubernetes PodDisruptionBudget linked to the Redis Cluster

func (*PodDisruptionBudgetsControl) GetRedisClusterPodDisruptionBudget

func (s *PodDisruptionBudgetsControl) GetRedisClusterPodDisruptionBudget(redisCluster *rapi.RedisCluster) (*policyv1.PodDisruptionBudget, error)

GetRedisClusterPodDisruptionBudget used to retrieve the Kubernetes PodDisruptionBudget associated to the RedisCluster

type PodDisruptionBudgetsControlInterface

type PodDisruptionBudgetsControlInterface interface {
	// CreateRedisClusterPodDisruptionBudget used to create the Kubernetes PodDisruptionBudget needed to access the Redis Cluster
	CreateRedisClusterPodDisruptionBudget(redisCluster *rapi.RedisCluster) (*policyv1.PodDisruptionBudget, error)
	// DeleteRedisClusterPodDisruptionBudget used to delete the Kubernetes PodDisruptionBudget linked to the Redis Cluster
	DeleteRedisClusterPodDisruptionBudget(redisCluster *rapi.RedisCluster) error
	// GetRedisClusterPodDisruptionBudget used to retrieve the Kubernetes PodDisruptionBudget associated to the RedisCluster
	GetRedisClusterPodDisruptionBudget(redisCluster *rapi.RedisCluster) (*policyv1.PodDisruptionBudget, error)
}

PodDisruptionBudgetsControlInterface interface for the PodDisruptionBudgetsControl

type ServicesControl

type ServicesControl struct {
	KubeClient client.Client
	Recorder   record.EventRecorder
}

ServicesControl contains all information for managing Kube Services

func NewServicesControl

func NewServicesControl(client client.Client, rec record.EventRecorder) *ServicesControl

NewServicesControl builds and returns new ServicesControl instance

func (*ServicesControl) CreateRedisClusterService

func (s *ServicesControl) CreateRedisClusterService(redisCluster *rapi.RedisCluster) (*v1.Service, error)

CreateRedisClusterService used to create the Kubernetes Service needed to access the Redis Cluster

func (*ServicesControl) DeleteRedisClusterService

func (s *ServicesControl) DeleteRedisClusterService(redisCluster *rapi.RedisCluster) error

DeleteRedisClusterService used to delete the Kubernetes Service linked to the Redis Cluster

func (*ServicesControl) GetRedisClusterService

func (s *ServicesControl) GetRedisClusterService(redisCluster *rapi.RedisCluster) (*v1.Service, error)

GetRedisClusterService used to retrieve the Kubernetes Service associated to the RedisCluster

type ServicesControlInterface

type ServicesControlInterface interface {
	// CreateRedisClusterService used to create the Kubernetes Service needed to access the Redis Cluster
	CreateRedisClusterService(redisCluster *rapi.RedisCluster) (*v1.Service, error)
	// DeleteRedisClusterService used to delete the Kubernetes Service linked to the Redis Cluster
	DeleteRedisClusterService(redisCluster *rapi.RedisCluster) error
	// GetRedisClusterService used to retrieve the Kubernetes Service associated to the RedisCluster
	GetRedisClusterService(redisCluster *rapi.RedisCluster) (*v1.Service, error)
}

ServicesControlInterface inferface for the ServicesControl