client

Documentation

Index

• type KubeClient
  • func NewKubeClient(kubeClientSet kubernetes.Interface, recorder record.EventRecorder) *KubeClient
  • func (k *KubeClient) RecordSyncFailure(swf *swfapi.ScheduledWorkflow, message string)
  • func (k *KubeClient) RecordSyncSuccess(swf *swfapi.ScheduledWorkflow, message string)
• type ScheduledWorkflowClient
  • func NewScheduledWorkflowClient(clientSet swfclientset.Interface, informer v1beta1.ScheduledWorkflowInformer) *ScheduledWorkflowClient
  • func (p *ScheduledWorkflowClient) AddEventHandler(funcs *cache.ResourceEventHandlerFuncs)
  • func (p *ScheduledWorkflowClient) Get(namespace string, name string) (*util.ScheduledWorkflow, error)
  • func (p *ScheduledWorkflowClient) HasSynced() func() bool
  • func (p *ScheduledWorkflowClient) Update(ctx context.Context, namespace string, schedule *util.ScheduledWorkflow) error
• type WorkflowClient
  • func NewWorkflowClient(clientSet workflowclientset.Interface, informer v1alpha1.WorkflowInformer) *WorkflowClient
  • func (p *WorkflowClient) AddEventHandler(funcs *cache.ResourceEventHandlerFuncs)
  • func (p *WorkflowClient) Create(ctx context.Context, namespace string, workflow *commonutil.Workflow) (*commonutil.Workflow, error)
  • func (p *WorkflowClient) Get(namespace string, name string) (wf *commonutil.Workflow, isNotFoundError bool, err error)
  • func (p *WorkflowClient) HasSynced() func() bool
  • func (p *WorkflowClient) List(swfName string, completed bool, minIndex int64) (status []swfapi.WorkflowStatus, err error)

Types

type KubeClient

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

KubeClient is a client to call the core Kubernetes APIs.

func NewKubeClient

func NewKubeClient(kubeClientSet kubernetes.Interface, recorder record.EventRecorder) *KubeClient

NewKubeClient creates a new client to call the core Kubernetes APIs.

func (*KubeClient) RecordSyncFailure

func (k *KubeClient) RecordSyncFailure(swf *swfapi.ScheduledWorkflow, message string)

RecordSyncFailure records the failure of a sync.

func (*KubeClient) RecordSyncSuccess

func (k *KubeClient) RecordSyncSuccess(swf *swfapi.ScheduledWorkflow, message string)

RecordSyncSuccess records the success of a sync.

type ScheduledWorkflowClient

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

ScheduledWorkflowClient is a client to call the ScheduledWorkflow API.

func NewScheduledWorkflowClient

func NewScheduledWorkflowClient(clientSet swfclientset.Interface,
	informer v1beta1.ScheduledWorkflowInformer) *ScheduledWorkflowClient

NewScheduledWorkflowClient creates an instance of the client.

func (*ScheduledWorkflowClient) AddEventHandler

func (p *ScheduledWorkflowClient) AddEventHandler(funcs *cache.ResourceEventHandlerFuncs)

AddEventHandler adds an event handler.

func (*ScheduledWorkflowClient) Get

func (p *ScheduledWorkflowClient) Get(namespace string, name string) (*util.ScheduledWorkflow, error)

Get returns a ScheduledWorkflow, given a namespace and a name.

func (*ScheduledWorkflowClient) HasSynced

func (p *ScheduledWorkflowClient) HasSynced() func() bool

HasSynced returns true if the shared informer's store has synced.

func (*ScheduledWorkflowClient) Update

func (p *ScheduledWorkflowClient) Update(ctx context.Context, namespace string,
	schedule *util.ScheduledWorkflow) error

Update Updates a ScheduledWorkflow in the Kubernetes API server.

type WorkflowClient

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

WorkflowClient is a client to call the Workflow API.

func NewWorkflowClient

func NewWorkflowClient(clientSet workflowclientset.Interface,
	informer v1alpha1.WorkflowInformer) *WorkflowClient

NewWorkflowClient creates an instance of the WorkflowClient.

func (*WorkflowClient) AddEventHandler

func (p *WorkflowClient) AddEventHandler(funcs *cache.ResourceEventHandlerFuncs)

AddEventHandler adds an event handler.

func (*WorkflowClient) Create

func (p *WorkflowClient) Create(ctx context.Context, namespace string, workflow *commonutil.Workflow) (
	*commonutil.Workflow, error)

Create creates a workflow given a namespace and its specification.

func (*WorkflowClient) Get

func (p *WorkflowClient) Get(namespace string, name string) (
	wf *commonutil.Workflow, isNotFoundError bool, err error)

Get returns a Workflow, given a namespace and name.

func (*WorkflowClient) HasSynced

func (p *WorkflowClient) HasSynced() func() bool

HasSynced returns true if the shared informer's store has synced.

func (*WorkflowClient) List

func (p *WorkflowClient) List(swfName string, completed bool, minIndex int64) (
	status []swfapi.WorkflowStatus, err error)

List returns a list of workflows given the name of their ScheduledWorkflow, whether they are completed, and their minimum index (to avoid returning the whole list).