client

Documentation

Index

• type PipelineClient
  • func NewPipelineClient(initializeTimeout time.Duration, timeout time.Duration, basePath string, ...) (*PipelineClient, error)
  • func (p *PipelineClient) ReadArtifact(request *api.ReadArtifactRequest) (*api.ReadArtifactResponse, error)
  • func (p *PipelineClient) ReportRunMetrics(request *api.ReportRunMetricsRequest) (*api.ReportRunMetricsResponse, error)
  • func (p *PipelineClient) ReportScheduledWorkflow(swf *util.ScheduledWorkflow) error
  • func (p *PipelineClient) ReportWorkflow(workflow *util.Workflow) error
• type PipelineClientFake
  • func NewPipelineClientFake() *PipelineClientFake
  • func (p *PipelineClientFake) GetReadArtifactRequest() *api.ReadArtifactRequest
  • func (p *PipelineClientFake) GetReportedMetricsRequest() *api.ReportRunMetricsRequest
  • func (p *PipelineClientFake) GetScheduledWorkflow(namespace string, name string) *util.ScheduledWorkflow
  • func (p *PipelineClientFake) GetWorkflow(namespace string, name string) *util.Workflow
  • func (p *PipelineClientFake) ReadArtifact(request *api.ReadArtifactRequest) (*api.ReadArtifactResponse, error)
  • func (p *PipelineClientFake) ReportRunMetrics(request *api.ReportRunMetricsRequest) (*api.ReportRunMetricsResponse, error)
  • func (p *PipelineClientFake) ReportScheduledWorkflow(swf *util.ScheduledWorkflow) error
  • func (p *PipelineClientFake) ReportWorkflow(workflow *util.Workflow) error
  • func (p *PipelineClientFake) SetError(err error)
  • func (p *PipelineClientFake) StubArtifact(request *api.ReadArtifactRequest, response *api.ReadArtifactResponse)
  • func (p *PipelineClientFake) StubReportRunMetrics(response *api.ReportRunMetricsResponse, err error)
• type PipelineClientInterface
• type ScheduledWorkflowClient
  • func NewScheduledWorkflowClient(informer v1beta1.ScheduledWorkflowInformer) *ScheduledWorkflowClient
  • func (c *ScheduledWorkflowClient) AddEventHandler(funcs *cache.ResourceEventHandlerFuncs)
  • func (c *ScheduledWorkflowClient) Get(namespace string, name string) (swf *util.ScheduledWorkflow, err error)
  • func (c *ScheduledWorkflowClient) HasSynced() func() bool
• type ScheduledWorkflowClientFake
  • func NewScheduledWorkflowClientFake() *ScheduledWorkflowClientFake
  • func (p *ScheduledWorkflowClientFake) Get(namespace string, name string) (swf *util.ScheduledWorkflow, err error)
  • func (p *ScheduledWorkflowClientFake) Put(namespace string, name string, swf *util.ScheduledWorkflow)
• type ScheduledWorkflowClientInterface
• type WorkflowClient
  • func NewWorkflowClient(informer v1alpha1.WorkflowInformer) *WorkflowClient
  • func (c *WorkflowClient) AddEventHandler(funcs *cache.ResourceEventHandlerFuncs)
  • func (c *WorkflowClient) Get(namespace string, name string) (wf *util.Workflow, err error)
  • func (c *WorkflowClient) HasSynced() func() bool
• type WorkflowClientFake
  • func NewWorkflowClientFake() *WorkflowClientFake
  • func (p *WorkflowClientFake) Get(namespace string, name string) (wf *util.Workflow, err error)
  • func (p *WorkflowClientFake) Put(namespace string, name string, wf *util.Workflow)
• type WorkflowClientInterface

Types

type PipelineClient

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

func NewPipelineClient

func NewPipelineClient(
	initializeTimeout time.Duration,
	timeout time.Duration,
	basePath string,
	mlPipelineServiceName string,
	mlPipelineServiceHttpPort string,
	mlPipelineServiceGRPCPort string) (*PipelineClient, error)

func (*PipelineClient) ReadArtifact

func (p *PipelineClient) ReadArtifact(request *api.ReadArtifactRequest) (*api.ReadArtifactResponse, error)

ReadArtifact reads artifact content from run service. If the artifact is not present, returns nil response.

func (*PipelineClient) ReportRunMetrics

func (p *PipelineClient) ReportRunMetrics(request *api.ReportRunMetricsRequest) (*api.ReportRunMetricsResponse, error)

ReportRunMetrics reports run metrics to run service.

func (*PipelineClient) ReportScheduledWorkflow

func (p *PipelineClient) ReportScheduledWorkflow(swf *util.ScheduledWorkflow) error

func (*PipelineClient) ReportWorkflow

func (p *PipelineClient) ReportWorkflow(workflow *util.Workflow) error

type PipelineClientFake

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

func NewPipelineClientFake

