controller

Documentation

Index

• func NewKubeClient(kubeconfig string, master_url string) (*kubernetes.Clientset, error)
• type ClientGenerator
• type Controller
  • func NewController(cfg *config.Config) *Controller
  • func (c *Controller) HandleSecrets(cli kubernetes.Interface) error
  • func (c *Controller) Run(stopChan <-chan struct{})
  • func (c *Controller) RunOnce() error
• type SingletonClientGenerator
  • func (p *SingletonClientGenerator) KubeClient() (kubernetes.Interface, error)

Functions

func NewKubeClient

func NewKubeClient(kubeconfig string, master_url string) (*kubernetes.Clientset, error)

will fallback to restclient.InClusterConfig() if both kubeconfig/master_url == ""

Types

type ClientGenerator

type ClientGenerator interface {
	KubeClient() (kubernetes.Interface, error)
}

ClientGenerator provides clients

type Controller

type Controller struct {
	Interval time.Duration
	Provider provider.Provider
	KubeGen  ClientGenerator
}

func NewController

func NewController(cfg *config.Config) *Controller

func (*Controller) HandleSecrets

func (c *Controller) HandleSecrets(cli kubernetes.Interface) error

func (*Controller) Run

func (c *Controller) Run(stopChan <-chan struct{})

func (*Controller) RunOnce

func (c *Controller) RunOnce() error

type SingletonClientGenerator

type SingletonClientGenerator struct {
	KubeConfig string
	KubeMaster string

	sync.Once
	// contains filtered or unexported fields
}

SingletonClientGenerator stores provider clients and guarantees that only one instance of client will be generated

func (*SingletonClientGenerator) KubeClient

func (p *SingletonClientGenerator) KubeClient() (kubernetes.Interface, error)

KubeClient generates a kube client if it was not created before