v1

Documentation

Index

• Constants
• Variables
• func AddToContainer(c *restful.Container, clusterOperator cluster.Operator, op operation.Operator, ...) error
• func CreateBasic(serverURL, clusterName, userName string, caCert []byte) *clientcmdapi.Config
• func CreateWithToken(serverURL, clusterName, userName string, caCert []byte, token string) *clientcmdapi.Config
• func MarkToOriginNode(ctx context.Context, operator cluster.Operator, kcNodeID string) (*v1.Node, error)
• func SetupWebService(h *handler) *restful.WebService
• type ClusterUpgrade
• type PatchComponents
• type SSHCredential
• type StepLog

Constants

const (
	ParameterMsg   = "msg"
	ParameterToken = "token"
	ParameterCols  = "cols"
	ParameterRows  = "rows"
)

const (
	CoreClusterTag = "Core-Cluster"
	CoreNodeTag    = "Core-Node"
	CoreRegionTag  = "Core-Region"
)

Variables

var (
	ErrNodesRegionDifferent = errors.New("nodes belongs to different region")
)

var GroupVersion = schema.GroupVersion{Group: corev1.GroupName, Version: "v1"}

Functions

func AddToContainer

func AddToContainer(c *restful.Container, clusterOperator cluster.Operator,
	op operation.Operator, platform platform.Operator, leaseOperator lease.Operator,
	coreOperator core.Operator, delivery service.IDelivery, tokenOperator auth.TokenManagementInterface,
	conf *generic.ServerRunOptions, terminationChan *chan struct{}) error

func CreateBasic

func CreateBasic(serverURL, clusterName, userName string, caCert []byte) *clientcmdapi.Config

CreateBasic creates a basic, general KubeConfig object that then can be extended Copy from k8s.io/kubernetes/cmd/kubeadm/app/util/kubeconfig/kubeconfig.go

func CreateWithToken

func CreateWithToken(serverURL, clusterName, userName string, caCert []byte, token string) *clientcmdapi.Config

CreateWithToken creates a KubeConfig object with access to the API server with a token Copy from k8s.io/kubernetes/cmd/kubeadm/app/util/kubeconfig/kubeconfig.go

func MarkToOriginNode

func MarkToOriginNode(ctx context.Context, operator cluster.Operator, kcNodeID string) (*v1.Node, error)

func SetupWebService

func SetupWebService(h *handler) *restful.WebService

this is how set up web service route only in that case cli tool can simply call it to get api route by pass in a nil parameter

Types

type ClusterUpgrade

type ClusterUpgrade struct {
	Version       string `json:"version"`
	Offline       bool   `json:"offline"`
	LocalRegistry string `json:"localRegistry"`
}

type PatchComponents

type PatchComponents struct {
	Uninstall bool           `json:"uninstall"`
	Addons    []corev1.Addon `json:"addons"`
}

type SSHCredential

type SSHCredential struct {
	Username []byte `json:"username"`
	Password []byte `json:"password"`
	Port     int    `json:"port"`
}

type StepLog

type StepLog struct {
	Content      string          `json:"content,omitempty"`
	Node         string          `json:"node,omitempty"`
	Timeout      metav1.Duration `json:"timeout,omitempty"`
	Status       string          `json:"status,omitempty"`
	DeliverySize int64           `json:"deliverySize,omitempty"`
	LogSize      int64           `json:"logSize,omitempty"`
}