location

Documentation

Index

• func FilterNonEvicting(syncTargets []*workloadv1alpha1.SyncTarget) []*workloadv1alpha1.SyncTarget
• func FilterReady(syncTargets []*workloadv1alpha1.SyncTarget) []*workloadv1alpha1.SyncTarget
• func LocationSyncTargets(syncTargets []*workloadv1alpha1.SyncTarget, ...) (ret []*workloadv1alpha1.SyncTarget, err error)
• func NewController(kcpClusterClient kcpclientset.ClusterInterface, ...) (*controller, error)
• type CommitFunc
• type Location
• type LocationSpec
• type LocationStatus
• type Patcher
• type Resource

Functions

func FilterNonEvicting

func FilterNonEvicting(syncTargets []*workloadv1alpha1.SyncTarget) []*workloadv1alpha1.SyncTarget

FilterNonEvicting filters out the evicting sync targets.

func FilterReady

func FilterReady(syncTargets []*workloadv1alpha1.SyncTarget) []*workloadv1alpha1.SyncTarget

FilterReady returns the ready sync targets.

func LocationSyncTargets

func LocationSyncTargets(syncTargets []*workloadv1alpha1.SyncTarget, location *schedulingv1alpha1.Location) (ret []*workloadv1alpha1.SyncTarget, err error)

LocationSyncTargets returns a list of sync targets that match the given location definition.

func NewController

func NewController(
	kcpClusterClient kcpclientset.ClusterInterface,
	tmcClusterClient tmcclientset.ClusterInterface,
	locationInformer schedulingv1alpha1informers.LocationClusterInformer,
	syncTargetInformer workloadv1alpha1informers.SyncTargetClusterInformer,
) (*controller, error)

NewController returns a new controller reconciling location status.

Types

type CommitFunc

type CommitFunc = func(context.Context, *Resource, *Resource) error

type Location

type Location = schedulingv1alpha1.Location

type LocationSpec

type LocationSpec = schedulingv1alpha1.LocationSpec

type LocationStatus

type LocationStatus = schedulingv1alpha1.LocationStatus

type Patcher

type Patcher = schedulingv1alpha1client.LocationInterface

type Resource

type Resource = committer.Resource[*LocationSpec, *LocationStatus]