client

Documentation

Index

• Constants
• func InitCloudConfig(client *ACKClient) error
• type ACKClient
  • func NewACKClient() (*ACKClient, error)
  • func (e *ACKClient) DeleteClusterNodes(clusterId, nodeName string) error
  • func (e *ACKClient) DescribeClusterAddonsUpgradeStatus(clusterId string, componentId string) (*AddonInfo, error)
  • func (e *ACKClient) DescribeClusterDetail(clusterId string) (*cs.DescribeClusterDetailResponseBody, error)
  • func (e *ACKClient) ModifyClusterConfiguration(clusterId string, addonName string, configs map[string]string) error
  • func (e *ACKClient) ScaleOutCluster(clusterId string, nodeCount int64) error
• type AddonInfo
• type E2EClient
  • func NewClient() (*E2EClient, error)
  • func (client *E2EClient) InitOptions() error
• type KubeClient
  • func NewKubeClient(client kubernetes.Interface) *KubeClient
  • func (client *KubeClient) AddTaint(nodeName string, taint v1.Taint) error
  • func (client *KubeClient) CreateDeployment() error
  • func (client *KubeClient) CreateEndpointsWithNotExistNode() (*v1.Endpoints, error)
  • func (client *KubeClient) CreateEndpointsWithoutNodeName() (*v1.Endpoints, error)
  • func (client *KubeClient) CreateNLBServiceByAnno(anno map[string]string) (*v1.Service, error)
  • func (client *KubeClient) CreateNLBServiceWithStringTargetPort(anno map[string]string) (*v1.Service, error)
  • func (client *KubeClient) CreateNLBServiceWithoutSelector(anno map[string]string) (*v1.Service, error)
  • func (client *KubeClient) CreateNamespace() error
  • func (client *KubeClient) CreateService(svc *v1.Service) (*v1.Service, error)
  • func (client *KubeClient) CreateServiceByAnno(anno map[string]string) (*v1.Service, error)
  • func (client *KubeClient) CreateServiceWithStringTargetPort(anno map[string]string) (*v1.Service, error)
  • func (client *KubeClient) CreateServiceWithoutSelector(anno map[string]string) (*v1.Service, error)
  • func (client *KubeClient) CreateVKDeployment() error
  • func (client *KubeClient) DefaultNLBService() *v1.Service
  • func (client *KubeClient) DefaultService() *v1.Service
  • func (client *KubeClient) DeleteNamespace() error
  • func (client *KubeClient) DeleteService() error
  • func (client *KubeClient) DeleteServiceByName(name string) error
  • func (client *KubeClient) GetEndpoint() (*v1.Endpoints, error)
  • func (client *KubeClient) GetLatestNode() (*v1.Node, error)
  • func (client *KubeClient) GetService() (*v1.Service, error)
  • func (client *KubeClient) LabelNode(nodeName string, key string, value string) error
  • func (client *KubeClient) ListNodes() ([]v1.Node, error)
  • func (client *KubeClient) PatchNode(oldNode, newNode *v1.Node) (*v1.Node, error)
  • func (client *KubeClient) PatchNodeStatus(oldNode, newNode *v1.Node) (*v1.Node, error)
  • func (client *KubeClient) PatchService(oldSvc, newSvc *v1.Service) (*v1.Service, error)
  • func (client *KubeClient) RemoveTaint(nodeName string, taint v1.Taint) error
  • func (client *KubeClient) ScaleDeployment(replica int32) error
  • func (client *KubeClient) ScheduledNode(nodeName string) error
  • func (client *KubeClient) UnLabelNode(nodeName string, key string) error
  • func (client *KubeClient) UnscheduledNode(nodeName string) error

Constants

const (
	Namespace        = "e2e-test"
	Service          = "basic-service"
	Deployment       = "nginx"
	VKDeployment     = "nginx-vk"
	NodeLabel        = "e2etest"
	ExcludeNodeLabel = "service.beta.kubernetes.io/exclude-node"
)

Functions

func InitCloudConfig

func InitCloudConfig(client *ACKClient) error

Types

type ACKClient

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

func NewACKClient

func NewACKClient() (*ACKClient, error)

func (*ACKClient) DeleteClusterNodes

func (e *ACKClient) DeleteClusterNodes(clusterId, nodeName string) error

func (*ACKClient) DescribeClusterAddonsUpgradeStatus

func (e *ACKClient) DescribeClusterAddonsUpgradeStatus(clusterId string, componentId string) (*AddonInfo, error)

func (*ACKClient) DescribeClusterDetail

func (e *ACKClient) DescribeClusterDetail(clusterId string) (*cs.DescribeClusterDetailResponseBody, error)

func (*ACKClient) ModifyClusterConfiguration

func (e *ACKClient) ModifyClusterConfiguration(clusterId string, addonName string, configs map[string]string) error

