resource

Documentation

Index

• func DeleteAll(kube common.Kube, name string, kind string, listKind string, ...) error
• func GetNamespaces(client kubernetes.Interface) ([]string, error)
• type Synchronizer
  • func NewSynchronizer(kube common.Kube, resyncPeriod time.Duration, source schema.GroupVersion, ...) (s *Synchronizer, err error)
  • func (s *Synchronizer) Start()
  • func (s *Synchronizer) Stop()

Functions

func DeleteAll

func DeleteAll(kube common.Kube, name string, kind string, listKind string, gv schema.GroupVersion, namespaces []string) error

DeleteAll deletes all resources in the specified custom resource set for given namespaces.

func GetNamespaces

func GetNamespaces(client kubernetes.Interface) ([]string, error)

GetNamespaces returns the currently known namespaces.

Types

type Synchronizer

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

Synchronizer is a Kubernetes controller that keeps a synchronized copy of an accessor set of custom resources in destination APIGroup/Version(s). The mapping from sources to destinations are specified by the respective schema.GroupVersion resources given during initialization.

func NewSynchronizer

func NewSynchronizer(kube common.Kube, resyncPeriod time.Duration, source schema.GroupVersion,
	destination schema.GroupVersion, name, kind, listKind string) (s *Synchronizer, err error)

NewSynchronizer returns a new instance of a Synchronizer

func (*Synchronizer) Start

func (s *Synchronizer) Start()

Start the resource synchronizer

func (*Synchronizer) Stop

func (s *Synchronizer) Stop()

Stop the resource synchronizer.