controllers

package
v0.11.0 Latest Latest
Warning

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

Go to latest
Published: Jun 22, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Package controllers provides Kubernetes controllers.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Controller

type Controller interface {
	Name() string
	Run(ctx context.Context)
}

Controller defines the interface for a Kubernetes controller.

type CronJobController

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

CronJobController manages CronJob resources.

func (*CronJobController) Name

func (c *CronJobController) Name() string

Name returns the controller name.

func (*CronJobController) Run

func (c *CronJobController) Run(ctx context.Context)

Run starts the CronJob reconciliation loop.

type DeploymentController

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

DeploymentController manages Deployment resources.

func (*DeploymentController) Name

func (c *DeploymentController) Name() string

Name returns the controller name.

func (*DeploymentController) Run

func (c *DeploymentController) Run(ctx context.Context)

Run starts the Deployment reconciliation loop.

type EndpointController

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

EndpointController manages Endpoint resources.

func (*EndpointController) Name

func (c *EndpointController) Name() string

Name returns the controller name.

func (*EndpointController) Run

func (c *EndpointController) Run(ctx context.Context)

Run starts the Endpoint reconciliation loop. It watches pods and rebuilds the Endpoints object for every service whose selector matches the pod.

type GarbageCollector

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

GarbageCollector removes orphaned Kubernetes resources.

func (*GarbageCollector) Name

func (c *GarbageCollector) Name() string

Name returns the controller name.

func (*GarbageCollector) Run

func (c *GarbageCollector) Run(ctx context.Context)

Run starts the garbage collection loop.

type JobController

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

JobController manages Job resources.

func (*JobController) Name

func (c *JobController) Name() string

Name returns the controller name.

func (*JobController) Run

func (c *JobController) Run(ctx context.Context)

Run starts the Job reconciliation loop. It watches both Jobs and Pods so that pod phase transitions (success/failure) drive job reconciliation even when the Job object itself is unchanged.

type Manager

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

Manager runs and manages a set of Kubernetes controllers.

func NewManager

func NewManager(s store.Store, logger *slog.Logger) *Manager

NewManager creates a new controller manager with all built-in controllers registered.

func (*Manager) Register

func (m *Manager) Register(c Controller)

Register adds a controller to the manager.

func (*Manager) Run

func (m *Manager) Run(ctx context.Context) error

Run starts all registered controllers and blocks until the context is cancelled.

type NamespaceController

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

NamespaceController manages Namespace resources.

func (*NamespaceController) Name

func (c *NamespaceController) Name() string

Name returns the controller name.

func (*NamespaceController) Run

func (c *NamespaceController) Run(ctx context.Context)

Run starts the Namespace reconciliation loop.

type NodeController

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

NodeController manages Node resources.

func (*NodeController) Name

func (c *NodeController) Name() string

Name returns the controller name.

func (*NodeController) Run

func (c *NodeController) Run(ctx context.Context)

Run starts the Node reconciliation loop.

type ReplicaSetController

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

ReplicaSetController manages ReplicaSet resources.

func (*ReplicaSetController) Name

func (c *ReplicaSetController) Name() string

Name returns the controller name.

func (*ReplicaSetController) Run

func (c *ReplicaSetController) Run(ctx context.Context)

Run starts the ReplicaSet reconciliation loop.

type ServiceAccountController

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

ServiceAccountController manages ServiceAccount resources.

func (*ServiceAccountController) Name

func (c *ServiceAccountController) Name() string

Name returns the controller name.

func (*ServiceAccountController) Run

Run starts the ServiceAccount reconciliation loop.

type ServiceController

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

ServiceController manages Service resources.

func (*ServiceController) Name

func (c *ServiceController) Name() string

Name returns the controller name.

func (*ServiceController) Run

func (c *ServiceController) Run(ctx context.Context)

Run starts the Service reconciliation loop.

Jump to

Keyboard shortcuts

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