workflow

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

type CreateWorkflowResponse struct {
	WorkflowName string `json:"workflow_name"`
}

type Logs struct {
	Logs []string `json:"logs"`
}

type Status struct {
	Name     string `json:"name"`
	Status   string `json:"status"`
	Created  string `json:"created"`
	Finished string `json:"finished,omitempty"`
}

type Workflow interface {
	ListStatus(ctx context.Context) ([]Status, error)
	Logs(ctx context.Context, workflowName string) (*Logs, error)
	LogStream(ctx context.Context, workflowName string, data http.ResponseWriter) error
	Status(ctx context.Context, workflowName string) (*Status, error)
	Submit(ctx context.Context, from string, parameters map[string]string, labels map[string]string) (string, error)
}