handler

Documentation

Index

• func CancelWorkflowRun(ctx context.Context, name, namespace string) (*v1alpha1.WorkflowRun, error)
• func ContinueWorkflowRun(ctx context.Context, name, namespace string) (*v1alpha1.WorkflowRun, error)
• func CreateResource(ctx context.Context) (*v1alpha1.Resource, error)
• func CreateStage(ctx context.Context) (*v1alpha1.Stage, error)
• func CreateWorkflow(ctx context.Context) (*v1alpha1.Workflow, error)
• func CreateWorkflowRun(ctx context.Context) (*v1alpha1.WorkflowRun, error)
• func CreateWorkflowTrigger(ctx context.Context) (*v1alpha1.WorkflowTrigger, error)
• func DeleteResource(ctx context.Context, name, namespace string) error
• func DeleteStage(ctx context.Context, name, namespace string) error
• func DeleteWorkflow(ctx context.Context, name, namespace string) error
• func DeleteWorkflowRun(ctx context.Context, name, namespace string) error
• func DeleteWorkflowTrigger(ctx context.Context, name, namespace string) error
• func GetContainerLogStream(ctx context.Context, workflowrun, stage, container, namespace string) error
• func GetContainerLogs(ctx context.Context, workflowrun, stage, container, namespace string, ...) ([]byte, map[string]string, error)
• func GetResource(ctx context.Context, name, namespace string) (*v1alpha1.Resource, error)
• func GetStage(ctx context.Context, name, namespace string) (*v1alpha1.Stage, error)
• func GetWorkflow(ctx context.Context, name, namespace string) (*v1alpha1.Workflow, error)
• func GetWorkflowRun(ctx context.Context, name, namespace string) (*v1alpha1.WorkflowRun, error)
• func GetWorkflowTrigger(ctx context.Context, name, namespace string) (*v1alpha1.WorkflowTrigger, error)
• func InitHandlers(c clientset.Interface)
• func ListResources(ctx context.Context, namespace string) (*v1alpha1.ResourceList, error)
• func ListStages(ctx context.Context, namespace string) (*v1alpha1.StageList, error)
• func ListWorkflowRuns(ctx context.Context, namespace string) (*v1alpha1.WorkflowRunList, error)
• func ListWorkflowTriggers(ctx context.Context, namespace string) (*v1alpha1.WorkflowTriggerList, error)
• func ListWorkflows(ctx context.Context, namespace string) (*v1alpha1.WorkflowList, error)
• func ReceiveContainerLogStream(ctx context.Context, workflowrun, stage, container, namespace string) error
• func UpdateResource(ctx context.Context, name string) (*v1alpha1.Resource, error)
• func UpdateStage(ctx context.Context, name string) (*v1alpha1.Stage, error)
• func UpdateWorkflow(ctx context.Context, name string) (*v1alpha1.Workflow, error)
• func UpdateWorkflowRun(ctx context.Context, name string) (*v1alpha1.WorkflowRun, error)
• func UpdateWorkflowTrigger(ctx context.Context, name string) (*v1alpha1.WorkflowTrigger, error)

Functions

func CancelWorkflowRun

func CancelWorkflowRun(ctx context.Context, name, namespace string) (*v1alpha1.WorkflowRun, error)

CancelWorkflowRun updates the workflowrun overall status to Cancelled.

func ContinueWorkflowRun

func ContinueWorkflowRun(ctx context.Context, name, namespace string) (*v1alpha1.WorkflowRun, error)

CancelWorkflowRun updates the workflowrun overall status to Running.

func CreateResource

func CreateResource(ctx context.Context) (*v1alpha1.Resource, error)

POST /apis/v1alpha1/resources/

func CreateStage

func CreateStage(ctx context.Context) (*v1alpha1.Stage, error)

POST /apis/v1alpha1/stages/

func CreateWorkflow

func CreateWorkflow(ctx context.Context) (*v1alpha1.Workflow, error)

POST /apis/v1alpha1/workflows/

func CreateWorkflowRun

func CreateWorkflowRun(ctx context.Context) (*v1alpha1.WorkflowRun, error)

POST /api/v1alpha1/workflowruns

func CreateWorkflowTrigger

func CreateWorkflowTrigger(ctx context.Context) (*v1alpha1.WorkflowTrigger, error)

POST /api/v1alpha1/workflowtriggers

func DeleteResource

func DeleteResource(ctx context.Context, name, namespace string) error

