provider

type NewClusterFunc func(cfg *rest.Config, clusterName logicalcluster.Name, wildcardCA mcpcache.WildcardCache, scheme *runtime.Scheme, recorderProvider mcrecorder.EventRecorderGetter) (*mcpcache.ScopedCluster, error)

type Options struct {
	// Scheme is the scheme to use for the provider.
	// If this is nil it defaults to the client-go scheme.
	Scheme *runtime.Scheme

	// EndpointSliceObject is the object type for the endpoint slice,
	// that records virtual workspace URLs of different shards.
	// If this is nil it defaults to [apisv1alpha2.APIExportEndpointSlice].
	EndpointSliceObject client.Object

	// ExtractURLsFromEndpointSlice is used to extract the URLs from the EndpointSliceObject.
	// If this is nil it defaults to [DefaultExtractURLsFromEndpointSlice].
	ExtractURLsFromEndpointSlice URLExtractor

	// ObjectToWatch is the object type the provider watches inside of
	// the virtual workspaces to observe logical clusters joining and
	// leaving the virtual workspaces.
	// If this is nil it defaults to [apisv1alpha2.APIBinding].
	ObjectToWatch client.Object

	// Log is the logger used to write any logs.
	Log *logr.Logger

	// NewCluster allows to customize the cluster instance that is being created for
	// each engaged cluster. If this is not set, it defaults to a ScopedCache that
	// uses the wildcard endpoint for its cache.
	NewCluster NewClusterFunc

	// AddFilter is called to filter objects to engage.
	// If false is returned the object is not engaged.
	AddFilter func(obj client.Object) (bool, error)

	// UpdateFilter is called to filter objects to engage.
	// If false is returned the object is not engaged.
	UpdateFilter func(obj client.Object) (bool, error)

	// Handlers are lifecycle handlers for logical clusters managed by this provider represented
	// by apibinding object.
	Handlers handlers.Handlers
}

type Provider struct {

	// Clusters keeps track of all engaged clusters.
	Clusters clusters.Clusters[cluster.Cluster]
	// contains filtered or unexported fields
}

type URLExtractor func(obj client.Object) ([]string, error)