client

package
v0.0.0-...-4f670de Latest Latest
Warning

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

 Go to latest Published: May 14, 2020 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	HTTP_TIMEOUT_SECONDS = 10
)

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) *ArgoClient

func (*ArgoClient) Workflow 

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

type ArgoClientInterface 

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

type Binding 

type Binding struct {
	User              User
	ReferredNamespace string
	RoleRef           RoleRef
}

type Bindings 

type Bindings struct {
	Bindings []Binding
}

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(name string, options *v1.DeleteOptions) error

type FakeBadScheduledWorkflowClient 

type FakeBadScheduledWorkflowClient struct {
	FakeScheduledWorkflowClient
}

func (FakeBadScheduledWorkflowClient) Create 

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

func (FakeBadScheduledWorkflowClient) Get 

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

func (FakeBadScheduledWorkflowClient) Patch 

func (FakeBadScheduledWorkflowClient) Patch(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(*v1alpha1.Workflow) (*v1alpha1.Workflow, error)

func (*FakeBadWorkflowClient) Delete 

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

func (FakeBadWorkflowClient) Get 

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

func (*FakeBadWorkflowClient) Update 

func (c *FakeBadWorkflowClient) Update(workflow *v1alpha1.Workflow) (*v1alpha1.Workflow, error)

type FakeKFAMClientAuthorized 

type FakeKFAMClientAuthorized struct {
}

func NewFakeKFAMClientAuthorized 

func NewFakeKFAMClientAuthorized() *FakeKFAMClientAuthorized

func (*FakeKFAMClientAuthorized) IsAuthorized 

func (c *FakeKFAMClientAuthorized) IsAuthorized(userIdentity string, namespace string) (bool, error)

type FakeKFAMClientUnauthorized 

type FakeKFAMClientUnauthorized struct {
}

func NewFakeKFAMClientUnauthorized 

func NewFakeKFAMClientUnauthorized() *FakeKFAMClientUnauthorized

func (*FakeKFAMClientUnauthorized) IsAuthorized 

func (c *FakeKFAMClientUnauthorized) IsAuthorized(userIdentity string, namespace string) (bool, 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(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 (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 (FakePodClient) Watch(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(scheduledWorkflow *v1beta1.ScheduledWorkflow) (*v1beta1.ScheduledWorkflow, error)

func (*FakeScheduledWorkflowClient) Delete 

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

func (*FakeScheduledWorkflowClient) DeleteCollection 

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

func (*FakeScheduledWorkflowClient) Get 

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

func (*FakeScheduledWorkflowClient) List 

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

func (*FakeScheduledWorkflowClient) Patch 

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

func (*FakeScheduledWorkflowClient) Update 

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

func (*FakeScheduledWorkflowClient) Watch 

func (c *FakeScheduledWorkflowClient) Watch(opts v1.ListOptions) (watch.Interface, 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 FakeWorkflowClient 

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

func NewWorkflowClientFake 

func NewWorkflowClientFake() *FakeWorkflowClient

func (*FakeWorkflowClient) Create 

func (c *FakeWorkflowClient) Create(workflow *v1alpha1.Workflow) (*v1alpha1.Workflow, error)

func (*FakeWorkflowClient) Delete 

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

func (*FakeWorkflowClient) DeleteCollection 

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

func (*FakeWorkflowClient) Get 

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

func (*FakeWorkflowClient) List 

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

func (*FakeWorkflowClient) Patch 

func (c *FakeWorkflowClient) Patch(name string, pt types.PatchType, data []byte,
	subresources ...string) (*v1alpha1.Workflow, error)

func (*FakeWorkflowClient) Update 

func (c *FakeWorkflowClient) Update(workflow *v1alpha1.Workflow) (*v1alpha1.Workflow, error)

func (*FakeWorkflowClient) Watch 

func (c *FakeWorkflowClient) Watch(opts v1.ListOptions) (watch.Interface, error)

type KFAMClient 

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

func NewKFAMClient 

func NewKFAMClient(kfamServiceHost string, kfamServicePort string) *KFAMClient

func (*KFAMClient) IsAuthorized 

func (c *KFAMClient) IsAuthorized(userIdentity string, namespace string) (bool, error)

type KFAMClientInterface 

type KFAMClientInterface interface {
	IsAuthorized(userIdentity string, namespace string) (bool, 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.

type RoleRef 

type RoleRef struct {
	ApiGroup string
	Kind     string
	Name     string
}

type SwfClient 

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

func NewScheduledWorkflowClientOrFatal 

func NewScheduledWorkflowClientOrFatal(initConnectionTimeout time.Duration) *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 User 

type User struct {
	Kind string
	Name string
}

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.