Documentation ¶
Overview ¶
Package protos is a generated protocol buffer package.
It is generated from these files:
deploy_controller.proto
It has these top-level messages:
Auth SSH Node Error TestConnectionRequest TestConnectionReply NodeCheckConfig CheckNodesRequest CheckNodesReply CheckItem ItemCheckResult NodeCheckResult GetCheckNodesResultRequest GetCheckNodesResultReply NodePortRange Keepalived Loadbalancer KubeAPIServerConnect ClusterConfig Taint NodeDeployConfig DeployRequest DeployReply GetDeployResultRequest DeployItem DeployItemResult GetDeployResultReply FetchKubeConfigRequest FetchKubeConfigReply CalicoOptions NetworkOptions CheckNetworkRequirementRequest ConnectivityCheckResult CheckNetworkRequirementsReply
Index ¶
- func RegisterDeployContollerServer(s *grpc.Server, srv DeployContollerServer)
- type Auth
- type CalicoOptions
- func (*CalicoOptions) Descriptor() ([]byte, []int)
- func (m *CalicoOptions) GetCheckConnectivityAll() bool
- func (m *CalicoOptions) GetEncapsulationMode() string
- func (m *CalicoOptions) GetVxlanPort() uint32
- func (*CalicoOptions) ProtoMessage()
- func (m *CalicoOptions) Reset()
- func (m *CalicoOptions) String() string
- type CheckItem
- type CheckNetworkRequirementRequest
- func (*CheckNetworkRequirementRequest) Descriptor() ([]byte, []int)
- func (m *CheckNetworkRequirementRequest) GetNodes() []*Node
- func (m *CheckNetworkRequirementRequest) GetOptions() *NetworkOptions
- func (*CheckNetworkRequirementRequest) ProtoMessage()
- func (m *CheckNetworkRequirementRequest) Reset()
- func (m *CheckNetworkRequirementRequest) String() string
- type CheckNetworkRequirementsReply
- func (*CheckNetworkRequirementsReply) Descriptor() ([]byte, []int)
- func (m *CheckNetworkRequirementsReply) GetConnectivities() []*ConnectivityCheckResult
- func (m *CheckNetworkRequirementsReply) GetErr() *Error
- func (m *CheckNetworkRequirementsReply) GetNodes() []*NodeCheckResult
- func (m *CheckNetworkRequirementsReply) GetPassed() bool
- func (*CheckNetworkRequirementsReply) ProtoMessage()
- func (m *CheckNetworkRequirementsReply) Reset()
- func (m *CheckNetworkRequirementsReply) String() string
- type CheckNodesReply
- type CheckNodesRequest
- type ClusterConfig
- func (*ClusterConfig) Descriptor() ([]byte, []int)
- func (m *ClusterConfig) GetClusterName() string
- func (m *ClusterConfig) GetImageRepository() string
- func (m *ClusterConfig) GetKubeAPIServerConnect() *KubeAPIServerConnect
- func (m *ClusterConfig) GetKubernetesVersion() string
- func (m *ClusterConfig) GetNodeAnnotations() map[string]string
- func (m *ClusterConfig) GetNodeLabels() map[string]string
- func (m *ClusterConfig) GetNodePortRange() *NodePortRange
- func (m *ClusterConfig) GetPodSubnet() string
- func (m *ClusterConfig) GetServiceSubnet() string
- func (*ClusterConfig) ProtoMessage()
- func (m *ClusterConfig) Reset()
- func (m *ClusterConfig) String() string
- type ConnectivityCheckResult
- func (*ConnectivityCheckResult) Descriptor() ([]byte, []int)
- func (m *ConnectivityCheckResult) GetDestinationNodeName() string
- func (m *ConnectivityCheckResult) GetErr() *Error
- func (m *ConnectivityCheckResult) GetItems() []*ItemCheckResult
- func (m *ConnectivityCheckResult) GetSourceNodeName() string
- func (m *ConnectivityCheckResult) GetStatus() string
- func (*ConnectivityCheckResult) ProtoMessage()
- func (m *ConnectivityCheckResult) Reset()
- func (m *ConnectivityCheckResult) String() string
- type DeployContollerClient
- type DeployContollerServer
- type DeployItem
- type DeployItemResult
- func (*DeployItemResult) Descriptor() ([]byte, []int)
- func (m *DeployItemResult) GetDeployItem() *DeployItem
- func (m *DeployItemResult) GetErr() *Error
- func (m *DeployItemResult) GetLogs() string
- func (m *DeployItemResult) GetStatus() string
- func (*DeployItemResult) ProtoMessage()
- func (m *DeployItemResult) Reset()
- func (m *DeployItemResult) String() string
- type DeployReply
- type DeployRequest
- type Error
- type FetchKubeConfigReply
- type FetchKubeConfigRequest
- type GetCheckNodesResultReply
- func (*GetCheckNodesResultReply) Descriptor() ([]byte, []int)
- func (m *GetCheckNodesResultReply) GetErr() *Error
- func (m *GetCheckNodesResultReply) GetNodes() map[string]*NodeCheckResult
- func (m *GetCheckNodesResultReply) GetStatus() string
- func (*GetCheckNodesResultReply) ProtoMessage()
- func (m *GetCheckNodesResultReply) Reset()
- func (m *GetCheckNodesResultReply) String() string
- type GetCheckNodesResultRequest
- type GetDeployResultReply
- func (*GetDeployResultReply) Descriptor() ([]byte, []int)
- func (m *GetDeployResultReply) GetErr() *Error
- func (m *GetDeployResultReply) GetItems() []*DeployItemResult
- func (m *GetDeployResultReply) GetStatus() string
- func (*GetDeployResultReply) ProtoMessage()
- func (m *GetDeployResultReply) Reset()
- func (m *GetDeployResultReply) String() string
- type GetDeployResultRequest
- type ItemCheckResult
- func (*ItemCheckResult) Descriptor() ([]byte, []int)
- func (m *ItemCheckResult) GetErr() *Error
- func (m *ItemCheckResult) GetItem() *CheckItem
- func (m *ItemCheckResult) GetLogs() string
- func (m *ItemCheckResult) GetStatus() string
- func (*ItemCheckResult) ProtoMessage()
- func (m *ItemCheckResult) Reset()
- func (m *ItemCheckResult) String() string
- type Keepalived
- type KubeAPIServerConnect
- func (*KubeAPIServerConnect) Descriptor() ([]byte, []int)
- func (m *KubeAPIServerConnect) GetKeepalived() *Keepalived
- func (m *KubeAPIServerConnect) GetLoadbalancer() *Loadbalancer
- func (m *KubeAPIServerConnect) GetType() string
- func (*KubeAPIServerConnect) ProtoMessage()
- func (m *KubeAPIServerConnect) Reset()
- func (m *KubeAPIServerConnect) String() string
- type Loadbalancer
- type NetworkOptions
- type Node
- type NodeCheckConfig
- type NodeCheckResult
- func (*NodeCheckResult) Descriptor() ([]byte, []int)
- func (m *NodeCheckResult) GetErr() *Error
- func (m *NodeCheckResult) GetItems() []*ItemCheckResult
- func (m *NodeCheckResult) GetNodeName() string
- func (m *NodeCheckResult) GetStatus() string
- func (*NodeCheckResult) ProtoMessage()
- func (m *NodeCheckResult) Reset()
- func (m *NodeCheckResult) String() string
- type NodeDeployConfig
- func (*NodeDeployConfig) Descriptor() ([]byte, []int)
- func (m *NodeDeployConfig) GetLabels() map[string]string
- func (m *NodeDeployConfig) GetNode() *Node
- func (m *NodeDeployConfig) GetRoles() []string
- func (m *NodeDeployConfig) GetTaints() []*Taint
- func (*NodeDeployConfig) ProtoMessage()
- func (m *NodeDeployConfig) Reset()
- func (m *NodeDeployConfig) String() string
- type NodePortRange
- type SSH
- type Taint
- type TestConnectionReply
- type TestConnectionRequest
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterDeployContollerServer ¶
func RegisterDeployContollerServer(s *grpc.Server, srv DeployContollerServer)
Types ¶
type Auth ¶
type Auth struct { // type could be ["password", "privatekey"] Type string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"` // credential stores the content of password or privatekey Credential string `protobuf:"bytes,2,opt,name=credential" json:"credential,omitempty"` // username is the user name used for password auth. Username string `protobuf:"bytes,3,opt,name=username" json:"username,omitempty"` }
func (*Auth) Descriptor ¶
func (*Auth) GetCredential ¶
func (*Auth) GetUsername ¶
func (*Auth) ProtoMessage ¶
func (*Auth) ProtoMessage()
type CalicoOptions ¶
type CalicoOptions struct { // if checkConnectivityAll = true, check connectivity between each pair of nodes bidirectionally. CheckConnectivityAll bool `protobuf:"varint,1,opt,name=checkConnectivityAll" json:"checkConnectivityAll,omitempty"` // EncapsulationMode could be ["vxlan","ipip","none"]. EncapsulationMode string `protobuf:"bytes,2,opt,name=encapsulationMode" json:"encapsulationMode,omitempty"` VxlanPort uint32 `protobuf:"varint,10,opt,name=vxlanPort" json:"vxlanPort,omitempty"` }
CalicoOptions options for checking requirements for deploying calico network.
func (*CalicoOptions) Descriptor ¶
func (*CalicoOptions) Descriptor() ([]byte, []int)
func (*CalicoOptions) GetCheckConnectivityAll ¶
func (m *CalicoOptions) GetCheckConnectivityAll() bool
func (*CalicoOptions) GetEncapsulationMode ¶
func (m *CalicoOptions) GetEncapsulationMode() string
func (*CalicoOptions) GetVxlanPort ¶
func (m *CalicoOptions) GetVxlanPort() uint32
func (*CalicoOptions) ProtoMessage ¶
func (*CalicoOptions) ProtoMessage()
func (*CalicoOptions) Reset ¶
func (m *CalicoOptions) Reset()
func (*CalicoOptions) String ¶
func (m *CalicoOptions) String() string
type CheckItem ¶
type CheckItem struct { Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` Description string `protobuf:"bytes,2,opt,name=description" json:"description,omitempty"` }
CheckItem is a check item of node pre-checking
func (*CheckItem) Descriptor ¶
func (*CheckItem) GetDescription ¶
func (*CheckItem) ProtoMessage ¶
func (*CheckItem) ProtoMessage()
type CheckNetworkRequirementRequest ¶
type CheckNetworkRequirementRequest struct { Nodes []*Node `protobuf:"bytes,1,rep,name=nodes" json:"nodes,omitempty"` Options *NetworkOptions `protobuf:"bytes,2,opt,name=options" json:"options,omitempty"` }
CheckNetworkRequirementRequest nodes and network options when checking
func (*CheckNetworkRequirementRequest) Descriptor ¶
func (*CheckNetworkRequirementRequest) Descriptor() ([]byte, []int)
func (*CheckNetworkRequirementRequest) GetNodes ¶
func (m *CheckNetworkRequirementRequest) GetNodes() []*Node
func (*CheckNetworkRequirementRequest) GetOptions ¶
func (m *CheckNetworkRequirementRequest) GetOptions() *NetworkOptions
func (*CheckNetworkRequirementRequest) ProtoMessage ¶
func (*CheckNetworkRequirementRequest) ProtoMessage()
func (*CheckNetworkRequirementRequest) Reset ¶
func (m *CheckNetworkRequirementRequest) Reset()
func (*CheckNetworkRequirementRequest) String ¶
func (m *CheckNetworkRequirementRequest) String() string
type CheckNetworkRequirementsReply ¶
type CheckNetworkRequirementsReply struct { Passed bool `protobuf:"varint,1,opt,name=passed" json:"passed,omitempty"` Err *Error `protobuf:"bytes,2,opt,name=err" json:"err,omitempty"` Nodes []*NodeCheckResult `protobuf:"bytes,3,rep,name=nodes" json:"nodes,omitempty"` Connectivities []*ConnectivityCheckResult `protobuf:"bytes,4,rep,name=connectivities" json:"connectivities,omitempty"` }
CheckNetworkRequirementsReply
func (*CheckNetworkRequirementsReply) Descriptor ¶
func (*CheckNetworkRequirementsReply) Descriptor() ([]byte, []int)
func (*CheckNetworkRequirementsReply) GetConnectivities ¶
func (m *CheckNetworkRequirementsReply) GetConnectivities() []*ConnectivityCheckResult
func (*CheckNetworkRequirementsReply) GetErr ¶
func (m *CheckNetworkRequirementsReply) GetErr() *Error
func (*CheckNetworkRequirementsReply) GetNodes ¶
func (m *CheckNetworkRequirementsReply) GetNodes() []*NodeCheckResult
func (*CheckNetworkRequirementsReply) GetPassed ¶
func (m *CheckNetworkRequirementsReply) GetPassed() bool
func (*CheckNetworkRequirementsReply) ProtoMessage ¶
func (*CheckNetworkRequirementsReply) ProtoMessage()
func (*CheckNetworkRequirementsReply) Reset ¶
func (m *CheckNetworkRequirementsReply) Reset()
func (*CheckNetworkRequirementsReply) String ¶
func (m *CheckNetworkRequirementsReply) String() string
type CheckNodesReply ¶
type CheckNodesReply struct { Accepted bool `protobuf:"varint,1,opt,name=accepted" json:"accepted,omitempty"` Err *Error `protobuf:"bytes,2,opt,name=err" json:"err,omitempty"` }
CheckNodesReply contains the result of node pre-checking.
func (*CheckNodesReply) Descriptor ¶
func (*CheckNodesReply) Descriptor() ([]byte, []int)
func (*CheckNodesReply) GetAccepted ¶
func (m *CheckNodesReply) GetAccepted() bool
func (*CheckNodesReply) GetErr ¶
func (m *CheckNodesReply) GetErr() *Error
func (*CheckNodesReply) ProtoMessage ¶
func (*CheckNodesReply) ProtoMessage()
func (*CheckNodesReply) Reset ¶
func (m *CheckNodesReply) Reset()
func (*CheckNodesReply) String ¶
func (m *CheckNodesReply) String() string
type CheckNodesRequest ¶
type CheckNodesRequest struct { Configs []*NodeCheckConfig `protobuf:"bytes,1,rep,name=configs" json:"configs,omitempty"` NetworkOptions *NetworkOptions `protobuf:"bytes,2,opt,name=networkOptions" json:"networkOptions,omitempty"` }
CheckNodesRequest contains the request of node pre-checking.
func (*CheckNodesRequest) Descriptor ¶
func (*CheckNodesRequest) Descriptor() ([]byte, []int)
func (*CheckNodesRequest) GetConfigs ¶
func (m *CheckNodesRequest) GetConfigs() []*NodeCheckConfig
func (*CheckNodesRequest) GetNetworkOptions ¶
func (m *CheckNodesRequest) GetNetworkOptions() *NetworkOptions
func (*CheckNodesRequest) ProtoMessage ¶
func (*CheckNodesRequest) ProtoMessage()
func (*CheckNodesRequest) Reset ¶
func (m *CheckNodesRequest) Reset()
func (*CheckNodesRequest) String ¶
func (m *CheckNodesRequest) String() string
type ClusterConfig ¶
type ClusterConfig struct { ClusterName string `protobuf:"bytes,1,opt,name=clusterName" json:"clusterName,omitempty"` KubeAPIServerConnect *KubeAPIServerConnect `protobuf:"bytes,2,opt,name=kubeAPIServerConnect" json:"kubeAPIServerConnect,omitempty"` NodePortRange *NodePortRange `protobuf:"bytes,3,opt,name=nodePortRange" json:"nodePortRange,omitempty"` NodeLabels map[string]string `` /* 140-byte string literal not displayed */ NodeAnnotations map[string]string `` /* 150-byte string literal not displayed */ ImageRepository string `protobuf:"bytes,6,opt,name=imageRepository" json:"imageRepository,omitempty"` PodSubnet string `protobuf:"bytes,7,opt,name=podSubnet" json:"podSubnet,omitempty"` ServiceSubnet string `protobuf:"bytes,8,opt,name=serviceSubnet" json:"serviceSubnet,omitempty"` KubernetesVersion string `protobuf:"bytes,9,opt,name=kubernetesVersion" json:"kubernetesVersion,omitempty"` }
ClusterConfig contains the configuraton of a cluster
func (*ClusterConfig) Descriptor ¶
func (*ClusterConfig) Descriptor() ([]byte, []int)
func (*ClusterConfig) GetClusterName ¶
func (m *ClusterConfig) GetClusterName() string
func (*ClusterConfig) GetImageRepository ¶
func (m *ClusterConfig) GetImageRepository() string
func (*ClusterConfig) GetKubeAPIServerConnect ¶
func (m *ClusterConfig) GetKubeAPIServerConnect() *KubeAPIServerConnect
func (*ClusterConfig) GetKubernetesVersion ¶
func (m *ClusterConfig) GetKubernetesVersion() string
func (*ClusterConfig) GetNodeAnnotations ¶
func (m *ClusterConfig) GetNodeAnnotations() map[string]string
func (*ClusterConfig) GetNodeLabels ¶
func (m *ClusterConfig) GetNodeLabels() map[string]string
func (*ClusterConfig) GetNodePortRange ¶
func (m *ClusterConfig) GetNodePortRange() *NodePortRange
func (*ClusterConfig) GetPodSubnet ¶
func (m *ClusterConfig) GetPodSubnet() string
func (*ClusterConfig) GetServiceSubnet ¶
func (m *ClusterConfig) GetServiceSubnet() string
func (*ClusterConfig) ProtoMessage ¶
func (*ClusterConfig) ProtoMessage()
func (*ClusterConfig) Reset ¶
func (m *ClusterConfig) Reset()
func (*ClusterConfig) String ¶
func (m *ClusterConfig) String() string
type ConnectivityCheckResult ¶
type ConnectivityCheckResult struct { SourceNodeName string `protobuf:"bytes,1,opt,name=SourceNodeName" json:"SourceNodeName,omitempty"` DestinationNodeName string `protobuf:"bytes,2,opt,name=DestinationNodeName" json:"DestinationNodeName,omitempty"` Status string `protobuf:"bytes,3,opt,name=status" json:"status,omitempty"` Err *Error `protobuf:"bytes,4,opt,name=err" json:"err,omitempty"` Items []*ItemCheckResult `protobuf:"bytes,5,rep,name=items" json:"items,omitempty"` }
func (*ConnectivityCheckResult) Descriptor ¶
func (*ConnectivityCheckResult) Descriptor() ([]byte, []int)
func (*ConnectivityCheckResult) GetDestinationNodeName ¶
func (m *ConnectivityCheckResult) GetDestinationNodeName() string
func (*ConnectivityCheckResult) GetErr ¶
func (m *ConnectivityCheckResult) GetErr() *Error
func (*ConnectivityCheckResult) GetItems ¶
func (m *ConnectivityCheckResult) GetItems() []*ItemCheckResult
func (*ConnectivityCheckResult) GetSourceNodeName ¶
func (m *ConnectivityCheckResult) GetSourceNodeName() string
func (*ConnectivityCheckResult) GetStatus ¶
func (m *ConnectivityCheckResult) GetStatus() string
func (*ConnectivityCheckResult) ProtoMessage ¶
func (*ConnectivityCheckResult) ProtoMessage()
func (*ConnectivityCheckResult) Reset ¶
func (m *ConnectivityCheckResult) Reset()
func (*ConnectivityCheckResult) String ¶
func (m *ConnectivityCheckResult) String() string
type DeployContollerClient ¶
type DeployContollerClient interface { TestConnection(ctx context.Context, in *TestConnectionRequest, opts ...grpc.CallOption) (*TestConnectionReply, error) CheckNodes(ctx context.Context, in *CheckNodesRequest, opts ...grpc.CallOption) (*CheckNodesReply, error) GetCheckNodesResult(ctx context.Context, in *GetCheckNodesResultRequest, opts ...grpc.CallOption) (*GetCheckNodesResultReply, error) Deploy(ctx context.Context, in *DeployRequest, opts ...grpc.CallOption) (*DeployReply, error) GetDeployResult(ctx context.Context, in *GetDeployResultRequest, opts ...grpc.CallOption) (*GetDeployResultReply, error) FetchKubeConfig(ctx context.Context, in *FetchKubeConfigRequest, opts ...grpc.CallOption) (*FetchKubeConfigReply, error) CheckNetworkRequirements(ctx context.Context, in *CheckNetworkRequirementRequest, opts ...grpc.CallOption) (*CheckNetworkRequirementsReply, error) }
func NewDeployContollerClient ¶
func NewDeployContollerClient(cc *grpc.ClientConn) DeployContollerClient
type DeployContollerServer ¶
type DeployContollerServer interface { TestConnection(context.Context, *TestConnectionRequest) (*TestConnectionReply, error) CheckNodes(context.Context, *CheckNodesRequest) (*CheckNodesReply, error) GetCheckNodesResult(context.Context, *GetCheckNodesResultRequest) (*GetCheckNodesResultReply, error) Deploy(context.Context, *DeployRequest) (*DeployReply, error) GetDeployResult(context.Context, *GetDeployResultRequest) (*GetDeployResultReply, error) FetchKubeConfig(context.Context, *FetchKubeConfigRequest) (*FetchKubeConfigReply, error) CheckNetworkRequirements(context.Context, *CheckNetworkRequirementRequest) (*CheckNetworkRequirementsReply, error) }
type DeployItem ¶
type DeployItem struct { Role string `protobuf:"bytes,1,opt,name=role" json:"role,omitempty"` NodeName string `protobuf:"bytes,2,opt,name=nodeName" json:"nodeName,omitempty"` FailureCanBeIgnored bool `protobuf:"varint,3,opt,name=failureCanBeIgnored" json:"failureCanBeIgnored,omitempty"` }
DeployItem represents a deploy action in a node for a role.
func (*DeployItem) Descriptor ¶
func (*DeployItem) Descriptor() ([]byte, []int)
func (*DeployItem) GetFailureCanBeIgnored ¶
func (m *DeployItem) GetFailureCanBeIgnored() bool
func (*DeployItem) GetNodeName ¶
func (m *DeployItem) GetNodeName() string
func (*DeployItem) GetRole ¶
func (m *DeployItem) GetRole() string
func (*DeployItem) ProtoMessage ¶
func (*DeployItem) ProtoMessage()
func (*DeployItem) Reset ¶
func (m *DeployItem) Reset()
func (*DeployItem) String ¶
func (m *DeployItem) String() string
type DeployItemResult ¶
type DeployItemResult struct { DeployItem *DeployItem `protobuf:"bytes,1,opt,name=deployItem" json:"deployItem,omitempty"` Status string `protobuf:"bytes,2,opt,name=status" json:"status,omitempty"` Err *Error `protobuf:"bytes,3,opt,name=err" json:"err,omitempty"` Logs string `protobuf:"bytes,4,opt,name=logs" json:"logs,omitempty"` }
DeployItemResult represents the deploy result in a node for a role.
func (*DeployItemResult) Descriptor ¶
func (*DeployItemResult) Descriptor() ([]byte, []int)
func (*DeployItemResult) GetDeployItem ¶
func (m *DeployItemResult) GetDeployItem() *DeployItem
func (*DeployItemResult) GetErr ¶
func (m *DeployItemResult) GetErr() *Error
func (*DeployItemResult) GetLogs ¶
func (m *DeployItemResult) GetLogs() string
func (*DeployItemResult) GetStatus ¶
func (m *DeployItemResult) GetStatus() string
func (*DeployItemResult) ProtoMessage ¶
func (*DeployItemResult) ProtoMessage()
func (*DeployItemResult) Reset ¶
func (m *DeployItemResult) Reset()
func (*DeployItemResult) String ¶
func (m *DeployItemResult) String() string
type DeployReply ¶
type DeployReply struct { Accepted bool `protobuf:"varint,1,opt,name=accepted" json:"accepted,omitempty"` Err *Error `protobuf:"bytes,2,opt,name=err" json:"err,omitempty"` }
DeployReply contains the response of a deploy request.
func (*DeployReply) Descriptor ¶
func (*DeployReply) Descriptor() ([]byte, []int)
func (*DeployReply) GetAccepted ¶
func (m *DeployReply) GetAccepted() bool
func (*DeployReply) GetErr ¶
func (m *DeployReply) GetErr() *Error
func (*DeployReply) ProtoMessage ¶
func (*DeployReply) ProtoMessage()
func (*DeployReply) Reset ¶
func (m *DeployReply) Reset()
func (*DeployReply) String ¶
func (m *DeployReply) String() string
type DeployRequest ¶
type DeployRequest struct { NodeConfigs []*NodeDeployConfig `protobuf:"bytes,1,rep,name=nodeConfigs" json:"nodeConfigs,omitempty"` ClusterConfig *ClusterConfig `protobuf:"bytes,2,opt,name=clusterConfig" json:"clusterConfig,omitempty"` }
DeployRequest contains the request of a deploy.
func (*DeployRequest) Descriptor ¶
func (*DeployRequest) Descriptor() ([]byte, []int)
func (*DeployRequest) GetClusterConfig ¶
func (m *DeployRequest) GetClusterConfig() *ClusterConfig
func (*DeployRequest) GetNodeConfigs ¶
func (m *DeployRequest) GetNodeConfigs() []*NodeDeployConfig
func (*DeployRequest) ProtoMessage ¶
func (*DeployRequest) ProtoMessage()
func (*DeployRequest) Reset ¶
func (m *DeployRequest) Reset()
func (*DeployRequest) String ¶
func (m *DeployRequest) String() string
type Error ¶
type Error struct { Reason string `protobuf:"bytes,1,opt,name=reason" json:"reason,omitempty"` Detail string `protobuf:"bytes,2,opt,name=detail" json:"detail,omitempty"` FixMethods string `protobuf:"bytes,3,opt,name=fixMethods" json:"fixMethods,omitempty"` }
func (*Error) Descriptor ¶
func (*Error) GetFixMethods ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
type FetchKubeConfigReply ¶
type FetchKubeConfigReply struct { KubeConfig []byte `protobuf:"bytes,1,opt,name=kubeConfig,proto3" json:"kubeConfig,omitempty"` Err *Error `protobuf:"bytes,2,opt,name=err" json:"err,omitempty"` }
FetchKubeConfigReply contains the response of getting kube config.
func (*FetchKubeConfigReply) Descriptor ¶
func (*FetchKubeConfigReply) Descriptor() ([]byte, []int)
func (*FetchKubeConfigReply) GetErr ¶
func (m *FetchKubeConfigReply) GetErr() *Error
func (*FetchKubeConfigReply) GetKubeConfig ¶
func (m *FetchKubeConfigReply) GetKubeConfig() []byte
func (*FetchKubeConfigReply) ProtoMessage ¶
func (*FetchKubeConfigReply) ProtoMessage()
func (*FetchKubeConfigReply) Reset ¶
func (m *FetchKubeConfigReply) Reset()
func (*FetchKubeConfigReply) String ¶
func (m *FetchKubeConfigReply) String() string
type FetchKubeConfigRequest ¶
type FetchKubeConfigRequest struct {
Node *Node `protobuf:"bytes,1,opt,name=node" json:"node,omitempty"`
}
FetchKubeConfigRequest contains the request of getting kube config.
func (*FetchKubeConfigRequest) Descriptor ¶
func (*FetchKubeConfigRequest) Descriptor() ([]byte, []int)
func (*FetchKubeConfigRequest) GetNode ¶
func (m *FetchKubeConfigRequest) GetNode() *Node
func (*FetchKubeConfigRequest) ProtoMessage ¶
func (*FetchKubeConfigRequest) ProtoMessage()
func (*FetchKubeConfigRequest) Reset ¶
func (m *FetchKubeConfigRequest) Reset()
func (*FetchKubeConfigRequest) String ¶
func (m *FetchKubeConfigRequest) String() string
type GetCheckNodesResultReply ¶
type GetCheckNodesResultReply struct { Status string `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"` Err *Error `protobuf:"bytes,2,opt,name=err" json:"err,omitempty"` Nodes map[string]*NodeCheckResult `` /* 130-byte string literal not displayed */ }
GetCheckNodesResultReply contains the result of nodes check
func (*GetCheckNodesResultReply) Descriptor ¶
func (*GetCheckNodesResultReply) Descriptor() ([]byte, []int)
func (*GetCheckNodesResultReply) GetErr ¶
func (m *GetCheckNodesResultReply) GetErr() *Error
func (*GetCheckNodesResultReply) GetNodes ¶
func (m *GetCheckNodesResultReply) GetNodes() map[string]*NodeCheckResult
func (*GetCheckNodesResultReply) GetStatus ¶
func (m *GetCheckNodesResultReply) GetStatus() string
func (*GetCheckNodesResultReply) ProtoMessage ¶
func (*GetCheckNodesResultReply) ProtoMessage()
func (*GetCheckNodesResultReply) Reset ¶
func (m *GetCheckNodesResultReply) Reset()
func (*GetCheckNodesResultReply) String ¶
func (m *GetCheckNodesResultReply) String() string
type GetCheckNodesResultRequest ¶
type GetCheckNodesResultRequest struct {
WithLogs bool `protobuf:"varint,1,opt,name=withLogs" json:"withLogs,omitempty"`
}
GetCheckNodesResultRequest contains the request of getting nodes check result.
func (*GetCheckNodesResultRequest) Descriptor ¶
func (*GetCheckNodesResultRequest) Descriptor() ([]byte, []int)
func (*GetCheckNodesResultRequest) GetWithLogs ¶
func (m *GetCheckNodesResultRequest) GetWithLogs() bool
func (*GetCheckNodesResultRequest) ProtoMessage ¶
func (*GetCheckNodesResultRequest) ProtoMessage()
func (*GetCheckNodesResultRequest) Reset ¶
func (m *GetCheckNodesResultRequest) Reset()
func (*GetCheckNodesResultRequest) String ¶
func (m *GetCheckNodesResultRequest) String() string
type GetDeployResultReply ¶
type GetDeployResultReply struct { Status string `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"` Err *Error `protobuf:"bytes,2,opt,name=err" json:"err,omitempty"` Items []*DeployItemResult `protobuf:"bytes,3,rep,name=items" json:"items,omitempty"` }
GetDeployResultReply represents the result of a deploy
func (*GetDeployResultReply) Descriptor ¶
func (*GetDeployResultReply) Descriptor() ([]byte, []int)
func (*GetDeployResultReply) GetErr ¶
func (m *GetDeployResultReply) GetErr() *Error
func (*GetDeployResultReply) GetItems ¶
func (m *GetDeployResultReply) GetItems() []*DeployItemResult
func (*GetDeployResultReply) GetStatus ¶
func (m *GetDeployResultReply) GetStatus() string
func (*GetDeployResultReply) ProtoMessage ¶
func (*GetDeployResultReply) ProtoMessage()
func (*GetDeployResultReply) Reset ¶
func (m *GetDeployResultReply) Reset()
func (*GetDeployResultReply) String ¶
func (m *GetDeployResultReply) String() string
type GetDeployResultRequest ¶
type GetDeployResultRequest struct {
WithLogs bool `protobuf:"varint,1,opt,name=withLogs" json:"withLogs,omitempty"`
}
GetDeployResultRequest contains the request of getting deploy result.
func (*GetDeployResultRequest) Descriptor ¶
func (*GetDeployResultRequest) Descriptor() ([]byte, []int)
func (*GetDeployResultRequest) GetWithLogs ¶
func (m *GetDeployResultRequest) GetWithLogs() bool
func (*GetDeployResultRequest) ProtoMessage ¶
func (*GetDeployResultRequest) ProtoMessage()
func (*GetDeployResultRequest) Reset ¶
func (m *GetDeployResultRequest) Reset()
func (*GetDeployResultRequest) String ¶
func (m *GetDeployResultRequest) String() string
type ItemCheckResult ¶
type ItemCheckResult struct { Item *CheckItem `protobuf:"bytes,1,opt,name=item" json:"item,omitempty"` Status string `protobuf:"bytes,2,opt,name=status" json:"status,omitempty"` Err *Error `protobuf:"bytes,3,opt,name=err" json:"err,omitempty"` Logs string `protobuf:"bytes,4,opt,name=logs" json:"logs,omitempty"` }
ItemCheckResult contains the pre-checking reuslt of an itme
func (*ItemCheckResult) Descriptor ¶
func (*ItemCheckResult) Descriptor() ([]byte, []int)
func (*ItemCheckResult) GetErr ¶
func (m *ItemCheckResult) GetErr() *Error
func (*ItemCheckResult) GetItem ¶
func (m *ItemCheckResult) GetItem() *CheckItem
func (*ItemCheckResult) GetLogs ¶
func (m *ItemCheckResult) GetLogs() string
func (*ItemCheckResult) GetStatus ¶
func (m *ItemCheckResult) GetStatus() string
func (*ItemCheckResult) ProtoMessage ¶
func (*ItemCheckResult) ProtoMessage()
func (*ItemCheckResult) Reset ¶
func (m *ItemCheckResult) Reset()
func (*ItemCheckResult) String ¶
func (m *ItemCheckResult) String() string
type Keepalived ¶
type Keepalived struct { Vip string `protobuf:"bytes,1,opt,name=vip" json:"vip,omitempty"` NetInterfaceName string `protobuf:"bytes,2,opt,name=netInterfaceName" json:"netInterfaceName,omitempty"` }
func (*Keepalived) Descriptor ¶
func (*Keepalived) Descriptor() ([]byte, []int)
func (*Keepalived) GetNetInterfaceName ¶
func (m *Keepalived) GetNetInterfaceName() string
func (*Keepalived) GetVip ¶
func (m *Keepalived) GetVip() string
func (*Keepalived) ProtoMessage ¶
func (*Keepalived) ProtoMessage()
func (*Keepalived) Reset ¶
func (m *Keepalived) Reset()
func (*Keepalived) String ¶
func (m *Keepalived) String() string
type KubeAPIServerConnect ¶
type KubeAPIServerConnect struct { // type could be ["firstMasterIP", "keepalived", "loadbalancer"] Type string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"` Keepalived *Keepalived `protobuf:"bytes,2,opt,name=keepalived" json:"keepalived,omitempty"` Loadbalancer *Loadbalancer `protobuf:"bytes,3,opt,name=loadbalancer" json:"loadbalancer,omitempty"` }
KubeAPIServerConnect contains the info of how to connect to k8s API server
func (*KubeAPIServerConnect) Descriptor ¶
func (*KubeAPIServerConnect) Descriptor() ([]byte, []int)
func (*KubeAPIServerConnect) GetKeepalived ¶
func (m *KubeAPIServerConnect) GetKeepalived() *Keepalived
func (*KubeAPIServerConnect) GetLoadbalancer ¶
func (m *KubeAPIServerConnect) GetLoadbalancer() *Loadbalancer
func (*KubeAPIServerConnect) GetType ¶
func (m *KubeAPIServerConnect) GetType() string
func (*KubeAPIServerConnect) ProtoMessage ¶
func (*KubeAPIServerConnect) ProtoMessage()
func (*KubeAPIServerConnect) Reset ¶
func (m *KubeAPIServerConnect) Reset()
func (*KubeAPIServerConnect) String ¶
func (m *KubeAPIServerConnect) String() string
type Loadbalancer ¶
type Loadbalancer struct { Ip string `protobuf:"bytes,1,opt,name=ip" json:"ip,omitempty"` Port uint32 `protobuf:"varint,2,opt,name=port" json:"port,omitempty"` }
func (*Loadbalancer) Descriptor ¶
func (*Loadbalancer) Descriptor() ([]byte, []int)
func (*Loadbalancer) GetIp ¶
func (m *Loadbalancer) GetIp() string
func (*Loadbalancer) GetPort ¶
func (m *Loadbalancer) GetPort() uint32
func (*Loadbalancer) ProtoMessage ¶
func (*Loadbalancer) ProtoMessage()
func (*Loadbalancer) Reset ¶
func (m *Loadbalancer) Reset()
func (*Loadbalancer) String ¶
func (m *Loadbalancer) String() string
type NetworkOptions ¶
type NetworkOptions struct { NetworkType string `protobuf:"bytes,1,opt,name=NetworkType" json:"NetworkType,omitempty"` // options for a specified network type. Starts from 10 to reserve field 2-9. CalicoOptions *CalicoOptions `protobuf:"bytes,10,opt,name=calicoOptions" json:"calicoOptions,omitempty"` }
NetworkOptions options for deploying network. affects checked items.
func (*NetworkOptions) Descriptor ¶
func (*NetworkOptions) Descriptor() ([]byte, []int)
func (*NetworkOptions) GetCalicoOptions ¶
func (m *NetworkOptions) GetCalicoOptions() *CalicoOptions
func (*NetworkOptions) GetNetworkType ¶
func (m *NetworkOptions) GetNetworkType() string
func (*NetworkOptions) ProtoMessage ¶
func (*NetworkOptions) ProtoMessage()
func (*NetworkOptions) Reset ¶
func (m *NetworkOptions) Reset()
func (*NetworkOptions) String ¶
func (m *NetworkOptions) String() string
type Node ¶
type Node struct { Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` Ip string `protobuf:"bytes,2,opt,name=ip" json:"ip,omitempty"` Ssh *SSH `protobuf:"bytes,3,opt,name=ssh" json:"ssh,omitempty"` }
Node contains the node metadata info
func (*Node) Descriptor ¶
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
type NodeCheckConfig ¶
type NodeCheckConfig struct { Node *Node `protobuf:"bytes,1,opt,name=node" json:"node,omitempty"` Roles []string `protobuf:"bytes,2,rep,name=roles" json:"roles,omitempty"` }
NodeCheckConfig contains the pre-checking configuration for a node
func (*NodeCheckConfig) Descriptor ¶
func (*NodeCheckConfig) Descriptor() ([]byte, []int)
func (*NodeCheckConfig) GetNode ¶
func (m *NodeCheckConfig) GetNode() *Node
func (*NodeCheckConfig) GetRoles ¶
func (m *NodeCheckConfig) GetRoles() []string
func (*NodeCheckConfig) ProtoMessage ¶
func (*NodeCheckConfig) ProtoMessage()
func (*NodeCheckConfig) Reset ¶
func (m *NodeCheckConfig) Reset()
func (*NodeCheckConfig) String ¶
func (m *NodeCheckConfig) String() string
type NodeCheckResult ¶
type NodeCheckResult struct { NodeName string `protobuf:"bytes,1,opt,name=nodeName" json:"nodeName,omitempty"` Status string `protobuf:"bytes,2,opt,name=status" json:"status,omitempty"` Err *Error `protobuf:"bytes,3,opt,name=err" json:"err,omitempty"` Items []*ItemCheckResult `protobuf:"bytes,4,rep,name=items" json:"items,omitempty"` }
ItemCheckResult contains the pre-checking reuslt of a node
func (*NodeCheckResult) Descriptor ¶
func (*NodeCheckResult) Descriptor() ([]byte, []int)
func (*NodeCheckResult) GetErr ¶
func (m *NodeCheckResult) GetErr() *Error
func (*NodeCheckResult) GetItems ¶
func (m *NodeCheckResult) GetItems() []*ItemCheckResult
func (*NodeCheckResult) GetNodeName ¶
func (m *NodeCheckResult) GetNodeName() string
func (*NodeCheckResult) GetStatus ¶
func (m *NodeCheckResult) GetStatus() string
func (*NodeCheckResult) ProtoMessage ¶
func (*NodeCheckResult) ProtoMessage()
func (*NodeCheckResult) Reset ¶
func (m *NodeCheckResult) Reset()
func (*NodeCheckResult) String ¶
func (m *NodeCheckResult) String() string
type NodeDeployConfig ¶
type NodeDeployConfig struct { Node *Node `protobuf:"bytes,1,opt,name=node" json:"node,omitempty"` // role cloud be ["etcd", "master", "worker", ...] Roles []string `protobuf:"bytes,2,rep,name=roles" json:"roles,omitempty"` Labels map[string]string `` /* 132-byte string literal not displayed */ Taints []*Taint `protobuf:"bytes,4,rep,name=taints" json:"taints,omitempty"` }
NodeDeployConfig contains the deploy configuration for a node
func (*NodeDeployConfig) Descriptor ¶
func (*NodeDeployConfig) Descriptor() ([]byte, []int)
func (*NodeDeployConfig) GetLabels ¶
func (m *NodeDeployConfig) GetLabels() map[string]string
func (*NodeDeployConfig) GetNode ¶
func (m *NodeDeployConfig) GetNode() *Node
func (*NodeDeployConfig) GetRoles ¶
func (m *NodeDeployConfig) GetRoles() []string
func (*NodeDeployConfig) GetTaints ¶
func (m *NodeDeployConfig) GetTaints() []*Taint
func (*NodeDeployConfig) ProtoMessage ¶
func (*NodeDeployConfig) ProtoMessage()
func (*NodeDeployConfig) Reset ¶
func (m *NodeDeployConfig) Reset()
func (*NodeDeployConfig) String ¶
func (m *NodeDeployConfig) String() string
type NodePortRange ¶
type NodePortRange struct { From uint32 `protobuf:"varint,1,opt,name=from" json:"from,omitempty"` To uint32 `protobuf:"varint,2,opt,name=to" json:"to,omitempty"` }
func (*NodePortRange) Descriptor ¶
func (*NodePortRange) Descriptor() ([]byte, []int)
func (*NodePortRange) GetFrom ¶
func (m *NodePortRange) GetFrom() uint32
func (*NodePortRange) GetTo ¶
func (m *NodePortRange) GetTo() uint32
func (*NodePortRange) ProtoMessage ¶
func (*NodePortRange) ProtoMessage()
func (*NodePortRange) Reset ¶
func (m *NodePortRange) Reset()
func (*NodePortRange) String ¶
func (m *NodePortRange) String() string
type SSH ¶
type SSH struct { Port uint32 `protobuf:"varint,1,opt,name=port" json:"port,omitempty"` Auth *Auth `protobuf:"bytes,2,opt,name=auth" json:"auth,omitempty"` }
SSH contains the ssh login info.
func (*SSH) Descriptor ¶
func (*SSH) ProtoMessage ¶
func (*SSH) ProtoMessage()
type Taint ¶
type Taint struct { Key string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"` Effect string `protobuf:"bytes,3,opt,name=effect" json:"effect,omitempty"` }
func (*Taint) Descriptor ¶
func (*Taint) ProtoMessage ¶
func (*Taint) ProtoMessage()
type TestConnectionReply ¶
type TestConnectionReply struct { Passed bool `protobuf:"varint,1,opt,name=passed" json:"passed,omitempty"` Err *Error `protobuf:"bytes,2,opt,name=err" json:"err,omitempty"` }
TestConnectionReply contains the result of node connection testing.
func (*TestConnectionReply) Descriptor ¶
func (*TestConnectionReply) Descriptor() ([]byte, []int)
func (*TestConnectionReply) GetErr ¶
func (m *TestConnectionReply) GetErr() *Error
func (*TestConnectionReply) GetPassed ¶
func (m *TestConnectionReply) GetPassed() bool
func (*TestConnectionReply) ProtoMessage ¶
func (*TestConnectionReply) ProtoMessage()
func (*TestConnectionReply) Reset ¶
func (m *TestConnectionReply) Reset()
func (*TestConnectionReply) String ¶
func (m *TestConnectionReply) String() string
type TestConnectionRequest ¶
type TestConnectionRequest struct {
Node *Node `protobuf:"bytes,1,opt,name=node" json:"node,omitempty"`
}
TestConnectionRequest contains the request of node connection testing.
func (*TestConnectionRequest) Descriptor ¶
func (*TestConnectionRequest) Descriptor() ([]byte, []int)
func (*TestConnectionRequest) GetNode ¶
func (m *TestConnectionRequest) GetNode() *Node
func (*TestConnectionRequest) ProtoMessage ¶
func (*TestConnectionRequest) ProtoMessage()
func (*TestConnectionRequest) Reset ¶
func (m *TestConnectionRequest) Reset()
func (*TestConnectionRequest) String ¶
func (m *TestConnectionRequest) String() string