Versions in this module Expand all Collapse all v0 v0.1.0 May 19, 2022 Changes in this version + var File_protobuf_proto protoreflect.FileDescriptor + var LeaderControl_ServiceDesc = grpc.ServiceDesc + func RegisterLeaderControlServer(s grpc.ServiceRegistrar, srv LeaderControlServer) + type BootStrapKubeProxyRequest struct + func (*BootStrapKubeProxyRequest) Descriptor() ([]byte, []int) + func (*BootStrapKubeProxyRequest) ProtoMessage() + func (x *BootStrapKubeProxyRequest) ProtoReflect() protoreflect.Message + func (x *BootStrapKubeProxyRequest) Reset() + func (x *BootStrapKubeProxyRequest) String() string + type BootStrapKubeProxyResponse struct + ClusterCIDR string + Kubeconfig string + Message string + StatusCode int32 + func (*BootStrapKubeProxyResponse) Descriptor() ([]byte, []int) + func (*BootStrapKubeProxyResponse) ProtoMessage() + func (x *BootStrapKubeProxyResponse) GetClusterCIDR() string + func (x *BootStrapKubeProxyResponse) GetKubeconfig() string + func (x *BootStrapKubeProxyResponse) GetMessage() string + func (x *BootStrapKubeProxyResponse) GetStatusCode() int32 + func (x *BootStrapKubeProxyResponse) ProtoReflect() protoreflect.Message + func (x *BootStrapKubeProxyResponse) Reset() + func (x *BootStrapKubeProxyResponse) String() string + type BootStrapKubeletRequest struct + NodeToken string + func (*BootStrapKubeletRequest) Descriptor() ([]byte, []int) + func (*BootStrapKubeletRequest) ProtoMessage() + func (x *BootStrapKubeletRequest) GetNodeToken() string + func (x *BootStrapKubeletRequest) ProtoReflect() protoreflect.Message + func (x *BootStrapKubeletRequest) Reset() + func (x *BootStrapKubeletRequest) String() string + type BootStrapKubeletResponse struct + ClusterDNS string + Kubeconfig string + Message string + ServerCert string + ServerKey string + StatusCode int32 + ValidataCaCert string + func (*BootStrapKubeletResponse) Descriptor() ([]byte, []int) + func (*BootStrapKubeletResponse) ProtoMessage() + func (x *BootStrapKubeletResponse) GetClusterDNS() string + func (x *BootStrapKubeletResponse) GetKubeconfig() string + func (x *BootStrapKubeletResponse) GetMessage() string + func (x *BootStrapKubeletResponse) GetServerCert() string + func (x *BootStrapKubeletResponse) GetServerKey() string + func (x *BootStrapKubeletResponse) GetStatusCode() int32 + func (x *BootStrapKubeletResponse) GetValidataCaCert() string + func (x *BootStrapKubeletResponse) ProtoReflect() protoreflect.Message + func (x *BootStrapKubeletResponse) Reset() + func (x *BootStrapKubeletResponse) String() string + type BootStrapNetworkRequest struct + Life int64 + func (*BootStrapNetworkRequest) Descriptor() ([]byte, []int) + func (*BootStrapNetworkRequest) ProtoMessage() + func (x *BootStrapNetworkRequest) GetLife() int64 + func (x *BootStrapNetworkRequest) ProtoReflect() protoreflect.Message + func (x *BootStrapNetworkRequest) Reset() + func (x *BootStrapNetworkRequest) String() string + type BootStrapNetworkResponse struct + Ip string + Message string + Port uint32 + StatusCode int32 + Token string + func (*BootStrapNetworkResponse) Descriptor() ([]byte, []int) + func (*BootStrapNetworkResponse) ProtoMessage() + func (x *BootStrapNetworkResponse) GetIp() string + func (x *BootStrapNetworkResponse) GetMessage() string + func (x *BootStrapNetworkResponse) GetPort() uint32 + func (x *BootStrapNetworkResponse) GetStatusCode() int32 + func (x *BootStrapNetworkResponse) GetToken() string + func (x *BootStrapNetworkResponse) ProtoReflect() protoreflect.Message + func (x *BootStrapNetworkResponse) Reset() + func (x *BootStrapNetworkResponse) String() string + type BootstrapValidateKubeApiserverClientResponse struct + Certificate string + Message string + StatusCode int32 + func (*BootstrapValidateKubeApiserverClientResponse) Descriptor() ([]byte, []int) + func (*BootstrapValidateKubeApiserverClientResponse) ProtoMessage() + func (x *BootstrapValidateKubeApiserverClientResponse) GetCertificate() string + func (x *BootstrapValidateKubeApiserverClientResponse) GetMessage() string + func (x *BootstrapValidateKubeApiserverClientResponse) GetStatusCode() int32 + func (x *BootstrapValidateKubeApiserverClientResponse) ProtoReflect() protoreflect.Message + func (x *BootstrapValidateKubeApiserverClientResponse) Reset() + func (x *BootstrapValidateKubeApiserverClientResponse) String() string + type CreateTokenRequest struct + IsAdmin bool + Life int64 + func (*CreateTokenRequest) Descriptor() ([]byte, []int) + func (*CreateTokenRequest) ProtoMessage() + func (x *CreateTokenRequest) GetIsAdmin() bool + func (x *CreateTokenRequest) GetLife() int64 + func (x *CreateTokenRequest) ProtoReflect() protoreflect.Message + func (x *CreateTokenRequest) Reset() + func (x *CreateTokenRequest) String() string + type HealthDescription struct + Message string + func (*HealthDescription) Descriptor() ([]byte, []int) + func (*HealthDescription) ProtoMessage() + func (x *HealthDescription) GetMessage() string + func (x *HealthDescription) ProtoReflect() protoreflect.Message + func (x *HealthDescription) Reset() + func (x *HealthDescription) String() string + type LeaderControlClient interface + BootStrapKubeProxy func(ctx context.Context, in *BootStrapKubeProxyRequest, opts ...grpc.CallOption) (*BootStrapKubeProxyResponse, error) + BootStrapKubelet func(ctx context.Context, in *BootStrapKubeletRequest, opts ...grpc.CallOption) (*BootStrapKubeletResponse, error) + BootStrapNetwork func(ctx context.Context, in *BootStrapNetworkRequest, opts ...grpc.CallOption) (*BootStrapNetworkResponse, error) + BootstrapValidateKubeApiserverClient func(ctx context.Context, in *NoneValue, opts ...grpc.CallOption) (*BootstrapValidateKubeApiserverClientResponse, error) + CheckHealth func(ctx context.Context, in *NoneValue, opts ...grpc.CallOption) (*HealthDescription, error) + CreateToken func(ctx context.Context, in *CreateTokenRequest, opts ...grpc.CallOption) (*TokenValue, error) + DeleteToken func(ctx context.Context, in *TokenString, opts ...grpc.CallOption) (*NoneResponse, error) + NodeToken func(ctx context.Context, in *NoneValue, opts ...grpc.CallOption) (*TokenString, error) + QueryTokens func(ctx context.Context, in *NoneValue, opts ...grpc.CallOption) (*TokenValueList, error) + func NewLeaderControlClient(cc grpc.ClientConnInterface) LeaderControlClient + type LeaderControlServer interface + BootStrapKubeProxy func(context.Context, *BootStrapKubeProxyRequest) (*BootStrapKubeProxyResponse, error) + BootStrapKubelet func(context.Context, *BootStrapKubeletRequest) (*BootStrapKubeletResponse, error) + BootStrapNetwork func(context.Context, *BootStrapNetworkRequest) (*BootStrapNetworkResponse, error) + BootstrapValidateKubeApiserverClient func(context.Context, *NoneValue) (*BootstrapValidateKubeApiserverClientResponse, error) + CheckHealth func(context.Context, *NoneValue) (*HealthDescription, error) + CreateToken func(context.Context, *CreateTokenRequest) (*TokenValue, error) + DeleteToken func(context.Context, *TokenString) (*NoneResponse, error) + NodeToken func(context.Context, *NoneValue) (*TokenString, error) + QueryTokens func(context.Context, *NoneValue) (*TokenValueList, error) + type NoneResponse struct + Message string + StatusCode int32 + func (*NoneResponse) Descriptor() ([]byte, []int) + func (*NoneResponse) ProtoMessage() + func (x *NoneResponse) GetMessage() string + func (x *NoneResponse) GetStatusCode() int32 + func (x *NoneResponse) ProtoReflect() protoreflect.Message + func (x *NoneResponse) Reset() + func (x *NoneResponse) String() string + type NoneValue struct + func (*NoneValue) Descriptor() ([]byte, []int) + func (*NoneValue) ProtoMessage() + func (x *NoneValue) ProtoReflect() protoreflect.Message + func (x *NoneValue) Reset() + func (x *NoneValue) String() string + type TokenDescription struct + CreateTime string + IsAdmin bool + Life int64 + Token string + Valid bool + func (*TokenDescription) Descriptor() ([]byte, []int) + func (*TokenDescription) ProtoMessage() + func (x *TokenDescription) GetCreateTime() string + func (x *TokenDescription) GetIsAdmin() bool + func (x *TokenDescription) GetLife() int64 + func (x *TokenDescription) GetToken() string + func (x *TokenDescription) GetValid() bool + func (x *TokenDescription) ProtoReflect() protoreflect.Message + func (x *TokenDescription) Reset() + func (x *TokenDescription) String() string + type TokenString struct + Token string + func (*TokenString) Descriptor() ([]byte, []int) + func (*TokenString) ProtoMessage() + func (x *TokenString) GetToken() string + func (x *TokenString) ProtoReflect() protoreflect.Message + func (x *TokenString) Reset() + func (x *TokenString) String() string + type TokenValue struct + Message string + StatusCode int32 + Token *TokenDescription + func (*TokenValue) Descriptor() ([]byte, []int) + func (*TokenValue) ProtoMessage() + func (x *TokenValue) GetMessage() string + func (x *TokenValue) GetStatusCode() int32 + func (x *TokenValue) GetToken() *TokenDescription + func (x *TokenValue) ProtoReflect() protoreflect.Message + func (x *TokenValue) Reset() + func (x *TokenValue) String() string + type TokenValueList struct + Message string + StatusCode int32 + TokenList []*TokenDescription + func (*TokenValueList) Descriptor() ([]byte, []int) + func (*TokenValueList) ProtoMessage() + func (x *TokenValueList) GetMessage() string + func (x *TokenValueList) GetStatusCode() int32 + func (x *TokenValueList) GetTokenList() []*TokenDescription + func (x *TokenValueList) ProtoReflect() protoreflect.Message + func (x *TokenValueList) Reset() + func (x *TokenValueList) String() string + type UnimplementedLeaderControlServer struct + func (UnimplementedLeaderControlServer) BootStrapKubeProxy(context.Context, *BootStrapKubeProxyRequest) (*BootStrapKubeProxyResponse, error) + func (UnimplementedLeaderControlServer) BootStrapKubelet(context.Context, *BootStrapKubeletRequest) (*BootStrapKubeletResponse, error) + func (UnimplementedLeaderControlServer) BootStrapNetwork(context.Context, *BootStrapNetworkRequest) (*BootStrapNetworkResponse, error) + func (UnimplementedLeaderControlServer) BootstrapValidateKubeApiserverClient(context.Context, *NoneValue) (*BootstrapValidateKubeApiserverClientResponse, error) + func (UnimplementedLeaderControlServer) CheckHealth(context.Context, *NoneValue) (*HealthDescription, error) + func (UnimplementedLeaderControlServer) CreateToken(context.Context, *CreateTokenRequest) (*TokenValue, error) + func (UnimplementedLeaderControlServer) DeleteToken(context.Context, *TokenString) (*NoneResponse, error) + func (UnimplementedLeaderControlServer) NodeToken(context.Context, *NoneValue) (*TokenString, error) + func (UnimplementedLeaderControlServer) QueryTokens(context.Context, *NoneValue) (*TokenValueList, error) + type UnsafeLeaderControlServer interface