cluster

package
v0.2.2-beta1 Latest Latest
Warning

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

 Go to latest Published: Nov 10, 2021 License: MIT Imports: 23 Imported by: 0

Documentation

Overview

Package cluster is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Kubernetes 

type Kubernetes struct {
	KubeConfig string
	Clientset  kubernetes.Interface
}

Kubernetes implements KubernetesInterface

func (*Kubernetes) AddEphemeralContainer added in v0.2.0 

func (k *Kubernetes) AddEphemeralContainer(ctx context.Context, containerName string, podName string,
	options *options.DaemonOptions, envs map[string]string) (sshcm string, err error)

AddEphemeralContainer add ephemeral container to specified pod

func (*Kubernetes) ClusterCidrs added in v0.1.0 

func (k *Kubernetes) ClusterCidrs(ctx context.Context, namespace string, opt *options.ConnectOptions) (cidrs []string, err error)

ClusterCidrs get cluster Cidrs

func (*Kubernetes) CreateService added in v0.1.0 

func (k *Kubernetes) CreateService(ctx context.Context, name, namespace string, external bool, port int, labels map[string]string) (*coreV1.Service, error)

CreateService create kubernetes service

func (*Kubernetes) DecreaseRef added in v0.1.0 

func (k *Kubernetes) DecreaseRef(ctx context.Context, namespace string, app string) (cleanup bool, err error)

DecreaseRef ...

func (*Kubernetes) Deployment 

func (k *Kubernetes) Deployment(ctx context.Context, name, namespace string) (*appv1.Deployment, error)

Deployment get deployment

func (*Kubernetes) GetAllExistingShadowPods added in v0.2.0 

func (k *Kubernetes) GetAllExistingShadowPods(ctx context.Context, namespace string) ([]coreV1.Pod, error)

GetAllExistingShadowPods fetch all shadow pods

func (*Kubernetes) GetDeployment added in v0.1.0 

func (k *Kubernetes) GetDeployment(ctx context.Context, name string, namespace string) (*appv1.Deployment, error)

GetDeployment ...

func (*Kubernetes) GetOrCreateShadow added in v0.1.0 

func (k *Kubernetes) GetOrCreateShadow(ctx context.Context, name string, options *options.DaemonOptions, labels, annotations, envs map[string]string) (
	podIP, podName, sshcm string, credential *util.SSHCredential, err error)

GetOrCreateShadow create shadow

func (*Kubernetes) GetPod added in v0.2.0 

func (k *Kubernetes) GetPod(ctx context.Context, name string, namespace string) (*coreV1.Pod, error)

GoPod ...

func (*Kubernetes) Pod added in v0.2.0 

func (k *Kubernetes) Pod(ctx context.Context, name, namespace string) (*coreV1.Pod, error)

Pod get pod

func (*Kubernetes) Pods added in v0.2.0 

func (k *Kubernetes) Pods(ctx context.Context, labels map[string]string, namespace string) (*coreV1.PodList, error)

Pods get pods

func (*Kubernetes) RemoveConfigMap added in v0.1.0 

func (k *Kubernetes) RemoveConfigMap(ctx context.Context, name, namespace string) (err error)

RemoveConfigMap remove ConfigMap instance

func (*Kubernetes) RemoveEphemeralContainer added in v0.2.0 

func (k *Kubernetes) RemoveEphemeralContainer(ctx context.Context, containerName, podName string, namespace string) (err error)

RemoveEphemeralContainer remove ephemeral container from specified pod

func (*Kubernetes) RemovePod added in v0.2.0 

func (k *Kubernetes) RemovePod(ctx context.Context, name, namespace string) (err error)

RemovePod remove pod instances

func (*Kubernetes) RemoveService added in v0.1.0 

func (k *Kubernetes) RemoveService(ctx context.Context, name, namespace string) (err error)

RemoveService remove service

func (*Kubernetes) Scale 

func (k *Kubernetes) Scale(ctx context.Context, deployment *appv1.Deployment, replicas *int32) (err error)

Scale scale deployment to

func (*Kubernetes) ScaleTo added in v0.1.0 

func (k *Kubernetes) ScaleTo(ctx context.Context, deployment, namespace string, replicas *int32) (err error)

ScaleTo scale deployment to

func (*Kubernetes) Service added in v0.2.0 

func (k *Kubernetes) Service(ctx context.Context, name, namespace string) (*coreV1.Service, error)

Service get service

func (*Kubernetes) ServiceHosts 

func (k *Kubernetes) ServiceHosts(ctx context.Context, namespace string) (hosts map[string]string)

ServiceHosts get service dns map

func (*Kubernetes) UpdatePod added in v0.2.0 

func (k *Kubernetes) UpdatePod(ctx context.Context, namespace string, pod *coreV1.Pod) (*coreV1.Pod, error)

