client

Documentation

Index

• func CreateMySQLConfig(user, password string, mysqlServiceHost string, mysqlServicePort string, ...) *mysql.Config
• type FakeBadPodClient
  • func (FakeBadPodClient) Delete(ctx context.Context, name string, options v1.DeleteOptions) error
• type FakeKuberneteCoreClient
  • func NewFakeKuberneteCoresClient() *FakeKuberneteCoreClient
  • func (c *FakeKuberneteCoreClient) PodClient(namespace string) v1.PodInterface
• type FakeKubernetesCoreClientWithBadPodClient
  • func NewFakeKubernetesCoreClientWithBadPodClient() *FakeKubernetesCoreClientWithBadPodClient
  • func (c *FakeKubernetesCoreClientWithBadPodClient) PodClient(namespace string) v1.PodInterface
• type FakePodClient
  • func (FakePodClient) Bind(ctx context.Context, binding *corev1.Binding, opts v1.CreateOptions) error
  • func (FakePodClient) Create(context.Context, *corev1.Pod, v1.CreateOptions) (*corev1.Pod, error)
  • func (FakePodClient) Delete(ctx context.Context, name string, options v1.DeleteOptions) error
  • func (FakePodClient) DeleteCollection(ctx context.Context, options v1.DeleteOptions, listOptions v1.ListOptions) error
  • func (FakePodClient) Evict(ctx context.Context, eviction *v1beta1.Eviction) error
  • func (FakePodClient) Get(ctx context.Context, name string, options v1.GetOptions) (*corev1.Pod, error)
  • func (FakePodClient) GetEphemeralContainers(context.Context, string, v1.GetOptions) (*corev1.EphemeralContainers, error)
  • func (FakePodClient) GetLogs(name string, opts *corev1.PodLogOptions) *rest.Request
  • func (FakePodClient) List(ctx context.Context, opts v1.ListOptions) (*corev1.PodList, error)
  • func (f FakePodClient) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, ...) (result *corev1.Pod, err error)
  • func (FakePodClient) ProxyGet(scheme string, name string, port string, path string, params map[string]string) rest.ResponseWrapper
  • func (FakePodClient) Update(context.Context, *corev1.Pod, v1.UpdateOptions) (*corev1.Pod, error)
  • func (FakePodClient) UpdateEphemeralContainers(context.Context, string, *corev1.EphemeralContainers, v1.UpdateOptions) (*corev1.EphemeralContainers, error)
  • func (FakePodClient) UpdateStatus(context.Context, *corev1.Pod, v1.UpdateOptions) (*corev1.Pod, error)
  • func (f FakePodClient) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error)
• type KubernetesCore
  • func (c *KubernetesCore) PodClient(namespace string) v1.PodInterface
• type KubernetesCoreInterface
  • func CreateKubernetesCoreOrFatal(initConnectionTimeout time.Duration, clientParams util.ClientParameters) KubernetesCoreInterface

Functions

func CreateMySQLConfig

func CreateMySQLConfig(user, password string, mysqlServiceHost string,
	mysqlServicePort string, dbName string, mysqlGroupConcatMaxLen string, mysqlExtraParams map[string]string) *mysql.Config

Types

type FakeBadPodClient

type FakeBadPodClient struct {
	FakePodClient
}

func (FakeBadPodClient) Delete

func (FakeBadPodClient) Delete(ctx context.Context, name string, options v1.DeleteOptions) error

type FakeKuberneteCoreClient

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

func NewFakeKuberneteCoresClient

func NewFakeKuberneteCoresClient() *FakeKuberneteCoreClient

func (*FakeKuberneteCoreClient) PodClient

func (c *FakeKuberneteCoreClient) PodClient(namespace string) v1.PodInterface

type FakeKubernetesCoreClientWithBadPodClient

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

func NewFakeKubernetesCoreClientWithBadPodClient

func NewFakeKubernetesCoreClientWithBadPodClient() *FakeKubernetesCoreClientWithBadPodClient

func (*FakeKubernetesCoreClientWithBadPodClient) PodClient

func (c *FakeKubernetesCoreClientWithBadPodClient) PodClient(namespace string) v1.PodInterface

type FakePodClient

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

func (FakePodClient) Bind

func (FakePodClient) Bind(ctx context.Context, binding *corev1.Binding, opts v1.CreateOptions) error

func (FakePodClient) Create

func (FakePodClient) Create(context.Context, *corev1.Pod, v1.CreateOptions) (*corev1.Pod, error)

func (FakePodClient) Delete

func (FakePodClient) Delete(ctx context.Context, name string, options v1.DeleteOptions) error

func (FakePodClient) DeleteCollection

func (FakePodClient) DeleteCollection(ctx context.Context, options v1.DeleteOptions, listOptions v1.ListOptions) error

func (FakePodClient) Evict

func (FakePodClient) Evict(ctx context.Context, eviction *v1beta1.Eviction) error

func (FakePodClient) Get

func (FakePodClient) Get(ctx context.Context, name string, options v1.GetOptions) (*corev1.Pod, error)

func (FakePodClient) GetEphemeralContainers

func (FakePodClient) GetEphemeralContainers(context.Context, string, v1.GetOptions) (*corev1.EphemeralContainers, error)

func (FakePodClient) GetLogs

func (FakePodClient) GetLogs(name string, opts *corev1.PodLogOptions) *rest.Request

func (FakePodClient) List

func (FakePodClient) List(ctx context.Context, opts v1.ListOptions) (*corev1.PodList, error)

func (FakePodClient) Patch

func (f FakePodClient) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *corev1.Pod, err error)

func (FakePodClient) ProxyGet

func (FakePodClient) ProxyGet(scheme string, name string, port string, path string, params map[string]string) rest.ResponseWrapper

func (FakePodClient) Update

func (FakePodClient) Update(context.Context, *corev1.Pod, v1.UpdateOptions) (*corev1.Pod, error)

func (FakePodClient) UpdateEphemeralContainers

func (FakePodClient) UpdateEphemeralContainers(context.Context, string, *corev1.EphemeralContainers, v1.UpdateOptions) (*corev1.EphemeralContainers, error)

func (FakePodClient) UpdateStatus

func (FakePodClient) UpdateStatus(context.Context, *corev1.Pod, v1.UpdateOptions) (*corev1.Pod, error)

func (FakePodClient) Watch

func (f FakePodClient) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error)

type KubernetesCore

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

func (*KubernetesCore) PodClient

func (c *KubernetesCore) PodClient(namespace string) v1.PodInterface

type KubernetesCoreInterface

type KubernetesCoreInterface interface {
	PodClient(namespace string) v1.PodInterface
}

func CreateKubernetesCoreOrFatal

func CreateKubernetesCoreOrFatal(initConnectionTimeout time.Duration, clientParams util.ClientParameters) KubernetesCoreInterface

CreateKubernetesCoreOrFatal creates a new client for the Kubernetes pod.