kube

Documentation

Index

• type Config
• type Kube
  • func New(c *Config) *Kube
  • func (c *Kube) Initialize() error
  • func (c *Kube) IntegrateWith(name string, r Runnable)
  • func (c *Kube) Run(stop <-chan struct{})
• type Runnable

Types

type Config

type Config struct {
	EnablePprof bool
	PprofAddr   string
	KlogLevel   string
}

type Kube

type Kube struct {
	*Config

	RunnableComponents map[string]Runnable
}

func New

func New(c *Config) *Kube

func (*Kube) Initialize

func (c *Kube) Initialize() error

Initialize init all components of kube, block util initialization completed or error occurred.

func (*Kube) IntegrateWith

func (c *Kube) IntegrateWith(name string, r Runnable)

func (*Kube) Run

func (c *Kube) Run(stop <-chan struct{})

type Runnable

type Runnable interface {
	Run(stop <-chan struct{})
	Initialize() error
}

Runnable run components after initialized