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(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: %+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(request ctrl.Request) (ctrl.Result, error)

func (*ClusterReconciler) SetupWithManager

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