config

Documentation

Index

• type ControlSignal
• type LeaderRuntime
  • func NewLeaderRuntime(flags *options.LeaderOptions) *LeaderRuntime
  • func (leaderRuntime *LeaderRuntime) Add()
  • func (leaderRuntime *LeaderRuntime) Done()
  • func (leaderRuntime *LeaderRuntime) LoadApiserver() error
  • func (leaderRuntime *LeaderRuntime) LoadControllermanager() error
  • func (leaderRuntime *LeaderRuntime) LoadFlags() error
  • func (leaderRuntime *LeaderRuntime) LoadGloabl() error
  • func (leaderRuntime *LeaderRuntime) LoadKine() error
  • func (leaderRuntime *LeaderRuntime) LoadNetManager() error
  • func (leaderRuntime *LeaderRuntime) LoadScheduler() error
  • func (leaderRuntime *LeaderRuntime) Run() error
  • func (leaderRuntime *LeaderRuntime) RunForward() error
  • func (leaderRuntime *LeaderRuntime) SetFlags(opt *options.LeaderOptions)
  • func (leaderRuntime *LeaderRuntime) Stop() error
  • func (leaderRuntime *LeaderRuntime) Wait()
• type RuntimeAuthentications
  • func NewRuntimeAuthentication(rootCertPath string) *RuntimeAuthentications

Types

type ControlSignal

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

control progress end

type LeaderRuntime

type LeaderRuntime struct {
	FlagsOption             *options.LeaderOptions
	RuntimeOption           *options.LeaderOptions
	RuntimeAuthentication   *RuntimeAuthentications
	KineServer              *runtime.KineServer
	NetworkControllerServer *runtime.NetWorkControllerServer
	NetworkJoinClient       *runtime.NetWorkJoinClient
	NetworkRegisterClient   *runtime.NetWorkRegisterClient
	KubernetesServer        *runtime.KubernatesServer

	OwnKineCert bool
	// contains filtered or unexported fields
}

func NewLeaderRuntime

func NewLeaderRuntime(flags *options.LeaderOptions) *LeaderRuntime

func (*LeaderRuntime) Add

func (leaderRuntime *LeaderRuntime) Add()

func (*LeaderRuntime) Done

func (leaderRuntime *LeaderRuntime) Done()

func (*LeaderRuntime) LoadApiserver

func (leaderRuntime *LeaderRuntime) LoadApiserver() error

func (*LeaderRuntime) LoadControllermanager

func (leaderRuntime *LeaderRuntime) LoadControllermanager() error

func (*LeaderRuntime) LoadFlags

func (leaderRuntime *LeaderRuntime) LoadFlags() error

load all flags

func (*LeaderRuntime) LoadGloabl

func (leaderRuntime *LeaderRuntime) LoadGloabl() error

load or generate args for litekube-global

func (*LeaderRuntime) LoadKine

func (leaderRuntime *LeaderRuntime) LoadKine() error

load or generate args for kine server client certificate will be generate to path, too

func (*LeaderRuntime) LoadNetManager

func (leaderRuntime *LeaderRuntime) LoadNetManager() error

load network-manager client config if run-network-manager==true, runtime.RuntimeAuthentication.NetWorkManager will init

func (*LeaderRuntime) LoadScheduler

func (leaderRuntime *LeaderRuntime) LoadScheduler() error

func (*LeaderRuntime) Run

func (leaderRuntime *LeaderRuntime) Run() error

run k8s and litekube controller

func (*LeaderRuntime) RunForward

func (leaderRuntime *LeaderRuntime) RunForward() error

run kine server, network manager server, network client

func (*LeaderRuntime) SetFlags

func (leaderRuntime *LeaderRuntime) SetFlags(opt *options.LeaderOptions)

func (*LeaderRuntime) Stop

func (leaderRuntime *LeaderRuntime) Stop() error

func (*LeaderRuntime) Wait

func (leaderRuntime *LeaderRuntime) Wait()

type RuntimeAuthentications

type RuntimeAuthentications struct {
	CertDir                 string
	NetWorkControllerClient *authentication.NetworkControllerClientAuthentication // nil if user provide certificate
	NetWorkController       *authentication.NetworkControllerAuthentication       // nil if network manager not run in leader
	Kine                    *authentication.KineAuthentication                    // nil if not run kine in leader or provide server certificate by user
	Kubernetes              *authentication.KubernetesAuthentication
}

func NewRuntimeAuthentication

func NewRuntimeAuthentication(rootCertPath string) *RuntimeAuthentications