argo/client/workflow.go

package client

const (
	createWorkflowRelativeUrl          = "/api/v1/workflows/{namespace}"
	deleteWorkflowRelativeUrl          = "/api/v1/workflows/{namespace}/{name}"
	getWorkflowsInNamespaceRelativeUrl = "/api/v1/workflows/{namespace}"
	getWorkflowRelativeUrl             = "/api/v1/workflows/{namespace}/{name}"
	lintWorkflowRelativeUrl            = "/api/v1/workflows/{namespace}/lint"
	submitWorkflowRelativeUrl          = "/api/v1/workflows/{namespace}/{name}/submit"
	resubmitWorkflowRelativeUrl        = "/api/v1/workflows/{namespace}/{name}/resubmit"
	resumeWorkflowRelativeUrl          = "/api/v1/workflows/{namespace}/{name}/resume"
	retryWorkflowRelativeUrl           = "/api/v1/workflows/{namespace}/{name}/retry"
	setWorkflowRelativeUrl             = "/api/v1/workflows/{namespace}/{name}/set"
	stopWorkflowRelativeUrl            = "/api/v1/workflows/{namespace}/{name}/stop"
	suspendWorkflowRelativeUrl         = "/api/v1/workflows/{namespace}/{name}/suspend"
	terminateWorkflowRelativeUrl       = "/api/v1/workflows/{namespace}/{name}/terminate"
	getEventsStreamRelativeUrl         = "/api/v1/stream/events/{namespace}"
	getWorkflowEventsStreamRelativeUrl = "/api/v1/workflow-events/{namespace}"
)

type CreateWorkflowParams struct {
	Namespace          string
	WorkflowDefinition map[string]any
}

func (c *Client) CreateWorkflow(params CreateWorkflowParams) (string, error) {
	return "", nil
}

type DeleteWorkflowParams struct {
	Namespace string
	Name      string
}

func (c *Client) DeleteWorkflow(params DeleteWorkflowParams) error {
	return nil
}

type GetWorkflowsInNamespaceParams struct {
	Namespace string
}

func (c *Client) GetWorkflowsInNamespace(params GetWorkflowsInNamespaceParams) ([]map[string]any, error) {
	workflowDefinitions := make([]map[string]any, 0)
	return workflowDefinitions, nil
}

type GetWorkflowParams struct {
	Namespace string
	Name      string
}

func (c *Client) GetWorkflow(params GetWorkflowParams) (map[string]any, error) {
	workflowDefinition := make(map[string]any)
	return workflowDefinition, nil
}

type LintWorkflowParams struct {
	Namespace          string
	WorkflowDefinition map[string]any
}

func (c *Client) LintWorkflow(params LintWorkflowParams) error {
	return nil
}

type SubmitWorkflowParams struct {
	Namespace string
	Name      string
}

func (c *Client) SubmitWorkflow(params SubmitWorkflowParams) error {
	return nil
}

type ResubmitWorkflowParams struct {
	Namespace              string
	Name                   string
	ResubmitParametersJson string
}

func (c *Client) ResubmitWorkflow(params ResubmitWorkflowParams) error {
	return nil
}

type ResumeWorkflowParams struct {
	Namespace string
	Name      string
}

func (c *Client) ResumeWorkflow(params ResumeWorkflowParams) error {
	return nil
}

type RetryWorkflowParams struct {
	Namespace                               string
	Name                                    string
	RetryParametersJson                     string
	RetryOnSuccessWorkflowNodeFieldSelector string
}

func (c *Client) RetryWorkflow(params RetryWorkflowParams) error {
	return nil
}

type SetWorkflowParams struct {
	Namespace            string
	Name                 string
	NodeFieldSelector    string
	Message              string
	Phase                string
	OutputParametersJson string
}

func (c *Client) SetWorkflow(params SetWorkflowParams) error {
	return nil
}

type StopWorkflowParams struct {
	Namespace         string
	Name              string
	NodeFieldSelector string
	Message           string
}

func (c *Client) StopWorkflow(params StopWorkflowParams) error {
	return nil
}

type SuspendWorkflowParams struct {
	Namespace string
	Name      string
}

func (c *Client) SuspendWorkflow(params SuspendWorkflowParams) error {
	return nil
}

type TerminalWorkflowParams struct {
	Namespace string
	Name      string
}

func (c *Client) TerminalWorkflow(params TerminalWorkflowParams) error {
	return nil
}

type EventCallback func(event map[string]any, eventErr error) error

type GetWorkflowEventsStreamParams struct {
	Namespace string
	Name      string
}

func (c *Client) GetWorkflowEventsStream(params GetWorkflowEventsStreamParams, callback EventCallback) error {
	return nil
}