workflows

Jan 24, 2026

Changes in this version

+ const Workflows_ResolveExecutionErrors_FullMethodName

+ type ResolveExecutionErrorsRequest struct

+ ExecutionIds []string

+ WorkflowId string

+ func (*ResolveExecutionErrorsRequest) Descriptor() ([]byte, []int)

+ func (*ResolveExecutionErrorsRequest) ProtoMessage()

+ func (x *ResolveExecutionErrorsRequest) GetExecutionIds() []string

+ func (x *ResolveExecutionErrorsRequest) GetWorkflowId() string

+ func (x *ResolveExecutionErrorsRequest) ProtoReflect() protoreflect.Message

+ func (x *ResolveExecutionErrorsRequest) Reset()

+ func (x *ResolveExecutionErrorsRequest) String() string

+ type ResolveExecutionErrorsResponse struct

+ func (*ResolveExecutionErrorsResponse) Descriptor() ([]byte, []int)

+ func (*ResolveExecutionErrorsResponse) ProtoMessage()

+ func (x *ResolveExecutionErrorsResponse) ProtoReflect() protoreflect.Message

+ func (x *ResolveExecutionErrorsResponse) Reset()

+ func (x *ResolveExecutionErrorsResponse) String() string

type UnimplementedWorkflowsServer

+ func (UnimplementedWorkflowsServer) ResolveExecutionErrors(context.Context, *ResolveExecutionErrorsRequest) (*ResolveExecutionErrorsResponse, error)

type WorkflowNodeExecution_ResultReason

+ const WorkflowNodeExecution_RESULT_REASON_ERROR_RESOLVED

type WorkflowsClient

+ ResolveExecutionErrors func(ctx context.Context, in *ResolveExecutionErrorsRequest, ...) (*ResolveExecutionErrorsResponse, error)

type WorkflowsServer

+ ResolveExecutionErrors func(context.Context, *ResolveExecutionErrorsRequest) (*ResolveExecutionErrorsResponse, error)

Jan 21, 2026

Changes in this version

type ListWorkflowsRequest

+ IncludeTemplates bool

+ func (x *ListWorkflowsRequest) GetIncludeTemplates() bool

type Workflow_Metadata

+ IsTemplate bool

+ func (x *Workflow_Metadata) GetIsTemplate() bool

Jan 15, 2026

Changes in this version

type WorkflowEvent

+ CustomName string

+ func (x *WorkflowEvent) GetCustomName() string

type WorkflowEventWithExecutions

+ CustomName string

+ func (x *WorkflowEventWithExecutions) GetCustomName() string

type WorkflowNodeExecution

+ CancelledBy *UserRef

+ func (x *WorkflowNodeExecution) GetCancelledBy() *UserRef

Jan 8, 2026

Changes in this version

+ type WorkflowEventWithExecutions struct

+ Channel string

+ CreatedAt *timestamp.Timestamp

+ Data *_struct.Struct

+ Executions []*WorkflowNodeExecution

+ Id string

+ NodeId string

+ WorkflowId string

+ func (*WorkflowEventWithExecutions) Descriptor() ([]byte, []int)

+ func (*WorkflowEventWithExecutions) ProtoMessage()

+ func (x *WorkflowEventWithExecutions) GetChannel() string

+ func (x *WorkflowEventWithExecutions) GetCreatedAt() *timestamp.Timestamp

+ func (x *WorkflowEventWithExecutions) GetData() *_struct.Struct

+ func (x *WorkflowEventWithExecutions) GetExecutions() []*WorkflowNodeExecution

+ func (x *WorkflowEventWithExecutions) GetId() string

+ func (x *WorkflowEventWithExecutions) GetNodeId() string

+ func (x *WorkflowEventWithExecutions) GetWorkflowId() string

+ func (x *WorkflowEventWithExecutions) ProtoReflect() protoreflect.Message

+ func (x *WorkflowEventWithExecutions) Reset()

+ func (x *WorkflowEventWithExecutions) String() string

Jan 6, 2026

Changes in this version

+ const Workflows_InvokeNodeTriggerAction_FullMethodName

+ type InvokeNodeTriggerActionRequest struct

+ ActionName string

+ NodeId string

+ Parameters *_struct.Struct

+ WorkflowId string

+ func (*InvokeNodeTriggerActionRequest) Descriptor() ([]byte, []int)

+ func (*InvokeNodeTriggerActionRequest) ProtoMessage()

+ func (x *InvokeNodeTriggerActionRequest) GetActionName() string

+ func (x *InvokeNodeTriggerActionRequest) GetNodeId() string

+ func (x *InvokeNodeTriggerActionRequest) GetParameters() *_struct.Struct

+ func (x *InvokeNodeTriggerActionRequest) GetWorkflowId() string

+ func (x *InvokeNodeTriggerActionRequest) ProtoReflect() protoreflect.Message

+ func (x *InvokeNodeTriggerActionRequest) Reset()

+ func (x *InvokeNodeTriggerActionRequest) String() string

+ type InvokeNodeTriggerActionResponse struct

+ Result *_struct.Struct

+ func (*InvokeNodeTriggerActionResponse) Descriptor() ([]byte, []int)

+ func (*InvokeNodeTriggerActionResponse) ProtoMessage()

+ func (x *InvokeNodeTriggerActionResponse) GetResult() *_struct.Struct

+ func (x *InvokeNodeTriggerActionResponse) ProtoReflect() protoreflect.Message

+ func (x *InvokeNodeTriggerActionResponse) Reset()

+ func (x *InvokeNodeTriggerActionResponse) String() string

type UnimplementedWorkflowsServer

+ func (UnimplementedWorkflowsServer) InvokeNodeTriggerAction(context.Context, *InvokeNodeTriggerActionRequest) (*InvokeNodeTriggerActionResponse, error)

