cluster

Documentation

Index

• Constants
• func GetOperatorImage(ctx context.Context, kubeClient kubernetes.Interface, ...) (string, error)
• type ClusterReconciler
  • func New(ctx context.Context, mgr ctrl.Manager, logger log.Logger) (*ClusterReconciler, error)
  • func (cc *ClusterReconciler) Reconcile(ctx context.Context, 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"
	MessagePodDisruptionBudgetSyncFailed = "Failed to sync Pod Disruption Budget for cluster"
	MessageAgentTokenSyncFailed          = "Failed to sync Agent token for cluster"
	MessageMemberServicesSyncFailed      = "Failed to sync MemberServices for cluster"
	MessageUpdateStatusFailed            = "Failed to update status for cluster: %+v"
	MessageCleanupFailed                 = "Failed to clean up cluster resources"
	MessageClusterSyncFailed             = "Failed to sync cluster, got error: %+v"
)

Functions

func GetOperatorImage

func GetOperatorImage(ctx context.Context, kubeClient kubernetes.Interface, opts *options.OperatorOptions) (string, error)

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(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

func (*ClusterReconciler) SetupWithManager

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