config

Documentation

Index

• type ControlSignal
• type RuntimeAuthentications
  • func NewRuntimeAuthentication(rootCertPath string) *RuntimeAuthentications
• type WorkerRuntime
  • func NewWorkerRuntime(flags *options.WorkerOptions) *WorkerRuntime
  • func (workerRuntime *WorkerRuntime) Add()
  • func (workerRuntime *WorkerRuntime) Done()
  • func (workerRuntime *WorkerRuntime) LoadFlags() error
  • func (workerRuntime *WorkerRuntime) LoadGloabl() error
  • func (workerRuntime *WorkerRuntime) LoadKubeProxy() error
  • func (workerRuntime *WorkerRuntime) LoadKubelet() error
  • func (workerRuntime *WorkerRuntime) LoadNetManager() error
  • func (workerRuntime *WorkerRuntime) Run() error
  • func (workerRuntime *WorkerRuntime) RunForward() error
  • func (workerRuntime *WorkerRuntime) SetFlags(opt *options.WorkerOptions)
  • func (workerRuntime *WorkerRuntime) Stop() error
  • func (workerRuntime *WorkerRuntime) Wait()

Types

type ControlSignal

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

control progress end

type RuntimeAuthentications

type RuntimeAuthentications struct {
	CertDir              string
	NetWorkManagerClient *leaderAuth.NetworkControllerClientAuthentication // nil if user provide certificate
	KubernetesNode       *authentication.KubernetesNode
}

func NewRuntimeAuthentication

func NewRuntimeAuthentication(rootCertPath string) *RuntimeAuthentications

type WorkerRuntime

type WorkerRuntime struct {
	FlagsOption           *options.WorkerOptions
	RuntimeOption         *options.WorkerOptions
	RuntimeAuthentication *RuntimeAuthentications
	NetworkJoinClient     *leaderruntime.NetWorkJoinClient
	NetworkRegisterClient *leaderruntime.NetWorkRegisterClient
	KubernatesClient      *workerruntime.KubernatesClient
	// contains filtered or unexported fields
}

func NewWorkerRuntime

func NewWorkerRuntime(flags *options.WorkerOptions) *WorkerRuntime

func (*WorkerRuntime) Add

func (workerRuntime *WorkerRuntime) Add()

func (*WorkerRuntime) Done

func (workerRuntime *WorkerRuntime) Done()

func (*WorkerRuntime) LoadFlags

func (workerRuntime *WorkerRuntime) LoadFlags() error

load all flags

func (*WorkerRuntime) LoadGloabl

func (workerRuntime *WorkerRuntime) LoadGloabl() error

load or generate args for litekube-global

func (*WorkerRuntime) LoadKubeProxy

func (workerRuntime *WorkerRuntime) LoadKubeProxy() error

func (*WorkerRuntime) LoadKubelet

func (workerRuntime *WorkerRuntime) LoadKubelet() error

func (*WorkerRuntime) LoadNetManager

func (workerRuntime *WorkerRuntime) LoadNetManager() error

func (*WorkerRuntime) Run

func (workerRuntime *WorkerRuntime) Run() error

run k8s

func (*WorkerRuntime) RunForward

func (workerRuntime *WorkerRuntime) RunForward() error

run kine server, network manager server, network client

func (*WorkerRuntime) SetFlags

func (workerRuntime *WorkerRuntime) SetFlags(opt *options.WorkerOptions)

func (*WorkerRuntime) Stop

func (workerRuntime *WorkerRuntime) Stop() error

func (*WorkerRuntime) Wait

func (workerRuntime *WorkerRuntime) Wait()