controlplane

Documentation

Index

• Constants
• type Action
  • func NewApplyAction(l logr.Logger) Action
  • func NewStatusAction(l logr.Logger) Action
• type ApplyAction
  • func (a *ApplyAction) Cleanup(_ context.Context, _ *ReconciliationRequest) error
  • func (a *ApplyAction) Configure(_ context.Context, _ *client.Client, b *builder.Builder) (*builder.Builder, error)
  • func (a *ApplyAction) Run(ctx context.Context, rr *ReconciliationRequest) error
• type Reconciler
  • func NewReconciler(ctx context.Context, manager ctrlRt.Manager, o helm.Options) (*Reconciler, error)
  • func (r *Reconciler) Cleanup(ctx context.Context, res *daprApi.DaprControlPlane) error
  • func (r *Reconciler) Client() *client.Client
  • func (r *Reconciler) Event(object runtime.Object, eventType string, reason string, message string)
  • func (r *Reconciler) Reconcile(ctx context.Context, res *daprApi.DaprControlPlane) (ctrl.Result, error)
• type ReconciliationRequest
• type StatusAction
  • func (a *StatusAction) Cleanup(_ context.Context, _ *ReconciliationRequest) error
  • func (a *StatusAction) Configure(_ context.Context, _ *client.Client, b *builder.Builder) (*builder.Builder, error)
  • func (a *StatusAction) Run(ctx context.Context, rr *ReconciliationRequest) error

Constants

const (
	DaprControlPlaneFinalizerName = "controlplane.operator.dapr.io/finalizer"
	DaprControlPlaneResourceName  = "dapr-control-plane"
)

Types

type Action

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

func NewApplyAction

func NewApplyAction(l logr.Logger) Action

func NewStatusAction

func NewStatusAction(l logr.Logger) Action

type ApplyAction

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

func (*ApplyAction) Cleanup

func (a *ApplyAction) Cleanup(_ context.Context, _ *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, rr *ReconciliationRequest) error

type Reconciler

type Reconciler struct {
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

func NewReconciler

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

func (*Reconciler) Cleanup

func (r *Reconciler) Cleanup(ctx context.Context, res *daprApi.DaprControlPlane) error

func (*Reconciler) Client

func (r *Reconciler) Client() *client.Client

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, res *daprApi.DaprControlPlane) (ctrl.Result, error)

type ReconciliationRequest

type ReconciliationRequest struct {
	*client.Client
	types.NamespacedName

	Reconciler *Reconciler
	Resource   *daprApi.DaprControlPlane
}

type StatusAction

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

StatusAction computes the state of a DaprControlPlane resource out of the owned DaprInstance resource.

func (*StatusAction) Cleanup

func (a *StatusAction) Cleanup(_ context.Context, _ *ReconciliationRequest) error

func (*StatusAction) Configure

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

func (*StatusAction) Run

func (a *StatusAction) Run(ctx context.Context, rr *ReconciliationRequest) error