client

package
v1.7.0-alpha.3 Latest Latest
Warning

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

 Go to latest Published: Jul 12, 2021 License: Apache-2.0 Imports: 36 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateMinioClient 

func CreateMinioClient(minioServiceHost string, minioServicePort string,
	accessKey string, secretKey string, secure bool, region string) (*minio.Client, error)

func CreateMinioClientOrFatal 

func CreateMinioClientOrFatal(minioServiceHost string, minioServicePort string,
	accessKey string, secretKey string, secure bool, region string, initConnectionTimeout time.Duration) *minio.Client

func CreateMySQLConfig 

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

Types

type ArgoClient 

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

func NewArgoClientOrFatal 

func NewArgoClientOrFatal(initConnectionTimeout time.Duration, clientParams util.ClientParameters) *ArgoClient

func (*ArgoClient) Workflow 

func (argoClient *ArgoClient) Workflow(namespace string) argoprojv1alpha1.WorkflowInterface

type ArgoClientInterface 

type ArgoClientInterface interface {
	Workflow(namespace string) argoprojv1alpha1.WorkflowInterface
}

type FakeArgoClient 

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

func NewFakeArgoClient 

func NewFakeArgoClient() *FakeArgoClient

func (*FakeArgoClient) GetWorkflowCount 

func (c *FakeArgoClient) GetWorkflowCount() int

func (*FakeArgoClient) GetWorkflowKeys 

func (c *FakeArgoClient) GetWorkflowKeys() map[string]bool

func (*FakeArgoClient) IsTerminated 

func (c *FakeArgoClient) IsTerminated(name string) (bool, error)

func (*FakeArgoClient) Workflow 

func (c *FakeArgoClient) Workflow(namespace string) argoprojv1alpha1.WorkflowInterface

type FakeArgoClientWithBadWorkflow 

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

func NewFakeArgoClientWithBadWorkflow 

func NewFakeArgoClientWithBadWorkflow() *FakeArgoClientWithBadWorkflow

func (*FakeArgoClientWithBadWorkflow) Workflow 

func (c *FakeArgoClientWithBadWorkflow) Workflow(namespace string) argoprojv1alpha1.WorkflowInterface

type FakeBadPodClient 

type FakeBadPodClient struct {
	FakePodClient
}

func (FakeBadPodClient) Delete 

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

type FakeBadScheduledWorkflowClient 

type FakeBadScheduledWorkflowClient struct {
	FakeScheduledWorkflowClient
}

func (FakeBadScheduledWorkflowClient) Create 

func (FakeBadScheduledWorkflowClient) Create(ctx context.Context, workflow *v1beta1.ScheduledWorkflow) (*v1beta1.ScheduledWorkflow, error)

func (*FakeBadScheduledWorkflowClient) Delete 

func (c *FakeBadScheduledWorkflowClient) Delete(ctx context.Context, name string, options *v1.DeleteOptions) error

func (FakeBadScheduledWorkflowClient) Get 

func (FakeBadScheduledWorkflowClient) Get(ctx context.Context, name string, options v1.GetOptions) (*v1beta1.ScheduledWorkflow, error)

func (FakeBadScheduledWorkflowClient) Patch 

func (FakeBadScheduledWorkflowClient) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1beta1.ScheduledWorkflow, err error)

type FakeBadWorkflowClient 

type FakeBadWorkflowClient struct {
	FakeWorkflowClient
}

func (FakeBadWorkflowClient) Create 

func (FakeBadWorkflowClient) Create(context.Context, *v1alpha1.Workflow, v1.CreateOptions) (*v1alpha1.Workflow, error)

func (*FakeBadWorkflowClient) Delete 

func (c *FakeBadWorkflowClient) Delete(ctx context.Context, name string, options v1.DeleteOptions) error

func (FakeBadWorkflowClient) Get 

func (FakeBadWorkflowClient) Get(ctx context.Context, name string, options v1.GetOptions) (*v1alpha1.Workflow, error)

func (*FakeBadWorkflowClient) Update 