type WorkflowsClient

+ InvokeNodeTriggerAction func(ctx context.Context, in *InvokeNodeTriggerActionRequest, ...) (*InvokeNodeTriggerActionResponse, error)

type WorkflowsServer

+ InvokeNodeTriggerAction func(context.Context, *InvokeNodeTriggerActionRequest) (*InvokeNodeTriggerActionResponse, error)

Dec 28, 2025

Changes in this version

+ const Workflows_CancelExecution_FullMethodName

+ const Workflows_CreateWorkflow_FullMethodName

+ const Workflows_DeleteNodeQueueItem_FullMethodName

+ const Workflows_DeleteWorkflow_FullMethodName

+ const Workflows_DescribeWorkflow_FullMethodName

+ const Workflows_EmitNodeEvent_FullMethodName

+ const Workflows_InvokeNodeExecutionAction_FullMethodName

+ const Workflows_ListChildExecutions_FullMethodName

+ const Workflows_ListEventExecutions_FullMethodName

+ const Workflows_ListNodeEvents_FullMethodName

+ const Workflows_ListNodeExecutions_FullMethodName

+ const Workflows_ListNodeQueueItems_FullMethodName

+ const Workflows_ListWorkflowEvents_FullMethodName

+ const Workflows_ListWorkflows_FullMethodName

+ const Workflows_UpdateWorkflow_FullMethodName

+ var File_workflows_proto protoreflect.FileDescriptor

+ var WorkflowNodeExecution_ResultReason_name = map[int32]string

+ var WorkflowNodeExecution_ResultReason_value = map[string]int32

+ var WorkflowNodeExecution_Result_name = map[int32]string

+ var WorkflowNodeExecution_Result_value = map[string]int32

+ var WorkflowNodeExecution_State_name = map[int32]string

+ var WorkflowNodeExecution_State_value = map[string]int32

+ var Workflows_ServiceDesc = grpc.ServiceDesc

+ func RegisterWorkflowsHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterWorkflowsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WorkflowsClient) error

+ func RegisterWorkflowsHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterWorkflowsHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WorkflowsServer) error

+ func RegisterWorkflowsServer(s grpc.ServiceRegistrar, srv WorkflowsServer)

+ type CancelExecutionRequest struct

+ ExecutionId string

+ WorkflowId string

+ func (*CancelExecutionRequest) Descriptor() ([]byte, []int)

+ func (*CancelExecutionRequest) ProtoMessage()

+ func (x *CancelExecutionRequest) GetExecutionId() string

+ func (x *CancelExecutionRequest) GetWorkflowId() string

+ func (x *CancelExecutionRequest) ProtoReflect() protoreflect.Message

+ func (x *CancelExecutionRequest) Reset()

+ func (x *CancelExecutionRequest) String() string

+ type CancelExecutionResponse struct

+ func (*CancelExecutionResponse) Descriptor() ([]byte, []int)

+ func (*CancelExecutionResponse) ProtoMessage()

+ func (x *CancelExecutionResponse) ProtoReflect() protoreflect.Message

+ func (x *CancelExecutionResponse) Reset()

+ func (x *CancelExecutionResponse) String() string

+ type CreateWorkflowRequest struct

+ Workflow *Workflow

+ func (*CreateWorkflowRequest) Descriptor() ([]byte, []int)

+ func (*CreateWorkflowRequest) ProtoMessage()

+ func (x *CreateWorkflowRequest) GetWorkflow() *Workflow

+ func (x *CreateWorkflowRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateWorkflowRequest) Reset()

+ func (x *CreateWorkflowRequest) String() string

+ type CreateWorkflowResponse struct

+ Workflow *Workflow

+ func (*CreateWorkflowResponse) Descriptor() ([]byte, []int)

+ func (*CreateWorkflowResponse) ProtoMessage()

+ func (x *CreateWorkflowResponse) GetWorkflow() *Workflow

+ func (x *CreateWorkflowResponse) ProtoReflect() protoreflect.Message

+ func (x *CreateWorkflowResponse) Reset()

+ func (x *CreateWorkflowResponse) String() string

+ type DeleteNodeQueueItemRequest struct

+ ItemId string

+ NodeId string

+ WorkflowId string

+ func (*DeleteNodeQueueItemRequest) Descriptor() ([]byte, []int)

+ func (*DeleteNodeQueueItemRequest) ProtoMessage()

+ func (x *DeleteNodeQueueItemRequest) GetItemId() string

+ func (x *DeleteNodeQueueItemRequest) GetNodeId() string

+ func (x *DeleteNodeQueueItemRequest) GetWorkflowId() string

+ func (x *DeleteNodeQueueItemRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteNodeQueueItemRequest) Reset()

+ func (x *DeleteNodeQueueItemRequest) String() string

+ type DeleteNodeQueueItemResponse struct

+ func (*DeleteNodeQueueItemResponse) Descriptor() ([]byte, []int)

+ func (*DeleteNodeQueueItemResponse) ProtoMessage()

+ func (x *DeleteNodeQueueItemResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteNodeQueueItemResponse) Reset()

+ func (x *DeleteNodeQueueItemResponse) String() string

+ type DeleteWorkflowRequest struct

+ Id string

+ func (*DeleteWorkflowRequest) Descriptor() ([]byte, []int)

+ func (*DeleteWorkflowRequest) ProtoMessage()

+ func (x *DeleteWorkflowRequest) GetId() string

+ func (x *DeleteWorkflowRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteWorkflowRequest) Reset()

+ func (x *DeleteWorkflowRequest) String() string

+ type DeleteWorkflowResponse struct

+ func (*DeleteWorkflowResponse) Descriptor() ([]byte, []int)

+ func (*DeleteWorkflowResponse) ProtoMessage()

+ func (x *DeleteWorkflowResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteWorkflowResponse) Reset()

+ func (x *DeleteWorkflowResponse) String() string

+ type DescribeWorkflowRequest struct

+ Id string

+ func (*DescribeWorkflowRequest) Descriptor() ([]byte, []int)

+ func (*DescribeWorkflowRequest) ProtoMessage()

+ func (x *DescribeWorkflowRequest) GetId() string

+ func (x *DescribeWorkflowRequest) ProtoReflect() protoreflect.Message

+ func (x *DescribeWorkflowRequest) Reset()

+ func (x *DescribeWorkflowRequest) String() string

+ type DescribeWorkflowResponse struct

+ Workflow *Workflow

+ func (*DescribeWorkflowResponse) Descriptor() ([]byte, []int)

+ func (*DescribeWorkflowResponse) ProtoMessage()

+ func (x *DescribeWorkflowResponse) GetWorkflow() *Workflow

+ func (x *DescribeWorkflowResponse) ProtoReflect() protoreflect.Message

+ func (x *DescribeWorkflowResponse) Reset()

+ func (x *DescribeWorkflowResponse) String() string

+ type EmitNodeEventRequest struct

+ Channel string

+ Data *_struct.Struct

+ NodeId string

+ WorkflowId string

+ func (*EmitNodeEventRequest) Descriptor() ([]byte, []int)

+ func (*EmitNodeEventRequest) ProtoMessage()

+ func (x *EmitNodeEventRequest) GetChannel() string

+ func (x *EmitNodeEventRequest) GetData() *_struct.Struct

+ func (x *EmitNodeEventRequest) GetNodeId() string

+ func (x *EmitNodeEventRequest) GetWorkflowId() string

+ func (x *EmitNodeEventRequest) ProtoReflect() protoreflect.Message

+ func (x *EmitNodeEventRequest) Reset()

+ func (x *EmitNodeEventRequest) String() string

+ type EmitNodeEventResponse struct

+ EventId string

+ func (*EmitNodeEventResponse) Descriptor() ([]byte, []int)

+ func (*EmitNodeEventResponse) ProtoMessage()

+ func (x *EmitNodeEventResponse) GetEventId() string

+ func (x *EmitNodeEventResponse) ProtoReflect() protoreflect.Message

+ func (x *EmitNodeEventResponse) Reset()

+ func (x *EmitNodeEventResponse) String() string

+ type InvokeNodeExecutionActionRequest struct

+ ActionName string

+ ExecutionId string

+ Parameters *_struct.Struct

+ WorkflowId string

+ func (*InvokeNodeExecutionActionRequest) Descriptor() ([]byte, []int)

+ func (*InvokeNodeExecutionActionRequest) ProtoMessage()

+ func (x *InvokeNodeExecutionActionRequest) GetActionName() string

+ func (x *InvokeNodeExecutionActionRequest) GetExecutionId() string

+ func (x *InvokeNodeExecutionActionRequest) GetParameters() *_struct.Struct

+ func (x *InvokeNodeExecutionActionRequest) GetWorkflowId() string

+ func (x *InvokeNodeExecutionActionRequest) ProtoReflect() protoreflect.Message

+ func (x *InvokeNodeExecutionActionRequest) Reset()

+ func (x *InvokeNodeExecutionActionRequest) String() string

+ type InvokeNodeExecutionActionResponse struct

+ func (*InvokeNodeExecutionActionResponse) Descriptor() ([]byte, []int)

+ func (*InvokeNodeExecutionActionResponse) ProtoMessage()

+ func (x *InvokeNodeExecutionActionResponse) ProtoReflect() protoreflect.Message

+ func (x *InvokeNodeExecutionActionResponse) Reset()

+ func (x *InvokeNodeExecutionActionResponse) String() string

+ type ListChildExecutionsRequest struct

+ ExecutionId string

+ WorkflowId string

+ func (*ListChildExecutionsRequest) Descriptor() ([]byte, []int)

+ func (*ListChildExecutionsRequest) ProtoMessage()

+ func (x *ListChildExecutionsRequest) GetExecutionId() string

+ func (x *ListChildExecutionsRequest) GetWorkflowId() string

+ func (x *ListChildExecutionsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListChildExecutionsRequest) Reset()

+ func (x *ListChildExecutionsRequest) String() string

+ type ListChildExecutionsResponse struct

+ Executions []*WorkflowNodeExecution

+ func (*ListChildExecutionsResponse) Descriptor() ([]byte, []int)

+ func (*ListChildExecutionsResponse) ProtoMessage()

+ func (x *ListChildExecutionsResponse) GetExecutions() []*WorkflowNodeExecution

+ func (x *ListChildExecutionsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListChildExecutionsResponse) Reset()

+ func (x *ListChildExecutionsResponse) String() string

+ type ListEventExecutionsRequest struct

+ EventId string

+ WorkflowId string

+ func (*ListEventExecutionsRequest) Descriptor() ([]byte, []int)

+ func (*ListEventExecutionsRequest) ProtoMessage()

+ func (x *ListEventExecutionsRequest) GetEventId() string

+ func (x *ListEventExecutionsRequest) GetWorkflowId() string

+ func (x *ListEventExecutionsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListEventExecutionsRequest) Reset()

+ func (x *ListEventExecutionsRequest) String() string

+ type ListEventExecutionsResponse struct

+ Executions []*WorkflowNodeExecution

+ func (*ListEventExecutionsResponse) Descriptor() ([]byte, []int)

+ func (*ListEventExecutionsResponse) ProtoMessage()

+ func (x *ListEventExecutionsResponse) GetExecutions() []*WorkflowNodeExecution

+ func (x *ListEventExecutionsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListEventExecutionsResponse) Reset()

+ func (x *ListEventExecutionsResponse) String() string

+ type ListNodeEventsRequest struct

+ Before *timestamp.Timestamp

+ Limit uint32

+ NodeId string

+ WorkflowId string

+ func (*ListNodeEventsRequest) Descriptor() ([]byte, []int)

+ func (*ListNodeEventsRequest) ProtoMessage()

+ func (x *ListNodeEventsRequest) GetBefore() *timestamp.Timestamp

+ func (x *ListNodeEventsRequest) GetLimit() uint32

+ func (x *ListNodeEventsRequest) GetNodeId() string

+ func (x *ListNodeEventsRequest) GetWorkflowId() string

+ func (x *ListNodeEventsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListNodeEventsRequest) Reset()

+ func (x *ListNodeEventsRequest) String() string

+ type ListNodeEventsResponse struct

+ Events []*WorkflowEvent

+ HasNextPage bool

+ LastTimestamp *timestamp.Timestamp

+ TotalCount uint32

+ func (*ListNodeEventsResponse) Descriptor() ([]byte, []int)

+ func (*ListNodeEventsResponse) ProtoMessage()

+ func (x *ListNodeEventsResponse) GetEvents() []*WorkflowEvent

+ func (x *ListNodeEventsResponse) GetHasNextPage() bool

+ func (x *ListNodeEventsResponse) GetLastTimestamp() *timestamp.Timestamp

+ func (x *ListNodeEventsResponse) GetTotalCount() uint32

+ func (x *ListNodeEventsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListNodeEventsResponse) Reset()

+ func (x *ListNodeEventsResponse) String() string

+ type ListNodeExecutionsRequest struct

+ Before *timestamp.Timestamp

+ Limit uint32

+ NodeId string

+ Results []WorkflowNodeExecution_Result

+ States []WorkflowNodeExecution_State

+ WorkflowId string

+ func (*ListNodeExecutionsRequest) Descriptor() ([]byte, []int)

+ func (*ListNodeExecutionsRequest) ProtoMessage()

+ func (x *ListNodeExecutionsRequest) GetBefore() *timestamp.Timestamp

+ func (x *ListNodeExecutionsRequest) GetLimit() uint32

+ func (x *ListNodeExecutionsRequest) GetNodeId() string

+ func (x *ListNodeExecutionsRequest) GetResults() []WorkflowNodeExecution_Result

+ func (x *ListNodeExecutionsRequest) GetStates() []WorkflowNodeExecution_State

+ func (x *ListNodeExecutionsRequest) GetWorkflowId() string

+ func (x *ListNodeExecutionsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListNodeExecutionsRequest) Reset()

+ func (x *ListNodeExecutionsRequest) String() string

+ type ListNodeExecutionsResponse struct

+ Executions []*WorkflowNodeExecution

+ HasNextPage bool

+ LastTimestamp *timestamp.Timestamp

+ TotalCount uint32

+ func (*ListNodeExecutionsResponse) Descriptor() ([]byte, []int)

+ func (*ListNodeExecutionsResponse) ProtoMessage()

+ func (x *ListNodeExecutionsResponse) GetExecutions() []*WorkflowNodeExecution

+ func (x *ListNodeExecutionsResponse) GetHasNextPage() bool

+ func (x *ListNodeExecutionsResponse) GetLastTimestamp() *timestamp.Timestamp

+ func (x *ListNodeExecutionsResponse) GetTotalCount() uint32

+ func (x *ListNodeExecutionsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListNodeExecutionsResponse) Reset()

+ func (x *ListNodeExecutionsResponse) String() string

+ type ListNodeQueueItemsRequest struct

+ Before *timestamp.Timestamp

+ Limit uint32

+ NodeId string

+ WorkflowId string

+ func (*ListNodeQueueItemsRequest) Descriptor() ([]byte, []int)

+ func (*ListNodeQueueItemsRequest) ProtoMessage()

+ func (x *ListNodeQueueItemsRequest) GetBefore() *timestamp.Timestamp

+ func (x *ListNodeQueueItemsRequest) GetLimit() uint32

+ func (x *ListNodeQueueItemsRequest) GetNodeId() string

+ func (x *ListNodeQueueItemsRequest) GetWorkflowId() string

+ func (x *ListNodeQueueItemsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListNodeQueueItemsRequest) Reset()

+ func (x *ListNodeQueueItemsRequest) String() string

+ type ListNodeQueueItemsResponse struct

+ HasNextPage bool

+ Items []*WorkflowNodeQueueItem

+ LastTimestamp *timestamp.Timestamp

+ TotalCount uint32

+ func (*ListNodeQueueItemsResponse) Descriptor() ([]byte, []int)

+ func (*ListNodeQueueItemsResponse) ProtoMessage()

+ func (x *ListNodeQueueItemsResponse) GetHasNextPage() bool

+ func (x *ListNodeQueueItemsResponse) GetItems() []*WorkflowNodeQueueItem

+ func (x *ListNodeQueueItemsResponse) GetLastTimestamp() *timestamp.Timestamp

+ func (x *ListNodeQueueItemsResponse) GetTotalCount() uint32

+ func (x *ListNodeQueueItemsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListNodeQueueItemsResponse) Reset()

+ func (x *ListNodeQueueItemsResponse) String() string

+ type ListWorkflowEventsRequest struct

+ Before *timestamp.Timestamp

+ Limit uint32

+ WorkflowId string

+ func (*ListWorkflowEventsRequest) Descriptor() ([]byte, []int)

+ func (*ListWorkflowEventsRequest) ProtoMessage()

+ func (x *ListWorkflowEventsRequest) GetBefore() *timestamp.Timestamp

+ func (x *ListWorkflowEventsRequest) GetLimit() uint32

+ func (x *ListWorkflowEventsRequest) GetWorkflowId() string

+ func (x *ListWorkflowEventsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListWorkflowEventsRequest) Reset()

+ func (x *ListWorkflowEventsRequest) String() string

+ type ListWorkflowEventsResponse struct

+ Events []*WorkflowEvent

+ HasNextPage bool

+ LastTimestamp *timestamp.Timestamp

+ TotalCount uint32

+ func (*ListWorkflowEventsResponse) Descriptor() ([]byte, []int)

+ func (*ListWorkflowEventsResponse) ProtoMessage()

+ func (x *ListWorkflowEventsResponse) GetEvents() []*WorkflowEvent

+ func (x *ListWorkflowEventsResponse) GetHasNextPage() bool

+ func (x *ListWorkflowEventsResponse) GetLastTimestamp() *timestamp.Timestamp

+ func (x *ListWorkflowEventsResponse) GetTotalCount() uint32

+ func (x *ListWorkflowEventsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListWorkflowEventsResponse) Reset()

+ func (x *ListWorkflowEventsResponse) String() string

+ type ListWorkflowsRequest struct

+ func (*ListWorkflowsRequest) Descriptor() ([]byte, []int)

+ func (*ListWorkflowsRequest) ProtoMessage()

+ func (x *ListWorkflowsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListWorkflowsRequest) Reset()

+ func (x *ListWorkflowsRequest) String() string

+ type ListWorkflowsResponse struct

+ Workflows []*Workflow

+ func (*ListWorkflowsResponse) Descriptor() ([]byte, []int)

+ func (*ListWorkflowsResponse) ProtoMessage()

+ func (x *ListWorkflowsResponse) GetWorkflows() []*Workflow

+ func (x *ListWorkflowsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListWorkflowsResponse) Reset()

+ func (x *ListWorkflowsResponse) String() string

+ type UnimplementedWorkflowsServer struct

+ func (UnimplementedWorkflowsServer) CancelExecution(context.Context, *CancelExecutionRequest) (*CancelExecutionResponse, error)

+ func (UnimplementedWorkflowsServer) CreateWorkflow(context.Context, *CreateWorkflowRequest) (*CreateWorkflowResponse, error)

+ func (UnimplementedWorkflowsServer) DeleteNodeQueueItem(context.Context, *DeleteNodeQueueItemRequest) (*DeleteNodeQueueItemResponse, error)

+ func (UnimplementedWorkflowsServer) DeleteWorkflow(context.Context, *DeleteWorkflowRequest) (*DeleteWorkflowResponse, error)

+ func (UnimplementedWorkflowsServer) DescribeWorkflow(context.Context, *DescribeWorkflowRequest) (*DescribeWorkflowResponse, error)

+ func (UnimplementedWorkflowsServer) EmitNodeEvent(context.Context, *EmitNodeEventRequest) (*EmitNodeEventResponse, error)

+ func (UnimplementedWorkflowsServer) InvokeNodeExecutionAction(context.Context, *InvokeNodeExecutionActionRequest) (*InvokeNodeExecutionActionResponse, error)

+ func (UnimplementedWorkflowsServer) ListChildExecutions(context.Context, *ListChildExecutionsRequest) (*ListChildExecutionsResponse, error)

+ func (UnimplementedWorkflowsServer) ListEventExecutions(context.Context, *ListEventExecutionsRequest) (*ListEventExecutionsResponse, error)

+ func (UnimplementedWorkflowsServer) ListNodeEvents(context.Context, *ListNodeEventsRequest) (*ListNodeEventsResponse, error)

+ func (UnimplementedWorkflowsServer) ListNodeExecutions(context.Context, *ListNodeExecutionsRequest) (*ListNodeExecutionsResponse, error)

+ func (UnimplementedWorkflowsServer) ListNodeQueueItems(context.Context, *ListNodeQueueItemsRequest) (*ListNodeQueueItemsResponse, error)

+ func (UnimplementedWorkflowsServer) ListWorkflowEvents(context.Context, *ListWorkflowEventsRequest) (*ListWorkflowEventsResponse, error)

+ func (UnimplementedWorkflowsServer) ListWorkflows(context.Context, *ListWorkflowsRequest) (*ListWorkflowsResponse, error)

+ func (UnimplementedWorkflowsServer) UpdateWorkflow(context.Context, *UpdateWorkflowRequest) (*UpdateWorkflowResponse, error)

+ type UnsafeWorkflowsServer interface

+ type UpdateWorkflowRequest struct

+ Id string

+ Workflow *Workflow

+ func (*UpdateWorkflowRequest) Descriptor() ([]byte, []int)

+ func (*UpdateWorkflowRequest) ProtoMessage()

+ func (x *UpdateWorkflowRequest) GetId() string

+ func (x *UpdateWorkflowRequest) GetWorkflow() *Workflow

+ func (x *UpdateWorkflowRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateWorkflowRequest) Reset()

+ func (x *UpdateWorkflowRequest) String() string

+ type UpdateWorkflowResponse struct

+ Workflow *Workflow

+ func (*UpdateWorkflowResponse) Descriptor() ([]byte, []int)

+ func (*UpdateWorkflowResponse) ProtoMessage()

+ func (x *UpdateWorkflowResponse) GetWorkflow() *Workflow

+ func (x *UpdateWorkflowResponse) ProtoReflect() protoreflect.Message

+ func (x *UpdateWorkflowResponse) Reset()

+ func (x *UpdateWorkflowResponse) String() string

+ type UserRef struct

+ Id string

+ Name string

+ func (*UserRef) Descriptor() ([]byte, []int)

+ func (*UserRef) ProtoMessage()

+ func (x *UserRef) GetId() string

+ func (x *UserRef) GetName() string

+ func (x *UserRef) ProtoReflect() protoreflect.Message

+ func (x *UserRef) Reset()

+ func (x *UserRef) String() string

+ type Workflow struct

+ Metadata *Workflow_Metadata

+ Spec *Workflow_Spec

+ Status *Workflow_Status

+ func (*Workflow) Descriptor() ([]byte, []int)

+ func (*Workflow) ProtoMessage()

+ func (x *Workflow) GetMetadata() *Workflow_Metadata

+ func (x *Workflow) GetSpec() *Workflow_Spec

+ func (x *Workflow) GetStatus() *Workflow_Status

+ func (x *Workflow) ProtoReflect() protoreflect.Message

+ func (x *Workflow) Reset()

+ func (x *Workflow) String() string

+ type WorkflowEvent struct

+ Channel string

+ CreatedAt *timestamp.Timestamp

+ Data *_struct.Struct

+ Id string

+ NodeId string

+ WorkflowId string

+ func (*WorkflowEvent) Descriptor() ([]byte, []int)

+ func (*WorkflowEvent) ProtoMessage()

+ func (x *WorkflowEvent) GetChannel() string

+ func (x *WorkflowEvent) GetCreatedAt() *timestamp.Timestamp

+ func (x *WorkflowEvent) GetData() *_struct.Struct

+ func (x *WorkflowEvent) GetId() string

+ func (x *WorkflowEvent) GetNodeId() string

+ func (x *WorkflowEvent) GetWorkflowId() string

+ func (x *WorkflowEvent) ProtoReflect() protoreflect.Message

+ func (x *WorkflowEvent) Reset()

+ func (x *WorkflowEvent) String() string

+ type WorkflowNodeEventMessage struct

+ Id string

+ NodeId string

+ Timestamp *timestamp.Timestamp

+ WorkflowId string

+ func (*WorkflowNodeEventMessage) Descriptor() ([]byte, []int)

+ func (*WorkflowNodeEventMessage) ProtoMessage()

+ func (x *WorkflowNodeEventMessage) GetId() string

+ func (x *WorkflowNodeEventMessage) GetNodeId() string

+ func (x *WorkflowNodeEventMessage) GetTimestamp() *timestamp.Timestamp

+ func (x *WorkflowNodeEventMessage) GetWorkflowId() string

+ func (x *WorkflowNodeEventMessage) ProtoReflect() protoreflect.Message

+ func (x *WorkflowNodeEventMessage) Reset()

+ func (x *WorkflowNodeEventMessage) String() string

+ type WorkflowNodeExecution struct

+ ChildExecutions []*WorkflowNodeExecution

+ Configuration *_struct.Struct

+ CreatedAt *timestamp.Timestamp

+ Id string

+ Input *_struct.Struct

+ Metadata *_struct.Struct

+ NodeId string

+ Outputs *_struct.Struct

+ ParentExecutionId string

+ PreviousExecutionId string

+ Result WorkflowNodeExecution_Result

+ ResultMessage string

+ ResultReason WorkflowNodeExecution_ResultReason

+ RootEvent *WorkflowEvent

+ State WorkflowNodeExecution_State

+ UpdatedAt *timestamp.Timestamp

+ WorkflowId string

+ func (*WorkflowNodeExecution) Descriptor() ([]byte, []int)

+ func (*WorkflowNodeExecution) ProtoMessage()

+ func (x *WorkflowNodeExecution) GetChildExecutions() []*WorkflowNodeExecution

+ func (x *WorkflowNodeExecution) GetConfiguration() *_struct.Struct

+ func (x *WorkflowNodeExecution) GetCreatedAt() *timestamp.Timestamp

+ func (x *WorkflowNodeExecution) GetId() string

+ func (x *WorkflowNodeExecution) GetInput() *_struct.Struct

+ func (x *WorkflowNodeExecution) GetMetadata() *_struct.Struct

+ func (x *WorkflowNodeExecution) GetNodeId() string

+ func (x *WorkflowNodeExecution) GetOutputs() *_struct.Struct

+ func (x *WorkflowNodeExecution) GetParentExecutionId() string

+ func (x *WorkflowNodeExecution) GetPreviousExecutionId() string

+ func (x *WorkflowNodeExecution) GetResult() WorkflowNodeExecution_Result

+ func (x *WorkflowNodeExecution) GetResultMessage() string

+ func (x *WorkflowNodeExecution) GetResultReason() WorkflowNodeExecution_ResultReason

+ func (x *WorkflowNodeExecution) GetRootEvent() *WorkflowEvent

+ func (x *WorkflowNodeExecution) GetState() WorkflowNodeExecution_State

+ func (x *WorkflowNodeExecution) GetUpdatedAt() *timestamp.Timestamp

+ func (x *WorkflowNodeExecution) GetWorkflowId() string

+ func (x *WorkflowNodeExecution) ProtoReflect() protoreflect.Message

+ func (x *WorkflowNodeExecution) Reset()

+ func (x *WorkflowNodeExecution) String() string

+ type WorkflowNodeExecutionMessage struct

+ Id string

+ NodeId string

+ Timestamp *timestamp.Timestamp

+ WorkflowId string

+ func (*WorkflowNodeExecutionMessage) Descriptor() ([]byte, []int)

+ func (*WorkflowNodeExecutionMessage) ProtoMessage()

+ func (x *WorkflowNodeExecutionMessage) GetId() string

+ func (x *WorkflowNodeExecutionMessage) GetNodeId() string

+ func (x *WorkflowNodeExecutionMessage) GetTimestamp() *timestamp.Timestamp

+ func (x *WorkflowNodeExecutionMessage) GetWorkflowId() string

+ func (x *WorkflowNodeExecutionMessage) ProtoReflect() protoreflect.Message

+ func (x *WorkflowNodeExecutionMessage) Reset()

+ func (x *WorkflowNodeExecutionMessage) String() string

+ type WorkflowNodeExecution_Result int32

+ const WorkflowNodeExecution_RESULT_CANCELLED

+ const WorkflowNodeExecution_RESULT_FAILED

+ const WorkflowNodeExecution_RESULT_PASSED

+ const WorkflowNodeExecution_RESULT_UNKNOWN

+ func (WorkflowNodeExecution_Result) Descriptor() protoreflect.EnumDescriptor

+ func (WorkflowNodeExecution_Result) EnumDescriptor() ([]byte, []int)

+ func (WorkflowNodeExecution_Result) Type() protoreflect.EnumType

+ func (x WorkflowNodeExecution_Result) Enum() *WorkflowNodeExecution_Result

+ func (x WorkflowNodeExecution_Result) Number() protoreflect.EnumNumber

+ func (x WorkflowNodeExecution_Result) String() string

+ type WorkflowNodeExecution_ResultReason int32

+ const WorkflowNodeExecution_RESULT_REASON_ERROR

+ const WorkflowNodeExecution_RESULT_REASON_OK

+ func (WorkflowNodeExecution_ResultReason) Descriptor() protoreflect.EnumDescriptor

+ func (WorkflowNodeExecution_ResultReason) EnumDescriptor() ([]byte, []int)

+ func (WorkflowNodeExecution_ResultReason) Type() protoreflect.EnumType

+ func (x WorkflowNodeExecution_ResultReason) Enum() *WorkflowNodeExecution_ResultReason

+ func (x WorkflowNodeExecution_ResultReason) Number() protoreflect.EnumNumber

+ func (x WorkflowNodeExecution_ResultReason) String() string

+ type WorkflowNodeExecution_State int32

+ const WorkflowNodeExecution_STATE_FINISHED

+ const WorkflowNodeExecution_STATE_PENDING

+ const WorkflowNodeExecution_STATE_STARTED

+ const WorkflowNodeExecution_STATE_UNKNOWN

+ func (WorkflowNodeExecution_State) Descriptor() protoreflect.EnumDescriptor

+ func (WorkflowNodeExecution_State) EnumDescriptor() ([]byte, []int)

+ func (WorkflowNodeExecution_State) Type() protoreflect.EnumType

+ func (x WorkflowNodeExecution_State) Enum() *WorkflowNodeExecution_State

+ func (x WorkflowNodeExecution_State) Number() protoreflect.EnumNumber

+ func (x WorkflowNodeExecution_State) String() string

+ type WorkflowNodeQueueItem struct

+ CreatedAt *timestamp.Timestamp

+ Id string

+ Input *_struct.Struct

+ NodeId string

+ RootEvent *WorkflowEvent

+ WorkflowId string

+ func (*WorkflowNodeQueueItem) Descriptor() ([]byte, []int)

+ func (*WorkflowNodeQueueItem) ProtoMessage()

+ func (x *WorkflowNodeQueueItem) GetCreatedAt() *timestamp.Timestamp

+ func (x *WorkflowNodeQueueItem) GetId() string

+ func (x *WorkflowNodeQueueItem) GetInput() *_struct.Struct

+ func (x *WorkflowNodeQueueItem) GetNodeId() string

+ func (x *WorkflowNodeQueueItem) GetRootEvent() *WorkflowEvent

+ func (x *WorkflowNodeQueueItem) GetWorkflowId() string

+ func (x *WorkflowNodeQueueItem) ProtoReflect() protoreflect.Message

+ func (x *WorkflowNodeQueueItem) Reset()

+ func (x *WorkflowNodeQueueItem) String() string

+ type WorkflowNodeQueueItemMessage struct

+ Id string

+ NodeId string

+ Timestamp *timestamp.Timestamp

+ WorkflowId string

+ func (*WorkflowNodeQueueItemMessage) Descriptor() ([]byte, []int)

+ func (*WorkflowNodeQueueItemMessage) ProtoMessage()

+ func (x *WorkflowNodeQueueItemMessage) GetId() string

+ func (x *WorkflowNodeQueueItemMessage) GetNodeId() string

+ func (x *WorkflowNodeQueueItemMessage) GetTimestamp() *timestamp.Timestamp

+ func (x *WorkflowNodeQueueItemMessage) GetWorkflowId() string

+ func (x *WorkflowNodeQueueItemMessage) ProtoReflect() protoreflect.Message

+ func (x *WorkflowNodeQueueItemMessage) Reset()

+ func (x *WorkflowNodeQueueItemMessage) String() string

+ type Workflow_Metadata struct

+ CreatedAt *timestamp.Timestamp

+ CreatedBy *UserRef

+ Description string

+ Id string

+ Name string

+ OrganizationId string

+ UpdatedAt *timestamp.Timestamp

+ func (*Workflow_Metadata) Descriptor() ([]byte, []int)

+ func (*Workflow_Metadata) ProtoMessage()

+ func (x *Workflow_Metadata) GetCreatedAt() *timestamp.Timestamp

+ func (x *Workflow_Metadata) GetCreatedBy() *UserRef

+ func (x *Workflow_Metadata) GetDescription() string

+ func (x *Workflow_Metadata) GetId() string

+ func (x *Workflow_Metadata) GetName() string

+ func (x *Workflow_Metadata) GetOrganizationId() string

+ func (x *Workflow_Metadata) GetUpdatedAt() *timestamp.Timestamp

+ func (x *Workflow_Metadata) ProtoReflect() protoreflect.Message

+ func (x *Workflow_Metadata) Reset()

+ func (x *Workflow_Metadata) String() string

+ type Workflow_Spec struct

+ Edges []*components.Edge

+ Nodes []*components.Node

+ func (*Workflow_Spec) Descriptor() ([]byte, []int)

