shard

type CommitFunc ¶ added in v0.20.0

type CommitFunc = func(ctx context.Context, original, updated *Resource) error

type Controller ¶

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

Controller watches WorkspaceShards and Secrets in order to make sure every Shard has its URL exposed when a valid kubeconfig is connected to it.

func NewController(
	rootKcpClient kcpclientset.ClusterInterface,
	shardInformer corev1alpha1informers.ShardClusterInformer,
) (*Controller, error)

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

type Patcher ¶ added in v0.20.0

type Patcher = corev1alpha1client.ShardInterface

type Resource ¶ added in v0.20.0

type Resource = committer.Resource[*ShardSpec, *ShardStatus]

type Shard ¶ added in v0.20.0

type Shard = corev1alpha1.Shard

type ShardSpec ¶ added in v0.20.0

type ShardSpec = corev1alpha1.ShardSpec

type ShardStatus ¶ added in v0.20.0

type ShardStatus = corev1alpha1.ShardStatus