cluster

package
v0.2.5 Latest Latest
Warning

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

 Go to latest Published: Dec 29, 2021 License: MIT Imports: 30 Imported by: 0

Documentation

Overview

Package cluster is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateRouterPod added in v0.2.3 

func CreateRouterPod(ctx context.Context, k KubernetesInterface, name string, options *options.DaemonOptions,
	labels, annotations map[string]string) error

func GetKtResources added in v0.2.3 

func GetKtResources(ctx context.Context, k KubernetesInterface, namespace string) ([]coreV1.Pod, []coreV1.ConfigMap, []coreV1.Service, error)

GetKtResources fetch all kt pods and deployments

func GetOrCreateShadow added in v0.2.3 

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

GetOrCreateShadow create shadow

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, name string,
	options *options.DaemonOptions, envs map[string]string) (string, 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) CreateConfigMapWithSshKey added in v0.2.3 

func (k *Kubernetes) CreateConfigMapWithSshKey(ctx context.Context, labels map[string]string, sshcm string, namespace string,
	generator *util.SSHGenerator) (configMap *coreV1.ConfigMap, err error)

func (*Kubernetes) CreatePod added in v0.2.3 

func (k *Kubernetes) CreatePod(ctx context.Context, metaAndSpec *PodMetaAndSpec, options *options.DaemonOptions) error

CreatePod create pod

func (*Kubernetes) CreateService added in v0.1.0 

func (k *Kubernetes) CreateService(ctx context.Context, metaAndSpec *SvcMetaAndSpec) (*coreV1.Service, error)

CreateService create kubernetes service

func (*Kubernetes) CreateShadowPod added in v0.2.3 

func (k *Kubernetes) CreateShadowPod(ctx context.Context, metaAndSpec *PodMetaAndSpec, sshcm string, options *options.DaemonOptions) error

CreateShadowPod create shadow pod

func (*Kubernetes) DecreaseRef added in v0.1.0 

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

DecreaseRef decrease pod ref count by 1

func (*Kubernetes) ExecInPod added in v0.2.3 

func (k *Kubernetes) ExecInPod(containerName, podName, namespace string, opts options.RuntimeOptions, cmd ...string) (string, string, error)

func (*Kubernetes) GetConfigMap added in v0.2.3 

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

GetConfigMap get configmap

func (*Kubernetes) GetConfigMapsByLabel added in v0.2.5 

func (k *Kubernetes) GetConfigMapsByLabel(ctx context.Context, labels map[string]string, namespace string) (pods *coreV1.ConfigMapList, err error)

GetConfigMapsByLabel get deployments by label

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) GetDeploymentsByLabel added in v0.2.3 

func (k *Kubernetes) GetDeploymentsByLabel(ctx context.Context, labels map[string]string, namespace string) (pods *appV1.DeploymentList, err error)

GetDeploymentsByLabel get deployments by label

func (*Kubernetes) GetPod added in v0.2.0 

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

GetPod ...

func (*Kubernetes) GetPodsByLabel added in v0.2.3 

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

GetPodsByLabel get pods by label

func (*Kubernetes) GetService added in v0.2.3 

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

GetService get service

func (*Kubernetes) GetServiceHosts added in v0.2.3 

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

GetServiceHosts get service dns map

func (*Kubernetes) GetServices added in v0.2.3 

func (k *Kubernetes) GetServices(ctx context.Context, matchLabels map[string]string, namespace string) ([]coreV1.Service, error)

GetServices get pods by label

func (*Kubernetes) GetServicesByLabel added in v0.2.4 

func (k *Kubernetes) GetServicesByLabel(ctx context.Context, labels map[string]string, namespace string) (svcs *coreV1.ServiceList, err error)

GetServicesByLabel get services by label

func (*Kubernetes) IncreaseRef added in v0.2.3 

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

IncreaseRef increase pod ref count by 1

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, _, 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) ScaleTo added in v0.1.0 

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

ScaleTo scale deployment to

func (*Kubernetes) UpdateDeployment added in v0.1.0 

func (k *Kubernetes) UpdateDeployment(ctx context.Context, deployment *appV1.Deployment) (*appV1.Deployment, error)

UpdateDeployment ...

func (*Kubernetes) UpdatePod added in v0.2.0 

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

UpdatePod ...

func (*Kubernetes) UpdateService added in v0.2.3 

func (k *Kubernetes) UpdateService(ctx context.Context, svc *coreV1.Service) (*coreV1.Service, error)

UpdateService ...

func (*Kubernetes) WaitPodReady added in v0.2.3 

func (k *Kubernetes) WaitPodReady(name, namespace string) (pod *coreV1.Pod, err error)

WaitPodReady ...

func (*Kubernetes) WatchService added in v0.2.5 

func (k *Kubernetes) WatchService(name, namespace string, f func(*coreV1.Service))

WatchService ...

type KubernetesInterface 

