syncer

Documentation

Index

• func LoadPlugins(config *config.SyncerConfiguration) []*plugin.Registration
• type Bootstrap
• type Syncer
  • func New(config *config.SyncerConfiguration, virtualClusterClient vcclient.Interface, ...) (*Syncer, error)
  • func (s *Syncer) ListenAndServe(address, certFile, keyFile string)
  • func (s *Syncer) Run(stopChan <-chan struct{})

Functions

func LoadPlugins

func LoadPlugins(config *config.SyncerConfiguration) []*plugin.Registration

Types

type Bootstrap

type Bootstrap interface {
	ListenAndServe(address, certFile, keyFile string)
	Run(<-chan struct{})
}

Bootstrap is a bootstrapping interface for syncer, targets the initialization protocol

type Syncer

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

func New

func New(
	config *config.SyncerConfiguration,
	virtualClusterClient vcclient.Interface,
	virtualClusterInformer vcinformers.VirtualClusterInformer,
	metaClusterClient clientset.Interface,
	superClusterClient clientset.Interface,
	superClusterInformers informers.SharedInformerFactory,
	recorder record.EventRecorder,
) (*Syncer, error)

func (*Syncer) ListenAndServe

func (s *Syncer) ListenAndServe(address, certFile, keyFile string)

ListenAndServe initializes a server to respond to HTTP network requests on the syncer.

func (*Syncer) Run

func (s *Syncer) Run(stopChan <-chan struct{})

Run begins watching and downward&upward syncing.