syncer

Documentation

Index

• Constants
• func NamespacesForSelector(kc kubernetes.Interface, selector string) (sets.String, error)
• type ConfigSyncer
  • func New(kc kubernetes.Interface, recorder record.EventRecorder) *ConfigSyncer
  • func (s *ConfigSyncer) ConfigMapHandler() cache.ResourceEventHandler
  • func (s *ConfigSyncer) Configure(clusterName string, kubeconfigFile string) error
  • func (s *ConfigSyncer) NamespaceHandler() cache.ResourceEventHandler
  • func (s *ConfigSyncer) SecretHandler() cache.ResourceEventHandler
  • func (s *ConfigSyncer) SyncConfigMap(src *core.ConfigMap) error
  • func (s *ConfigSyncer) SyncDeletedConfigMap(src *core.ConfigMap) error
  • func (s *ConfigSyncer) SyncDeletedSecret(src *core.Secret) error
  • func (s *ConfigSyncer) SyncIntoNamespace(namespace string) error
  • func (s *ConfigSyncer) SyncSecret(src *core.Secret) error
• type SyncOptions
  • func GetSyncOptions(annotations map[string]string) SyncOptions

Constants

const (
	ConfigSyncKey      = "kubed.appscode.com/sync"
	ConfigOriginKey    = "kubed.appscode.com/origin"
	ConfigSyncContexts = "kubed.appscode.com/sync-contexts"

	OriginNameLabelKey      = "kubed.appscode.com/origin.name"
	OriginNamespaceLabelKey = "kubed.appscode.com/origin.namespace"
	OriginClusterLabelKey   = "kubed.appscode.com/origin.cluster"
)

Functions

func NamespacesForSelector

func NamespacesForSelector(kc kubernetes.Interface, selector string) (sets.String, error)

Types

type ConfigSyncer

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

func New

func New(kc kubernetes.Interface, recorder record.EventRecorder) *ConfigSyncer

func (*ConfigSyncer) ConfigMapHandler

func (s *ConfigSyncer) ConfigMapHandler() cache.ResourceEventHandler

func (*ConfigSyncer) Configure

func (s *ConfigSyncer) Configure(clusterName string, kubeconfigFile string) error

func (*ConfigSyncer) NamespaceHandler

func (s *ConfigSyncer) NamespaceHandler() cache.ResourceEventHandler

func (*ConfigSyncer) SecretHandler

func (s *ConfigSyncer) SecretHandler() cache.ResourceEventHandler

func (*ConfigSyncer) SyncConfigMap

func (s *ConfigSyncer) SyncConfigMap(src *core.ConfigMap) error

func (*ConfigSyncer) SyncDeletedConfigMap

func (s *ConfigSyncer) SyncDeletedConfigMap(src *core.ConfigMap) error

source deleted, delete that were previously added

func (*ConfigSyncer) SyncDeletedSecret

func (s *ConfigSyncer) SyncDeletedSecret(src *core.Secret) error

source deleted, delete that were previously added

func (*ConfigSyncer) SyncIntoNamespace

func (s *ConfigSyncer) SyncIntoNamespace(namespace string) error

func (*ConfigSyncer) SyncSecret

func (s *ConfigSyncer) SyncSecret(src *core.Secret) error

type SyncOptions

type SyncOptions struct {
	NamespaceSelector *string // if nil, delete from cluster
	Contexts          sets.String
}

func GetSyncOptions

func GetSyncOptions(annotations map[string]string) SyncOptions