cluster

Documentation

Index

• Constants
• type ClusterReconciler
  • func New(ctx context.Context, mgr ctrl.Manager, logger log.Logger) (*ClusterReconciler, error)
  • func (cc *ClusterReconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)
  • func (r *ClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	// Messages to display when experiencing an error.
	MessageHeadlessServiceSyncFailed = "Failed to sync Headless Service for cluster"
	MessageMemberServicesSyncFailed  = "Failed to sync MemberServices for cluster"
	MessageUpdateStatusFailed        = "Failed to update status for cluster"
	MessageCleanupFailed             = "Failed to clean up cluster resources"
	MessageClusterSyncFailed         = "Failed to sync cluster, got error: %+v"
)

Types

type ClusterReconciler

type ClusterReconciler struct {
	client.Client

	// Original k8s client needed for patch ops
	// Will replace once the dynamic client adds this feature
	// https://github.com/kubernetes-sigs/controller-runtime/pull/235
	// Feature depends on server-side apply, landing in 1.14
	// https://github.com/kubernetes/enhancements/issues/555
	KubeClient     kubernetes.Interface
	UncachedClient client.Client
	Recorder       record.EventRecorder
	OperatorImage  string

	Scheme *runtime.Scheme
	Logger log.Logger
}

ClusterReconciler reconciles a Cluster object

func New

func New(ctx context.Context, mgr ctrl.Manager, logger log.Logger) (*ClusterReconciler, error)

func (*ClusterReconciler) Reconcile

func (cc *ClusterReconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)

+kubebuilder:rbac:groups=,resources=pods,verbs=get;list;watch;delete +kubebuilder:rbac:groups=,resources=services,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=,resources=persistentvolumeclaims,verbs=get;list;watch;delete +kubebuilder:rbac:groups=,resources=events,verbs=create;update;patch +kubebuilder:rbac:groups=apps,resources=statefulsets,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=scylla.scylla.scylladb.com,resources=clusters,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=scylla.scylla.scylladb.com,resources=clusters/status,verbs=update;get;patch

func (*ClusterReconciler) SetupWithManager

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