cluster

package
v0.1.0-rc2 Latest Latest
Warning

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

 Go to latest Published: Jul 31, 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) ClusterCidrs added in v0.1.0 

func (k *Kubernetes) ClusterCidrs(namespace string, connectOptions *options.ConnectOptions) (cidrs []string, err error)

ClusterCidrs get cluster Cidrs

func (*Kubernetes) CreateService added in v0.1.0 

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

CreateService create kubernetes service

func (*Kubernetes) DecreaseRef added in v0.1.0 

func (k *Kubernetes) DecreaseRef(namespace string, app string) (cleanup bool, err error)

DecreaseRef ...

func (*Kubernetes) Deployment 

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

Deployment get deployment

func (*Kubernetes) GetAllExistingShadowDeployments added in v0.1.0 

func (k *Kubernetes) GetAllExistingShadowDeployments(namespace string) ([]appv1.Deployment, error)

GetAllExistingShadowDeployments fetch all shadow deployments

func (*Kubernetes) GetDeployment added in v0.1.0 

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

GetDeployment ...

func (*Kubernetes) GetOrCreateShadow added in v0.1.0 

func (k *Kubernetes) GetOrCreateShadow(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) RemoveConfigMap added in v0.1.0 

func (k *Kubernetes) RemoveConfigMap(name, namespace string) (err error)

RemoveConfigMap remove ConfigMap instance

func (*Kubernetes) RemoveDeployment added in v0.1.0 

func (k *Kubernetes) RemoveDeployment(name, namespace string) (err error)

RemoveDeployment remove deployment instances

func (*Kubernetes) RemoveService added in v0.1.0 

func (k *Kubernetes) RemoveService(name, namespace string) (err error)

RemoveService remove service

func (*Kubernetes) Scale 

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

Scale scale deployment to

func (*Kubernetes) ScaleTo added in v0.1.0 

func (k *Kubernetes) ScaleTo(deployment, namespace string, replicas *int32) (err error)

ScaleTo scale deployment to

func (*Kubernetes) ServiceHosts 

func (k *Kubernetes) ServiceHosts(namespace string) (hosts map[string]string)

ServiceHosts get service dns map

func (*Kubernetes) UpdateDeployment added in v0.1.0 

func (k *Kubernetes) UpdateDeployment(namespace string, deployment *appv1.Deployment) (*appv1.Deployment, error)

UpdateDeployment ...

type KubernetesInterface 

type KubernetesInterface interface {
	RemoveDeployment(name, namespace string) (err error)
	RemoveConfigMap(name, namespace string) (err error)
	RemoveService(name, namespace string) (err error)
	Deployment(name, namespace string) (deployment *appV1.Deployment, err error)
	Scale(deployment *appV1.Deployment, replicas *int32) (err error)
	ScaleTo(deployment, namespace string, replicas *int32) (err error)
	ServiceHosts(namespace string) (hosts map[string]string)
	ClusterCidrs(namespace string, connectOptions *options.ConnectOptions) (cidrs []string, err error)
	GetOrCreateShadow(name string, options *options.DaemonOptions, labels, annotations, envs map[string]string) (podIP, podName, sshcm string, credential *util.SSHCredential, err error)
	GetAllExistingShadowDeployments(namespace string) (list []appV1.Deployment, err error)
	CreateService(name, namespace string, external bool, port int, labels map[string]string) (*coreV1.Service, error)
	GetDeployment(name string, namespace string) (*appV1.Deployment, error)
	UpdateDeployment(namespace string, deployment *appV1.Deployment) (*appV1.Deployment, error)
	DecreaseRef(namespace string, deployment string) (cleanup bool, err error)
}

KubernetesInterface kubernetes interface

func Create 

func Create(kubeConfig string) (kubernetes KubernetesInterface, err error)

Create kubernetes instance

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) ClusterCidrs added in v0.1.0 

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

ClusterCidrs mocks base method.

func (*MockKubernetesInterface) CreateService added in v0.1.0 

