control

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 19, 2022 License: Apache-2.0 Imports: 8 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_protobuf_proto protoreflect.FileDescriptor
View Source
var LeaderControl_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "control.LeaderControl",
	HandlerType: (*LeaderControlServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CheckHealth",
			Handler:    _LeaderControl_CheckHealth_Handler,
		},
		{
			MethodName: "NodeToken",
			Handler:    _LeaderControl_NodeToken_Handler,
		},
		{
			MethodName: "CreateToken",
			Handler:    _LeaderControl_CreateToken_Handler,
		},
		{
			MethodName: "DeleteToken",
			Handler:    _LeaderControl_DeleteToken_Handler,
		},
		{
			MethodName: "QueryTokens",
			Handler:    _LeaderControl_QueryTokens_Handler,
		},
		{
			MethodName: "BootstrapValidateKubeApiserverClient",
			Handler:    _LeaderControl_BootstrapValidateKubeApiserverClient_Handler,
		},
		{
			MethodName: "BootStrapKubelet",
			Handler:    _LeaderControl_BootStrapKubelet_Handler,
		},
		{
			MethodName: "BootStrapNetwork",
			Handler:    _LeaderControl_BootStrapNetwork_Handler,
		},
		{
			MethodName: "BootStrapKubeProxy",
			Handler:    _LeaderControl_BootStrapKubeProxy_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protobuf.proto",
}

LeaderControl_ServiceDesc is the grpc.ServiceDesc for LeaderControl service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterLeaderControlServer

func RegisterLeaderControlServer(s grpc.ServiceRegistrar, srv LeaderControlServer)

Types

type BootStrapKubeProxyRequest

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

func (*BootStrapKubeProxyRequest) Descriptor deprecated

func (*BootStrapKubeProxyRequest) Descriptor() ([]byte, []int)

Deprecated: Use BootStrapKubeProxyRequest.ProtoReflect.Descriptor instead.

func (*BootStrapKubeProxyRequest) ProtoMessage

func (*BootStrapKubeProxyRequest) ProtoMessage()

func (*BootStrapKubeProxyRequest) ProtoReflect

func (*BootStrapKubeProxyRequest) Reset

func (x *BootStrapKubeProxyRequest) Reset()

func (*BootStrapKubeProxyRequest) String

func (x *BootStrapKubeProxyRequest) String() string

type BootStrapKubeProxyResponse

type BootStrapKubeProxyResponse struct {
	StatusCode  int32  `protobuf:"varint,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	Message     string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	ClusterCIDR string `protobuf:"bytes,3,opt,name=clusterCIDR,proto3" json:"clusterCIDR,omitempty"`
	Kubeconfig  string `protobuf:"bytes,4,opt,name=kubeconfig,proto3" json:"kubeconfig,omitempty"`
	// contains filtered or unexported fields
}

func (*BootStrapKubeProxyResponse) Descriptor deprecated

func (*BootStrapKubeProxyResponse) Descriptor() ([]byte, []int)

Deprecated: Use BootStrapKubeProxyResponse.ProtoReflect.Descriptor instead.

func (*BootStrapKubeProxyResponse) GetClusterCIDR

func (x *BootStrapKubeProxyResponse) GetClusterCIDR() string

func (*BootStrapKubeProxyResponse) GetKubeconfig

func (x *BootStrapKubeProxyResponse) GetKubeconfig() string

func (*BootStrapKubeProxyResponse) GetMessage

func (x *BootStrapKubeProxyResponse) GetMessage() string

func (*BootStrapKubeProxyResponse) GetStatusCode

func (x *BootStrapKubeProxyResponse) GetStatusCode() int32

func (*BootStrapKubeProxyResponse) ProtoMessage

func (*BootStrapKubeProxyResponse) ProtoMessage()

func (*BootStrapKubeProxyResponse) ProtoReflect

func (*BootStrapKubeProxyResponse) Reset

func (x *BootStrapKubeProxyResponse) Reset()

func (*BootStrapKubeProxyResponse) String

func (x *BootStrapKubeProxyResponse) String() string

type BootStrapKubeletRequest

type BootStrapKubeletRequest struct {
	NodeToken string `protobuf:"bytes,1,opt,name=nodeToken,proto3" json:"nodeToken,omitempty"`
	// contains filtered or unexported fields
}

func (*BootStrapKubeletRequest) Descriptor deprecated

func (*BootStrapKubeletRequest) Descriptor() ([]byte, []int)

Deprecated: Use BootStrapKubeletRequest.ProtoReflect.Descriptor instead.

func (*BootStrapKubeletRequest) GetNodeToken

func (x *BootStrapKubeletRequest) GetNodeToken() string

func (*BootStrapKubeletRequest) ProtoMessage

func (*BootStrapKubeletRequest) ProtoMessage()

func (*BootStrapKubeletRequest) ProtoReflect

func (x *BootStrapKubeletRequest) ProtoReflect() protoreflect.Message

func (*BootStrapKubeletRequest) Reset

func (x *BootStrapKubeletRequest) Reset()

func (*BootStrapKubeletRequest) String

func (x *BootStrapKubeletRequest) String() string

type BootStrapKubeletResponse

type BootStrapKubeletResponse struct {
	StatusCode     int32  `protobuf:"varint,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	Message        string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Kubeconfig     string `protobuf:"bytes,3,opt,name=kubeconfig,proto3" json:"kubeconfig,omitempty"`
	ValidataCaCert string `protobuf:"bytes,4,opt,name=validataCaCert,proto3" json:"validataCaCert,omitempty"`
	ServerCert     string `protobuf:"bytes,5,opt,name=serverCert,proto3" json:"serverCert,omitempty"`
	ServerKey      string `protobuf:"bytes,6,opt,name=serverKey,proto3" json:"serverKey,omitempty"`
	ClusterDNS     string `protobuf:"bytes,7,opt,name=clusterDNS,proto3" json:"clusterDNS,omitempty"`
	// contains filtered or unexported fields
}

