multicluster

Documentation

Index

• Constants
• func InitClusterStatusChecker(ctx context.Context, mgr ctrl.Manager) (clusterchecker.Checker, error)
• type ClusterCheckEvent
• type RemoteClusterReconciler
  • func (r *RemoteClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, err error)
  • func (r *RemoteClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
• type RemoteClusterStatusChecker
  • func (r *RemoteClusterStatusChecker) Start(ctx context.Context) error
• type RemoteClusterUUIDReconciler
  • func (r *RemoteClusterUUIDReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, err error)
  • func (r *RemoteClusterUUIDReconciler) SetupWithManager(mgr ctrl.Manager) error
• type RemoteSubnetGarbageCollection
  • func NewRemoteSubnetGarbageCollection(logger logr.Logger, reconciler *RemoteSubnetReconciler) *RemoteSubnetGarbageCollection
  • func (r *RemoteSubnetGarbageCollection) EventChannel() <-chan event.GenericEvent
  • func (r *RemoteSubnetGarbageCollection) Start(ctx context.Context) error
• type RemoteSubnetReconciler
  • func (r *RemoteSubnetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, err error)
  • func (r *RemoteSubnetReconciler) SetupWithManager(mgr ctrl.Manager) (err error)
• type RemoteVTEPGarbageCollection
  • func NewRemoteVTEPGarbageCollection(logger logr.Logger, eventChan chan<- event.GenericEvent, ...) *RemoteVTEPGarbageCollection
  • func (r *RemoteVTEPGarbageCollection) Start(ctx context.Context) error
• type RemoteVtepReconciler
  • func (r *RemoteVtepReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, err error)
  • func (r *RemoteVtepReconciler) RefreshAll()
  • func (r *RemoteVtepReconciler) SetupWithManager(mgr ctrl.Manager) (err error)
• type UUIDMutex
  • func NewUUIDMutex() UUIDMutex
  • func NewUUIDMutexFromClient(ctx context.Context, c client.Reader) (UUIDMutex, error)

Constants

const (
	ConditionDaemonRegistered = "DaemonRegistered"
	ConditionCheckerExecuted  = "CheckerExecuted"
)

const CheckerRemoteClusterStatus = "RemoteClusterStatus"

const ControllerRemoteCluster = "RemoteCluster"

const ControllerRemoteClusterUUID = "RemoteClusterUUID"

const ControllerRemoteSubnet = "RemoteSubnet"

const ControllerRemoteVTEP = "RemoteVTEP"

Functions

func InitClusterStatusChecker

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

Types

type ClusterCheckEvent

type ClusterCheckEvent struct {
	Context  context.Context
	Name     string
	DaemonID managerruntime.DaemonID
}

type RemoteClusterReconciler

type RemoteClusterReconciler struct {
	context.Context
	client.Client

	Recorder record.EventRecorder

	UUIDMutex UUIDMutex

	DaemonHub managerruntime.DaemonHub

	Event chan<- ClusterCheckEvent

	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

	CheckPeriod time.Duration

	DaemonHub managerruntime.DaemonHub

	Checker clusterchecker.Checker

	Event <-chan ClusterCheckEvent

	Recorder record.EventRecorder
}

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 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)