operator

Documentation

Index

• func GetNamespace() string
• func RunWebhooks(ctx context.Context, enableLeaderElection bool)
• type Config
  • func LoadConfiguration(name string, client client.Client) (*Config, error)
• type DaprWatchdog
  • func (dw *DaprWatchdog) NeedLeaderElection() bool
  • func (dw *DaprWatchdog) Start(parentCtx context.Context) error
• type Operator
  • func NewOperator(opts Options) Operator
• type Options

Functions

func GetNamespace

func GetNamespace() string

GetNamespace returns the namespace for Dapr.

func RunWebhooks

func RunWebhooks(ctx context.Context, enableLeaderElection bool)

Types

type Config

type Config struct {
	MTLSEnabled bool
	Credentials credentials.TLSCredentials
}

Config returns an operator config options.

func LoadConfiguration

func LoadConfiguration(name string, client client.Client) (*Config, error)

LoadConfiguration loads the Kubernetes configuration and returns an Operator Config.

type DaprWatchdog

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

DaprWatchdog is a controller that periodically polls all pods and ensures that they are in the correct state. This controller only runs on the cluster's leader. Currently, this ensures that the sidecar is injected in each pod, otherwise it kills the pod so it can be restarted.

func (*DaprWatchdog) NeedLeaderElection

func (dw *DaprWatchdog) NeedLeaderElection() bool

NeedLeaderElection makes it so the controller runs on the leader node only. Implements sigs.k8s.io/controller-runtime/pkg/manager.LeaderElectionRunnable .

func (*DaprWatchdog) Start

func (dw *DaprWatchdog) Start(parentCtx context.Context) error

Start the controller. This method blocks until the context is canceled. Implements sigs.k8s.io/controller-runtime/pkg/manager.Runnable .

type Operator

type Operator interface {
	Run(ctx context.Context)
}

Operator is an Dapr Kubernetes Operator for managing components and sidecar lifecycle.

func NewOperator

func NewOperator(opts Options) Operator

NewOperator returns a new Dapr Operator.

type Options

type Options struct {
	Config                    string
	CertChainPath             string
	LeaderElection            bool
	WatchdogEnabled           bool
	WatchdogInterval          time.Duration
	WatchdogMaxRestartsPerMin int
}

Options contains the options for `NewOperator`.