func (*BootStrapKubeletResponse) Descriptor deprecated

func (*BootStrapKubeletResponse) Descriptor() ([]byte, []int)

Deprecated: Use BootStrapKubeletResponse.ProtoReflect.Descriptor instead.

func (*BootStrapKubeletResponse) GetClusterDNS

func (x *BootStrapKubeletResponse) GetClusterDNS() string

func (*BootStrapKubeletResponse) GetKubeconfig

func (x *BootStrapKubeletResponse) GetKubeconfig() string

func (*BootStrapKubeletResponse) GetMessage

func (x *BootStrapKubeletResponse) GetMessage() string

func (*BootStrapKubeletResponse) GetServerCert

func (x *BootStrapKubeletResponse) GetServerCert() string

func (*BootStrapKubeletResponse) GetServerKey

func (x *BootStrapKubeletResponse) GetServerKey() string

func (*BootStrapKubeletResponse) GetStatusCode

func (x *BootStrapKubeletResponse) GetStatusCode() int32

func (*BootStrapKubeletResponse) GetValidataCaCert

func (x *BootStrapKubeletResponse) GetValidataCaCert() string

func (*BootStrapKubeletResponse) ProtoMessage

func (*BootStrapKubeletResponse) ProtoMessage()

func (*BootStrapKubeletResponse) ProtoReflect

func (x *BootStrapKubeletResponse) ProtoReflect() protoreflect.Message

func (*BootStrapKubeletResponse) Reset

func (x *BootStrapKubeletResponse) Reset()

func (*BootStrapKubeletResponse) String

func (x *BootStrapKubeletResponse) String() string

type BootStrapNetworkRequest

type BootStrapNetworkRequest struct {
	Life int64 `protobuf:"varint,1,opt,name=life,proto3" json:"life,omitempty"`
	// contains filtered or unexported fields
}

func (*BootStrapNetworkRequest) Descriptor deprecated

func (*BootStrapNetworkRequest) Descriptor() ([]byte, []int)

Deprecated: Use BootStrapNetworkRequest.ProtoReflect.Descriptor instead.

func (*BootStrapNetworkRequest) GetLife

func (x *BootStrapNetworkRequest) GetLife() int64

func (*BootStrapNetworkRequest) ProtoMessage

func (*BootStrapNetworkRequest) ProtoMessage()

func (*BootStrapNetworkRequest) ProtoReflect

func (x *BootStrapNetworkRequest) ProtoReflect() protoreflect.Message

