cluster

package

v1.0.0 Latest Latest Go to latest Published: Oct 31, 2025 License: Apache-2.0 Imports: 50 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/rancher/k3k

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func Add(ctx context.Context, mgr manager.Manager, config *Config, ...) error
func AddPodController(ctx context.Context, mgr manager.Manager, maxConcurrentReconciles int) error
func AddServiceController(ctx context.Context, mgr manager.Manager, maxConcurrentReconciles int) error
func AddStatefulSetController(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 Config
type PodReconciler
- func (r *PodReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
type ServiceReconciler
- func (r *ServiceReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
type StatefulSetReconciler
- func (p *StatefulSetReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

Constants ¶

View Source

const (
	// Condition Types
	ConditionReady = "Ready"

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

View Source

const (
	ClusterInvalidName = "system"
)

Variables ¶

View Source

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, config *Config, maxConcurrentReconciles int, portAllocator *agent.PortAllocator, eventRecorder record.EventRecorder) error

Add adds a new controller to the manager

func AddPodController ¶ added in v0.3.0

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

AddPodController adds a new controller for Pods to the manager. It will reconcile the Pods of the Host Cluster with the one of the Virtual Cluster.

func AddServiceController ¶ added in v1.0.0

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

Add adds a new controller to the manager

func AddStatefulSetController ¶ added in v1.0.0

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

Add adds a new controller to the manager

func TokenSecretName ¶ added in v0.3.0

func TokenSecretName(clusterName string) string

func TokenSecretObj ¶ added in v0.3.0

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

Types ¶

type ClusterReconciler ¶

type ClusterReconciler struct {
	DiscoveryClient *discovery.DiscoveryClient
	Client          client.Client
	Scheme          *runtime.Scheme
	PortAllocator   *agent.PortAllocator

	record.EventRecorder
	Config
}

func (*ClusterReconciler) Reconcile ¶

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

type Config ¶ added in v0.3.5

type Config struct {
	ClusterCIDR                 string
	SharedAgentImage            string
	SharedAgentImagePullPolicy  string
	VirtualAgentImage           string
	VirtualAgentImagePullPolicy string
	K3SServerImage              string
	K3SServerImagePullPolicy    string
	ServerImagePullSecrets      []string
	AgentImagePullSecrets       []string
}

type PodReconciler ¶ added in v0.3.0

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

func (*PodReconciler) Reconcile ¶ added in v0.3.0

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

type ServiceReconciler ¶ added in v1.0.0

type ServiceReconciler struct {
	HostClient ctrlruntimeclient.Client
}

func (*ServiceReconciler) Reconcile ¶ added in v1.0.0

func (r *ServiceReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

type StatefulSetReconciler ¶ added in v1.0.0

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

func (*StatefulSetReconciler) Reconcile ¶ added in v1.0.0

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
agent
server
bootstrap

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