controller

package

v1.19.0-rc.2 Latest Latest Go to latest Published: Oct 9, 2026 License: Apache-2.0 Imports: 22 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

Documentation ¶

Index ¶

type Controller
- func New(opts Options) (*Controller, error)
type Options
type PresenceSink

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Controller ¶ added in v1.18.0

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

Controller wraps a long-lived controller-runtime manager. It must only be created once per process because controller-runtime registers controller names globally in the metrics registry.

func New ¶

func New(opts Options) (*Controller, error)

func (*Controller) Run ¶ added in v1.18.0

func (c *Controller) Run(ctx context.Context) error

func (*Controller) SetCron ¶ added in v1.18.0

func (c *Controller) SetCron(cr cron.Interface)

SetCron updates the cron interface used by the namespace reconciler.

func (*Controller) SetPresenceSink ¶

func (c *Controller) SetPresenceSink(s PresenceSink)

SetPresenceSink updates the sink receiving placement pod observations, pushing the current observation into it right away.

type Options ¶

type Options struct {
	KubeConfig *string
	Healthz    healthz.Healthz
	Namespace  string
}

type PresenceSink ¶

type PresenceSink interface {
	SetKubernetesPresence(present bool)
}

PresenceSink receives the placement pod observations.

Source Files ¶

View all Source files

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