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

func (c *Client) CreateWorkflow() error {
	return nil
}

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

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

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

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

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

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

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

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

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

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

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

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

func (c *Client) GetEventsStream(callback EventCallback) error {
	return nil
}

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