workflowdataclient

package

v1.17.0 Latest Latest Go to latest Published: May 27, 2026 License: MIT Imports: 6 Imported by: 0

Details

View Source

const DefaultPageSize = 100

This section is empty.

This section is empty.

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

Client fetches workflow data from the CRE platform GraphQL API.

func New(gql *graphqlclient.Client, log *zerolog.Logger) *Client

New creates a WorkflowDataClient backed by the provided GraphQL client.

func (c *Client) CreateServiceContextWithTimeout(parent context.Context) (context.Context, context.CancelFunc)

func (c *Client) ListAll(parent context.Context, pageSize int) ([]Workflow, error)

ListAll pages through the ListWorkflows query and returns all workflows.

func (c *Client) SearchByName(parent context.Context, name string, pageSize int) ([]Workflow, error)

SearchByName pages through the ListWorkflows query with the given search filter (server-side contains match on workflow name).

func (c *Client) SetServiceTimeout(timeout time.Duration)

type Workflow struct {
	Name           string
	WorkflowID     string
	OwnerAddress   string
	Status         string
	WorkflowSource string
}

Workflow is a workflow row returned by the platform list API.