kubernetes

Documentation

Overview

Package kubernetes provides functionality to bootstrap a Kubernetes cluster, or join an exiting one.

Index

• type KubeWrapper
  • func New(cloudProvider string, clusterUtil clusterUtil, ...) *KubeWrapper
  • func (k *KubeWrapper) InitCluster(ctx context.Context, versionString, clusterName string, conformanceMode bool, ...) ([]byte, error)
  • func (k *KubeWrapper) JoinCluster(ctx context.Context, args *kubeadm.BootstrapTokenDiscovery, peerRole role.Role, ...) error
  • func (k *KubeWrapper) StartKubelet() error
• type ProviderMetadata

Types

type KubeWrapper

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

KubeWrapper implements Cluster interface.

func New

func New(cloudProvider string, clusterUtil clusterUtil, configProvider configurationProvider, client k8sapi.Client,
	providerMetadata ProviderMetadata, kubeAPIWaiter kubeAPIWaiter, log *slog.Logger,
) *KubeWrapper

New creates a new KubeWrapper with real values.

func (*KubeWrapper) InitCluster

func (k *KubeWrapper) InitCluster(
	ctx context.Context, versionString, clusterName string, conformanceMode bool, kubernetesComponents components.Components, apiServerCertSANs []string, serviceCIDR string,
) ([]byte, error)

InitCluster initializes a new Kubernetes cluster and applies pod network provider.

func (*KubeWrapper) JoinCluster

func (k *KubeWrapper) JoinCluster(ctx context.Context, args *kubeadm.BootstrapTokenDiscovery, peerRole role.Role, k8sComponents components.Components) error

JoinCluster joins existing Kubernetes cluster.

func (*KubeWrapper) StartKubelet

func (k *KubeWrapper) StartKubelet() error

StartKubelet starts the kubelet service.

type ProviderMetadata

type ProviderMetadata interface {
	// UID returns the unique identifier for the constellation.
	UID(ctx context.Context) (string, error)
	// Self retrieves the current instance.
	Self(ctx context.Context) (metadata.InstanceMetadata, error)
	// GetLoadBalancerEndpoint retrieves the load balancer endpoint.
	GetLoadBalancerEndpoint(ctx context.Context) (host, port string, err error)
}

ProviderMetadata implementers read/write cloud provider metadata.