controllers

Documentation

Index

• Constants
• type AutoScalerReconciler
  • func (r *AutoScalerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AutoScalerReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ChaosReconciler
  • func (r *ChaosReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ChaosReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ComputeNodeReconciler
  • func (r *ComputeNodeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ComputeNodeReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ExecCtrl
• type ProxyConfigReconciler
  • func (r *ProxyConfigReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ProxyConfigReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ProxyReconciler
  • func (r *ProxyReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ProxyReconciler) SetupWithManager(mgr ctrl.Manager) error
• type StorageNodeReconciler
  • func (r *StorageNodeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *StorageNodeReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	ChaosControllerName = "chaos-controller"
	ChaosFinalizerName  = "shardingsphere.apache.org/finalizer"
)

const (
	StorageNodeControllerName = "storage-node-controller"
	FinalizerName             = "shardingsphere.apache.org/finalizer"

	AnnotationKeyRegisterStorageUnitEnabled = "shardingsphere.apache.org/register-storage-unit-enabled"
	AnnotationKeyComputeNodeName            = "shardingsphere.apache.org/compute-node-name"
	AnnotationKeyLogicDatabaseName          = "shardingsphere.apache.org/logic-database-name"

	ShardingSphereProtocolType = "proxy-frontend-database-protocol-type"
)

const (
	//WaitingForReady Time selection reference kubelet restart time
	WaitingForReady = 10 * time.Second
)

Types

type AutoScalerReconciler

type AutoScalerReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	Log    logr.Logger

	Builder   reconcile.Builder
	Resources kubernetes.Resources
}

AutoScalerReconciler is a controller for the shardingsphere cluster

func (*AutoScalerReconciler) Reconcile

func (r *AutoScalerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+kubebuilder:rbac:groups=shardingsphere.apache.org,resources=computenodes,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=autoscaling/v2,resources=horizontalpodautoscaler,verbs=get;list;watch;create;update;patch;delete Reconcile handles main function of this controller

func (*AutoScalerReconciler) SetupWithManager

func (r *AutoScalerReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager

type ChaosReconciler

type ChaosReconciler struct {
	client.Client

	Scheme    *runtime.Scheme
	Log       logr.Logger
	Events    record.EventRecorder
	ClientSet *clientset.Clientset

	Chaos chaosmesh.Chaos

	Job       job.Job
	ExecCtrls []*ExecCtrl
	ConfigMap configmap.ConfigMap
}

ChaosReconciler is a controller for the Chaos

func (*ChaosReconciler) Reconcile

func (r *ChaosReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile handles main function of this controller

func (*ChaosReconciler) SetupWithManager

func (r *ChaosReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type ComputeNodeReconciler

type ComputeNodeReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	Log    logr.Logger

	Builder   reconcile.Builder
	Resources kubernetes.Resources

	Deployment deployment.Deployment
	Service    service.Service
	ConfigMap  configmap.ConfigMap
}

ComputeNodeReconciler is a controller for the compute node

func (*ComputeNodeReconciler) Reconcile

func (r *ComputeNodeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile handles main function of this controller

func (*ComputeNodeReconciler) SetupWithManager

func (r *ComputeNodeReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager

type ExecCtrl

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

type ProxyConfigReconciler

type ProxyConfigReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	Log    logr.Logger
}

ProxyConfigReconciler reconciles a ShardingSphereProxyServerConfig object

func (*ProxyConfigReconciler) Reconcile

func (r *ProxyConfigReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile the ProxyConfig

func (*ProxyConfigReconciler) SetupWithManager

func (r *ProxyConfigReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type ProxyReconciler

type ProxyReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	Log    logr.Logger
}

ProxyReconciler reconciles a ShardingSphereProxy object

func (*ProxyReconciler) Reconcile

func (r *ProxyReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*ProxyReconciler) SetupWithManager

func (r *ProxyReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type StorageNodeReconciler

type StorageNodeReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Log      logr.Logger
	Recorder record.EventRecorder
	Service  service.Service

	AwsRegion          string
	AwsAccessKeyID     string
	AwsSecretAccessKey string
	AwsSessions        dbmeshaws.Sessions

	CNPG cloudnativepg.CloudNativePG
}

StorageNodeReconciler is a controller for storage nodes

func (*StorageNodeReconciler) Reconcile

func (r *StorageNodeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile handles main function of this controller nolint:gocognit

func (*StorageNodeReconciler) SetupWithManager

func (r *StorageNodeReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager