Documentation ¶
Index ¶
- Constants
- func Create(ctx context.Context, client *cs.Client, config *ackv1.ACKClusterConfig) error
- func GetACKClient(regionID, accessKeyID, accessKeySecret string) (*ackapi.Client, error)
- func GetCluster(svc *cs.Client, state *ackv1.ACKClusterConfigSpec) (*ackapi.DescribeClusterDetailResponseBody, error)
- func NewCsAPIRequest(apiName, method string) *requests.CommonRequest
- func ProcessRequest(svc *cs.Client, request *requests.CommonRequest, obj interface{}) error
- func RemoveCluster(ctx context.Context, client *cs.Client, config *ackv1.ACKClusterConfig) error
- func TickerContext(ctx context.Context, duration time.Duration) <-chan time.Time
- type Status
Constants ¶
View Source
const ( ClusterStatusRunning = "running" ClusterStatusError = "failed" ClusterStatusUpdating = "updating" )
Variables ¶
This section is empty.
Functions ¶
func GetACKClient ¶
func GetCluster ¶
func GetCluster(svc *cs.Client, state *ackv1.ACKClusterConfigSpec) (*ackapi.DescribeClusterDetailResponseBody, error)
func NewCsAPIRequest ¶
func NewCsAPIRequest(apiName, method string) *requests.CommonRequest
NewCsAPIRequest constructs general aliyun sdk request
func ProcessRequest ¶
func ProcessRequest(svc *cs.Client, request *requests.CommonRequest, obj interface{}) error
func RemoveCluster ¶
RemoveCluster attempts to delete a cluster and retries the delete request if the cluster is busy.
Types ¶
type Status ¶
type Status int
Status indicates how to handle the response from a request to update a resource
const ( // Changed means the request to change resource was accepted and change is in progress Changed Status = iota // Retry means the request to change resource was rejected due to an expected error and should be retried later Retry // NotChanged means the resource was not changed, either due to error or because it was unnecessary NotChanged )
Status indicators
func UpdateMasterKubernetesVersion ¶
func UpdateMasterKubernetesVersion(ctx context.Context, client *cs.Client, config *ackv1.ACKClusterConfig, upstreamSpec *ackv1.ACKClusterConfigSpec) (Status, error)
UpdateMasterKubernetesVersion updates the Kubernetes version for the control plane. This must occur before the Kubernetes version is changed on the nodes.
Click to show internal directories.
Click to hide internal directories.