controller

Documentation

Index

• func Start(kubeClient *kubernetes.Clientset, namespace string, ...)
• type Controller
  • func (c *Controller) GetPodName() string
  • func (c *Controller) GetPodNamespace() string
  • func (c *Controller) HasSynced() bool
  • func (c *Controller) LastSyncResourceVersion() string
  • func (c *Controller) Run(stopCh <-chan struct{})
• type Tail
  • func (t *Tail) CloseTail()
  • func (t *Tail) DoTail()

Functions

func Start

func Start(kubeClient *kubernetes.Clientset, namespace string, listOptions meta_v1.ListOptions)

Start function starts setting up the informer. This method also find pods with label appType=installer

Types

type Controller

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

Controller object

func (*Controller) GetPodName

func (c *Controller) GetPodName() string

GetPodName - Retrieve the Pod name associated with this controller

func (*Controller) GetPodNamespace

func (c *Controller) GetPodNamespace() string

GetPodNamespace - Retrieves the Namespace associated with this controller

func (*Controller) HasSynced

func (c *Controller) HasSynced() bool

HasSynced is required for the cache.Controller interface.

func (*Controller) LastSyncResourceVersion

func (c *Controller) LastSyncResourceVersion() string

LastSyncResourceVersion is required for the cache.Controller interface.

func (*Controller) Run

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

Run starts the pod runner controller

type Tail

type Tail struct {
	TailClosed chan int
	// contains filtered or unexported fields
}

Tail object

func (*Tail) CloseTail

func (t *Tail) CloseTail()

CloseTail - signal to close the tail channel

func (*Tail) DoTail

func (t *Tail) DoTail()

DoTail - Start tailing the pod logs.