func NewPipelineClientFake() *PipelineClientFake

func (*PipelineClientFake) GetReadArtifactRequest

func (p *PipelineClientFake) GetReadArtifactRequest() *api.ReadArtifactRequest

func (*PipelineClientFake) GetReportedMetricsRequest

func (p *PipelineClientFake) GetReportedMetricsRequest() *api.ReportRunMetricsRequest

func (*PipelineClientFake) GetScheduledWorkflow

func (p *PipelineClientFake) GetScheduledWorkflow(namespace string, name string) *util.ScheduledWorkflow

func (*PipelineClientFake) GetWorkflow

func (p *PipelineClientFake) GetWorkflow(namespace string, name string) *util.Workflow

func (*PipelineClientFake) ReadArtifact

func (p *PipelineClientFake) ReadArtifact(request *api.ReadArtifactRequest) (*api.ReadArtifactResponse, error)

func (*PipelineClientFake) ReportRunMetrics

func (p *PipelineClientFake) ReportRunMetrics(request *api.ReportRunMetricsRequest) (*api.ReportRunMetricsResponse, error)

func (*PipelineClientFake) ReportScheduledWorkflow

func (p *PipelineClientFake) ReportScheduledWorkflow(swf *util.ScheduledWorkflow) error

func (*PipelineClientFake) ReportWorkflow

func (p *PipelineClientFake) ReportWorkflow(workflow *util.Workflow) error

func (*PipelineClientFake) SetError

func (p *PipelineClientFake) SetError(err error)

func (*PipelineClientFake) StubArtifact

func (p *PipelineClientFake) StubArtifact(request *api.ReadArtifactRequest, response *api.ReadArtifactResponse)

func (*PipelineClientFake) StubReportRunMetrics

func (p *PipelineClientFake) StubReportRunMetrics(response *api.ReportRunMetricsResponse, err error)

type PipelineClientInterface

type PipelineClientInterface interface {
	ReportWorkflow(workflow *util.Workflow) error
	ReportScheduledWorkflow(swf *util.ScheduledWorkflow) error
	ReadArtifact(request *api.ReadArtifactRequest) (*api.ReadArtifactResponse, error)
	ReportRunMetrics(request *api.ReportRunMetricsRequest) (*api.ReportRunMetricsResponse, error)
}

type ScheduledWorkflowClient

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

ScheduledWorkflowClient is a client to call the ScheduledWorkflow API.

func NewScheduledWorkflowClient

func NewScheduledWorkflowClient(informer v1beta1.ScheduledWorkflowInformer) *ScheduledWorkflowClient

NewScheduledWorkflowClient creates an instance of the client.

func (*ScheduledWorkflowClient) AddEventHandler

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

AddEventHandler adds an event handler.

func (*ScheduledWorkflowClient) Get

func (c *ScheduledWorkflowClient) Get(namespace string, name string) (
	swf *util.ScheduledWorkflow, err error)

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

func (*ScheduledWorkflowClient) HasSynced

func (c *ScheduledWorkflowClient) HasSynced() func() bool

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

type ScheduledWorkflowClientFake

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

func NewScheduledWorkflowClientFake

func NewScheduledWorkflowClientFake() *ScheduledWorkflowClientFake

func (*ScheduledWorkflowClientFake) Get

func (p *ScheduledWorkflowClientFake) Get(namespace string, name string) (
	swf *util.ScheduledWorkflow, err error)

func (*ScheduledWorkflowClientFake) Put

func (p *ScheduledWorkflowClientFake) Put(namespace string, name string,
	swf *util.ScheduledWorkflow)

type ScheduledWorkflowClientInterface

type ScheduledWorkflowClientInterface interface {
	Get(namespace string, name string) (swf *util.ScheduledWorkflow, err error)
}

type WorkflowClient

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

WorkflowClient is a client to call the Workflow API.

func NewWorkflowClient

func NewWorkflowClient(informer v1alpha1.WorkflowInformer) *WorkflowClient

NewWorkflowClient creates an instance of the WorkflowClient.

func (*WorkflowClient) AddEventHandler

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

AddEventHandler adds an event handler.

func (*WorkflowClient) Get

func (c *WorkflowClient) Get(namespace string, name string) (
	wf *util.Workflow, err error)

Get returns a Workflow, given a namespace and name.

func (*WorkflowClient) HasSynced

func (c *WorkflowClient) HasSynced() func() bool

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

type WorkflowClientFake

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

func NewWorkflowClientFake

func NewWorkflowClientFake() *WorkflowClientFake

func (*WorkflowClientFake) Get

func (p *WorkflowClientFake) Get(namespace string, name string) (
	wf *util.Workflow, err error)

func (*WorkflowClientFake) Put

func (p *WorkflowClientFake) Put(namespace string, name string, wf *util.Workflow)

type WorkflowClientInterface

type WorkflowClientInterface interface {
	Get(namespace string, name string) (wf *util.Workflow, err error)
}