master

Documentation

Index

• type Controller
  • func NewMasterController(conf option.Config, store store.Storer, kubeClient kubernetes.Interface, ...) (*Controller, error)
  • func (m *Controller) GetStore() store.Storer
  • func (m *Controller) IsLeader() bool
  • func (m *Controller) Scrape(ch chan<- prometheus.Metric, scrapeDurationDesc *prometheus.Desc)
  • func (m *Controller) Start() error
  • func (m *Controller) Stop()

Types

type Controller

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

Controller app runtime master controller

func NewMasterController

func NewMasterController(conf option.Config, store store.Storer, kubeClient kubernetes.Interface, katoClient versioned.Interface, restConfig *rest.Config) (*Controller, error)

NewMasterController new master controller

func (*Controller) GetStore

func (m *Controller) GetStore() store.Storer

GetStore -

func (*Controller) IsLeader

func (m *Controller) IsLeader() bool

IsLeader is leader

func (*Controller) Scrape

func (m *Controller) Scrape(ch chan<- prometheus.Metric, scrapeDurationDesc *prometheus.Desc)

Scrape scrape app runtime

func (*Controller) Start

func (m *Controller) Start() error

Start start

func (*Controller) Stop

func (m *Controller) Stop()

Stop stop