handlers

Documentation

Index

• type DaprHandler
  • func NewDaprHandler(mgr ctrl.Manager) *DaprHandler
  • func NewDaprHandlerWithOptions(mgr ctrl.Manager, opts *Options) *DaprHandler
  • func (h *DaprHandler) Init(ctx context.Context) error
• type DeploymentWrapper
  • func (d *DeploymentWrapper) GetMatchLabels() map[string]string
  • func (d *DeploymentWrapper) GetObject() client.Object
  • func (d *DeploymentWrapper) GetTemplateAnnotations() map[string]string
• type ObjectWrapper
• type Options
• type Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
• type RolloutWrapper
  • func (r *RolloutWrapper) GetMatchLabels() map[string]string
  • func (r *RolloutWrapper) GetObject() client.Object
  • func (r *RolloutWrapper) GetTemplateAnnotations() map[string]string
• type StatefulSetWrapper
  • func (s *StatefulSetWrapper) GetMatchLabels() map[string]string
  • func (s *StatefulSetWrapper) GetObject() client.Object
  • func (s *StatefulSetWrapper) GetTemplateAnnotations() map[string]string

Types

type DaprHandler

type DaprHandler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

DaprHandler handles the lifetime for Dapr CRDs.

func NewDaprHandler

func NewDaprHandler(mgr ctrl.Manager) *DaprHandler

NewDaprHandler returns a new Dapr handler. This is a reconciler that watches all Deployment and StatefulSet resources and ensures that a matching Service resource is deployed to allow Dapr sidecar-to-sidecar communication and access to other ports.

func NewDaprHandlerWithOptions

func NewDaprHandlerWithOptions(mgr ctrl.Manager, opts *Options) *DaprHandler

NewDaprHandlerWithOptions returns a new Dapr handler with options.

func (*DaprHandler) Init

func (h *DaprHandler) Init(ctx context.Context) error

Init allows for various startup tasks.

type DeploymentWrapper

type DeploymentWrapper struct {
	appsv1.Deployment
}

func (*DeploymentWrapper) GetMatchLabels

func (d *DeploymentWrapper) GetMatchLabels() map[string]string

func (*DeploymentWrapper) GetObject

func (d *DeploymentWrapper) GetObject() client.Object

func (*DeploymentWrapper) GetTemplateAnnotations

func (d *DeploymentWrapper) GetTemplateAnnotations() map[string]string

type ObjectWrapper

type ObjectWrapper interface {
	GetMatchLabels() map[string]string
	GetTemplateAnnotations() map[string]string
	GetObject() client.Object
}

type Options

type Options struct {
	ArgoRolloutServiceReconcilerEnabled bool
}

type Reconciler

type Reconciler struct {
	*DaprHandler
	// contains filtered or unexported fields
}

func (*Reconciler) Reconcile

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

Reconcile the expected services for Deployment and StatefulSet resources annotated for Dapr.

type RolloutWrapper

type RolloutWrapper struct {
	argov1alpha1.Rollout
}

func (*RolloutWrapper) GetMatchLabels

func (r *RolloutWrapper) GetMatchLabels() map[string]string

func (*RolloutWrapper) GetObject

func (r *RolloutWrapper) GetObject() client.Object

func (*RolloutWrapper) GetTemplateAnnotations

func (r *RolloutWrapper) GetTemplateAnnotations() map[string]string

type StatefulSetWrapper

type StatefulSetWrapper struct {
	appsv1.StatefulSet
}

func (*StatefulSetWrapper) GetMatchLabels

func (s *StatefulSetWrapper) GetMatchLabels() map[string]string

func (*StatefulSetWrapper) GetObject

func (s *StatefulSetWrapper) GetObject() client.Object

func (*StatefulSetWrapper) GetTemplateAnnotations

func (s *StatefulSetWrapper) GetTemplateAnnotations() map[string]string