tekton

Documentation

Index

• Constants
• type EnvVarMap
• type WorkflowBackend
  • func NewWorkflowBackend(logger *log.Logger, namespace string) (*WorkflowBackend, error)
  • func (w *WorkflowBackend) CreateWorkflow(ctx context.Context, workflow *domain.Workflow) error
  • func (w *WorkflowBackend) CreateWorkflowListener(ctx context.Context, workflowName string, timeout time.Duration) (*domain.WorkflowListener, error)
  • func (w *WorkflowBackend) CreateWorkflowRun(ctx context.Context, workflowName string, codeset *domain.Codeset) error
  • func (w *WorkflowBackend) DeleteWorkflow(ctx context.Context, name string) error
  • func (w *WorkflowBackend) DeleteWorkflowListener(ctx context.Context, name string) error
  • func (w *WorkflowBackend) GetWorkflowListener(ctx context.Context, workflowName string) (wl *domain.WorkflowListener, err error)
  • func (w *WorkflowBackend) GetWorkflowRuns(ctx context.Context, wf *domain.Workflow, filter *domain.WorkflowRunFilter) ([]*domain.WorkflowRun, error)
• type WorkflowBackendErr
  • func (e WorkflowBackendErr) Error() string

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"
)

Types

type EnvVarMap

type EnvVarMap map[string]string

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(logger *log.Logger, namespace string) (*WorkflowBackend, error)

NewWorkflowBackend initializes Tekton backend

func (*WorkflowBackend) CreateWorkflow

func (w *WorkflowBackend) CreateWorkflow(ctx context.Context, workflow *domain.Workflow) error

CreateWorkflow receives a FuseML workflow and creates a Tekton pipeline from it

func (*WorkflowBackend) CreateWorkflowListener

func (w *WorkflowBackend) CreateWorkflowListener(ctx context.Context, 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, workflowName string, codeset *domain.Codeset) error

CreateWorkflowRun creates a PipelineRun with its default values for the specified workflow and codeset

func (*WorkflowBackend) DeleteWorkflow

func (w *WorkflowBackend) DeleteWorkflow(ctx context.Context, name string) error

DeleteWorkflow deletes a tekton pipeline with the specified name

func (*WorkflowBackend) DeleteWorkflowListener

func (w *WorkflowBackend) DeleteWorkflowListener(ctx context.Context, name string) error

DeleteWorkflowListener deletes all tekton resources associated to the specified listener name

func (*WorkflowBackend) GetWorkflowListener

func (w *WorkflowBackend) GetWorkflowListener(ctx context.Context, workflowName string) (wl *domain.WorkflowListener, err error)

GetWorkflowListener returns the listener for a given workflow

func (*WorkflowBackend) GetWorkflowRuns

func (w *WorkflowBackend) GetWorkflowRuns(ctx context.Context, wf *domain.Workflow, filter *domain.WorkflowRunFilter) ([]*domain.WorkflowRun, error)

GetWorkflowRuns 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