UpdatePod ...

type KubernetesInterface 

type KubernetesInterface interface {
	RemovePod(ctx context.Context, name, namespace string) (err error)
	RemoveConfigMap(ctx context.Context, name, namespace string) (err error)
	RemoveService(ctx context.Context, name, namespace string) (err error)
	Deployment(ctx context.Context, name, namespace string) (deployment *appV1.Deployment, err error)
	Service(ctx context.Context, name, namespace string) (*coreV1.Service, error)
	Pod(ctx context.Context, name, namespace string) (pod *coreV1.Pod, err error)
	Pods(ctx context.Context, labels map[string]string, namespace string) (pods *coreV1.PodList, err error)
	Scale(ctx context.Context, deployment *appV1.Deployment, replicas *int32) (err error)
	ScaleTo(ctx context.Context, deployment, namespace string, replicas *int32) (err error)
	ServiceHosts(ctx context.Context, namespace string) (hosts map[string]string)
	ClusterCidrs(ctx context.Context, namespace string, connectOptions *options.ConnectOptions) (cidrs []string, err error)
	GetOrCreateShadow(ctx context.Context, name string, options *options.DaemonOptions, labels, annotations, envs map[string]string) (podIP, podName, sshcm string, credential *util.SSHCredential, err error)
	GetAllExistingShadowPods(ctx context.Context, namespace string) (list []coreV1.Pod, err error)
	CreateService(ctx context.Context, name, namespace string, external bool, port int, labels map[string]string) (*coreV1.Service, error)
	GetDeployment(ctx context.Context, name string, namespace string) (*appV1.Deployment, error)
	GetPod(ctx context.Context, name string, namespace string) (*coreV1.Pod, error)
	UpdatePod(ctx context.Context, namespace string, pod *coreV1.Pod) (*coreV1.Pod, error)
	DecreaseRef(ctx context.Context, namespace string, deployment string) (cleanup bool, err error)
	AddEphemeralContainer(ctx context.Context, containerName, podName string, options *options.DaemonOptions, envs map[string]string) (sshcm string, err error)
	RemoveEphemeralContainer(ctx context.Context, containerName, podName string, namespace string) (err error)
}

KubernetesInterface kubernetes interface

func CreateFromClientSet added in v0.1.0 

func CreateFromClientSet(clientSet kubernetes.Interface) (kubernetes KubernetesInterface, err error)

CreateFromClientSet kubernetes instance

type MockKubernetesInterface added in v0.1.0 

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

MockKubernetesInterface is a mock of KubernetesInterface interface.

func NewMockKubernetesInterface added in v0.1.0 

func NewMockKubernetesInterface(ctrl *gomock.Controller) *MockKubernetesInterface

NewMockKubernetesInterface creates a new mock instance.

func (*MockKubernetesInterface) AddEphemeralContainer added in v0.2.0 

func (m *MockKubernetesInterface) AddEphemeralContainer(ctx context.Context, containerName, podName string, options *options.DaemonOptions, envs map[string]string) (string, error)

AddEphemeralContainer mocks base method.

func (*MockKubernetesInterface) ClusterCidrs added in v0.1.0 

func (m *MockKubernetesInterface) ClusterCidrs(ctx context.Context, namespace string, connectOptions *options.ConnectOptions) ([]string, error)

ClusterCidrs mocks base method.

func (*MockKubernetesInterface) CreateService added in v0.1.0 

func (m *MockKubernetesInterface) CreateService(ctx context.Context, name, namespace string, external bool, port int, labels map[string]string) (*v10.Service, error)

CreateService mocks base method.

func (*MockKubernetesInterface) DecreaseRef added in v0.1.0 

func (m *MockKubernetesInterface) DecreaseRef(ctx context.Context, namespace, deployment string) (bool, error)

DecreaseRef mocks base method.

func (*MockKubernetesInterface) Deployment added in v0.1.0 

func (m *MockKubernetesInterface) Deployment(ctx context.Context, name, namespace string) (*v1.Deployment, error)

Deployment mocks base method.

func (*MockKubernetesInterface) EXPECT added in v0.1.0 

func (m *MockKubernetesInterface) EXPECT() *MockKubernetesInterfaceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockKubernetesInterface) GetAllExistingShadowPods added in v0.2.0 

func (m *MockKubernetesInterface) GetAllExistingShadowPods(ctx context.Context, namespace string) ([]v10.Pod, error)

GetAllExistingShadowPods mocks base method.

func (*MockKubernetesInterface) GetDeployment added in v0.1.0 

func (m *MockKubernetesInterface) GetDeployment(ctx context.Context, name, namespace string) (*v1.Deployment, error)

GetDeployment mocks base method.

func (*MockKubernetesInterface) GetOrCreateShadow added in v0.1.0 