func (c *FakeBadWorkflowClient) Update(ctx context.Context, workflow *v1alpha1.Workflow, opts v1.UpdateOptions) (*v1alpha1.Workflow, 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 {
}

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 (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, name, port, 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 (FakePodClient) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error)

type FakeScheduledWorkflowClient 

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

func NewScheduledWorkflowClientFake 

func NewScheduledWorkflowClientFake() *FakeScheduledWorkflowClient

func (*FakeScheduledWorkflowClient) Create 

func (c *FakeScheduledWorkflowClient) Create(ctx context.Context, scheduledWorkflow *v1beta1.ScheduledWorkflow) (*v1beta1.ScheduledWorkflow, error)

func (*FakeScheduledWorkflowClient) Delete 

func (c *FakeScheduledWorkflowClient) Delete(ctx context.Context, name string, options *v1.DeleteOptions) error

func (*FakeScheduledWorkflowClient) DeleteCollection 

func (c *FakeScheduledWorkflowClient) DeleteCollection(ctx context.Context, options *v1.DeleteOptions, listOptions v1.ListOptions) error

func (*FakeScheduledWorkflowClient) Get 

func (c *FakeScheduledWorkflowClient) Get(ctx context.Context, name string, options v1.GetOptions) (*v1beta1.ScheduledWorkflow, error)

func (*FakeScheduledWorkflowClient) List 

func (c *FakeScheduledWorkflowClient) List(ctx context.Context, opts v1.ListOptions) (*v1beta1.ScheduledWorkflowList, error)

func (*FakeScheduledWorkflowClient) Patch 

func (c *FakeScheduledWorkflowClient) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1beta1.ScheduledWorkflow, err error)

func (*FakeScheduledWorkflowClient) Update 

func (c *FakeScheduledWorkflowClient) Update(context.Context, *v1beta1.ScheduledWorkflow) (*v1beta1.ScheduledWorkflow, error)

func (*FakeScheduledWorkflowClient) Watch 

func (c *FakeScheduledWorkflowClient) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error)

type FakeSubjectAccessReviewClient 

type FakeSubjectAccessReviewClient struct {
}

func NewFakeSubjectAccessReviewClient 

func NewFakeSubjectAccessReviewClient() FakeSubjectAccessReviewClient

func (FakeSubjectAccessReviewClient) Create 

func (FakeSubjectAccessReviewClient) Create(context.Context, *authzv1.SubjectAccessReview, v1.CreateOptions) (*authzv1.SubjectAccessReview, error)

type FakeSubjectAccessReviewClientError 

type FakeSubjectAccessReviewClientError struct {
}

func NewFakeSubjectAccessReviewClientError 

func NewFakeSubjectAccessReviewClientError() FakeSubjectAccessReviewClientError

func (FakeSubjectAccessReviewClientError) Create 

func (FakeSubjectAccessReviewClientError) Create(*authzv1.SubjectAccessReview) (*authzv1.SubjectAccessReview, error)

type FakeSubjectAccessReviewClientUnauthorized 

type FakeSubjectAccessReviewClientUnauthorized struct {
}

func NewFakeSubjectAccessReviewClientUnauthorized 

func NewFakeSubjectAccessReviewClientUnauthorized() FakeSubjectAccessReviewClientUnauthorized

func (FakeSubjectAccessReviewClientUnauthorized) Create 

func (FakeSubjectAccessReviewClientUnauthorized) Create(context.Context, *authzv1.SubjectAccessReview, v1.CreateOptions) (*authzv1.SubjectAccessReview, error)

type FakeSwfClient 

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

func NewFakeSwfClient 

func NewFakeSwfClient() *FakeSwfClient

func (*FakeSwfClient) ScheduledWorkflow 

func (c *FakeSwfClient) ScheduledWorkflow(namespace string) v1beta1.ScheduledWorkflowInterface

type FakeSwfClientWithBadWorkflow 

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

func NewFakeSwfClientWithBadWorkflow 

func NewFakeSwfClientWithBadWorkflow() *FakeSwfClientWithBadWorkflow

func (*FakeSwfClientWithBadWorkflow) ScheduledWorkflow 

func (c *FakeSwfClientWithBadWorkflow) ScheduledWorkflow(namespace string) v1beta1.ScheduledWorkflowInterface

type FakeTokenReviewClient 

type FakeTokenReviewClient struct {
}

func NewFakeTokenReviewClient 

func NewFakeTokenReviewClient() FakeTokenReviewClient

func (FakeTokenReviewClient) Create 