DELETE /apis/v1alpha1/resources/{resource}

func DeleteStage

func DeleteStage(ctx context.Context, name, namespace string) error

DELETE /apis/v1alpha1/stages/{stage}

func DeleteWorkflow

func DeleteWorkflow(ctx context.Context, name, namespace string) error

DELETE /apis/v1alpha1/workflows/{workflow}

func DeleteWorkflowRun

func DeleteWorkflowRun(ctx context.Context, name, namespace string) error

DELETE /apis/v1alpha1/workflowruns/{workflowrun}

func DeleteWorkflowTrigger

func DeleteWorkflowTrigger(ctx context.Context, name, namespace string) error

DELETE /apis/v1alpha1/workflowtriggers/{workflowtrigger}

func GetContainerLogStream

func GetContainerLogStream(ctx context.Context, workflowrun, stage, container, namespace string) error

GetContainerLogStream gets real-time log of container within stage.

func GetContainerLogs

func GetContainerLogs(ctx context.Context, workflowrun, stage, container, namespace string, download bool) ([]byte, map[string]string, error)

GetContainerLogs handles the request to get container logs, only supports finished stage records.

func GetResource

func GetResource(ctx context.Context, name, namespace string) (*v1alpha1.Resource, error)

GET /apis/v1alpha1/resources/{resource}

func GetStage

func GetStage(ctx context.Context, name, namespace string) (*v1alpha1.Stage, error)

GET /apis/v1alpha1/stages/{stage}

func GetWorkflow

func GetWorkflow(ctx context.Context, name, namespace string) (*v1alpha1.Workflow, error)

GET /apis/v1alpha1/workflows/{workflow}

func GetWorkflowRun

func GetWorkflowRun(ctx context.Context, name, namespace string) (*v1alpha1.WorkflowRun, error)

GET /apis/v1alpha1/workflowruns/{workflowrun}

func GetWorkflowTrigger

func GetWorkflowTrigger(ctx context.Context, name, namespace string) (*v1alpha1.WorkflowTrigger, error)

GET /apis/v1alpha1/workflowtriggers/{workflowtrigger}

func InitHandlers

func InitHandlers(c clientset.Interface)

InitHandlers initializes the server resources handlers.

func ListResources

func ListResources(ctx context.Context, namespace string) (*v1alpha1.ResourceList, error)

GET /apis/v1alpha1/resources/

func ListStages

func ListStages(ctx context.Context, namespace string) (*v1alpha1.StageList, error)

GET /apis/v1alpha1/Stages/

func ListWorkflowRuns

func ListWorkflowRuns(ctx context.Context, namespace string) (*v1alpha1.WorkflowRunList, error)

GET /apis/v1alpha1/workflowruns/

func ListWorkflowTriggers

func ListWorkflowTriggers(ctx context.Context, namespace string) (*v1alpha1.WorkflowTriggerList, error)

GET /apis/v1alpha1/workflowtriggers/

func ListWorkflows

func ListWorkflows(ctx context.Context, namespace string) (*v1alpha1.WorkflowList, error)

GET /apis/v1alpha1/workflows/

func ReceiveContainerLogStream

func ReceiveContainerLogStream(ctx context.Context, workflowrun, stage, container, namespace string) error

GET /workflowruns/{workflowrun-name}/stages/{stage-name}/streamlogs?container-name=c0 ReceiveContainerLogStream receives real-time log of container within workflowrun stage.

func UpdateResource

func UpdateResource(ctx context.Context, name string) (*v1alpha1.Resource, error)

PUT /apis/v1alpha1/resources/{resource}

func UpdateStage

func UpdateStage(ctx context.Context, name string) (*v1alpha1.Stage, error)

PUT /apis/v1alpha1/stages/{stage}

func UpdateWorkflow

func UpdateWorkflow(ctx context.Context, name string) (*v1alpha1.Workflow, error)

PUT /apis/v1alpha1/workflows/{workflow}

func UpdateWorkflowRun

func UpdateWorkflowRun(ctx context.Context, name string) (*v1alpha1.WorkflowRun, error)

PUT /apis/v1alpha1/workflowruns/{workflowrun}

func UpdateWorkflowTrigger

func UpdateWorkflowTrigger(ctx context.Context, name string) (*v1alpha1.WorkflowTrigger, error)

PUT /apis/v1alpha1/workflowtriggers/{workflowtrigger}