handlers

package

v1.16.21 Latest Latest Go to latest Published: Oct 21, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dapr/dapr

Links

Open Source Insights

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
type ObjectWrapper
type Options
type Reconciler
- func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
type RolloutWrapper
type StatefulSetWrapper

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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 ¶ added in v1.11.0

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 ¶ added in v1.6.0

type DeploymentWrapper struct {
	appsv1.Deployment
}

func (*DeploymentWrapper) GetMatchLabels ¶ added in v1.6.0

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

func (*DeploymentWrapper) GetObject ¶ added in v1.6.0

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

func (*DeploymentWrapper) GetTemplateAnnotations ¶ added in v1.6.0

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

type ObjectWrapper ¶ added in v1.6.0

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

type Options ¶ added in v1.11.0

type Options struct {
	ArgoRolloutServiceReconcilerEnabled bool
}

type Reconciler ¶ added in v1.6.0

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

func (*Reconciler) Reconcile ¶ added in v1.6.0

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 ¶ added in v1.11.0

type RolloutWrapper struct {
	argov1alpha1.Rollout
}

func (*RolloutWrapper) GetMatchLabels ¶ added in v1.11.0

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

func (*RolloutWrapper) GetObject ¶ added in v1.11.0

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

func (*RolloutWrapper) GetTemplateAnnotations ¶ added in v1.11.0

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

type StatefulSetWrapper ¶ added in v1.6.0

type StatefulSetWrapper struct {
	appsv1.StatefulSet
}

func (*StatefulSetWrapper) GetMatchLabels ¶ added in v1.6.0

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

func (*StatefulSetWrapper) GetObject ¶ added in v1.6.0

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

func (*StatefulSetWrapper) GetTemplateAnnotations ¶ added in v1.6.0

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL