service

func (*RunService) AbortAction ¶

func (s *RunService) AbortAction(
	ctx context.Context,
	req *connect.Request[workflow.AbortActionRequest],
) (*connect.Response[workflow.AbortActionResponse], error)

AbortAction aborts a specific action

func (*RunService) AbortRun ¶

func (s *RunService) AbortRun(
	ctx context.Context,
	req *connect.Request[workflow.AbortRunRequest],
) (*connect.Response[workflow.AbortRunResponse], error)

AbortRun aborts a run

func (*RunService) CreateRun ¶

func (s *RunService) CreateRun(
	ctx context.Context,
	req *connect.Request[workflow.CreateRunRequest],
) (*connect.Response[workflow.CreateRunResponse], error)

CreateRun creates a new run

func (*RunService) GetActionData ¶

func (s *RunService) GetActionData(
	ctx context.Context,
	req *connect.Request[workflow.GetActionDataRequest],
) (*connect.Response[workflow.GetActionDataResponse], error)

GetActionData gets input and output data for an action

func (*RunService) GetActionDetails ¶

func (s *RunService) GetActionDetails(
	ctx context.Context,
	req *connect.Request[workflow.GetActionDetailsRequest],
) (*connect.Response[workflow.GetActionDetailsResponse], error)

GetActionDetails gets detailed information about an action

func (*RunService) GetRunDetails ¶

func (s *RunService) GetRunDetails(
	ctx context.Context,
	req *connect.Request[workflow.GetRunDetailsRequest],
) (*connect.Response[workflow.GetRunDetailsResponse], error)

GetRunDetails gets detailed information about a run

func (*RunService) ListActions ¶

func (s *RunService) ListActions(
	ctx context.Context,
	req *connect.Request[workflow.ListActionsRequest],
) (*connect.Response[workflow.ListActionsResponse], error)

ListActions lists actions for a run

func (*RunService) ListRuns ¶

func (s *RunService) ListRuns(
	ctx context.Context,
	req *connect.Request[workflow.ListRunsRequest],
) (*connect.Response[workflow.ListRunsResponse], error)

ListRuns lists runs based on filter criteria

func (*RunService) WatchActionDetails ¶

func (s *RunService) WatchActionDetails(
	ctx context.Context,
	req *connect.Request[workflow.WatchActionDetailsRequest],
	stream *connect.ServerStream[workflow.WatchActionDetailsResponse],
) error

WatchActionDetails streams action details updates

func (*RunService) WatchActions ¶

func (s *RunService) WatchActions(
	ctx context.Context,
	req *connect.Request[workflow.WatchActionsRequest],
	stream *connect.ServerStream[workflow.WatchActionsResponse],
) error

WatchActions streams action updates for a run

func (*RunService) WatchClusterEvents ¶

func (s *RunService) WatchClusterEvents(
	ctx context.Context,
	req *connect.Request[workflow.WatchClusterEventsRequest],
	stream *connect.ServerStream[workflow.WatchClusterEventsResponse],
) error

WatchClusterEvents streams cluster events for an action attempt

func (*RunService) WatchGroups ¶

func (s *RunService) WatchGroups(ctx context.Context, c *connect.Request[workflow.WatchGroupsRequest], c2 *connect.ServerStream[workflow.WatchGroupsResponse]) error

func (*RunService) WatchRunDetails ¶

func (s *RunService) WatchRunDetails(
	ctx context.Context,
	req *connect.Request[workflow.WatchRunDetailsRequest],
	stream *connect.ServerStream[workflow.WatchRunDetailsResponse],
) error

WatchRunDetails streams run details updates

func (*RunService) WatchRuns ¶

func (s *RunService) WatchRuns(
	ctx context.Context,
	req *connect.Request[workflow.WatchRunsRequest],
	stream *connect.ServerStream[workflow.WatchRunsResponse],
) error

WatchRuns streams run updates based on filter criteria

func (*StateService) Get ¶

func (s *StateService) Get(ctx context.Context, req *connect.Request[workflow.GetRequest]) (*connect.Response[workflow.GetResponse], error)

Get handles the unary Get RPC Client sends a single GetRequest, server responds with GetResponse

func (*StateService) Put ¶

func (s *StateService) Put(ctx context.Context, req *connect.Request[workflow.PutRequest]) (*connect.Response[workflow.PutResponse], error)

Put handles the unary Put RPC Client sends a single PutRequest, server responds with PutResponse

func (*StateService) Watch ¶

func (s *StateService) Watch(ctx context.Context, req *connect.Request[workflow.WatchRequest], stream *connect.ServerStream[workflow.WatchResponse]) error

Watch handles the server-side streaming Watch RPC Streams ActionUpdate messages for actions matching the filter