syncer

type APIImporter ¶ added in v0.6.0

type APIImporter struct {
	SyncedGVRs map[string]metav1.GroupVersionResource
	// contains filtered or unexported fields
}

func NewAPIImporter(
	upstreamConfig, downstreamConfig *rest.Config,
	resourcesToSync []string,
	logicalClusterName logicalcluster.LogicalCluster,
	location string,
) (*APIImporter, error)

func (i *APIImporter) ImportAPIs(ctx context.Context)

func (i *APIImporter) Start(ctx context.Context, pollInterval time.Duration)

func (i *APIImporter) Stop()

type Controller ¶

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

func New(kcpClusterName logicalcluster.LogicalCluster, pcluster string, fromClient, toClient dynamic.Interface, direction SyncDirection, gvrs []string, pclusterID string, mutators mutatorGvrMap) (*Controller, error)

func NewSpecSyncer(from, to *rest.Config, gvrs []string, kcpClusterName logicalcluster.LogicalCluster, pclusterID string) (*Controller, error)

func NewStatusSyncer(from, to *rest.Config, gvrs []string, kcpClusterName logicalcluster.LogicalCluster, pclusterID string) (*Controller, error)

func (c *Controller) AddToQueue(gvr schema.GroupVersionResource, obj interface{})

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

type DeleteFunc ¶

type DeleteFunc func(ctx context.Context, gvr schema.GroupVersionResource, namespace, name string) error

type HandlersProvider ¶

type HandlersProvider func(c *Controller, gvr schema.GroupVersionResource) cache.ResourceEventHandlerFuncs

type NamespaceLocator ¶

type NamespaceLocator struct {
	LogicalCluster logicalcluster.LogicalCluster `json:"logical-cluster"`
	Namespace      string                        `json:"namespace"`
}

NamespaceLocator stores a logical cluster and namespace and is used as the source for the mapped namespace name in a physical cluster.

func LocatorFromAnnotations(annotations map[string]string) (*NamespaceLocator, error)

type SyncDirection ¶

type SyncDirection string

SyncDirection indicates which direction data is flowing for this particular syncer

const SyncDown SyncDirection = "down"

const SyncUp SyncDirection = "up"

type SyncerConfig ¶ added in v0.6.0

type SyncerConfig struct {
	UpstreamConfig      *rest.Config
	DownstreamConfig    *rest.Config
	ResourcesToSync     sets.String
	KCPClusterName      logicalcluster.LogicalCluster
	WorkloadClusterName string
}

SyncerConfig defines the syncer configuration that is guaranteed to vary across syncer deployments. Capturing these details in a struct simplifies defining these details in test fixture.

func (sc *SyncerConfig) ID() string

type UpsertFunc ¶

type UpsertFunc func(ctx context.Context, gvr schema.GroupVersionResource, namespace string, unstrob *unstructured.Unstructured) error