Versions in this module Expand all Collapse all v0 v0.1.0 May 19, 2022 Changes in this version + type Apiserver struct + LogPath string + Options *apiserver.ApiserverOptions + func NewApiserver(ctx context.Context, opt *apiserver.ApiserverOptions, logPath string) *Apiserver + func (s *Apiserver) Run() error + type ControllerManager struct + LogPath string + Options *controllermanager.ControllerManagerOptions + func NewControllerManager(ctx context.Context, opt *controllermanager.ControllerManagerOptions, ...) *ControllerManager + func (s *ControllerManager) Run(kubeAdminPath string) error + func (s *ControllerManager) WaitForAPIServer(ctx context.Context, kubeAdminPath string) error + type KineServer struct + BindAddress string + CAPath string + CertPath string + DBPath string + KeyPath string + LogPath string + Port uint16 + func NewKineServer(ctx context.Context, opt *kine.KineOptions, dbPath string, logPath string) *KineServer + func (s *KineServer) Run() error + type KubernatesServer struct + ApiserverOptions *apiserver.ApiserverOptions + ControllerOptions *controllermanager.ControllerManagerOptions + KubeAdminPath string + SchedulerOptions *scheduler.SchedulerOptions + func NewKubernatesServer(ctx context.Context, apiserverOptions *apiserver.ApiserverOptions, ...) *KubernatesServer + func (s *KubernatesServer) Run() error + func (s *KubernatesServer) RunAfter() error + type LiteKubeControl struct + AuthFile string + AuthTokenFile string + BindAddress string + BindPort uint16 + BufferPath string + CacheClientCertPath string + CacheClientKeyPath string + CacheServerCertPath string + CacheServerKeyPath string + ClusterCIDR string + ClusterDNS string + EndPoint string + LocalHostNodeToken string + NetworkClient *NetWorkRegisterClient + ServiceClusterIpRange string + SignalApiserverClientCert string + SignalApiserverClientKey string + SignalKubeletServerCert string + SignalKubeletServerKey string + Token string + ValidateApiserverClientCA string + ValidateApiserverClientCABase64 string + ValidateApiserverServerCA string + ValidateApiserverServerCABase64 string + func NewLiteKubeControl(ctx context.Context, networkClient *NetWorkRegisterClient, bufferPath string, ...) *LiteKubeControl + func (s *LiteKubeControl) BootStrapKubeProxy(ctx context.Context, request *control.BootStrapKubeProxyRequest) (*control.BootStrapKubeProxyResponse, error) + func (s *LiteKubeControl) BootStrapKubelet(ctx context.Context, in *control.BootStrapKubeletRequest) (*control.BootStrapKubeletResponse, error) + func (s *LiteKubeControl) BootStrapNetwork(ctx context.Context, in *control.BootStrapNetworkRequest) (*control.BootStrapNetworkResponse, error) + func (s *LiteKubeControl) BootstrapValidateKubeApiserverClient(ctx context.Context, in *control.NoneValue) (*control.BootstrapValidateKubeApiserverClientResponse, error) + func (s *LiteKubeControl) CheckHealth(ctx context.Context, in *control.NoneValue) (*control.HealthDescription, error) + func (s *LiteKubeControl) CreateToken(ctx context.Context, in *control.CreateTokenRequest) (*control.TokenValue, error) + func (s *LiteKubeControl) DeleteToken(ctx context.Context, in *control.TokenString) (*control.NoneResponse, error) + func (s *LiteKubeControl) Init() error + func (s *LiteKubeControl) NodeToken(ctx context.Context, in *control.NoneValue) (*control.TokenString, error) + func (s *LiteKubeControl) QueryTokens(ctx context.Context, in *control.NoneValue) (*control.TokenValueList, error) + func (s *LiteKubeControl) Run() error + func (s *LiteKubeControl) TokenInterceptor() ... + type NetWorkControllerServer struct + JoinBindAddress string + JoinCACert string + JoinCAKey string + JoinPort uint16 + JoinServerCert string + JoinServerkey string + LogDir string + RegisterBindAddress string + RegisterCACert string + RegisterCAKey string + RegisterPort uint16 + RegisterServerCert string + RegisterServerkey string + TLSDir string + WorkDir string + func NewNetWorkControllerServer(ctx context.Context, opt *authentication.NetworkControllerAuthentication, ...) *NetWorkControllerServer + func (s *NetWorkControllerServer) Run() error + type NetWorkJoinClient struct + BindAddress string + CAPath string + CertPath string + KeyPath string + LogDir string + NodeToken string + Port uint16 + TLSDir string + WorkDir string + func NewNetWorkJoinClient(ctx context.Context, opt *netmanager.NetManagerOptions, workDir string, ...) *NetWorkJoinClient + func (s *NetWorkJoinClient) Run() error + type NetWorkRegisterClient struct + BindAddress string + BootstrapClient *grpc_client.GrpcBootStrapClient + CAPath string + CertPath string + KeyPath string + NCClient *grpc_client.GrpcClient + NodeToken string + Port uint16 + func NewNetWorkRegisterClient(ctx context.Context, opt *netmanager.NetManagerOptions) *NetWorkRegisterClient + func (c *NetWorkRegisterClient) CreateBootStrapToken(life int64) (string, error) + func (c *NetWorkRegisterClient) GetBootStrapAddress() (string, error) + func (c *NetWorkRegisterClient) GetBootStrapPort() (uint16, error) + func (c *NetWorkRegisterClient) QueryIp() (string, error) + func (c *NetWorkRegisterClient) QueryIpByToken(nodeToken string) (string, error) + type Scheduler struct + LogPath string + Options *scheduler.SchedulerOptions + func NewScheduler(ctx context.Context, opt *scheduler.SchedulerOptions, logPath string) *Scheduler + func (s *Scheduler) Run() error + type TokenDesc struct + CreateBy string + CreateTime string + IsAdmin bool + IsValid bool + Life int64 + Token string