fleet

package
v1.27.0-rc.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 8, 2026 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Daemon

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

Daemon subscribes to fleet-specific RC products (installer configs and tasks) and runs after leader election as a controller-runtime Runnable.

func NewDaemon

func NewDaemon(rcClient remoteconfig.RCClient, k8sClient client.Client, revisionsEnabled bool) *Daemon

NewDaemon creates a new Fleet Daemon. When revisionsEnabled is false, experiment signals are rejected because the reconciler cannot process them without the ControllerRevision machinery.

func (*Daemon) NeedLeaderElection

func (d *Daemon) NeedLeaderElection() bool

NeedLeaderElection implements manager.LeaderElectionRunnable. The daemon only runs on the elected leader.

func (*Daemon) Start

func (d *Daemon) Start(ctx context.Context) error

Start implements manager.Runnable. It subscribes to fleet RC products and blocks until ctx is cancelled.

type Operation

type Operation string

Operation is the type of fleet management operation to perform on a Kubernetes resource.

const (
	OperationCreate Operation = "create"
	OperationUpdate Operation = "update"
	OperationDelete Operation = "delete"
)

Jump to

Keyboard shortcuts

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