apireconciler

Documentation

Index

• Constants
• func IndexAPIExportsByAPIResourceSchemas(obj interface{}) ([]string, error)
• func IndexSyncTargetsByExports(obj interface{}) ([]string, error)
• type APIReconciler
  • func NewAPIReconciler(virtualWorkspaceName string, ...) (*APIReconciler, error)
  • func (c *APIReconciler) GetAPIDefinitionSet(_ context.Context, key dynamiccontext.APIDomainKey) (apidefinition.APIDefinitionSet, bool, error)
  • func (c *APIReconciler) ShutDown()
  • func (c *APIReconciler) Start(ctx context.Context)
• type AllowedAPIfilterFunc
• type CreateAPIDefinitionFunc

Constants

const (
	ControllerName                     = "tmc-virtual-syncer-api-reconciler-"
	IndexSyncTargetsByExport           = ControllerName + "ByExport"
	IndexAPIExportsByAPIResourceSchema = ControllerName + "ByAPIResourceSchema"
)

Functions

func IndexAPIExportsByAPIResourceSchemas

func IndexAPIExportsByAPIResourceSchemas(obj interface{}) ([]string, error)

IndexAPIExportsByAPIResourceSchemas is an index function that maps an APIExport to its spec.latestResourceSchemas.

func IndexSyncTargetsByExports

func IndexSyncTargetsByExports(obj interface{}) ([]string, error)

Types

type APIReconciler

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

APIReconciler is a controller watching APIExports, APIResourceSchemas and SyncTargets, and updates the API definitions driving the virtual workspace.

func NewAPIReconciler

func NewAPIReconciler(
	virtualWorkspaceName string,
	syncTargetInformer workloadv1alpha1informers.SyncTargetClusterInformer,
	apiResourceSchemaInformer apisv1alpha1informers.APIResourceSchemaClusterInformer,
	apiExportInformer apisv1alpha1informers.APIExportClusterInformer,
	createAPIDefinition CreateAPIDefinitionFunc,
	allowedAPIfilter AllowedAPIfilterFunc,
) (*APIReconciler, error)

func (*APIReconciler) GetAPIDefinitionSet

func (c *APIReconciler) GetAPIDefinitionSet(_ context.Context, key dynamiccontext.APIDomainKey) (apidefinition.APIDefinitionSet, bool, error)

func (*APIReconciler) ShutDown

func (c *APIReconciler) ShutDown()

func (*APIReconciler) Start

func (c *APIReconciler) Start(ctx context.Context)

type AllowedAPIfilterFunc

type AllowedAPIfilterFunc func(apiGroupResource schema.GroupResource) bool

type CreateAPIDefinitionFunc

type CreateAPIDefinitionFunc func(syncTargetWorkspace logicalcluster.Name, syncTargetName string, apiResourceSchema *apisv1alpha1.APIResourceSchema, version string, identityHash string) (apidefinition.APIDefinition, error)