package sync

import "k8s.io/kubernetes/federation/pkg/federation-controller/sync"

Index ¶

• func StartFederationSyncController(kind string, adapterFactory federatedtypes.AdapterFactory, config *restclient.Config, stopChan <-chan struct{}, minimizeLatency bool, adapterSpecificArgs map[string]interface{})
• type FederationSyncController
• func (s *FederationSyncController) Run(stopChan <-chan struct{})

Functions ¶

func StartFederationSyncController ¶

func StartFederationSyncController(kind string, adapterFactory federatedtypes.AdapterFactory, config *restclient.Config, stopChan <-chan struct{}, minimizeLatency bool, adapterSpecificArgs map[string]interface{})

StartFederationSyncController starts a new sync controller for a type adapter

Types ¶

type FederationSyncController ¶

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

FederationSyncController synchronizes the state of a federated type to clusters that are members of the federation.

func (*FederationSyncController) Run ¶

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

Source Files ¶

controller.go