Documentation
¶
Index ¶
- Constants
- type EnvVar
- type WorkflowBackend
- func (w *WorkflowBackend) CreateWorkflow(ctx context.Context, logger *log.Logger, workflow *workflow.Workflow) error
- func (w *WorkflowBackend) CreateWorkflowListener(ctx context.Context, logger *log.Logger, workflowName string, ...) (*domain.WorkflowListener, error)
- func (w *WorkflowBackend) CreateWorkflowRun(ctx context.Context, logger *log.Logger, workflowName string, ...) error
- func (w *WorkflowBackend) DeleteWorkflow(ctx context.Context, logger *log.Logger, name string) error
- func (w *WorkflowBackend) DeleteWorkflowListener(ctx context.Context, logger *log.Logger, name string) error
- func (w *WorkflowBackend) GetWorkflowListener(ctx context.Context, workflowName string) (wl *domain.WorkflowListener, err error)
- func (w *WorkflowBackend) ListWorkflowRuns(ctx context.Context, wf workflow.Workflow, filters domain.WorkflowRunFilter) ([]*workflow.WorkflowRun, error)
- type WorkflowBackendErr
Constants ¶
const ( // LabelCodesetName is the label key for the codeset name LabelCodesetName = "fuseml/codeset-name" // LabelCodesetProject is the label key for the codeset project LabelCodesetProject = "fuseml/codeset-project" // LabelCodesetVersion is the label key for the codeset version LabelCodesetVersion = "fuseml/codeset-version" // LabelWorkflowRef is the label key for the reference of the workflow LabelWorkflowRef = "fuseml/workflow-ref" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EnvVar ¶
type EnvVar struct {
// contains filtered or unexported fields
}
EnvVar describes environment variable and its value that needs to be passed to tekton task
type WorkflowBackend ¶
type WorkflowBackend struct {
// contains filtered or unexported fields
}
WorkflowBackend implements the FuseML WorkflowBackend interface for tekton
func NewWorkflowBackend ¶
func NewWorkflowBackend(namespace string) (*WorkflowBackend, error)
NewWorkflowBackend initializes Tekton backend
func (*WorkflowBackend) CreateWorkflow ¶
func (w *WorkflowBackend) CreateWorkflow(ctx context.Context, logger *log.Logger, workflow *workflow.Workflow) error
CreateWorkflow receives a FuseML workflow and creates a Tekton pipeline from it
func (*WorkflowBackend) CreateWorkflowListener ¶ added in v0.0.2
func (w *WorkflowBackend) CreateWorkflowListener(ctx context.Context, logger *log.Logger, workflowName string, timeout time.Duration) (*domain.WorkflowListener, error)
CreateWorkflowListener creates tekton resources required to have a listener ready for triggering the pipeline
func (*WorkflowBackend) CreateWorkflowRun ¶
func (w *WorkflowBackend) CreateWorkflowRun(ctx context.Context, logger *log.Logger, workflowName string, codeset *domain.Codeset) error
CreateWorkflowRun creates a PipelineRun with its default values for the specified workflow and codeset
func (*WorkflowBackend) DeleteWorkflow ¶ added in v0.1.0
func (w *WorkflowBackend) DeleteWorkflow(ctx context.Context, logger *log.Logger, name string) error
DeleteWorkflow deletes a tekton pipeline with the specified name
func (*WorkflowBackend) DeleteWorkflowListener ¶ added in v0.1.0
func (w *WorkflowBackend) DeleteWorkflowListener(ctx context.Context, logger *log.Logger, name string) error
DeleteWorkflowListener deletes all tekton resources associated to the specified listener name
func (*WorkflowBackend) GetWorkflowListener ¶ added in v0.0.2
func (w *WorkflowBackend) GetWorkflowListener(ctx context.Context, workflowName string) (wl *domain.WorkflowListener, err error)
GetWorkflowListener returns the listener for a given workflow
func (*WorkflowBackend) ListWorkflowRuns ¶
func (w *WorkflowBackend) ListWorkflowRuns(ctx context.Context, wf workflow.Workflow, filters domain.WorkflowRunFilter) ([]*workflow.WorkflowRun, error)
ListWorkflowRuns returns a list of WorkflowRun for the given Workflow
type WorkflowBackendErr ¶
type WorkflowBackendErr string
WorkflowBackendErr are expected errors returned from the WorkflowBackend
func (WorkflowBackendErr) Error ¶
func (e WorkflowBackendErr) Error() string
Source Files
Directories