func (FakeTokenReviewClient) Create(context.Context, *authv1.TokenReview, v1.CreateOptions) (*authv1.TokenReview, error)

type FakeTokenReviewClientError 

type FakeTokenReviewClientError struct {
}

func NewFakeTokenReviewClientError 

func NewFakeTokenReviewClientError() FakeTokenReviewClientError

func (FakeTokenReviewClientError) Create 

func (FakeTokenReviewClientError) Create(context.Context, *authv1.TokenReview, v1.CreateOptions) (*authv1.TokenReview, error)

type FakeTokenReviewClientUnauthenticated 

type FakeTokenReviewClientUnauthenticated struct {
}

func NewFakeTokenReviewClientUnauthenticated 

func NewFakeTokenReviewClientUnauthenticated() FakeTokenReviewClientUnauthenticated

func (FakeTokenReviewClientUnauthenticated) Create 

func (FakeTokenReviewClientUnauthenticated) Create(context.Context, *authv1.TokenReview, v1.CreateOptions) (*authv1.TokenReview, error)

type FakeWorkflowClient 

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

func NewWorkflowClientFake 

func NewWorkflowClientFake() *FakeWorkflowClient

func (*FakeWorkflowClient) Create 

func (c *FakeWorkflowClient) Create(ctx context.Context, workflow *v1alpha1.Workflow, opts v1.CreateOptions) (*v1alpha1.Workflow, error)

func (*FakeWorkflowClient) Delete 

func (c *FakeWorkflowClient) Delete(ctx context.Context, name string, options v1.DeleteOptions) error

func (*FakeWorkflowClient) DeleteCollection 

func (c *FakeWorkflowClient) DeleteCollection(ctx context.Context, options v1.DeleteOptions,
	listOptions v1.ListOptions) error

func (*FakeWorkflowClient) Get 

func (c *FakeWorkflowClient) Get(ctx context.Context, name string, options v1.GetOptions) (*v1alpha1.Workflow, error)

func (*FakeWorkflowClient) List 

func (c *FakeWorkflowClient) List(ctx context.Context, opts v1.ListOptions) (*v1alpha1.WorkflowList, error)

func (*FakeWorkflowClient) Patch 

func (c *FakeWorkflowClient) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions,
	subresources ...string) (*v1alpha1.Workflow, error)

func (*FakeWorkflowClient) Update 

func (c *FakeWorkflowClient) Update(ctx context.Context, workflow *v1alpha1.Workflow, opts v1.UpdateOptions) (*v1alpha1.Workflow, error)

func (*FakeWorkflowClient) Watch 

func (c *FakeWorkflowClient) 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.

type SubjectAccessReviewInterface 

type SubjectAccessReviewInterface interface {
	Create(ctx context.Context, sar *authzv1.SubjectAccessReview, opts v1.CreateOptions) (result *authzv1.SubjectAccessReview, err error)
}

func CreateSubjectAccessReviewClientOrFatal 

func CreateSubjectAccessReviewClientOrFatal(initConnectionTimeout time.Duration, clientParams util.ClientParameters) SubjectAccessReviewInterface

CreateSubjectAccessReviewClientOrFatal creates a new SubjectAccessReview client.

type SwfClient 

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

func NewScheduledWorkflowClientOrFatal 

func NewScheduledWorkflowClientOrFatal(initConnectionTimeout time.Duration, clientParams util.ClientParameters) *SwfClient

creates a new client for the Kubernetes ScheduledWorkflow CRD.

func (*SwfClient) ScheduledWorkflow 

func (swfClient *SwfClient) ScheduledWorkflow(namespace string) v1beta1.ScheduledWorkflowInterface

type SwfClientInterface 

type SwfClientInterface interface {
	ScheduledWorkflow(namespace string) v1beta1.ScheduledWorkflowInterface
}

type TokenReviewInterface 

type TokenReviewInterface interface {
	Create(ctx context.Context, tokenReview *authv1.TokenReview, opts v1.CreateOptions) (result *authv1.TokenReview, err error)
}

func CreateTokenReviewClientOrFatal 

func CreateTokenReviewClientOrFatal(initConnectionTimeout time.Duration, clientParams util.ClientParameters) TokenReviewInterface

CreateTokenReviewClientOrFatal creates a new TokenReview client.

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.