syncer

Documentation

Index

• func StartSyncer(ctx context.Context, cfg *SyncerConfig, numSyncerThreads int) error
• type Controller
  • func New(fromClient, toClient dynamic.Interface, direction SyncDirection) (*Controller, error)
  • func NewSpecSyncer(from, to *rest.Config) (*Controller, error)
  • func NewStatusSyncer(from, to *rest.Config) (*Controller, error)
  • func (c *Controller) AddToQueue(gvr schema.GroupVersionResource, obj interface{})
  • func (c *Controller) Start(ctx context.Context, numThreads int)
• type DeleteFunc
• type SyncDirection
• type SyncerConfig
• type UpsertFunc

Functions

func StartSyncer

func StartSyncer(ctx context.Context, cfg *SyncerConfig, numSyncerThreads int) error

Types

type Controller

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

func New

func New(fromClient, toClient dynamic.Interface, direction SyncDirection) (*Controller, error)

New returns a new syncer Controller syncing spec from "from" to "to".

func NewSpecSyncer

func NewSpecSyncer(from, to *rest.Config) (*Controller, error)

func NewStatusSyncer

func NewStatusSyncer(from, to *rest.Config) (*Controller, error)

func (*Controller) AddToQueue

func (c *Controller) AddToQueue(gvr schema.GroupVersionResource, obj interface{})

func (*Controller) Start

func (c *Controller) Start(ctx context.Context, numThreads int)

Start starts N worker processes processing work items.

type DeleteFunc

type DeleteFunc func(ctx context.Context, gvr schema.GroupVersionResource, namespace, name string) error

type SyncDirection

type SyncDirection string

SyncDirection indicates which direction data is flowing for this particular syncer

const (

	// SyncDown indicates a syncer watches resources on HoH and applies the spec to the leaf cluster
	SyncDown SyncDirection = "down"

	// SyncUp indicates a syncer watches resources on the leaft cluster and applies the status to HoH
	SyncUp SyncDirection = "up"
)

type SyncerConfig

type SyncerConfig struct {
	UpstreamConfig   *rest.Config
	DownstreamConfig *rest.Config
}

SyncerConfig defines the syncer configuration that is guaranteed to vary across syncer deployments.

type UpsertFunc

type UpsertFunc func(ctx context.Context, gvr schema.GroupVersionResource, namespace string, unstrob *unstructured.Unstructured) error