syncer

Documentation

Index

• Constants
• func StartSyncer(ctx context.Context, cfg *SyncerConfig, numSyncerThreads int, ...) error
• type APIImporter
  • func NewAPIImporter(upstreamConfig, downstreamConfig *rest.Config, resourcesToSync []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 SyncerConfig

Constants

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

Functions

func StartSyncer

func StartSyncer(ctx context.Context, cfg *SyncerConfig, numSyncerThreads int, importPollInterval time.Duration) 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,
	resourcesToSync []string,
	logicalClusterName logicalcluster.Name,
	location string,
) (*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()

type SyncerConfig

type SyncerConfig struct {
	UpstreamConfig      *rest.Config
	DownstreamConfig    *rest.Config
	ResourcesToSync     sets.String
	SyncTargetWorkspace logicalcluster.Name
	SyncTargetName      string
	SyncTargetUID       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.