index

Documentation

Index

• type ClusterClientGetter
• type Controller
  • func NewController(ctx context.Context, shardInformer corev1alpha1informers.ShardInformer, ...) *Controller
  • func (c *Controller) LookupURL(path logicalcluster.Path) (url string, found bool)
  • func (c *Controller) Start(ctx context.Context, numThreads int)
• type Index

Types

type ClusterClientGetter

type ClusterClientGetter func(shard *corev1alpha1.Shard) (kcpclientset.ClusterInterface, error)

type Controller

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

Controller watches Shards on the root shard, and then starts informers for every Shard, watching the Workspaces on them. It then updates the workspace index, which maps logical clusters to shard URLs.

func NewController

func NewController(
	ctx context.Context,
	shardInformer corev1alpha1informers.ShardInformer,
	clientGetter ClusterClientGetter,
) *Controller

func (*Controller) LookupURL

func (c *Controller) LookupURL(path logicalcluster.Path) (url string, found bool)

func (*Controller) Start

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

Start the controller. It does not really do anything, but to keep the shape of a normal controller, we keep it.

type Index

type Index interface {
	LookupURL(path logicalcluster.Path) (url string, found bool)
}