func (m *MockKubernetesInterface) GetOrCreateShadow(ctx context.Context, name string, options *options.DaemonOptions, labels, annotations, envs map[string]string) (string, string, string, *util.SSHCredential, error)

GetOrCreateShadow mocks base method.

func (*MockKubernetesInterface) GetPod added in v0.2.0 

func (m *MockKubernetesInterface) GetPod(ctx context.Context, name, namespace string) (*v10.Pod, error)

GetPod mocks base method.

func (*MockKubernetesInterface) Pod added in v0.2.0 

func (m *MockKubernetesInterface) Pod(ctx context.Context, name, namespace string) (*v10.Pod, error)

Pod mocks base method.

func (*MockKubernetesInterface) Pods added in v0.2.0 

func (m *MockKubernetesInterface) Pods(ctx context.Context, labels map[string]string, namespace string) (*v10.PodList, error)

Pods mocks base method.

func (*MockKubernetesInterface) RemoveConfigMap added in v0.1.0 

func (m *MockKubernetesInterface) RemoveConfigMap(ctx context.Context, name, namespace string) error

RemoveConfigMap mocks base method.

func (*MockKubernetesInterface) RemoveEphemeralContainer added in v0.2.2 

func (m *MockKubernetesInterface) RemoveEphemeralContainer(ctx context.Context, containerName, podName, namespace string) error

RemoveEphemeralContainer mocks base method.

func (*MockKubernetesInterface) RemovePod added in v0.2.0 

func (m *MockKubernetesInterface) RemovePod(ctx context.Context, name, namespace string) error

RemovePod mocks base method.

func (*MockKubernetesInterface) RemoveService added in v0.1.0 

func (m *MockKubernetesInterface) RemoveService(ctx context.Context, name, namespace string) error

RemoveService mocks base method.

func (*MockKubernetesInterface) Scale added in v0.1.0 

func (m *MockKubernetesInterface) Scale(ctx context.Context, deployment *v1.Deployment, replicas *int32) error

Scale mocks base method.

func (*MockKubernetesInterface) ScaleTo added in v0.1.0 

func (m *MockKubernetesInterface) ScaleTo(ctx context.Context, deployment, namespace string, replicas *int32) error

ScaleTo mocks base method.

func (*MockKubernetesInterface) Service added in v0.2.2 

func (m *MockKubernetesInterface) Service(ctx context.Context, name, namespace string) (*v10.Service, error)

Service mocks base method.

func (*MockKubernetesInterface) ServiceHosts added in v0.1.0 

func (m *MockKubernetesInterface) ServiceHosts(ctx context.Context, namespace string) map[string]string

ServiceHosts mocks base method.

func (*MockKubernetesInterface) UpdatePod added in v0.2.0 

func (m *MockKubernetesInterface) UpdatePod(ctx context.Context, namespace string, pod *v10.Pod) (*v10.Pod, error)

UpdatePod mocks base method.

type MockKubernetesInterfaceMockRecorder added in v0.1.0 

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

MockKubernetesInterfaceMockRecorder is the mock recorder for MockKubernetesInterface.

func (*MockKubernetesInterfaceMockRecorder) AddEphemeralContainer added in v0.2.0 

func (mr *MockKubernetesInterfaceMockRecorder) AddEphemeralContainer(ctx, containerName, podName, options, envs interface{}) *gomock.Call

AddEphemeralContainer indicates an expected call of AddEphemeralContainer.

func (*MockKubernetesInterfaceMockRecorder) ClusterCidrs added in v0.1.0 

func (mr *MockKubernetesInterfaceMockRecorder) ClusterCidrs(ctx, namespace, connectOptions interface{}) *gomock.Call

ClusterCidrs indicates an expected call of ClusterCidrs.

func (*MockKubernetesInterfaceMockRecorder) CreateService added in v0.1.0 

func (mr *MockKubernetesInterfaceMockRecorder) CreateService(ctx, name, namespace, external, port, labels interface{}) *gomock.Call

CreateService indicates an expected call of CreateService.

func (*MockKubernetesInterfaceMockRecorder) DecreaseRef added in v0.1.0 

func (mr *MockKubernetesInterfaceMockRecorder) DecreaseRef(ctx, namespace, deployment interface{}) *gomock.Call

DecreaseRef indicates an expected call of DecreaseRef.

func (*MockKubernetesInterfaceMockRecorder) Deployment added in v0.1.0 

func (mr *MockKubernetesInterfaceMockRecorder) Deployment(ctx, name, namespace interface{}) *gomock.Call

Deployment indicates an expected call of Deployment.

func (*MockKubernetesInterfaceMockRecorder) GetAllExistingShadowPods added in v0.2.0 

