workspace

Documentation

Index

• Constants
• func ByBase36Sha224NameValue(name string) string
• func LogicalClustersInitializers(resolver workspacetypeexists.TransitiveTypeResolver, ...) ([]corev1alpha1.LogicalClusterInitializer, error)
• type Controller
  • func NewController(shardName string, shardExternalURL func() string, ...) (*Controller, error)
  • func (c *Controller) Start(ctx context.Context, numThreads int)

Constants

const (
	ControllerName = "kcp-workspace"
)

const (
	// WorkspaceShardHashAnnotationKey keeps track on which shard LogicalCluster must be scheduled. The value
	// is a base36(sha224) hash of the Shard name.
	WorkspaceShardHashAnnotationKey = "internal.tenancy.kcp.io/shard"
)

Functions

func ByBase36Sha224NameValue

func ByBase36Sha224NameValue(name string) string

func LogicalClustersInitializers

func LogicalClustersInitializers(
	resolver workspacetypeexists.TransitiveTypeResolver,
	getWorkspaceType func(clusterName logicalcluster.Path, name string) (*tenancyv1alpha1.WorkspaceType, error),
	typePath logicalcluster.Path, typeName string,
) ([]corev1alpha1.LogicalClusterInitializer, error)

LogicalClustersInitializers returns the initializers for a LogicalCluster of a given fully-qualified WorkspaceType reference.

Types

type Controller

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

Controller watches Workspaces and WorkspaceShards in order to make sure every Workspace is scheduled to a valid Shard.

func NewController

func NewController(
	shardName string,
	shardExternalURL func() string,
	kcpClusterClient kcpclientset.ClusterInterface,
	kubeClusterClient kubernetes.ClusterInterface,
	logicalClusterAdminConfig *rest.Config,
	workspaceInformer tenancyv1alpha1informers.WorkspaceClusterInformer,
	globalShardInformer corev1alpha1informers.ShardClusterInformer,
	globalWorkspaceTypeInformer tenancyv1alpha1informers.WorkspaceTypeClusterInformer,
	logicalClusterInformer corev1alpha1informers.LogicalClusterClusterInformer,
) (*Controller, error)

func (*Controller) Start

func (c *Controller) Start(ctx context.Context, numThreads int)