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, wait bool) (*domain.WorkflowListener, error)
- func (w *WorkflowBackend) CreateWorkflowRun(ctx context.Context, workflowName string, codeset *domain.Codeset) error
- func (w *WorkflowBackend) GetWorkflowListener(ctx context.Context, logger *log.Logger, 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 ¶
View Source
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, wait bool) (*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, workflowName string, codeset *domain.Codeset) error
CreateWorkflowRun creates a PipelineRun with its default values for received workflow and codeset
func (*WorkflowBackend) GetWorkflowListener ¶ added in v0.0.2
func (w *WorkflowBackend) GetWorkflowListener(ctx context.Context, logger *log.Logger, 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
Click to show internal directories.
Click to hide internal directories.