controller

Documentation

Index

• Variables
• type Controller
  • func NewController(toolName string, cluster bool, namespace string, ...) *Controller
  • func (self *Controller) GetConfigMap(namespace string, networkName string) (*core.ConfigMap, error)
  • func (self *Controller) Run(concurrency uint, startup func()) error

Variables

var ConfigMapGVK = schema.GroupVersionKind{Group: "", Version: "v1", Kind: "ConfigMap"}

Types

type Controller

type Controller struct {
	Namespace   string
	Kubernetes  kubernetes.Interface
	Dynamic     *kubernetesutil.Dynamic
	StopChannel <-chan struct{}

	Processors *kubernetesutil.Processors
	Events     record.EventRecorder

	KubernetesInformerFactory informers.SharedInformerFactory

	ConfigMaps listers.ConfigMapLister

	Context contextpkg.Context
	Log     commonlog.Logger
}

func NewController

func NewController(toolName string, cluster bool, namespace string, kubernetes kubernetes.Interface, dynamic dynamicpkg.Interface, informerResyncPeriod time.Duration, stopChannel <-chan struct{}) *Controller

func (*Controller) GetConfigMap

func (self *Controller) GetConfigMap(namespace string, networkName string) (*core.ConfigMap, error)

func (*Controller) Run

func (self *Controller) Run(concurrency uint, startup func()) error