type KubernetesInterface interface {
	CreatePod(ctx context.Context, metaAndSpec *PodMetaAndSpec, options *options.DaemonOptions) error
	CreateShadowPod(ctx context.Context, metaAndSpec *PodMetaAndSpec, sshcm string, options *options.DaemonOptions) error
	GetPod(ctx context.Context, name string, namespace string) (*coreV1.Pod, error)
	GetPodsByLabel(ctx context.Context, labels map[string]string, namespace string) (*coreV1.PodList, error)
	UpdatePod(ctx context.Context, pod *coreV1.Pod) (*coreV1.Pod, error)
	WaitPodReady(name, namespace string) (*coreV1.Pod, error)
	IncreaseRef(ctx context.Context, name, namespace string) error
	DecreaseRef(ctx context.Context, name, namespace string) (bool, error)
	AddEphemeralContainer(ctx context.Context, containerName, podName string, options *options.DaemonOptions, envs map[string]string) (string, error)
	RemoveEphemeralContainer(ctx context.Context, containerName, podName string, namespace string) error
	ExecInPod(containerName, podName, namespace string, opts options.RuntimeOptions, cmd ...string) (string, string, error)
	RemovePod(ctx context.Context, name, namespace string) error

	GetDeployment(ctx context.Context, name string, namespace string) (*appV1.Deployment, error)
	GetDeploymentsByLabel(ctx context.Context, labels map[string]string, namespace string) (*appV1.DeploymentList, error)
	UpdateDeployment(ctx context.Context, deployment *appV1.Deployment) (*appV1.Deployment, error)
	ScaleTo(ctx context.Context, deployment, namespace string, replicas *int32) (err error)

	CreateService(ctx context.Context, metaAndSpec *SvcMetaAndSpec) (*coreV1.Service, error)
	UpdateService(ctx context.Context, svc *coreV1.Service) (*coreV1.Service, error)
	GetService(ctx context.Context, name, namespace string) (*coreV1.Service, error)
	GetServices(ctx context.Context, matchLabels map[string]string, namespace string) ([]coreV1.Service, error)
	GetServiceHosts(ctx context.Context, namespace string) (hosts map[string]string)
	GetServicesByLabel(ctx context.Context, labels map[string]string, namespace string) (*coreV1.ServiceList, error)
	RemoveService(ctx context.Context, name, namespace string) (err error)
	WatchService(name, namespace string, f func(*coreV1.Service))

	CreateConfigMapWithSshKey(ctx context.Context, labels map[string]string, sshcm string, namespace string,
		generator *util.SSHGenerator) (configMap *coreV1.ConfigMap, err error)
	GetConfigMap(ctx context.Context, name, namespace string) (*coreV1.ConfigMap, error)
	GetConfigMapsByLabel(ctx context.Context, labels map[string]string, namespace string) (*coreV1.ConfigMapList, error)
	RemoveConfigMap(ctx context.Context, name, namespace string) (err error)

	ClusterCidrs(ctx context.Context, namespace string, connectOptions *options.ConnectOptions) (cidrs []string, err error)
}

KubernetesInterface kubernetes interface

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) CreateConfigMapWithSshKey added in v0.2.3 

func (m *MockKubernetesInterface) CreateConfigMapWithSshKey(ctx context.Context, labels map[string]string, sshcm, namespace string, generator *util.SSHGenerator) (*v10.ConfigMap, error)

CreateConfigMapWithSshKey mocks base method.

func (*MockKubernetesInterface) CreatePod added in v0.2.3 

func (m *MockKubernetesInterface) CreatePod(ctx context.Context, metaAndSpec *PodMetaAndSpec, options *options.DaemonOptions) error

CreatePod mocks base method.

func (*MockKubernetesInterface) CreateService added in v0.1.0 

func (m *MockKubernetesInterface) CreateService(ctx context.Context, metaAndSpec *SvcMetaAndSpec) (*v10.Service, error)

CreateService mocks base method.

func (*MockKubernetesInterface) CreateShadowPod added in v0.2.3 

func (m *MockKubernetesInterface) CreateShadowPod(ctx context.Context, metaAndSpec *PodMetaAndSpec, sshcm string, options *options.DaemonOptions) error

CreateShadowPod mocks base method.

func (*MockKubernetesInterface) DecreaseRef added in v0.1.0 

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

DecreaseRef 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) ExecInPod added in v0.2.3 

func (m *MockKubernetesInterface) ExecInPod(containerName, podName, namespace string, opts options.RuntimeOptions, cmd ...string) (string, string, error)

ExecInPod mocks base method.

func (*MockKubernetesInterface) GetConfigMap added in v0.2.3 

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

GetConfigMap 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) GetDeploymentsByLabel added in v0.2.3 

func (m *MockKubernetesInterface) GetDeploymentsByLabel(ctx context.Context, labels map[string]string, namespace string) (*v1.DeploymentList, error)

GetDeploymentsByLabel 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) GetPodsByLabel added in v0.2.3 

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

GetPodsByLabel mocks base method.

func (*MockKubernetesInterface) GetService added in v0.2.3 

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

