multicluster

Documentation

Index

• Constants
• type StaleResCleanupController
  • func NewStaleResCleanupController(Client client.Client, Scheme *runtime.Scheme, namespace string, ...) *StaleResCleanupController
  • func (c *StaleResCleanupController) Enqueue()
  • func (c *StaleResCleanupController) Run(stopCh <-chan struct{})
  • func (c *StaleResCleanupController) RunOnce(ctx context.Context) error

Constants

const (
	LeaderCluster = "leader"
	MemberCluster = "member"
)

Types

type StaleResCleanupController

type StaleResCleanupController struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

StaleResCleanupController will clean up ServiceImport, MC Service, ACNP, ClusterInfoImport and LabelIdentity resources if no corresponding ResourceImports in the leader cluster and remove stale ResourceExports in the leader cluster if no corresponding ServiceExport or Gateway in the member cluster when it runs in the member cluster. It will clean up stale MemberClusterAnnounce resources in the leader cluster if no corresponding member cluster in the ClusterSet.Spec.Members when it runs in the leader cluster.

func NewStaleResCleanupController

func NewStaleResCleanupController(
	Client client.Client,
	Scheme *runtime.Scheme,
	namespace string,
	commonAreaGetter commonarea.RemoteCommonAreaGetter,
	clusterRole string,
) *StaleResCleanupController

func (*StaleResCleanupController) Enqueue

func (c *StaleResCleanupController) Enqueue()

Enqueue will be called after StaleResCleanupController is initialized.

func (*StaleResCleanupController) Run

func (c *StaleResCleanupController) Run(stopCh <-chan struct{})

Run starts the StaleResCleanupController and blocks until stopCh is closed. it will run only once to clean up stale resources if no error happens.

func (*StaleResCleanupController) RunOnce

func (c *StaleResCleanupController) RunOnce(ctx context.Context) error