client

package
v0.0.0-...-894910e Latest Latest
Warning

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

 Go to latest Published: Apr 25, 2024 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.