syncer

Documentation

Index

• Constants
• func GetGVRForLocationIndexKey(location string, gvr metav1.GroupVersionResource) string
• func GetLocationIndexKey(location string) string
• func StartHeartbeat(ctx context.Context, kcpSyncTargetClient kcpclientset.Interface, ...)
• func StartSyncer(ctx context.Context, cfg *SyncerConfig, numSyncerThreads int, ...) error
• type APIImporter
  • func NewAPIImporter(upstreamConfig, downstreamConfig *rest.Config, ...) (*APIImporter, error)
  • func (i *APIImporter) ImportAPIs(ctx context.Context)
  • func (i *APIImporter) Start(ctx context.Context, pollInterval time.Duration)
  • func (i *APIImporter) Stop(ctx context.Context)
• type SyncerConfig

Constants

const (
	AdvancedSchedulingFeatureAnnotation = "featuregates.experimental.workload.kcp.io/advancedscheduling"
)

const GVRForLocationIndexName = "GVRForLocation"

const LocationIndexName = "Location"

Functions

func GetGVRForLocationIndexKey

func GetGVRForLocationIndexKey(location string, gvr metav1.GroupVersionResource) string

func GetLocationIndexKey

func GetLocationIndexKey(location string) string

func StartHeartbeat

func StartHeartbeat(ctx context.Context, kcpSyncTargetClient kcpclientset.Interface, syncTargetName, syncTargetUID string)

func StartSyncer

func StartSyncer(ctx context.Context, cfg *SyncerConfig, numSyncerThreads int, importPollInterval time.Duration, syncerNamespace string) error

Types

type APIImporter

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

func NewAPIImporter

func NewAPIImporter(
	upstreamConfig, downstreamConfig *rest.Config,
	synctargetInformer workloadinformers.SyncTargetInformer,
	apiImportInformer apiresourceinformer.APIResourceImportInformer,
	resourcesToSync []string,
	syncTargetPath logicalcluster.Path,
	syncTargetName string,
	syncTargetUID types.UID,
) (*APIImporter, error)

func (*APIImporter) ImportAPIs

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

func (*APIImporter) Start

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

func (*APIImporter) Stop

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

type SyncerConfig

type SyncerConfig struct {
	UpstreamConfig                *rest.Config
	DownstreamConfig              *rest.Config
	ResourcesToSync               sets.String
	SyncTargetPath                logicalcluster.Path
	SyncTargetName                string
	SyncTargetUID                 string
	DownstreamNamespaceCleanDelay time.Duration
	DNSImage                      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.