func (m *MockKubernetesInterface) CreateService(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(namespace, deployment string) (bool, error)

DecreaseRef mocks base method.

func (*MockKubernetesInterface) Deployment added in v0.1.0 

func (m *MockKubernetesInterface) Deployment(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) GetAllExistingShadowDeployments added in v0.1.0 

func (m *MockKubernetesInterface) GetAllExistingShadowDeployments(namespace string) ([]v1.Deployment, error)

GetAllExistingShadowDeployments mocks base method.

func (*MockKubernetesInterface) GetDeployment added in v0.1.0 

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

GetDeployment mocks base method.

func (*MockKubernetesInterface) GetOrCreateShadow added in v0.1.0 

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

GetOrCreateShadow mocks base method.

func (*MockKubernetesInterface) RemoveConfigMap added in v0.1.0 

func (m *MockKubernetesInterface) RemoveConfigMap(name, namespace string) error

RemoveConfigMap mocks base method.

func (*MockKubernetesInterface) RemoveDeployment added in v0.1.0 

func (m *MockKubernetesInterface) RemoveDeployment(name, namespace string) error

RemoveDeployment mocks base method.

func (*MockKubernetesInterface) RemoveService added in v0.1.0 

func (m *MockKubernetesInterface) RemoveService(name, namespace string) error

RemoveService mocks base method.

func (*MockKubernetesInterface) Scale added in v0.1.0 

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

Scale mocks base method.

func (*MockKubernetesInterface) ScaleTo added in v0.1.0 

func (m *MockKubernetesInterface) ScaleTo(deployment, namespace string, replicas *int32) error

ScaleTo mocks base method.

func (*MockKubernetesInterface) ServiceHosts added in v0.1.0 

func (m *MockKubernetesInterface) ServiceHosts(namespace string) map[string]string

ServiceHosts mocks base method.

func (*MockKubernetesInterface) UpdateDeployment added in v0.1.0 

func (m *MockKubernetesInterface) UpdateDeployment(namespace string, deployment *v1.Deployment) (*v1.Deployment, error)

UpdateDeployment 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) ClusterCidrs added in v0.1.0 

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

ClusterCidrs indicates an expected call of ClusterCidrs.

func (*MockKubernetesInterfaceMockRecorder) CreateService added in v0.1.0 

func (mr *MockKubernetesInterfaceMockRecorder) CreateService(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(namespace, deployment interface{}) *gomock.Call

DecreaseRef indicates an expected call of DecreaseRef.

func (*MockKubernetesInterfaceMockRecorder) Deployment added in v0.1.0 

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

Deployment indicates an expected call of Deployment.

func (*MockKubernetesInterfaceMockRecorder) GetAllExistingShadowDeployments added in v0.1.0 

func (mr *MockKubernetesInterfaceMockRecorder) GetAllExistingShadowDeployments(namespace interface{}) *gomock.Call

GetAllExistingShadowDeployments indicates an expected call of GetAllExistingShadowDeployments.

func (*MockKubernetesInterfaceMockRecorder) GetDeployment added in v0.1.0 

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

GetDeployment indicates an expected call of GetDeployment.

func (*MockKubernetesInterfaceMockRecorder) GetOrCreateShadow added in v0.1.0 

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

GetOrCreateShadow indicates an expected call of GetOrCreateShadow.

func (*MockKubernetesInterfaceMockRecorder) RemoveConfigMap added in v0.1.0 

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

RemoveConfigMap indicates an expected call of RemoveConfigMap.

func (*MockKubernetesInterfaceMockRecorder) RemoveDeployment added in v0.1.0 

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

RemoveDeployment indicates an expected call of RemoveDeployment.

func (*MockKubernetesInterfaceMockRecorder) RemoveService added in v0.1.0 

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

RemoveService indicates an expected call of RemoveService.

func (*MockKubernetesInterfaceMockRecorder) Scale added in v0.1.0 

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

Scale indicates an expected call of Scale.

func (*MockKubernetesInterfaceMockRecorder) ScaleTo added in v0.1.0 

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

ScaleTo indicates an expected call of ScaleTo.

func (*MockKubernetesInterfaceMockRecorder) ServiceHosts added in v0.1.0 

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

ServiceHosts indicates an expected call of ServiceHosts.

func (*MockKubernetesInterfaceMockRecorder) UpdateDeployment added in v0.1.0 

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

UpdateDeployment indicates an expected call of UpdateDeployment.

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 {
	Sshcm          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.