GetService mocks base method.

func (*MockKubernetesInterface) GetServiceHosts added in v0.2.3 

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

GetServiceHosts mocks base method.

func (*MockKubernetesInterface) GetServices added in v0.2.3 

func (m *MockKubernetesInterface) GetServices(ctx context.Context, matchLabels map[string]string, namespace string) ([]v10.Service, error)

GetServices mocks base method.

func (*MockKubernetesInterface) GetServicesByLabel added in v0.2.4 

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

GetServicesByLabel mocks base method.

func (*MockKubernetesInterface) IncreaseRef added in v0.2.3 

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

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

func (m *MockKubernetesInterface) UpdateDeployment(ctx context.Context, deployment *v1.Deployment) (*v1.Deployment, error)

UpdateDeployment mocks base method.

func (*MockKubernetesInterface) UpdatePod added in v0.2.0 

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

UpdatePod mocks base method.

func (*MockKubernetesInterface) UpdateService added in v0.2.3 

func (m *MockKubernetesInterface) UpdateService(ctx context.Context, svc *v10.Service) (*v10.Service, error)

UpdateService mocks base method.

func (*MockKubernetesInterface) WaitPodReady added in v0.2.3 

func (m *MockKubernetesInterface) WaitPodReady(name, namespace string) (*v10.Pod, error)

WaitPodReady 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) CreateConfigMapWithSshKey added in v0.2.3 

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

CreateConfigMapWithSshKey indicates an expected call of CreateConfigMapWithSshKey.

func (*MockKubernetesInterfaceMockRecorder) CreatePod added in v0.2.3 

func (mr *MockKubernetesInterfaceMockRecorder) CreatePod(ctx, metaAndSpec, options interface{}) *gomock.Call

CreatePod indicates an expected call of CreatePod.

func (*MockKubernetesInterfaceMockRecorder) CreateService added in v0.1.0 

func (mr *MockKubernetesInterfaceMockRecorder) CreateService(ctx, metaAndSpec interface{}) *gomock.Call

CreateService indicates an expected call of CreateService.

func (*MockKubernetesInterfaceMockRecorder) CreateShadowPod added in v0.2.3 

func (mr *MockKubernetesInterfaceMockRecorder) CreateShadowPod(ctx, metaAndSpec, sshcm, options interface{}) *gomock.Call

CreateShadowPod indicates an expected call of CreateShadowPod.

func (*MockKubernetesInterfaceMockRecorder) DecreaseRef added in v0.1.0 

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

DecreaseRef indicates an expected call of DecreaseRef.

func (*MockKubernetesInterfaceMockRecorder) ExecInPod added in v0.2.3 

func (mr *MockKubernetesInterfaceMockRecorder) ExecInPod(containerName, podName, namespace, opts interface{}, cmd ...interface{}) *gomock.Call

ExecInPod indicates an expected call of ExecInPod.

func (*MockKubernetesInterfaceMockRecorder) GetConfigMap added in v0.2.3 

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

GetConfigMap indicates an expected call of GetConfigMap.

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) GetDeploymentsByLabel added in v0.2.3 

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

GetDeploymentsByLabel indicates an expected call of GetDeploymentsByLabel.

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) GetPodsByLabel added in v0.2.3 

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

GetPodsByLabel indicates an expected call of GetPodsByLabel.

func (*MockKubernetesInterfaceMockRecorder) GetService added in v0.2.3 

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

GetService indicates an expected call of GetService.

func (*MockKubernetesInterfaceMockRecorder) GetServiceHosts added in v0.2.3 

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

GetServiceHosts indicates an expected call of GetServiceHosts.

func (*MockKubernetesInterfaceMockRecorder) GetServices added in v0.2.3 

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

GetServices indicates an expected call of GetServices.

func (*MockKubernetesInterfaceMockRecorder) GetServicesByLabel added in v0.2.4 

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

GetServicesByLabel indicates an expected call of GetServicesByLabel.

func (*MockKubernetesInterfaceMockRecorder) IncreaseRef added in v0.2.3 

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

IncreaseRef indicates an expected call of IncreaseRef.

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

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

UpdateDeployment indicates an expected call of UpdateDeployment.

func (*MockKubernetesInterfaceMockRecorder) UpdatePod added in v0.2.0 

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

UpdatePod indicates an expected call of UpdatePod.

func (*MockKubernetesInterfaceMockRecorder) UpdateService added in v0.2.3 

func (mr *MockKubernetesInterfaceMockRecorder) UpdateService(ctx, svc interface{}) *gomock.Call

UpdateService indicates an expected call of UpdateService.

func (*MockKubernetesInterfaceMockRecorder) WaitPodReady added in v0.2.3 

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

WaitPodReady indicates an expected call of WaitPodReady.

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

type SvcMetaAndSpec added in v0.2.3 

type SvcMetaAndSpec struct {
	Meta      *ResourceMeta
	External  bool
	Ports     map[int]int
	Selectors map[string]string
}

SvcMetaAndSpec ...

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.