multicluster

package
v0.8.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 10, 2023 License: Apache-2.0 Imports: 46 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ConditionDaemonRegistered = "DaemonRegistered"
	ConditionCheckerExecuted  = "CheckerExecuted"
)
View Source 
const CheckerRemoteClusterStatus = "RemoteClusterStatus"
View Source 
const ControllerGlobalService = "GlobalService"
View Source 
const ControllerRemoteCluster = "RemoteCluster"
View Source 
const ControllerRemoteClusterUUID = "RemoteClusterUUID"
View Source 
const (
	ControllerRemoteEndpointSlice = "RemoteEndpointSlice"
)
View Source 
const ControllerRemoteSubnet = "RemoteSubnet"
View Source 
const ControllerRemoteVTEP = "RemoteVTEP"

Variables

This section is empty.

Functions

func InitClusterStatusChecker added in v0.5.0 

func InitClusterStatusChecker(ctx context.Context, mgr ctrl.Manager) (clusterchecker.Checker, error)

func RegisterToManager added in v0.6.0 

func RegisterToManager(ctx context.Context, mgr manager.Manager, options RegisterOptions) error

Types

type GlobalServiceReconciler added in v0.7.0 

type GlobalServiceReconciler struct {
	context.Context
	client.Client

	concurrency.ControllerConcurrency
}

GlobalServiceReconciler reconciles a global Service object

func (*GlobalServiceReconciler) Reconcile added in v0.7.0 

func (r *GlobalServiceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, err error)

func (*GlobalServiceReconciler) SetupWithManager added in v0.7.0 

func (r *GlobalServiceReconciler) SetupWithManager(mgr ctrl.Manager) (err error)

type RegisterOptions added in v0.6.0 

type RegisterOptions struct {
	ConcurrencyMap map[string]int
}

type RemoteClusterReconciler 

type RemoteClusterReconciler struct {
	context.Context
	client.Client

	Recorder record.EventRecorder

	UUIDMutex UUIDMutex

	DaemonHub managerruntime.DaemonHub

	ClusterStatusCheckChan chan<- string

	LocalManager manager.Manager

	concurrency.ControllerConcurrency
}

RemoteClusterReconciler reconciles a RemoteCluster object

func (*RemoteClusterReconciler) Reconcile 

func (r *RemoteClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, err error)

func (*RemoteClusterReconciler) SetupWithManager 

func (r *RemoteClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type RemoteClusterStatusChecker 

type RemoteClusterStatusChecker struct {
	client.Client

	Logger   logr.Logger
	Recorder record.EventRecorder

	CheckPeriod            time.Duration
	Checker                clusterchecker.Checker
	ClusterStatusCheckChan <-chan string
	Queue                  workqueue.RateLimitingInterface
	DaemonHub              managerruntime.DaemonHub

	Concurrency concurrency.ControllerConcurrency
}

func (*RemoteClusterStatusChecker) Start 

func (r *RemoteClusterStatusChecker) Start(ctx context.Context) error

type RemoteClusterUUIDReconciler 

type RemoteClusterUUIDReconciler struct {
	client.Client

	Recorder record.EventRecorder

	UUIDMutex UUIDMutex

	concurrency.ControllerConcurrency
}

func (*RemoteClusterUUIDReconciler) Reconcile 

func (r *RemoteClusterUUIDReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, err error)

func (*RemoteClusterUUIDReconciler) SetupWithManager 

func (r *RemoteClusterUUIDReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type RemoteEndpointSliceReconciler added in v0.7.0 

type RemoteEndpointSliceReconciler struct {
	context.Context
	client.Client

	ClusterName         string
	ParentCluster       cluster.Cluster
	ParentClusterObject *multiclusterv1.RemoteCluster
}

RemoteEndpointSliceReconciler reconciles EndpointSlice objects of parent cluster

func (*RemoteEndpointSliceReconciler) Reconcile added in v0.7.0 

func (r *RemoteEndpointSliceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, err error)

func (*RemoteEndpointSliceReconciler) SetupWithManager added in v0.7.0 

func (r *RemoteEndpointSliceReconciler) SetupWithManager(mgr ctrl.Manager) (err error)

type RemoteSubnetGarbageCollection 

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

func NewRemoteSubnetGarbageCollection 

func NewRemoteSubnetGarbageCollection(logger logr.Logger, reconciler *RemoteSubnetReconciler) *RemoteSubnetGarbageCollection

func (*RemoteSubnetGarbageCollection) EventChannel 

func (r *RemoteSubnetGarbageCollection) EventChannel() <-chan event.GenericEvent

func (*RemoteSubnetGarbageCollection) Start 

func (r *RemoteSubnetGarbageCollection) Start(ctx context.Context) error

type RemoteSubnetReconciler 

type RemoteSubnetReconciler struct {
	client.Client

	ClusterName         string
	ParentCluster       cluster.Cluster
	ParentClusterObject *multiclusterv1.RemoteCluster

	SubnetSet sets.CallbackSet
}

RemoteSubnetReconciler reconciles a RemoteSubnet object

func (*RemoteSubnetReconciler) Reconcile 

func (r *RemoteSubnetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, err error)

func (*RemoteSubnetReconciler) SetupWithManager 

func (r *RemoteSubnetReconciler) SetupWithManager(mgr ctrl.Manager) (err error)

SetupWithManager sets up the controller with the Manager.

type RemoteVTEPGarbageCollection 

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

func NewRemoteVTEPGarbageCollection 

func NewRemoteVTEPGarbageCollection(logger logr.Logger, eventChan chan<- event.GenericEvent, reconciler *RemoteVtepReconciler) *RemoteVTEPGarbageCollection

func (*RemoteVTEPGarbageCollection) Start 

func (r *RemoteVTEPGarbageCollection) Start(ctx context.Context) error

type RemoteVtepReconciler 

type RemoteVtepReconciler struct {
	context.Context
	client.Client

	ClusterName         string
	ParentCluster       cluster.Cluster
	ParentClusterObject *multiclusterv1.RemoteCluster

	SubnetSet    sets.CallbackSet
	EventTrigger chan event.GenericEvent
}

RemoteVtepReconciler reconciles a Node object to RemoveVtep in parent cluster

func (*RemoteVtepReconciler) Reconcile 

func (r *RemoteVtepReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, err error)

func (*RemoteVtepReconciler) RefreshAll 

func (r *RemoteVtepReconciler) RefreshAll()

RefreshAll will trigger all nodes to reconcile, this function should be called when recognized subnet set change

func (*RemoteVtepReconciler) SetupWithManager 

func (r *RemoteVtepReconciler) SetupWithManager(mgr ctrl.Manager) (err error)

SetupWithManager sets up the controller with the Manager.

type UUIDMutex 

type UUIDMutex interface {
	Lock(UUID types.UID, name string) (bool, error)
	Unlock(UUID types.UID) bool
	GetLatestUUID(name string) (bool, types.UID)
	GetUUIDs(name string) []types.UID
}

func NewUUIDMutex 

func NewUUIDMutex() UUIDMutex

func NewUUIDMutexFromClient 

func NewUUIDMutexFromClient(ctx context.Context, c client.Reader) (UUIDMutex, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.