operator

Documentation

Index

• Constants
• type Action
  • func NewApplyAction() Action
• type ApplyAction
  • func (a *ApplyAction) Cleanup(ctx context.Context, rc *ReconciliationRequest) error
  • func (a *ApplyAction) Configure(_ context.Context, _ *client.Client, b *builder.Builder) (*builder.Builder, error)
  • func (a *ApplyAction) Run(ctx context.Context, rc *ReconciliationRequest) error
• type HelmOptions
• type Reconciler
  • func NewReconciler(ctx context.Context, manager ctrlRt.Manager, o HelmOptions) (*Reconciler, error)
  • func (r *Reconciler) EnqueueRequestForOwner(owner ctrlCli.Object, opts ...handler.OwnerOption) handler.EventHandler
  • func (r *Reconciler) EnqueueRequestsFromMapFunc(fn func(context.Context, ctrlCli.Object) []reconcile.Request) handler.EventHandler
  • func (r *Reconciler) Event(object runtime.Object, eventType string, reason string, message string)
  • func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *Reconciler) Watch(obj ctrlCli.Object, eh handler.EventHandler, predicates ...predicate.Predicate) error
• type ReconciliationRequest

Constants

const (
	DaprReleaseGeneration = "controlplane.operator.dapr.io/release.generation"
	DaprReleaseName       = "controlplane.operator.dapr.io/release.name"
	DaprReleaseNamespace  = "controlplane.operator.dapr.io/release.namespace"

	DaprFinalizerName = "controlplane.operator.dapr.io/finalizer"
	DaprFieldManager  = "dapr-controlplane"

	HelmChartsDir = "helm-charts/dapr"

	DaprControlPlaneName             = "dapr-control-plane"
	DaprControlPlaneNamespaceDefault = "dapr-system"
	DaprControlPlaneNamespaceEnv     = "DAPR_CONTROL_PLANE_NAMESPACE"

	DaprConditionReconcile                      = "Reconcile"
	DaprPhaseError                              = "Error"
	DaprPhaseReady                              = "Ready"
	DaprConditionReasonUnsupportedConfiguration = "UnsupportedConfiguration"
)

Types

type Action

type Action interface {
	Configure(context.Context, *client.Client, *builder.Builder) (*builder.Builder, error)
	Run(context.Context, *ReconciliationRequest) error
	Cleanup(context.Context, *ReconciliationRequest) error
}

func NewApplyAction

func NewApplyAction() Action

type ApplyAction

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

func (*ApplyAction) Cleanup

func (a *ApplyAction) Cleanup(ctx context.Context, rc *ReconciliationRequest) error

func (*ApplyAction) Configure

func (a *ApplyAction) Configure(_ context.Context, _ *client.Client, b *builder.Builder) (*builder.Builder, error)

func (*ApplyAction) Run

func (a *ApplyAction) Run(ctx context.Context, rc *ReconciliationRequest) error

type HelmOptions

type HelmOptions struct {
	ChartsDir string
}

type Reconciler

type Reconciler struct {
	*client.Client

	Scheme      *runtime.Scheme
	ClusterType controller.ClusterType
	// contains filtered or unexported fields
}

func NewReconciler

func NewReconciler(ctx context.Context, manager ctrlRt.Manager, o HelmOptions) (*Reconciler, error)

func (*Reconciler) EnqueueRequestForOwner

func (r *Reconciler) EnqueueRequestForOwner(owner ctrlCli.Object, opts ...handler.OwnerOption) handler.EventHandler

func (*Reconciler) EnqueueRequestsFromMapFunc

func (r *Reconciler) EnqueueRequestsFromMapFunc(fn func(context.Context, ctrlCli.Object) []reconcile.Request) handler.EventHandler

func (*Reconciler) Event

func (r *Reconciler) Event(object runtime.Object, eventType string, reason string, message string)

func (*Reconciler) Reconcile

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

func (*Reconciler) Watch

func (r *Reconciler) Watch(obj ctrlCli.Object, eh handler.EventHandler, predicates ...predicate.Predicate) error

type ReconciliationRequest

type ReconciliationRequest struct {
	*client.Client
	types.NamespacedName

	Reconciler  *Reconciler
	ClusterType controller.ClusterType
	Resource    *daprApi.DaprControlPlane
	Chart       *chart.Chart
	Overrides   map[string]interface{}
}