client

Documentation

Index

• func CreateMySQLConfig(user, password string, mysqlServiceHost string, mysqlServicePort string, ...) *mysql.Config
• type FakeBadPodClient
  • func (FakeBadPodClient) Delete(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(binding *corev1.Binding) error
  • func (FakePodClient) Create(*corev1.Pod) (*corev1.Pod, error)
  • func (FakePodClient) Delete(name string, options *v1.DeleteOptions) error
  • func (FakePodClient) DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error
  • func (FakePodClient) Evict(eviction *v1beta1.Eviction) error
  • func (FakePodClient) Get(name string, options v1.GetOptions) (*corev1.Pod, error)
  • func (FakePodClient) GetLogs(name string, opts *corev1.PodLogOptions) *rest.Request
  • func (FakePodClient) List(opts v1.ListOptions) (*corev1.PodList, error)
  • func (f FakePodClient) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *corev1.Pod, err error)
  • func (FakePodClient) Update(*corev1.Pod) (*corev1.Pod, error)
  • func (FakePodClient) UpdateStatus(*corev1.Pod) (*corev1.Pod, error)
  • func (f FakePodClient) Watch(opts v1.ListOptions) (watch.Interface, error)
• type KubernetesCore
  • func (c *KubernetesCore) PodClient(namespace string) v1.PodInterface
• type KubernetesCoreInterface
  • func CreateKubernetesCoreOrFatal(initConnectionTimeout time.Duration) 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(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(binding *corev1.Binding) error

func (FakePodClient) Create

func (FakePodClient) Create(*corev1.Pod) (*corev1.Pod, error)

func (FakePodClient) Delete

func (FakePodClient) Delete(name string, options *v1.DeleteOptions) error

func (FakePodClient) DeleteCollection

func (FakePodClient) DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error

func (FakePodClient) Evict

func (FakePodClient) Evict(eviction *v1beta1.Eviction) error

func (FakePodClient) Get

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

func (FakePodClient) GetLogs

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

func (FakePodClient) List

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

func (FakePodClient) Patch

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

func (FakePodClient) Update

func (FakePodClient) Update(*corev1.Pod) (*corev1.Pod, error)

func (FakePodClient) UpdateStatus

func (FakePodClient) UpdateStatus(*corev1.Pod) (*corev1.Pod, error)

func (FakePodClient) Watch

func (f FakePodClient) Watch(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) KubernetesCoreInterface

CreateKubernetesCoreOrFatal creates a new client for the Kubernetes pod.