cluster

Documentation

Index

• Constants
• Variables
• func Add(ctx context.Context, mgr manager.Manager, ...) error
• func AddPodController(ctx context.Context, mgr manager.Manager, maxConcurrentReconciles int) error
• func TokenSecretName(clusterName string) string
• func TokenSecretObj(token, name, namespace string) v1.Secret
• type ClusterReconciler
  • func (c *ClusterReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
• type PodReconciler
  • func (p *PodReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

Constants

const (
	// Condition Types
	ConditionReady = "Ready"

	// Condition Reasons
	ReasonValidationFailed   = "ValidationFailed"
	ReasonProvisioning       = "Provisioning"
	ReasonProvisioned        = "Provisioned"
	ReasonProvisioningFailed = "ProvisioningFailed"
	ReasonTerminating        = "Terminating"
)

const (
	ClusterInvalidName = "system"
)

Variables

var (
	ErrClusterValidation         = errors.New("cluster validation error")
	ErrCustomCACertSecretMissing = errors.New("custom CA certificate secret is missing")
)

Functions

func Add

func Add(ctx context.Context, mgr manager.Manager, sharedAgentImage, sharedAgentImagePullPolicy, k3SImage string, k3SImagePullPolicy string, maxConcurrentReconciles int, portAllocator *agent.PortAllocator, eventRecorder record.EventRecorder) error

Add adds a new controller to the manager

func AddPodController

func AddPodController(ctx context.Context, mgr manager.Manager, maxConcurrentReconciles int) error

Add adds a new controller to the manager

func TokenSecretName

func TokenSecretName(clusterName string) string

func TokenSecretObj

func TokenSecretObj(token, name, namespace string) v1.Secret

Types

type ClusterReconciler

type ClusterReconciler struct {
	DiscoveryClient *discovery.DiscoveryClient
	Client          client.Client
	Scheme          *runtime.Scheme
	record.EventRecorder
	SharedAgentImage           string
	SharedAgentImagePullPolicy string
	K3SImage                   string
	K3SImagePullPolicy         string
	PortAllocator              *agent.PortAllocator
}

func (*ClusterReconciler) Reconcile

func (c *ClusterReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

type PodReconciler

type PodReconciler struct {
	Client ctrlruntimeclient.Client
	Scheme *runtime.Scheme
}

func (*PodReconciler) Reconcile

func (p *PodReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)