func (mr *MockKubernetesInterfaceMockRecorder) GetAllExistingShadowPods(ctx, namespace interface{}) *gomock.Call

GetAllExistingShadowPods indicates an expected call of GetAllExistingShadowPods.

func (*MockKubernetesInterfaceMockRecorder) GetDeployment added in v0.1.0 

func (mr *MockKubernetesInterfaceMockRecorder) GetDeployment(ctx, name, namespace interface{}) *gomock.Call

GetDeployment indicates an expected call of GetDeployment.

func (*MockKubernetesInterfaceMockRecorder) GetOrCreateShadow added in v0.1.0 

func (mr *MockKubernetesInterfaceMockRecorder) GetOrCreateShadow(ctx, name, options, labels, annotations, envs interface{}) *gomock.Call

GetOrCreateShadow indicates an expected call of GetOrCreateShadow.

func (*MockKubernetesInterfaceMockRecorder) GetPod added in v0.2.0 

func (mr *MockKubernetesInterfaceMockRecorder) GetPod(ctx, name, namespace interface{}) *gomock.Call

GetPod indicates an expected call of GetPod.

func (*MockKubernetesInterfaceMockRecorder) Pod added in v0.2.0 

func (mr *MockKubernetesInterfaceMockRecorder) Pod(ctx, name, namespace interface{}) *gomock.Call

Pod indicates an expected call of Pod.

func (*MockKubernetesInterfaceMockRecorder) Pods added in v0.2.0 

func (mr *MockKubernetesInterfaceMockRecorder) Pods(ctx, labels, namespace interface{}) *gomock.Call

Pods indicates an expected call of Pods.

func (*MockKubernetesInterfaceMockRecorder) RemoveConfigMap added in v0.1.0 

func (mr *MockKubernetesInterfaceMockRecorder) RemoveConfigMap(ctx, name, namespace interface{}) *gomock.Call

RemoveConfigMap indicates an expected call of RemoveConfigMap.

func (*MockKubernetesInterfaceMockRecorder) RemoveEphemeralContainer added in v0.2.2 

func (mr *MockKubernetesInterfaceMockRecorder) RemoveEphemeralContainer(ctx, containerName, podName, namespace interface{}) *gomock.Call

RemoveEphemeralContainer indicates an expected call of RemoveEphemeralContainer.

func (*MockKubernetesInterfaceMockRecorder) RemovePod added in v0.2.0 

func (mr *MockKubernetesInterfaceMockRecorder) RemovePod(ctx, name, namespace interface{}) *gomock.Call

RemovePod indicates an expected call of RemovePod.

func (*MockKubernetesInterfaceMockRecorder) RemoveService added in v0.1.0 

func (mr *MockKubernetesInterfaceMockRecorder) RemoveService(ctx, name, namespace interface{}) *gomock.Call

RemoveService indicates an expected call of RemoveService.

func (*MockKubernetesInterfaceMockRecorder) Scale added in v0.1.0 

func (mr *MockKubernetesInterfaceMockRecorder) Scale(ctx, deployment, replicas interface{}) *gomock.Call

Scale indicates an expected call of Scale.

func (*MockKubernetesInterfaceMockRecorder) ScaleTo added in v0.1.0 

func (mr *MockKubernetesInterfaceMockRecorder) ScaleTo(ctx, deployment, namespace, replicas interface{}) *gomock.Call

ScaleTo indicates an expected call of ScaleTo.

func (*MockKubernetesInterfaceMockRecorder) Service added in v0.2.2 

func (mr *MockKubernetesInterfaceMockRecorder) Service(ctx, name, namespace interface{}) *gomock.Call

Service indicates an expected call of Service.

func (*MockKubernetesInterfaceMockRecorder) ServiceHosts added in v0.1.0 

func (mr *MockKubernetesInterfaceMockRecorder) ServiceHosts(ctx, namespace interface{}) *gomock.Call

ServiceHosts indicates an expected call of ServiceHosts.

func (*MockKubernetesInterfaceMockRecorder) UpdatePod added in v0.2.0 

func (mr *MockKubernetesInterfaceMockRecorder) UpdatePod(ctx, namespace, pod interface{}) *gomock.Call

UpdatePod indicates an expected call of UpdatePod.

type PodMetaAndSpec added in v0.1.0 

type PodMetaAndSpec struct {
	Meta  *ResourceMeta
	Image string
	Envs  map[string]string
}

PodMetaAndSpec ...

type ResourceMeta added in v0.1.0 

type ResourceMeta struct {
	Name        string
	Namespace   string
	Labels      map[string]string
	Annotations map[string]string
}

ResourceMeta ...

type SSHkeyMeta added in v0.1.0 

type SSHkeyMeta struct {
	SshConfigMapName string
	PrivateKeyPath   string
}

SSHkeyMeta ...

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.