kubefed

Documentation

Index

• Constants
• type Federator
  • func New(kubeFedConfig *rest.Config, stopChan <-chan struct{}) (*Federator, error)
  • func (f *Federator) AddHandler(handler federate.ClusterEventHandler) error
  • func (f *Federator) Delete(resource runtime.Object) error
  • func (f *Federator) Distribute(resource runtime.Object) error
  • func (f *Federator) OnAdd(obj interface{})
  • func (f *Federator) OnDelete(obj interface{})
  • func (f *Federator) OnUpdate(oldObj, newObj interface{})
• type UnstructuredConversionError
  • func (err *UnstructuredConversionError) Error() string

Constants

const (
	DefaultFederatedGroup   = "types.kubefed.k8s.io"
	DefaultFederatedVersion = "v1beta1"
	SpecField               = "spec"
	TemplateField           = "template"
	PlacementField          = "placement"
	MatchLabelsField        = "matchLabels"
	ClusterSelectorField    = "clusterSelector"
	ApiEndpointField        = "apiEndpoint"
	SecretRefField          = "secretRef"
	NameField               = "name"
	CaBundleField           = "caBundle"
)

Types

type Federator

type Federator struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New(kubeFedConfig *rest.Config, stopChan <-chan struct{}) (*Federator, error)

New creates a new Federator instance.

func (*Federator) AddHandler

func (f *Federator) AddHandler(handler federate.ClusterEventHandler) error

func (*Federator) Delete

func (f *Federator) Delete(resource runtime.Object) error

func (*Federator) Distribute

func (f *Federator) Distribute(resource runtime.Object) error

func (*Federator) OnAdd

func (f *Federator) OnAdd(obj interface{})

func (*Federator) OnDelete

func (f *Federator) OnDelete(obj interface{})

func (*Federator) OnUpdate

func (f *Federator) OnUpdate(oldObj, newObj interface{})

type UnstructuredConversionError

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

func (*UnstructuredConversionError) Error

func (err *UnstructuredConversionError) Error() string