func (*ACKClient) ScaleOutCluster

func (e *ACKClient) ScaleOutCluster(clusterId string, nodeCount int64) error

type AddonInfo

type AddonInfo struct {
	ComponentName string
	Version       string
}

type E2EClient

type E2EClient struct {
	CloudClient   *alibaba.AlibabaCloud
	KubeClient    *KubeClient
	RuntimeClient runtime.Client
	ACKClient     *ACKClient
}

func NewClient

func NewClient() (*E2EClient, error)

func (*E2EClient) InitOptions

func (client *E2EClient) InitOptions() error

type KubeClient

type KubeClient struct {
	kubernetes.Interface
}

func NewKubeClient

func NewKubeClient(client kubernetes.Interface) *KubeClient

func (*KubeClient) AddTaint

func (client *KubeClient) AddTaint(nodeName string, taint v1.Taint) error

func (*KubeClient) CreateDeployment

func (client *KubeClient) CreateDeployment() error

deployment

func (*KubeClient) CreateEndpointsWithNotExistNode

func (client *KubeClient) CreateEndpointsWithNotExistNode() (*v1.Endpoints, error)

func (*KubeClient) CreateEndpointsWithoutNodeName

func (client *KubeClient) CreateEndpointsWithoutNodeName() (*v1.Endpoints, error)

func (*KubeClient) CreateNLBServiceByAnno

func (client *KubeClient) CreateNLBServiceByAnno(anno map[string]string) (*v1.Service, error)

func (*KubeClient) CreateNLBServiceWithStringTargetPort

func (client *KubeClient) CreateNLBServiceWithStringTargetPort(anno map[string]string) (*v1.Service, error)

func (*KubeClient) CreateNLBServiceWithoutSelector

func (client *KubeClient) CreateNLBServiceWithoutSelector(anno map[string]string) (*v1.Service, error)

func (*KubeClient) CreateNamespace

func (client *KubeClient) CreateNamespace() error

namespace

func (*KubeClient) CreateService

func (client *KubeClient) CreateService(svc *v1.Service) (*v1.Service, error)

func (*KubeClient) CreateServiceByAnno

func (client *KubeClient) CreateServiceByAnno(anno map[string]string) (*v1.Service, error)

func (*KubeClient) CreateServiceWithStringTargetPort

func (client *KubeClient) CreateServiceWithStringTargetPort(anno map[string]string) (*v1.Service, error)

func (*KubeClient) CreateServiceWithoutSelector

func (client *KubeClient) CreateServiceWithoutSelector(anno map[string]string) (*v1.Service, error)

func (*KubeClient) CreateVKDeployment

func (client *KubeClient) CreateVKDeployment() error

func (*KubeClient) DefaultNLBService

func (client *KubeClient) DefaultNLBService() *v1.Service

func (*KubeClient) DefaultService

func (client *KubeClient) DefaultService() *v1.Service

service

func (*KubeClient) DeleteNamespace

func (client *KubeClient) DeleteNamespace() error

func (*KubeClient) DeleteService

func (client *KubeClient) DeleteService() error

func (*KubeClient) DeleteServiceByName

func (client *KubeClient) DeleteServiceByName(name string) error

func (*KubeClient) GetEndpoint

func (client *KubeClient) GetEndpoint() (*v1.Endpoints, error)

func (*KubeClient) GetLatestNode

func (client *KubeClient) GetLatestNode() (*v1.Node, error)

func (*KubeClient) GetService

func (client *KubeClient) GetService() (*v1.Service, error)

func (*KubeClient) LabelNode

func (client *KubeClient) LabelNode(nodeName string, key string, value string) error

node

func (*KubeClient) ListNodes

func (client *KubeClient) ListNodes() ([]v1.Node, error)

func (*KubeClient) PatchNode

func (client *KubeClient) PatchNode(oldNode, newNode *v1.Node) (*v1.Node, error)

func (*KubeClient) PatchNodeStatus

func (client *KubeClient) PatchNodeStatus(oldNode, newNode *v1.Node) (*v1.Node, error)

func (*KubeClient) PatchService

func (client *KubeClient) PatchService(oldSvc, newSvc *v1.Service) (*v1.Service, error)

func (*KubeClient) RemoveTaint

func (client *KubeClient) RemoveTaint(nodeName string, taint v1.Taint) error

func (*KubeClient) ScaleDeployment

func (client *KubeClient) ScaleDeployment(replica int32) error

func (*KubeClient) ScheduledNode

func (client *KubeClient) ScheduledNode(nodeName string) error

func (*KubeClient) UnLabelNode

func (client *KubeClient) UnLabelNode(nodeName string, key string) error

func (*KubeClient) UnscheduledNode

func (client *KubeClient) UnscheduledNode(nodeName string) error