crdreplicator

Documentation

Overview

Package crdreplicator implements the logic for the replication of CustomResourceDefinitions between the peered clusters.

Index

• type Controller
  • func (c *Controller) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, err error)
  • func (c *Controller) SetupWithManager(mgr ctrl.Manager) error

Types

type Controller

type Controller struct {
	Scheme *runtime.Scheme
	client.Client
	ClusterID string

	// RegisteredResources is a list of GVRs of resources to be replicated, with the associated peering phase when the replication has to occur.
	RegisteredResources []resources.Resource

	// ReflectionManager is the object managing the reflection towards remote clusters.
	ReflectionManager *reflection.Manager
	// Reflectors is a map containing the reflectors towards each remote cluster.
	Reflectors map[string]*reflection.Reflector

	// IdentityReader is an interface to manage remote identities, and to get the rest config.
	IdentityReader identitymanager.IdentityReader
	// contains filtered or unexported fields
}

Controller reconciles ForeignCluster objects to start/stop the reflection of registered resources to remote clusters.

func (*Controller) Reconcile

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

Reconcile handles requests for subscribed types of object.

func (*Controller) SetupWithManager

func (c *Controller) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager registers a new controller for ForeignCluster resources.