multicluster

Documentation

Index

• Variables
• func NewAggregatedWatchClusterClientHandler(aggregator wrapper.WatchAggregator) *clusterWatchAggregator
• func NewClusterClientManager(ctx context.Context, clientFactory factory.ClusterClientFactory, ...) *clusterClientManager
• func NewMultiClusterResourceClient(resourceType resources.Resource, clientSet ClusterClientGetter) *multiClusterResourceClient
• type ClientForClusterHandler
• type ClusterClientGetter

Variables

var (
	NoClientForClusterError = func(kind, cluster string) error {
		return errors.Errorf("%v client does not exist for %v", kind, cluster)
	}
)

Functions

func NewAggregatedWatchClusterClientHandler

func NewAggregatedWatchClusterClientHandler(aggregator wrapper.WatchAggregator) *clusterWatchAggregator

Provides a ClientForClusterHandler to sync an aggregated watch with clients available on a cluster.

func NewClusterClientManager

func NewClusterClientManager(ctx context.Context, clientFactory factory.ClusterClientFactory, handlers ...ClientForClusterHandler) *clusterClientManager

func NewMultiClusterResourceClient

func NewMultiClusterResourceClient(resourceType resources.Resource, clientSet ClusterClientGetter) *multiClusterResourceClient

Types

type ClientForClusterHandler

type ClientForClusterHandler interface {
	HandleNewClusterClient(cluster string, client clients.ResourceClient)
	HandleRemovedClusterClient(cluster string, client clients.ResourceClient)
}

Allows objects to register callbacks with a ClusterClientGetter.

type ClusterClientGetter

type ClusterClientGetter interface {
	// Returns a client for the given cluster if one exists.
	ClientForCluster(cluster string) (client clients.ResourceClient, found bool)
}

Stores clients for clusters as they are discovered by a config watcher. Implementation in this package allows registration of ClusterClientHandlers.