func (*BootStrapNetworkRequest) Reset

func (x *BootStrapNetworkRequest) Reset()

func (*BootStrapNetworkRequest) String

func (x *BootStrapNetworkRequest) String() string

type BootStrapNetworkResponse

type BootStrapNetworkResponse struct {
	StatusCode int32  `protobuf:"varint,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	Message    string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Ip         string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	Port       uint32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	Token      string `protobuf:"bytes,5,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*BootStrapNetworkResponse) Descriptor deprecated

func (*BootStrapNetworkResponse) Descriptor() ([]byte, []int)

Deprecated: Use BootStrapNetworkResponse.ProtoReflect.Descriptor instead.

func (*BootStrapNetworkResponse) GetIp

func (x *BootStrapNetworkResponse) GetIp() string

func (*BootStrapNetworkResponse) GetMessage

func (x *BootStrapNetworkResponse) GetMessage() string

func (*BootStrapNetworkResponse) GetPort

func (x *BootStrapNetworkResponse) GetPort() uint32

func (*BootStrapNetworkResponse) GetStatusCode

func (x *BootStrapNetworkResponse) GetStatusCode() int32

func (*BootStrapNetworkResponse) GetToken

func (x *BootStrapNetworkResponse) GetToken() string

func (*BootStrapNetworkResponse) ProtoMessage

func (*BootStrapNetworkResponse) ProtoMessage()

func (*BootStrapNetworkResponse) ProtoReflect

func (x *BootStrapNetworkResponse) ProtoReflect() protoreflect.Message

func (*BootStrapNetworkResponse) Reset

func (x *BootStrapNetworkResponse) Reset()

func (*BootStrapNetworkResponse) String

func (x *BootStrapNetworkResponse) String() string

type BootstrapValidateKubeApiserverClientResponse

type BootstrapValidateKubeApiserverClientResponse struct {
	StatusCode  int32  `protobuf:"varint,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	Message     string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Certificate string `protobuf:"bytes,3,opt,name=certificate,proto3" json:"certificate,omitempty"`
	// contains filtered or unexported fields
}

func (*BootstrapValidateKubeApiserverClientResponse) Descriptor deprecated

Deprecated: Use BootstrapValidateKubeApiserverClientResponse.ProtoReflect.Descriptor instead.

func (*BootstrapValidateKubeApiserverClientResponse) GetCertificate

func (*BootstrapValidateKubeApiserverClientResponse) GetMessage

func (*BootstrapValidateKubeApiserverClientResponse) GetStatusCode

func (*BootstrapValidateKubeApiserverClientResponse) ProtoMessage

func (*BootstrapValidateKubeApiserverClientResponse) ProtoReflect

func (*BootstrapValidateKubeApiserverClientResponse) Reset

func (*BootstrapValidateKubeApiserverClientResponse) String

type CreateTokenRequest

type CreateTokenRequest struct {
	Life    int64 `protobuf:"varint,1,opt,name=life,proto3" json:"life,omitempty"`
	IsAdmin bool  `protobuf:"varint,2,opt,name=isAdmin,proto3" json:"isAdmin,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTokenRequest) Descriptor deprecated

func (*CreateTokenRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateTokenRequest.ProtoReflect.Descriptor instead.

func (*CreateTokenRequest) GetIsAdmin

func (x *CreateTokenRequest) GetIsAdmin() bool

func (*CreateTokenRequest) GetLife

func (x *CreateTokenRequest) GetLife() int64

func (*CreateTokenRequest) ProtoMessage

func (*CreateTokenRequest) ProtoMessage()

func (*CreateTokenRequest) ProtoReflect

func (x *CreateTokenRequest) ProtoReflect() protoreflect.Message

func (*CreateTokenRequest) Reset

func (x *CreateTokenRequest) Reset()

func (*CreateTokenRequest) String

func (x *CreateTokenRequest) String() string

type HealthDescription

type HealthDescription struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthDescription) Descriptor deprecated

func (*HealthDescription) Descriptor() ([]byte, []int)

Deprecated: Use HealthDescription.ProtoReflect.Descriptor instead.

func (*HealthDescription) GetMessage

func (x *HealthDescription) GetMessage() string

func (*HealthDescription) ProtoMessage

func (*HealthDescription) ProtoMessage()

func (*HealthDescription) ProtoReflect

func (x *HealthDescription) ProtoReflect() protoreflect.Message

func (*HealthDescription) Reset

func (x *HealthDescription) Reset()

func (*HealthDescription) String

func (x *HealthDescription) String() string

type LeaderControlClient

type LeaderControlClient interface {
	CheckHealth(ctx context.Context, in *NoneValue, opts ...grpc.CallOption) (*HealthDescription, error)
	NodeToken(ctx context.Context, in *NoneValue, opts ...grpc.CallOption) (*TokenString, error)
	CreateToken(ctx context.Context, in *CreateTokenRequest, opts ...grpc.CallOption) (*TokenValue, error)
	DeleteToken(ctx context.Context, in *TokenString, opts ...grpc.CallOption) (*NoneResponse, error)
	QueryTokens(ctx context.Context, in *NoneValue, opts ...grpc.CallOption) (*TokenValueList, error)
	BootstrapValidateKubeApiserverClient(ctx context.Context, in *NoneValue, opts ...grpc.CallOption) (*BootstrapValidateKubeApiserverClientResponse, error)
	BootStrapKubelet(ctx context.Context, in *BootStrapKubeletRequest, opts ...grpc.CallOption) (*BootStrapKubeletResponse, error)
	BootStrapNetwork(ctx context.Context, in *BootStrapNetworkRequest, opts ...grpc.CallOption) (*BootStrapNetworkResponse, error)
	BootStrapKubeProxy(ctx context.Context, in *BootStrapKubeProxyRequest, opts ...grpc.CallOption) (*BootStrapKubeProxyResponse, error)
}

LeaderControlClient is the client API for LeaderControl service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type LeaderControlServer

LeaderControlServer is the server API for LeaderControl service. All implementations should embed UnimplementedLeaderControlServer for forward compatibility

type NoneResponse

type NoneResponse struct {
	StatusCode int32  `protobuf:"varint,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	Message    string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*NoneResponse) Descriptor deprecated

func (*NoneResponse) Descriptor() ([]byte, []int)

Deprecated: Use NoneResponse.ProtoReflect.Descriptor instead.

func (*NoneResponse) GetMessage

func (x *NoneResponse) GetMessage() string

func (*NoneResponse) GetStatusCode

func (x *NoneResponse) GetStatusCode() int32

func (*NoneResponse) ProtoMessage

func (*NoneResponse) ProtoMessage()

func (*NoneResponse) ProtoReflect

func (x *NoneResponse) ProtoReflect() protoreflect.Message

func (*NoneResponse) Reset

func (x *NoneResponse) Reset()

func (*NoneResponse) String

func (x *NoneResponse) String() string

type NoneValue

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

func (*NoneValue) Descriptor deprecated

func (*NoneValue) Descriptor() ([]byte, []int)

Deprecated: Use NoneValue.ProtoReflect.Descriptor instead.

func (*NoneValue) ProtoMessage

func (*NoneValue) ProtoMessage()

func (*NoneValue) ProtoReflect

func (x *NoneValue) ProtoReflect() protoreflect.Message

func (*NoneValue) Reset

func (x *NoneValue) Reset()

func (*NoneValue) String

func (x *NoneValue) String() string

type TokenDescription

type TokenDescription struct {
	Token      string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	CreateTime string `protobuf:"bytes,2,opt,name=createTime,proto3" json:"createTime,omitempty"`
	Life       int64  `protobuf:"varint,4,opt,name=life,proto3" json:"life,omitempty"`
	IsAdmin    bool   `protobuf:"varint,5,opt,name=isAdmin,proto3" json:"isAdmin,omitempty"`
	Valid      bool   `protobuf:"varint,6,opt,name=valid,proto3" json:"valid,omitempty"`
	// contains filtered or unexported fields
}

func (*TokenDescription) Descriptor deprecated

func (*TokenDescription) Descriptor() ([]byte, []int)

Deprecated: Use TokenDescription.ProtoReflect.Descriptor instead.

func (*TokenDescription) GetCreateTime

func (x *TokenDescription) GetCreateTime() string

func (*TokenDescription) GetIsAdmin

func (x *TokenDescription) GetIsAdmin() bool

func (*TokenDescription) GetLife

func (x *TokenDescription) GetLife() int64

func (*TokenDescription) GetToken

func (x *TokenDescription) GetToken() string

func (*TokenDescription) GetValid

func (x *TokenDescription) GetValid() bool

func (*TokenDescription) ProtoMessage

func (*TokenDescription) ProtoMessage()

func (*TokenDescription) ProtoReflect

func (x *TokenDescription) ProtoReflect() protoreflect.Message

func (*TokenDescription) Reset

func (x *TokenDescription) Reset()

func (*TokenDescription) String

func (x *TokenDescription) String() string

type TokenString

type TokenString struct {
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*TokenString) Descriptor deprecated

func (*TokenString) Descriptor() ([]byte, []int)

Deprecated: Use TokenString.ProtoReflect.Descriptor instead.

func (*TokenString) GetToken

func (x *TokenString) GetToken() string

func (*TokenString) ProtoMessage

func (*TokenString) ProtoMessage()

func (*TokenString) ProtoReflect

func (x *TokenString) ProtoReflect() protoreflect.Message

func (*TokenString) Reset

func (x *TokenString) Reset()

func (*TokenString) String

func (x *TokenString) String() string

type TokenValue

type TokenValue struct {
	StatusCode int32             `protobuf:"varint,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	Message    string            `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Token      *TokenDescription `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*TokenValue) Descriptor deprecated

func (*TokenValue) Descriptor() ([]byte, []int)

Deprecated: Use TokenValue.ProtoReflect.Descriptor instead.

func (*TokenValue) GetMessage

func (x *TokenValue) GetMessage() string

func (*TokenValue) GetStatusCode

func (x *TokenValue) GetStatusCode() int32

func (*TokenValue) GetToken

func (x *TokenValue) GetToken() *TokenDescription

func (*TokenValue) ProtoMessage

func (*TokenValue) ProtoMessage()

func (*TokenValue) ProtoReflect

func (x *TokenValue) ProtoReflect() protoreflect.Message

func (*TokenValue) Reset

func (x *TokenValue) Reset()

func (*TokenValue) String

func (x *TokenValue) String() string

type TokenValueList

type TokenValueList struct {
	StatusCode int32               `protobuf:"varint,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	Message    string              `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	TokenList  []*TokenDescription `protobuf:"bytes,3,rep,name=tokenList,proto3" json:"tokenList,omitempty"`
	// contains filtered or unexported fields
}

func (*TokenValueList) Descriptor deprecated

func (*TokenValueList) Descriptor() ([]byte, []int)

Deprecated: Use TokenValueList.ProtoReflect.Descriptor instead.

func (*TokenValueList) GetMessage

func (x *TokenValueList) GetMessage() string

func (*TokenValueList) GetStatusCode

func (x *TokenValueList) GetStatusCode() int32

func (*TokenValueList) GetTokenList

func (x *TokenValueList) GetTokenList() []*TokenDescription

func (*TokenValueList) ProtoMessage

func (*TokenValueList) ProtoMessage()

func (*TokenValueList) ProtoReflect

func (x *TokenValueList) ProtoReflect() protoreflect.Message

func (*TokenValueList) Reset

func (x *TokenValueList) Reset()

func (*TokenValueList) String

func (x *TokenValueList) String() string

type UnimplementedLeaderControlServer

type UnimplementedLeaderControlServer struct {
}

UnimplementedLeaderControlServer should be embedded to have forward compatible implementations.

func (UnimplementedLeaderControlServer) BootStrapKubeProxy

func (UnimplementedLeaderControlServer) BootStrapKubelet

func (UnimplementedLeaderControlServer) BootStrapNetwork

func (UnimplementedLeaderControlServer) BootstrapValidateKubeApiserverClient

func (UnimplementedLeaderControlServer) CheckHealth

func (UnimplementedLeaderControlServer) CreateToken

func (UnimplementedLeaderControlServer) DeleteToken

func (UnimplementedLeaderControlServer) NodeToken

func (UnimplementedLeaderControlServer) QueryTokens

type UnsafeLeaderControlServer

type UnsafeLeaderControlServer interface {
	// contains filtered or unexported methods
}

UnsafeLeaderControlServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LeaderControlServer will result in compilation errors.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL