setup

Documentation

Index

• func ApplyCoreDNS(controllerContext *options.ControllerContext)
• func CreateVClusterKubeConfig(config *clientcmdapi.Config, options *options.VirtualClusterOptions) (*clientcmdapi.Config, error)
• func FindOwner(ctx *options.ControllerContext) error
• func GenerateK8sCerts(ctx context.Context, currentNamespaceClient kubernetes.Interface, ...) error
• func GetDefaultNamespaces(currentNamespace string, options *options.VirtualClusterOptions) map[string]cache.Config
• func InitControllerContext(ctx context.Context, currentNamespace string, ...) (*options.ControllerContext, error)
• func Initialize(ctx context.Context, ...) error
• func LoadVirtualConfig(ctx context.Context, options *options.VirtualClusterOptions) (*rest.Config, *clientcmdapi.Config, error)
• func NewControllerContext(ctx context.Context, options *options.VirtualClusterOptions, ...) (*options.ControllerContext, error)
• func RegisterOrDeregisterAPIService(ctx *options.ControllerContext)
• func StartControllers(controllerContext *options.ControllerContext) error
• func StartManagers(controllerContext *options.ControllerContext, syncers []syncertypes.Object) error
• func StartPlugins(ctx context.Context, currentNamespace string, ...) error
• func StartProxy(ctx *options.ControllerContext) error
• func SyncKubernetesService(ctx *options.ControllerContext) error
• func ValidateOptions(options *options.VirtualClusterOptions) error
• func WaitForClientConfig(ctx context.Context, options *options.VirtualClusterOptions) (clientcmd.ClientConfig, error)
• func WriteKubeConfigToSecret(ctx context.Context, currentNamespace string, ...) error

Functions

func ApplyCoreDNS

func ApplyCoreDNS(controllerContext *options.ControllerContext)

func CreateVClusterKubeConfig

func CreateVClusterKubeConfig(config *clientcmdapi.Config, options *options.VirtualClusterOptions) (*clientcmdapi.Config, error)

func FindOwner

func FindOwner(ctx *options.ControllerContext) error

func GenerateK8sCerts

func GenerateK8sCerts(ctx context.Context, currentNamespaceClient kubernetes.Interface, vClusterName, currentNamespace, serviceCIDR, certificatesDir, clusterDomain string) error

func GetDefaultNamespaces

func GetDefaultNamespaces(currentNamespace string, options *options.VirtualClusterOptions) map[string]cache.Config

func InitControllerContext

func InitControllerContext(
	ctx context.Context,
	currentNamespace string,
	localManager,
	virtualManager ctrl.Manager,
	virtualRawConfig *clientcmdapi.Config,
	vClusterOptions *options.VirtualClusterOptions,
) (*options.ControllerContext, error)

func Initialize

func Initialize(
	ctx context.Context,
	workspaceNamespaceClient,
	currentNamespaceClient kubernetes.Interface,
	workspaceNamespace,
	currentNamespace,
	vClusterName string,
	options *options.VirtualClusterOptions,
) error

Initialize creates the required secrets and configmaps for the control plane to start

func LoadVirtualConfig

func LoadVirtualConfig(ctx context.Context, options *options.VirtualClusterOptions) (*rest.Config, *clientcmdapi.Config, error)

func NewControllerContext

func NewControllerContext(
	ctx context.Context,
	options *options.VirtualClusterOptions,
	currentNamespace string,
	inClusterConfig *rest.Config,
	scheme *runtime.Scheme,
) (*options.ControllerContext, error)

NewControllerContext builds the controller context we can use to start the syncer

func RegisterOrDeregisterAPIService

func RegisterOrDeregisterAPIService(ctx *options.ControllerContext)

func StartControllers

func StartControllers(controllerContext *options.ControllerContext) error

func StartManagers

func StartManagers(controllerContext *options.ControllerContext, syncers []syncertypes.Object) error

func StartPlugins

func StartPlugins(
	ctx context.Context,
	currentNamespace string,
	inClusterConfig,
	virtualConfig *rest.Config,
	virtualRawConfig *clientcmdapi.Config,
	options *options.VirtualClusterOptions,
) error

func StartProxy

func StartProxy(ctx *options.ControllerContext) error

func SyncKubernetesService

func SyncKubernetesService(ctx *options.ControllerContext) error

func ValidateOptions

func ValidateOptions(options *options.VirtualClusterOptions) error

func WaitForClientConfig

func WaitForClientConfig(ctx context.Context, options *options.VirtualClusterOptions) (clientcmd.ClientConfig, error)

func WriteKubeConfigToSecret

func WriteKubeConfigToSecret(ctx context.Context, currentNamespace string, currentNamespaceClient client.Client, options *options.VirtualClusterOptions, config *clientcmdapi.Config) error