sync

Documentation

Overview

Package sync contains a controller that watches the APIExport we manage in kcp. Once the virtual workspace URL for said APIExport is ready, the controller will begin to synchronize resources back and forth between kcp (i.e. all relevant workspaces) and the service cluster.

Index

• Constants
• func Create(ctx context.Context, localManager manager.Manager, ...) (mccontroller.Controller, error)
• type Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, request mcreconcile.Request) (reconcile.Result, error)

Constants

const (
	ControllerName = "syncagent-sync"
)

Functions

func Create

func Create(
	ctx context.Context,
	localManager manager.Manager,
	remoteManager mcmanager.Manager,
	pubRes *syncagentv1alpha1.PublishedResource,
	discoveryClient *discovery.Client,
	stateNamespace string,
	agentName string,
	log *zap.SugaredLogger,
	numWorkers int,
) (mccontroller.Controller, error)

Create creates a new controller and importantly does *not* add it to the manager, as this controller is started/stopped by the syncmanager controller instead.

Types

type Reconciler

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

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, request mcreconcile.Request) (reconcile.Result, error)