+ func (*Workflow_Spec) ProtoMessage()

+ func (x *Workflow_Spec) GetEdges() []*components.Edge

+ func (x *Workflow_Spec) GetNodes() []*components.Node

+ func (x *Workflow_Spec) ProtoReflect() protoreflect.Message

+ func (x *Workflow_Spec) Reset()

+ func (x *Workflow_Spec) String() string

+ type Workflow_Status struct

+ LastEvents []*WorkflowEvent

+ LastExecutions []*WorkflowNodeExecution

+ NextQueueItems []*WorkflowNodeQueueItem

+ func (*Workflow_Status) Descriptor() ([]byte, []int)

+ func (*Workflow_Status) ProtoMessage()

+ func (x *Workflow_Status) GetLastEvents() []*WorkflowEvent

+ func (x *Workflow_Status) GetLastExecutions() []*WorkflowNodeExecution

+ func (x *Workflow_Status) GetNextQueueItems() []*WorkflowNodeQueueItem

+ func (x *Workflow_Status) ProtoReflect() protoreflect.Message

+ func (x *Workflow_Status) Reset()

+ func (x *Workflow_Status) String() string

+ type WorkflowsClient interface

+ CancelExecution func(ctx context.Context, in *CancelExecutionRequest, opts ...grpc.CallOption) (*CancelExecutionResponse, error)

+ CreateWorkflow func(ctx context.Context, in *CreateWorkflowRequest, opts ...grpc.CallOption) (*CreateWorkflowResponse, error)

+ DeleteNodeQueueItem func(ctx context.Context, in *DeleteNodeQueueItemRequest, opts ...grpc.CallOption) (*DeleteNodeQueueItemResponse, error)

+ DeleteWorkflow func(ctx context.Context, in *DeleteWorkflowRequest, opts ...grpc.CallOption) (*DeleteWorkflowResponse, error)

+ DescribeWorkflow func(ctx context.Context, in *DescribeWorkflowRequest, opts ...grpc.CallOption) (*DescribeWorkflowResponse, error)

+ EmitNodeEvent func(ctx context.Context, in *EmitNodeEventRequest, opts ...grpc.CallOption) (*EmitNodeEventResponse, error)

+ InvokeNodeExecutionAction func(ctx context.Context, in *InvokeNodeExecutionActionRequest, ...) (*InvokeNodeExecutionActionResponse, error)

+ ListChildExecutions func(ctx context.Context, in *ListChildExecutionsRequest, opts ...grpc.CallOption) (*ListChildExecutionsResponse, error)

+ ListEventExecutions func(ctx context.Context, in *ListEventExecutionsRequest, opts ...grpc.CallOption) (*ListEventExecutionsResponse, error)

+ ListNodeEvents func(ctx context.Context, in *ListNodeEventsRequest, opts ...grpc.CallOption) (*ListNodeEventsResponse, error)

+ ListNodeExecutions func(ctx context.Context, in *ListNodeExecutionsRequest, opts ...grpc.CallOption) (*ListNodeExecutionsResponse, error)

+ ListNodeQueueItems func(ctx context.Context, in *ListNodeQueueItemsRequest, opts ...grpc.CallOption) (*ListNodeQueueItemsResponse, error)

+ ListWorkflowEvents func(ctx context.Context, in *ListWorkflowEventsRequest, opts ...grpc.CallOption) (*ListWorkflowEventsResponse, error)

+ ListWorkflows func(ctx context.Context, in *ListWorkflowsRequest, opts ...grpc.CallOption) (*ListWorkflowsResponse, error)

+ UpdateWorkflow func(ctx context.Context, in *UpdateWorkflowRequest, opts ...grpc.CallOption) (*UpdateWorkflowResponse, error)

+ func NewWorkflowsClient(cc grpc.ClientConnInterface) WorkflowsClient

+ type WorkflowsServer interface

+ CancelExecution func(context.Context, *CancelExecutionRequest) (*CancelExecutionResponse, error)

+ CreateWorkflow func(context.Context, *CreateWorkflowRequest) (*CreateWorkflowResponse, error)

+ DeleteNodeQueueItem func(context.Context, *DeleteNodeQueueItemRequest) (*DeleteNodeQueueItemResponse, error)

+ DeleteWorkflow func(context.Context, *DeleteWorkflowRequest) (*DeleteWorkflowResponse, error)

+ DescribeWorkflow func(context.Context, *DescribeWorkflowRequest) (*DescribeWorkflowResponse, error)

+ EmitNodeEvent func(context.Context, *EmitNodeEventRequest) (*EmitNodeEventResponse, error)

+ InvokeNodeExecutionAction func(context.Context, *InvokeNodeExecutionActionRequest) (*InvokeNodeExecutionActionResponse, error)

+ ListChildExecutions func(context.Context, *ListChildExecutionsRequest) (*ListChildExecutionsResponse, error)

+ ListEventExecutions func(context.Context, *ListEventExecutionsRequest) (*ListEventExecutionsResponse, error)

+ ListNodeEvents func(context.Context, *ListNodeEventsRequest) (*ListNodeEventsResponse, error)

+ ListNodeExecutions func(context.Context, *ListNodeExecutionsRequest) (*ListNodeExecutionsResponse, error)

+ ListNodeQueueItems func(context.Context, *ListNodeQueueItemsRequest) (*ListNodeQueueItemsResponse, error)

+ ListWorkflowEvents func(context.Context, *ListWorkflowEventsRequest) (*ListWorkflowEventsResponse, error)

+ ListWorkflows func(context.Context, *ListWorkflowsRequest) (*ListWorkflowsResponse, error)

+ UpdateWorkflow func(context.Context, *UpdateWorkflowRequest) (*UpdateWorkflowResponse, error)