Documentation ¶
Index ¶
- Variables
- func Get[V any](vars Vars, key string) (V, error)
- func Marshal[T any](v *Vars, key string, t *T) error
- func Unmarshal[T any](vars Vars, key string) (*T, error)
- type ApiAuthenticationRequest
- func (*ApiAuthenticationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApiAuthenticationRequest) GetHeaders() map[string]string
- func (*ApiAuthenticationRequest) ProtoMessage()
- func (x *ApiAuthenticationRequest) ProtoReflect() protoreflect.Message
- func (x *ApiAuthenticationRequest) Reset()
- func (x *ApiAuthenticationRequest) String() string
- type ApiAuthenticationResponse
- func (*ApiAuthenticationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApiAuthenticationResponse) GetAuthenticated() bool
- func (x *ApiAuthenticationResponse) GetUser() string
- func (*ApiAuthenticationResponse) ProtoMessage()
- func (x *ApiAuthenticationResponse) ProtoReflect() protoreflect.Message
- func (x *ApiAuthenticationResponse) Reset()
- func (x *ApiAuthenticationResponse) String() string
- type ApiAuthorizationRequest
- func (*ApiAuthorizationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApiAuthorizationRequest) GetFunction() string
- func (x *ApiAuthorizationRequest) GetHeaders() map[string]string
- func (x *ApiAuthorizationRequest) GetUser() string
- func (x *ApiAuthorizationRequest) GetWorkflowName() string
- func (*ApiAuthorizationRequest) ProtoMessage()
- func (x *ApiAuthorizationRequest) ProtoReflect() protoreflect.Message
- func (x *ApiAuthorizationRequest) Reset()
- func (x *ApiAuthorizationRequest) String() string
- type ApiAuthorizationResponse
- func (*ApiAuthorizationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApiAuthorizationResponse) GetAuthorized() bool
- func (x *ApiAuthorizationResponse) GetUserId() string
- func (*ApiAuthorizationResponse) ProtoMessage()
- func (x *ApiAuthorizationResponse) ProtoReflect() protoreflect.Message
- func (x *ApiAuthorizationResponse) Reset()
- func (x *ApiAuthorizationResponse) String() string
- type CancelProcessInstanceRequest
- func (*CancelProcessInstanceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CancelProcessInstanceRequest) GetError() *Error
- func (x *CancelProcessInstanceRequest) GetId() string
- func (x *CancelProcessInstanceRequest) GetState() CancellationState
- func (*CancelProcessInstanceRequest) ProtoMessage()
- func (x *CancelProcessInstanceRequest) ProtoReflect() protoreflect.Message
- func (x *CancelProcessInstanceRequest) Reset()
- func (x *CancelProcessInstanceRequest) String() string
- type CancelProcessInstanceResponse
- func (*CancelProcessInstanceResponse) Descriptor() ([]byte, []int)deprecated
- func (*CancelProcessInstanceResponse) ProtoMessage()
- func (x *CancelProcessInstanceResponse) ProtoReflect() protoreflect.Message
- func (x *CancelProcessInstanceResponse) Reset()
- func (x *CancelProcessInstanceResponse) String() string
- type CancellationState
- func (CancellationState) Descriptor() protoreflect.EnumDescriptor
- func (x CancellationState) Enum() *CancellationState
- func (CancellationState) EnumDescriptor() ([]byte, []int)deprecated
- func (x CancellationState) Number() protoreflect.EnumNumber
- func (x CancellationState) String() string
- func (CancellationState) Type() protoreflect.EnumType
- type CatchError
- func (*CatchError) Descriptor() ([]byte, []int)deprecated
- func (x *CatchError) GetErrorId() string
- func (x *CatchError) GetId() string
- func (x *CatchError) GetOutputTransform() map[string]string
- func (x *CatchError) GetTarget() string
- func (*CatchError) ProtoMessage()
- func (x *CatchError) ProtoReflect() protoreflect.Message
- func (x *CatchError) Reset()
- func (x *CatchError) String() string
- type Collaboration
- func (*Collaboration) Descriptor() ([]byte, []int)deprecated
- func (x *Collaboration) GetMessageFlow() []*MessageFlow
- func (x *Collaboration) GetParticipant() []*Participant
- func (*Collaboration) ProtoMessage()
- func (x *Collaboration) ProtoReflect() protoreflect.Message
- func (x *Collaboration) Reset()
- func (x *Collaboration) String() string
- type CompleteManualTaskRequest
- func (*CompleteManualTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CompleteManualTaskRequest) GetTrackingId() string
- func (x *CompleteManualTaskRequest) GetVars() []byte
- func (*CompleteManualTaskRequest) ProtoMessage()
- func (x *CompleteManualTaskRequest) ProtoReflect() protoreflect.Message
- func (x *CompleteManualTaskRequest) Reset()
- func (x *CompleteManualTaskRequest) String() string
- type CompleteManualTaskResponse
- type CompleteSendMessageRequest
- func (*CompleteSendMessageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CompleteSendMessageRequest) GetTrackingId() string
- func (x *CompleteSendMessageRequest) GetVars() []byte
- func (*CompleteSendMessageRequest) ProtoMessage()
- func (x *CompleteSendMessageRequest) ProtoReflect() protoreflect.Message
- func (x *CompleteSendMessageRequest) Reset()
- func (x *CompleteSendMessageRequest) String() string
- type CompleteSendMessageResponse
- type CompleteServiceTaskRequest
- func (*CompleteServiceTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CompleteServiceTaskRequest) GetTrackingId() string
- func (x *CompleteServiceTaskRequest) GetVars() []byte
- func (*CompleteServiceTaskRequest) ProtoMessage()
- func (x *CompleteServiceTaskRequest) ProtoReflect() protoreflect.Message
- func (x *CompleteServiceTaskRequest) Reset()
- func (x *CompleteServiceTaskRequest) String() string
- type CompleteServiceTaskResponse
- type CompleteUserTaskRequest
- func (*CompleteUserTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CompleteUserTaskRequest) GetOwner() string
- func (x *CompleteUserTaskRequest) GetTrackingId() string
- func (x *CompleteUserTaskRequest) GetVars() []byte
- func (*CompleteUserTaskRequest) ProtoMessage()
- func (x *CompleteUserTaskRequest) ProtoReflect() protoreflect.Message
- func (x *CompleteUserTaskRequest) Reset()
- func (x *CompleteUserTaskRequest) String() string
- type CompleteUserTaskResponse
- type DefaultRetryExceededBehaviour
- func (*DefaultRetryExceededBehaviour) Descriptor() ([]byte, []int)deprecated
- func (x *DefaultRetryExceededBehaviour) GetAction() RetryErrorAction
- func (x *DefaultRetryExceededBehaviour) GetErrorCode() string
- func (x *DefaultRetryExceededBehaviour) GetVariable() string
- func (x *DefaultRetryExceededBehaviour) GetVariableType() string
- func (x *DefaultRetryExceededBehaviour) GetVariableValue() string
- func (*DefaultRetryExceededBehaviour) ProtoMessage()
- func (x *DefaultRetryExceededBehaviour) ProtoReflect() protoreflect.Message
- func (x *DefaultRetryExceededBehaviour) Reset()
- func (x *DefaultRetryExceededBehaviour) String() string
- type DefaultTaskRetry
- func (*DefaultTaskRetry) Descriptor() ([]byte, []int)deprecated
- func (x *DefaultTaskRetry) GetDefaultExceeded() *DefaultRetryExceededBehaviour
- func (x *DefaultTaskRetry) GetInitMilli() int64
- func (x *DefaultTaskRetry) GetIntervalMilli() int64
- func (x *DefaultTaskRetry) GetMaxMilli() int64
- func (x *DefaultTaskRetry) GetNumber() uint32
- func (x *DefaultTaskRetry) GetStrategy() RetryStrategy
- func (*DefaultTaskRetry) ProtoMessage()
- func (x *DefaultTaskRetry) ProtoReflect() protoreflect.Message
- func (x *DefaultTaskRetry) Reset()
- func (x *DefaultTaskRetry) String() string
- type DeprecateServiceTaskRequest
- func (*DeprecateServiceTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeprecateServiceTaskRequest) GetName() string
- func (*DeprecateServiceTaskRequest) ProtoMessage()
- func (x *DeprecateServiceTaskRequest) ProtoReflect() protoreflect.Message
- func (x *DeprecateServiceTaskRequest) Reset()
- func (x *DeprecateServiceTaskRequest) String() string
- type DeprecateServiceTaskResponse
- func (*DeprecateServiceTaskResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeprecateServiceTaskResponse) GetSuccess() bool
- func (x *DeprecateServiceTaskResponse) GetUsage() *TaskSpecUsageReport
- func (*DeprecateServiceTaskResponse) ProtoMessage()
- func (x *DeprecateServiceTaskResponse) ProtoReflect() protoreflect.Message
- func (x *DeprecateServiceTaskResponse) Reset()
- func (x *DeprecateServiceTaskResponse) String() string
- type Element
- func (*Element) Descriptor() ([]byte, []int)deprecated
- func (x *Element) GetBoundaryTimer() []*Timer
- func (x *Element) GetCandidateGroups() string
- func (x *Element) GetCandidates() string
- func (x *Element) GetDocumentation() string
- func (x *Element) GetError() *Error
- func (x *Element) GetErrors() []*CatchError
- func (x *Element) GetExecute() string
- func (x *Element) GetGateway() *GatewaySpec
- func (x *Element) GetId() string
- func (x *Element) GetInputTransform() map[string]string
- func (x *Element) GetIteration() *Iteration
- func (x *Element) GetMsg() string
- func (x *Element) GetName() string
- func (x *Element) GetOutbound() *Targets
- func (x *Element) GetOutputTransform() map[string]string
- func (x *Element) GetProcess() *Process
- func (x *Element) GetRetryBehaviour() *DefaultTaskRetry
- func (x *Element) GetTimer() *WorkflowTimerDefinition
- func (x *Element) GetType() string
- func (x *Element) GetVersion() string
- func (*Element) ProtoMessage()
- func (x *Element) ProtoReflect() protoreflect.Message
- func (x *Element) Reset()
- func (x *Element) String() string
- type Error
- type Exchange
- type Execution
- func (*Execution) Descriptor() ([]byte, []int)deprecated
- func (x *Execution) GetExecutionId() string
- func (x *Execution) GetProcessInstanceId() []string
- func (x *Execution) GetWorkflowId() string
- func (x *Execution) GetWorkflowName() string
- func (*Execution) ProtoMessage()
- func (x *Execution) ProtoReflect() protoreflect.Message
- func (x *Execution) Reset()
- func (x *Execution) String() string
- type Gateway
- func (*Gateway) Descriptor() ([]byte, []int)deprecated
- func (x *Gateway) GetMetExpectations() map[string]string
- func (x *Gateway) GetVars() [][]byte
- func (x *Gateway) GetVisits() int64
- func (*Gateway) ProtoMessage()
- func (x *Gateway) ProtoReflect() protoreflect.Message
- func (x *Gateway) Reset()
- func (x *Gateway) String() string
- type GatewayDirection
- func (GatewayDirection) Descriptor() protoreflect.EnumDescriptor
- func (x GatewayDirection) Enum() *GatewayDirection
- func (GatewayDirection) EnumDescriptor() ([]byte, []int)deprecated
- func (x GatewayDirection) Number() protoreflect.EnumNumber
- func (x GatewayDirection) String() string
- func (GatewayDirection) Type() protoreflect.EnumType
- type GatewayExpectations
- func (*GatewayExpectations) Descriptor() ([]byte, []int)deprecated
- func (x *GatewayExpectations) GetExpectedPaths() []string
- func (*GatewayExpectations) ProtoMessage()
- func (x *GatewayExpectations) ProtoReflect() protoreflect.Message
- func (x *GatewayExpectations) Reset()
- func (x *GatewayExpectations) String() string
- type GatewaySpec
- func (*GatewaySpec) Descriptor() ([]byte, []int)deprecated
- func (x *GatewaySpec) GetDirection() GatewayDirection
- func (x *GatewaySpec) GetFixedExpectations() []string
- func (x *GatewaySpec) GetReciprocalId() string
- func (x *GatewaySpec) GetType() GatewayType
- func (*GatewaySpec) ProtoMessage()
- func (x *GatewaySpec) ProtoReflect() protoreflect.Message
- func (x *GatewaySpec) Reset()
- func (x *GatewaySpec) String() string
- type GatewayType
- func (GatewayType) Descriptor() protoreflect.EnumDescriptor
- func (x GatewayType) Enum() *GatewayType
- func (GatewayType) EnumDescriptor() ([]byte, []int)deprecated
- func (x GatewayType) Number() protoreflect.EnumNumber
- func (x GatewayType) String() string
- func (GatewayType) Type() protoreflect.EnumType
- type GetProcessHistoryRequest
- func (*GetProcessHistoryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetProcessHistoryRequest) GetId() string
- func (*GetProcessHistoryRequest) ProtoMessage()
- func (x *GetProcessHistoryRequest) ProtoReflect() protoreflect.Message
- func (x *GetProcessHistoryRequest) Reset()
- func (x *GetProcessHistoryRequest) String() string
- type GetProcessHistoryResponse
- func (*GetProcessHistoryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetProcessHistoryResponse) GetEntry() []*ProcessHistoryEntry
- func (*GetProcessHistoryResponse) ProtoMessage()
- func (x *GetProcessHistoryResponse) ProtoReflect() protoreflect.Message
- func (x *GetProcessHistoryResponse) Reset()
- func (x *GetProcessHistoryResponse) String() string
- type GetProcessInstanceStatusRequest
- func (*GetProcessInstanceStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetProcessInstanceStatusRequest) GetId() string
- func (*GetProcessInstanceStatusRequest) ProtoMessage()
- func (x *GetProcessInstanceStatusRequest) ProtoReflect() protoreflect.Message
- func (x *GetProcessInstanceStatusRequest) Reset()
- func (x *GetProcessInstanceStatusRequest) String() string
- type GetProcessInstanceStatusResponse
- func (*GetProcessInstanceStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (*GetProcessInstanceStatusResponse) ProtoMessage()
- func (x *GetProcessInstanceStatusResponse) ProtoReflect() protoreflect.Message
- func (x *GetProcessInstanceStatusResponse) Reset()
- func (x *GetProcessInstanceStatusResponse) String() string
- type GetProcessInstanceStatusResult
- func (*GetProcessInstanceStatusResult) Descriptor() ([]byte, []int)deprecated
- func (x *GetProcessInstanceStatusResult) GetProcessState() []*WorkflowState
- func (*GetProcessInstanceStatusResult) ProtoMessage()
- func (x *GetProcessInstanceStatusResult) ProtoReflect() protoreflect.Message
- func (x *GetProcessInstanceStatusResult) Reset()
- func (x *GetProcessInstanceStatusResult) String() string
- type GetServiceTaskRoutingIDRequest
- func (*GetServiceTaskRoutingIDRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetServiceTaskRoutingIDRequest) GetName() string
- func (x *GetServiceTaskRoutingIDRequest) GetRequestedId() string
- func (*GetServiceTaskRoutingIDRequest) ProtoMessage()
- func (x *GetServiceTaskRoutingIDRequest) ProtoReflect() protoreflect.Message
- func (x *GetServiceTaskRoutingIDRequest) Reset()
- func (x *GetServiceTaskRoutingIDRequest) String() string
- type GetServiceTaskRoutingIDResponse
- func (*GetServiceTaskRoutingIDResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetServiceTaskRoutingIDResponse) GetId() string
- func (*GetServiceTaskRoutingIDResponse) ProtoMessage()
- func (x *GetServiceTaskRoutingIDResponse) ProtoReflect() protoreflect.Message
- func (x *GetServiceTaskRoutingIDResponse) Reset()
- func (x *GetServiceTaskRoutingIDResponse) String() string
- type GetTaskSpecRequest
- type GetTaskSpecResponse
- func (*GetTaskSpecResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTaskSpecResponse) GetSpec() *TaskSpec
- func (*GetTaskSpecResponse) ProtoMessage()
- func (x *GetTaskSpecResponse) ProtoReflect() protoreflect.Message
- func (x *GetTaskSpecResponse) Reset()
- func (x *GetTaskSpecResponse) String() string
- type GetTaskSpecUsageRequest
- func (*GetTaskSpecUsageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTaskSpecUsageRequest) GetId() string
- func (*GetTaskSpecUsageRequest) ProtoMessage()
- func (x *GetTaskSpecUsageRequest) ProtoReflect() protoreflect.Message
- func (x *GetTaskSpecUsageRequest) Reset()
- func (x *GetTaskSpecUsageRequest) String() string
- type GetTaskSpecUsageResponse
- type GetTaskSpecVersionsRequest
- func (*GetTaskSpecVersionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTaskSpecVersionsRequest) GetName() string
- func (*GetTaskSpecVersionsRequest) ProtoMessage()
- func (x *GetTaskSpecVersionsRequest) ProtoReflect() protoreflect.Message
- func (x *GetTaskSpecVersionsRequest) Reset()
- func (x *GetTaskSpecVersionsRequest) String() string
- type GetTaskSpecVersionsResponse
- func (*GetTaskSpecVersionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTaskSpecVersionsResponse) GetVersions() *TaskSpecVersions
- func (*GetTaskSpecVersionsResponse) ProtoMessage()
- func (x *GetTaskSpecVersionsResponse) ProtoReflect() protoreflect.Message
- func (x *GetTaskSpecVersionsResponse) Reset()
- func (x *GetTaskSpecVersionsResponse) String() string
- type GetUserTaskRequest
- func (*GetUserTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetUserTaskRequest) GetOwner() string
- func (x *GetUserTaskRequest) GetTrackingId() string
- func (*GetUserTaskRequest) ProtoMessage()
- func (x *GetUserTaskRequest) ProtoReflect() protoreflect.Message
- func (x *GetUserTaskRequest) Reset()
- func (x *GetUserTaskRequest) String() string
- type GetUserTaskResponse
- func (*GetUserTaskResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetUserTaskResponse) GetDescription() string
- func (x *GetUserTaskResponse) GetName() string
- func (x *GetUserTaskResponse) GetOwner() string
- func (x *GetUserTaskResponse) GetTrackingId() string
- func (x *GetUserTaskResponse) GetVars() []byte
- func (*GetUserTaskResponse) ProtoMessage()
- func (x *GetUserTaskResponse) ProtoReflect() protoreflect.Message
- func (x *GetUserTaskResponse) Reset()
- func (x *GetUserTaskResponse) String() string
- type GetVersionInfoRequest
- func (*GetVersionInfoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetVersionInfoRequest) GetClientVersion() string
- func (x *GetVersionInfoRequest) GetCompatibleVersion() string
- func (*GetVersionInfoRequest) ProtoMessage()
- func (x *GetVersionInfoRequest) ProtoReflect() protoreflect.Message
- func (x *GetVersionInfoRequest) Reset()
- func (x *GetVersionInfoRequest) String() string
- type GetVersionInfoResponse
- func (*GetVersionInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetVersionInfoResponse) GetConnect() bool
- func (x *GetVersionInfoResponse) GetMinCompatibleVersion() string
- func (x *GetVersionInfoResponse) GetServerVersion() string
- func (*GetVersionInfoResponse) ProtoMessage()
- func (x *GetVersionInfoResponse) ProtoReflect() protoreflect.Message
- func (x *GetVersionInfoResponse) Reset()
- func (x *GetVersionInfoResponse) String() string
- type GetWorkflowRequest
- type GetWorkflowResponse
- func (*GetWorkflowResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowResponse) GetDefinition() *Workflow
- func (*GetWorkflowResponse) ProtoMessage()
- func (x *GetWorkflowResponse) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowResponse) Reset()
- func (x *GetWorkflowResponse) String() string
- type GetWorkflowVersionsRequest
- func (*GetWorkflowVersionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowVersionsRequest) GetName() string
- func (*GetWorkflowVersionsRequest) ProtoMessage()
- func (x *GetWorkflowVersionsRequest) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowVersionsRequest) Reset()
- func (x *GetWorkflowVersionsRequest) String() string
- type GetWorkflowVersionsResponse
- func (*GetWorkflowVersionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowVersionsResponse) GetVersions() *WorkflowVersions
- func (*GetWorkflowVersionsResponse) ProtoMessage()
- func (x *GetWorkflowVersionsResponse) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowVersionsResponse) Reset()
- func (x *GetWorkflowVersionsResponse) String() string
- type HandleWorkflowErrorRequest
- func (*HandleWorkflowErrorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HandleWorkflowErrorRequest) GetErrorCode() string
- func (x *HandleWorkflowErrorRequest) GetMessage() string
- func (x *HandleWorkflowErrorRequest) GetTrackingId() string
- func (x *HandleWorkflowErrorRequest) GetVars() []byte
- func (*HandleWorkflowErrorRequest) ProtoMessage()
- func (x *HandleWorkflowErrorRequest) ProtoReflect() protoreflect.Message
- func (x *HandleWorkflowErrorRequest) Reset()
- func (x *HandleWorkflowErrorRequest) String() string
- type HandleWorkflowErrorResponse
- func (*HandleWorkflowErrorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HandleWorkflowErrorResponse) GetHandled() bool
- func (*HandleWorkflowErrorResponse) ProtoMessage()
- func (x *HandleWorkflowErrorResponse) ProtoReflect() protoreflect.Message
- func (x *HandleWorkflowErrorResponse) Reset()
- func (x *HandleWorkflowErrorResponse) String() string
- type Iteration
- func (*Iteration) Descriptor() ([]byte, []int)deprecated
- func (x *Iteration) GetCollateAs() string
- func (x *Iteration) GetCollateFrom() string
- func (x *Iteration) GetCollection() string
- func (x *Iteration) GetExecute() ThreadingType
- func (x *Iteration) GetIterator() string
- func (x *Iteration) GetUntil() string
- func (*Iteration) ProtoMessage()
- func (x *Iteration) ProtoReflect() protoreflect.Message
- func (x *Iteration) Reset()
- func (x *Iteration) String() string
- type Iterator
- func (*Iterator) Descriptor() ([]byte, []int)deprecated
- func (x *Iterator) GetCollated() [][]byte
- func (x *Iterator) GetId() string
- func (x *Iterator) GetValue() [][]byte
- func (*Iterator) ProtoMessage()
- func (x *Iterator) ProtoReflect() protoreflect.Message
- func (x *Iterator) Reset()
- func (x *Iterator) String() string
- type LaunchWorkflowRequest
- func (*LaunchWorkflowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LaunchWorkflowRequest) GetName() string
- func (x *LaunchWorkflowRequest) GetVars() []byte
- func (*LaunchWorkflowRequest) ProtoMessage()
- func (x *LaunchWorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *LaunchWorkflowRequest) Reset()
- func (x *LaunchWorkflowRequest) String() string
- type LaunchWorkflowResponse
- func (*LaunchWorkflowResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LaunchWorkflowResponse) GetInstanceId() string
- func (x *LaunchWorkflowResponse) GetWorkflowId() string
- func (*LaunchWorkflowResponse) ProtoMessage()
- func (x *LaunchWorkflowResponse) ProtoReflect() protoreflect.Message
- func (x *LaunchWorkflowResponse) Reset()
- func (x *LaunchWorkflowResponse) String() string
- type ListExecutionItem
- func (*ListExecutionItem) Descriptor() ([]byte, []int)deprecated
- func (x *ListExecutionItem) GetId() string
- func (x *ListExecutionItem) GetVersion() int32
- func (*ListExecutionItem) ProtoMessage()
- func (x *ListExecutionItem) ProtoReflect() protoreflect.Message
- func (x *ListExecutionItem) Reset()
- func (x *ListExecutionItem) String() string
- type ListExecutionProcessesRequest
- func (*ListExecutionProcessesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListExecutionProcessesRequest) GetId() string
- func (*ListExecutionProcessesRequest) ProtoMessage()
- func (x *ListExecutionProcessesRequest) ProtoReflect() protoreflect.Message
- func (x *ListExecutionProcessesRequest) Reset()
- func (x *ListExecutionProcessesRequest) String() string
- type ListExecutionProcessesResponse
- func (*ListExecutionProcessesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListExecutionProcessesResponse) GetProcessInstanceId() []string
- func (*ListExecutionProcessesResponse) ProtoMessage()
- func (x *ListExecutionProcessesResponse) ProtoReflect() protoreflect.Message
- func (x *ListExecutionProcessesResponse) Reset()
- func (x *ListExecutionProcessesResponse) String() string
- type ListExecutionRequest
- func (*ListExecutionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListExecutionRequest) GetWorkflowName() string
- func (*ListExecutionRequest) ProtoMessage()
- func (x *ListExecutionRequest) ProtoReflect() protoreflect.Message
- func (x *ListExecutionRequest) Reset()
- func (x *ListExecutionRequest) String() string
- type ListExecutionResponse
- func (*ListExecutionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListExecutionResponse) GetResult() []*ListExecutionItem
- func (*ListExecutionResponse) ProtoMessage()
- func (x *ListExecutionResponse) ProtoReflect() protoreflect.Message
- func (x *ListExecutionResponse) Reset()
- func (x *ListExecutionResponse) String() string
- type ListTaskSpecUIDsRequest
- func (*ListTaskSpecUIDsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListTaskSpecUIDsRequest) GetIncludeDeprecated() bool
- func (*ListTaskSpecUIDsRequest) ProtoMessage()
- func (x *ListTaskSpecUIDsRequest) ProtoReflect() protoreflect.Message
- func (x *ListTaskSpecUIDsRequest) Reset()
- func (x *ListTaskSpecUIDsRequest) String() string
- type ListTaskSpecUIDsResponse
- func (*ListTaskSpecUIDsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListTaskSpecUIDsResponse) GetUid() []string
- func (*ListTaskSpecUIDsResponse) ProtoMessage()
- func (x *ListTaskSpecUIDsResponse) ProtoReflect() protoreflect.Message
- func (x *ListTaskSpecUIDsResponse) Reset()
- func (x *ListTaskSpecUIDsResponse) String() string
- type ListUserTasksRequest
- func (*ListUserTasksRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListUserTasksRequest) GetOwner() string
- func (*ListUserTasksRequest) ProtoMessage()
- func (x *ListUserTasksRequest) ProtoReflect() protoreflect.Message
- func (x *ListUserTasksRequest) Reset()
- func (x *ListUserTasksRequest) String() string
- type ListUserTasksResponse
- type ListWorkflowResponse
- func (*ListWorkflowResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListWorkflowResponse) GetName() string
- func (x *ListWorkflowResponse) GetVersion() int32
- func (*ListWorkflowResponse) ProtoMessage()
- func (x *ListWorkflowResponse) ProtoReflect() protoreflect.Message
- func (x *ListWorkflowResponse) Reset()
- func (x *ListWorkflowResponse) String() string
- type ListWorkflowsRequest
- type ListWorkflowsResponse
- func (*ListWorkflowsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListWorkflowsResponse) GetResult() []*ListWorkflowResponse
- func (*ListWorkflowsResponse) ProtoMessage()
- func (x *ListWorkflowsResponse) ProtoReflect() protoreflect.Message
- func (x *ListWorkflowsResponse) Reset()
- func (x *ListWorkflowsResponse) String() string
- type LogSource
- type Message
- func (*Message) Descriptor() ([]byte, []int)deprecated
- func (x *Message) GetCorrelationKey() string
- func (x *Message) GetDescription() string
- func (x *Message) GetName() string
- func (x *Message) GetShort() string
- func (*Message) ProtoMessage()
- func (x *Message) ProtoReflect() protoreflect.Message
- func (x *Message) Reset()
- func (x *Message) String() string
- type MessageFlow
- func (*MessageFlow) Descriptor() ([]byte, []int)deprecated
- func (x *MessageFlow) GetId() string
- func (x *MessageFlow) GetRecipient() string
- func (x *MessageFlow) GetSender() string
- func (*MessageFlow) ProtoMessage()
- func (x *MessageFlow) ProtoReflect() protoreflect.Message
- func (x *MessageFlow) Reset()
- func (x *MessageFlow) String() string
- type MessageInstance
- func (*MessageInstance) Descriptor() ([]byte, []int)deprecated
- func (x *MessageInstance) GetCorrelationKey() string
- func (x *MessageInstance) GetName() string
- func (x *MessageInstance) GetVars() []byte
- func (*MessageInstance) ProtoMessage()
- func (x *MessageInstance) ProtoReflect() protoreflect.Message
- func (x *MessageInstance) Reset()
- func (x *MessageInstance) String() string
- type MessageReceiver
- func (*MessageReceiver) Descriptor() ([]byte, []int)deprecated
- func (x *MessageReceiver) GetId() string
- func (x *MessageReceiver) GetProcessIdToStart() string
- func (*MessageReceiver) ProtoMessage()
- func (x *MessageReceiver) ProtoReflect() protoreflect.Message
- func (x *MessageReceiver) Reset()
- func (x *MessageReceiver) String() string
- type MessageReceivers
- func (*MessageReceivers) Descriptor() ([]byte, []int)deprecated
- func (x *MessageReceivers) GetAssociatedWorkflowName() string
- func (x *MessageReceivers) GetMessageReceiver() []*MessageReceiver
- func (*MessageReceivers) ProtoMessage()
- func (x *MessageReceivers) ProtoReflect() protoreflect.Message
- func (x *MessageReceivers) Reset()
- func (x *MessageReceivers) String() string
- type MessageRecipient
- func (*MessageRecipient) Descriptor() ([]byte, []int)deprecated
- func (x *MessageRecipient) GetCorrelationKey() string
- func (x *MessageRecipient) GetId() string
- func (x *MessageRecipient) GetType() RecipientType
- func (*MessageRecipient) ProtoMessage()
- func (x *MessageRecipient) ProtoReflect() protoreflect.Message
- func (x *MessageRecipient) Reset()
- func (x *MessageRecipient) String() string
- type Metadata
- type Parameter
- func (*Parameter) Descriptor() ([]byte, []int)deprecated
- func (x *Parameter) GetCollection() bool
- func (x *Parameter) GetCustomTypeExtension() string
- func (x *Parameter) GetDescription() string
- func (x *Parameter) GetExample() string
- func (x *Parameter) GetExtensionData() map[string]string
- func (x *Parameter) GetGroup() string
- func (x *Parameter) GetMandatory() bool
- func (x *Parameter) GetName() string
- func (x *Parameter) GetShort() string
- func (x *Parameter) GetType() string
- func (x *Parameter) GetValidateExpr() string
- func (*Parameter) ProtoMessage()
- func (x *Parameter) ProtoReflect() protoreflect.Message
- func (x *Parameter) Reset()
- func (x *Parameter) String() string
- type ParameterGroup
- func (*ParameterGroup) Descriptor() ([]byte, []int)deprecated
- func (x *ParameterGroup) GetDescription() string
- func (x *ParameterGroup) GetName() string
- func (x *ParameterGroup) GetShort() string
- func (*ParameterGroup) ProtoMessage()
- func (x *ParameterGroup) ProtoReflect() protoreflect.Message
- func (x *ParameterGroup) Reset()
- func (x *ParameterGroup) String() string
- type Participant
- func (*Participant) Descriptor() ([]byte, []int)deprecated
- func (x *Participant) GetId() string
- func (x *Participant) GetProcessId() string
- func (*Participant) ProtoMessage()
- func (x *Participant) ProtoReflect() protoreflect.Message
- func (x *Participant) Reset()
- func (x *Participant) String() string
- type Process
- func (*Process) Descriptor() ([]byte, []int)deprecated
- func (x *Process) GetElements() []*Element
- func (x *Process) GetMetadata() *Metadata
- func (x *Process) GetName() string
- func (*Process) ProtoMessage()
- func (x *Process) ProtoReflect() protoreflect.Message
- func (x *Process) Reset()
- func (x *Process) String() string
- type ProcessHistory
- type ProcessHistoryEntry
- func (*ProcessHistoryEntry) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessHistoryEntry) GetCancellationState() CancellationState
- func (x *ProcessHistoryEntry) GetElementId() string
- func (x *ProcessHistoryEntry) GetError() *Error
- func (x *ProcessHistoryEntry) GetExecute() string
- func (x *ProcessHistoryEntry) GetExecutionId() string
- func (x *ProcessHistoryEntry) GetItemType() ProcessHistoryType
- func (x *ProcessHistoryEntry) GetProcessInstanceId() string
- func (x *ProcessHistoryEntry) GetTimer() *WorkflowTimer
- func (x *ProcessHistoryEntry) GetUnixTimeNano() int64
- func (x *ProcessHistoryEntry) GetVars() []byte
- func (x *ProcessHistoryEntry) GetWorkflowId() string
- func (*ProcessHistoryEntry) ProtoMessage()
- func (x *ProcessHistoryEntry) ProtoReflect() protoreflect.Message
- func (x *ProcessHistoryEntry) Reset()
- func (x *ProcessHistoryEntry) String() string
- type ProcessHistoryType
- func (ProcessHistoryType) Descriptor() protoreflect.EnumDescriptor
- func (x ProcessHistoryType) Enum() *ProcessHistoryType
- func (ProcessHistoryType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ProcessHistoryType) Number() protoreflect.EnumNumber
- func (x ProcessHistoryType) String() string
- func (ProcessHistoryType) Type() protoreflect.EnumType
- type ProcessInstance
- func (*ProcessInstance) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessInstance) GetExecutionId() string
- func (x *ProcessInstance) GetGatewayComplete() map[string]bool
- func (x *ProcessInstance) GetParentElementId() string
- func (x *ProcessInstance) GetParentProcessId() string
- func (x *ProcessInstance) GetProcessInstanceId() string
- func (x *ProcessInstance) GetProcessName() string
- func (x *ProcessInstance) GetWorkflowId() string
- func (x *ProcessInstance) GetWorkflowName() string
- func (*ProcessInstance) ProtoMessage()
- func (x *ProcessInstance) ProtoReflect() protoreflect.Message
- func (x *ProcessInstance) Reset()
- func (x *ProcessInstance) String() string
- type Receiver
- type RecipientType
- func (RecipientType) Descriptor() protoreflect.EnumDescriptor
- func (x RecipientType) Enum() *RecipientType
- func (RecipientType) EnumDescriptor() ([]byte, []int)deprecated
- func (x RecipientType) Number() protoreflect.EnumNumber
- func (x RecipientType) String() string
- func (RecipientType) Type() protoreflect.EnumType
- type RegisterTaskRequest
- func (*RegisterTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterTaskRequest) GetSpec() *TaskSpec
- func (*RegisterTaskRequest) ProtoMessage()
- func (x *RegisterTaskRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterTaskRequest) Reset()
- func (x *RegisterTaskRequest) String() string
- type RegisterTaskResponse
- func (*RegisterTaskResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterTaskResponse) GetUid() string
- func (*RegisterTaskResponse) ProtoMessage()
- func (x *RegisterTaskResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterTaskResponse) Reset()
- func (x *RegisterTaskResponse) String() string
- type RetryErrorAction
- func (RetryErrorAction) Descriptor() protoreflect.EnumDescriptor
- func (x RetryErrorAction) Enum() *RetryErrorAction
- func (RetryErrorAction) EnumDescriptor() ([]byte, []int)deprecated
- func (x RetryErrorAction) Number() protoreflect.EnumNumber
- func (x RetryErrorAction) String() string
- func (RetryErrorAction) Type() protoreflect.EnumType
- type RetryStrategy
- func (RetryStrategy) Descriptor() protoreflect.EnumDescriptor
- func (x RetryStrategy) Enum() *RetryStrategy
- func (RetryStrategy) EnumDescriptor() ([]byte, []int)deprecated
- func (x RetryStrategy) Number() protoreflect.EnumNumber
- func (x RetryStrategy) String() string
- func (RetryStrategy) Type() protoreflect.EnumType
- type SatisfiesGateway
- func (*SatisfiesGateway) Descriptor() ([]byte, []int)deprecated
- func (x *SatisfiesGateway) GetInstanceTracking() []string
- func (*SatisfiesGateway) ProtoMessage()
- func (x *SatisfiesGateway) ProtoReflect() protoreflect.Message
- func (x *SatisfiesGateway) Reset()
- func (x *SatisfiesGateway) String() string
- type SendMessageRequest
- func (*SendMessageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SendMessageRequest) GetCorrelationKey() string
- func (x *SendMessageRequest) GetName() string
- func (x *SendMessageRequest) GetVars() []byte
- func (*SendMessageRequest) ProtoMessage()
- func (x *SendMessageRequest) ProtoReflect() protoreflect.Message
- func (x *SendMessageRequest) Reset()
- func (x *SendMessageRequest) String() string
- type SendMessageResponse
- func (*SendMessageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SendMessageResponse) GetExecutionId() string
- func (x *SendMessageResponse) GetWorkflowId() string
- func (*SendMessageResponse) ProtoMessage()
- func (x *SendMessageResponse) ProtoReflect() protoreflect.Message
- func (x *SendMessageResponse) Reset()
- func (x *SendMessageResponse) String() string
- type Sender
- type StoreWorkflowRequest
- func (*StoreWorkflowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StoreWorkflowRequest) GetWorkflow() string
- func (*StoreWorkflowRequest) ProtoMessage()
- func (x *StoreWorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *StoreWorkflowRequest) Reset()
- func (x *StoreWorkflowRequest) String() string
- type StoreWorkflowResponse
- type Target
- func (*Target) Descriptor() ([]byte, []int)deprecated
- func (x *Target) GetConditions() []string
- func (x *Target) GetId() string
- func (x *Target) GetTarget() string
- func (*Target) ProtoMessage()
- func (x *Target) ProtoReflect() protoreflect.Message
- func (x *Target) Reset()
- func (x *Target) String() string
- type Targets
- type TaskBehaviour
- func (*TaskBehaviour) Descriptor() ([]byte, []int)deprecated
- func (x *TaskBehaviour) GetDefaultRetry() *DefaultTaskRetry
- func (x *TaskBehaviour) GetDeprecated() bool
- func (x *TaskBehaviour) GetMock() bool
- func (x *TaskBehaviour) GetUnsafe() bool
- func (*TaskBehaviour) ProtoMessage()
- func (x *TaskBehaviour) ProtoReflect() protoreflect.Message
- func (x *TaskBehaviour) Reset()
- func (x *TaskBehaviour) String() string
- type TaskError
- func (*TaskError) Descriptor() ([]byte, []int)deprecated
- func (x *TaskError) GetCode() string
- func (x *TaskError) GetDescription() string
- func (x *TaskError) GetName() string
- func (x *TaskError) GetShort() string
- func (*TaskError) ProtoMessage()
- func (x *TaskError) ProtoReflect() protoreflect.Message
- func (x *TaskError) Reset()
- func (x *TaskError) String() string
- type TaskEvents
- func (*TaskEvents) Descriptor() ([]byte, []int)deprecated
- func (x *TaskEvents) GetError() []*Error
- func (x *TaskEvents) GetMessage() []*Message
- func (*TaskEvents) ProtoMessage()
- func (x *TaskEvents) ProtoReflect() protoreflect.Message
- func (x *TaskEvents) Reset()
- func (x *TaskEvents) String() string
- type TaskMetadata
- func (*TaskMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *TaskMetadata) GetDescription() string
- func (x *TaskMetadata) GetEstimatedMaxDuration() uint64
- func (x *TaskMetadata) GetExtensionData() map[string]string
- func (x *TaskMetadata) GetLabels() []string
- func (x *TaskMetadata) GetShort() string
- func (x *TaskMetadata) GetType() string
- func (x *TaskMetadata) GetUid() string
- func (x *TaskMetadata) GetVersion() string
- func (*TaskMetadata) ProtoMessage()
- func (x *TaskMetadata) ProtoReflect() protoreflect.Message
- func (x *TaskMetadata) Reset()
- func (x *TaskMetadata) String() string
- type TaskParameters
- func (*TaskParameters) Descriptor() ([]byte, []int)deprecated
- func (x *TaskParameters) GetInput() []*Parameter
- func (x *TaskParameters) GetOutput() []*Parameter
- func (x *TaskParameters) GetParameterGroup() []*ParameterGroup
- func (*TaskParameters) ProtoMessage()
- func (x *TaskParameters) ProtoReflect() protoreflect.Message
- func (x *TaskParameters) Reset()
- func (x *TaskParameters) String() string
- type TaskSpec
- func (*TaskSpec) Descriptor() ([]byte, []int)deprecated
- func (x *TaskSpec) GetBehaviour() *TaskBehaviour
- func (x *TaskSpec) GetEvents() *TaskEvents
- func (x *TaskSpec) GetKind() string
- func (x *TaskSpec) GetMetadata() *TaskMetadata
- func (x *TaskSpec) GetParameters() *TaskParameters
- func (x *TaskSpec) GetVersion() string
- func (*TaskSpec) ProtoMessage()
- func (x *TaskSpec) ProtoReflect() protoreflect.Message
- func (x *TaskSpec) Reset()
- func (x *TaskSpec) String() string
- type TaskSpecUsageReport
- func (*TaskSpecUsageReport) Descriptor() ([]byte, []int)deprecated
- func (x *TaskSpecUsageReport) GetExecutingProcessInstance() []string
- func (x *TaskSpecUsageReport) GetExecutingWorkflow() []string
- func (x *TaskSpecUsageReport) GetProcess() []string
- func (x *TaskSpecUsageReport) GetWorkflow() []string
- func (*TaskSpecUsageReport) ProtoMessage()
- func (x *TaskSpecUsageReport) ProtoReflect() protoreflect.Message
- func (x *TaskSpecUsageReport) Reset()
- func (x *TaskSpecUsageReport) String() string
- type TaskSpecVersions
- type TelemetryLogEntry
- func (*TelemetryLogEntry) Descriptor() ([]byte, []int)deprecated
- func (x *TelemetryLogEntry) GetAttributes() map[string]string
- func (x *TelemetryLogEntry) GetCode() int32
- func (x *TelemetryLogEntry) GetMessage() string
- func (x *TelemetryLogEntry) GetSource() LogSource
- func (x *TelemetryLogEntry) GetTrackingID() string
- func (*TelemetryLogEntry) ProtoMessage()
- func (x *TelemetryLogEntry) ProtoReflect() protoreflect.Message
- func (x *TelemetryLogEntry) Reset()
- func (x *TelemetryLogEntry) String() string
- type TelemetryState
- func (*TelemetryState) Descriptor() ([]byte, []int)deprecated
- func (x *TelemetryState) GetLog() map[int64]*TelemetryLogEntry
- func (x *TelemetryState) GetState() *WorkflowState
- func (*TelemetryState) ProtoMessage()
- func (x *TelemetryState) ProtoReflect() protoreflect.Message
- func (x *TelemetryState) Reset()
- func (x *TelemetryState) String() string
- type ThreadingType
- func (ThreadingType) Descriptor() protoreflect.EnumDescriptor
- func (x ThreadingType) Enum() *ThreadingType
- func (ThreadingType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ThreadingType) Number() protoreflect.EnumNumber
- func (x ThreadingType) String() string
- func (ThreadingType) Type() protoreflect.EnumType
- type Timer
- func (*Timer) Descriptor() ([]byte, []int)deprecated
- func (x *Timer) GetDuration() string
- func (x *Timer) GetId() string
- func (x *Timer) GetOutputTransform() map[string]string
- func (x *Timer) GetTarget() string
- func (*Timer) ProtoMessage()
- func (x *Timer) ProtoReflect() protoreflect.Message
- func (x *Timer) Reset()
- func (x *Timer) String() string
- type UserTasks
- type Vars
- func (vars Vars) GetBool(key string) (bool, error)
- func (vars Vars) GetByte(key string) ([]byte, error)
- func (vars Vars) GetBytes(key string) ([]byte, error)
- func (vars Vars) GetFloat32(key string) (float32, error)
- func (vars Vars) GetFloat64(key string) (float64, error)
- func (vars Vars) GetInt(key string) (int, error)
- func (vars Vars) GetInt16(key string) (int16, error)
- func (vars Vars) GetInt32(key string) (int32, error)
- func (vars Vars) GetInt64(key string) (int64, error)
- func (vars Vars) GetInt8(key string) (int8, error)
- func (vars Vars) GetString(key string) (string, error)
- func (vars Vars) GetUint16(key string) (uint16, error)
- func (vars Vars) GetUint32(key string) (uint32, error)
- func (vars Vars) GetUint64(key string) (uint64, error)
- func (vars Vars) GetUint8(key string) (uint8, error)
- type Workflow
- func (*Workflow) Descriptor() ([]byte, []int)deprecated
- func (x *Workflow) GetCollaboration() *Collaboration
- func (x *Workflow) GetErrors() []*Error
- func (x *Workflow) GetGzipSource() []byte
- func (x *Workflow) GetMessageReceivers() map[string]*MessageReceivers
- func (x *Workflow) GetMessages() []*Element
- func (x *Workflow) GetName() string
- func (x *Workflow) GetProcess() map[string]*Process
- func (*Workflow) ProtoMessage()
- func (x *Workflow) ProtoReflect() protoreflect.Message
- func (x *Workflow) Reset()
- func (x *Workflow) String() string
- type WorkflowInstanceComplete
- func (*WorkflowInstanceComplete) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowInstanceComplete) GetError() *Error
- func (x *WorkflowInstanceComplete) GetWorkflowId() string
- func (x *WorkflowInstanceComplete) GetWorkflowInstanceId() string
- func (x *WorkflowInstanceComplete) GetWorkflowName() string
- func (x *WorkflowInstanceComplete) GetWorkflowState() CancellationState
- func (*WorkflowInstanceComplete) ProtoMessage()
- func (x *WorkflowInstanceComplete) ProtoReflect() protoreflect.Message
- func (x *WorkflowInstanceComplete) Reset()
- func (x *WorkflowInstanceComplete) String() string
- type WorkflowInstanceInfo
- func (*WorkflowInstanceInfo) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowInstanceInfo) GetId() string
- func (x *WorkflowInstanceInfo) GetWorkflowId() string
- func (*WorkflowInstanceInfo) ProtoMessage()
- func (x *WorkflowInstanceInfo) ProtoReflect() protoreflect.Message
- func (x *WorkflowInstanceInfo) Reset()
- func (x *WorkflowInstanceInfo) String() string
- type WorkflowInstanceStatus
- func (*WorkflowInstanceStatus) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowInstanceStatus) GetState() []*WorkflowState
- func (*WorkflowInstanceStatus) ProtoMessage()
- func (x *WorkflowInstanceStatus) ProtoReflect() protoreflect.Message
- func (x *WorkflowInstanceStatus) Reset()
- func (x *WorkflowInstanceStatus) String() string
- type WorkflowState
- func (*WorkflowState) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowState) GetCondition() string
- func (x *WorkflowState) GetElementId() string
- func (x *WorkflowState) GetElementType() string
- func (x *WorkflowState) GetError() *Error
- func (x *WorkflowState) GetExecute() string
- func (x *WorkflowState) GetExecuteVersion() string
- func (x *WorkflowState) GetExecutionId() string
- func (x *WorkflowState) GetGatewayExpectations() map[string]*GatewayExpectations
- func (x *WorkflowState) GetGroups() []string
- func (x *WorkflowState) GetId() []string
- func (x *WorkflowState) GetOwners() []string
- func (x *WorkflowState) GetProcessInstanceId() string
- func (x *WorkflowState) GetProcessName() string
- func (x *WorkflowState) GetSatisfiesGatewayExpectation() map[string]*SatisfiesGateway
- func (x *WorkflowState) GetState() CancellationState
- func (x *WorkflowState) GetTimer() *WorkflowTimer
- func (x *WorkflowState) GetUnixTimeNano() int64
- func (x *WorkflowState) GetVars() []byte
- func (x *WorkflowState) GetWorkflowId() string
- func (x *WorkflowState) GetWorkflowName() string
- func (*WorkflowState) ProtoMessage()
- func (x *WorkflowState) ProtoReflect() protoreflect.Message
- func (x *WorkflowState) Reset()
- func (x *WorkflowState) String() string
- type WorkflowStateSummary
- func (*WorkflowStateSummary) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowStateSummary) GetCondition() string
- func (x *WorkflowStateSummary) GetElementId() string
- func (x *WorkflowStateSummary) GetElementType() string
- func (x *WorkflowStateSummary) GetError() *Error
- func (x *WorkflowStateSummary) GetExecute() string
- func (x *WorkflowStateSummary) GetExecutionId() string
- func (x *WorkflowStateSummary) GetId() []string
- func (x *WorkflowStateSummary) GetProcessInstanceId() string
- func (x *WorkflowStateSummary) GetState() CancellationState
- func (x *WorkflowStateSummary) GetTimer() *WorkflowTimer
- func (x *WorkflowStateSummary) GetUnixTimeNano() int64
- func (x *WorkflowStateSummary) GetVars() []byte
- func (x *WorkflowStateSummary) GetWorkflowId() string
- func (*WorkflowStateSummary) ProtoMessage()
- func (x *WorkflowStateSummary) ProtoReflect() protoreflect.Message
- func (x *WorkflowStateSummary) Reset()
- func (x *WorkflowStateSummary) String() string
- type WorkflowStats
- func (*WorkflowStats) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowStats) GetInstancesComplete() int64
- func (x *WorkflowStats) GetInstancesStarted() int64
- func (x *WorkflowStats) GetWorkflows() int64
- func (*WorkflowStats) ProtoMessage()
- func (x *WorkflowStats) ProtoReflect() protoreflect.Message
- func (x *WorkflowStats) Reset()
- func (x *WorkflowStats) String() string
- type WorkflowTimer
- func (*WorkflowTimer) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowTimer) GetCount() int64
- func (x *WorkflowTimer) GetLastFired() int64
- func (*WorkflowTimer) ProtoMessage()
- func (x *WorkflowTimer) ProtoReflect() protoreflect.Message
- func (x *WorkflowTimer) Reset()
- func (x *WorkflowTimer) String() string
- type WorkflowTimerDefinition
- func (*WorkflowTimerDefinition) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowTimerDefinition) GetDropEvents() bool
- func (x *WorkflowTimerDefinition) GetRepeat() int64
- func (x *WorkflowTimerDefinition) GetType() WorkflowTimerType
- func (x *WorkflowTimerDefinition) GetValue() int64
- func (*WorkflowTimerDefinition) ProtoMessage()
- func (x *WorkflowTimerDefinition) ProtoReflect() protoreflect.Message
- func (x *WorkflowTimerDefinition) Reset()
- func (x *WorkflowTimerDefinition) String() string
- type WorkflowTimerType
- func (WorkflowTimerType) Descriptor() protoreflect.EnumDescriptor
- func (x WorkflowTimerType) Enum() *WorkflowTimerType
- func (WorkflowTimerType) EnumDescriptor() ([]byte, []int)deprecated
- func (x WorkflowTimerType) Number() protoreflect.EnumNumber
- func (x WorkflowTimerType) String() string
- func (WorkflowTimerType) Type() protoreflect.EnumType
- type WorkflowVersion
- func (*WorkflowVersion) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowVersion) GetId() string
- func (x *WorkflowVersion) GetNumber() int32
- func (x *WorkflowVersion) GetSha256() []byte
- func (*WorkflowVersion) ProtoMessage()
- func (x *WorkflowVersion) ProtoReflect() protoreflect.Message
- func (x *WorkflowVersion) Reset()
- func (x *WorkflowVersion) String() string
- type WorkflowVersions
- func (*WorkflowVersions) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowVersions) GetVersion() []*WorkflowVersion
- func (*WorkflowVersions) ProtoMessage()
- func (x *WorkflowVersions) ProtoReflect() protoreflect.Message
- func (x *WorkflowVersions) Reset()
- func (x *WorkflowVersions) String() string
Constants ¶
This section is empty.
Variables ¶
var ( ThreadingType_name = map[int32]string{ 0: "Sequential", 2: "Parallel", } ThreadingType_value = map[string]int32{ "Sequential": 0, "Parallel": 2, } )
Enum value maps for ThreadingType.
var ( GatewayType_name = map[int32]string{ 0: "exclusive", 1: "inclusive", 2: "parallel", } GatewayType_value = map[string]int32{ "exclusive": 0, "inclusive": 1, "parallel": 2, } )
Enum value maps for GatewayType.
var ( GatewayDirection_name = map[int32]string{ 0: "divergent", 1: "convergent", } GatewayDirection_value = map[string]int32{ "divergent": 0, "convergent": 1, } )
Enum value maps for GatewayDirection.
var ( ProcessHistoryType_name = map[int32]string{ 0: "processExecute", 1: "activityExecute", 2: "activityComplete", 3: "processSpawnSync", 4: "processComplete", 5: "processAbort", 6: "activityAbort", } ProcessHistoryType_value = map[string]int32{ "processExecute": 0, "activityExecute": 1, "activityComplete": 2, "processSpawnSync": 3, "processComplete": 4, "processAbort": 5, "activityAbort": 6, } )
Enum value maps for ProcessHistoryType.
var ( WorkflowTimerType_name = map[int32]string{ 0: "duration", 1: "fixed", } WorkflowTimerType_value = map[string]int32{ "duration": 0, "fixed": 1, } )
Enum value maps for WorkflowTimerType.
var ( RecipientType_name = map[int32]string{ 0: "job", } RecipientType_value = map[string]int32{ "job": 0, } )
Enum value maps for RecipientType.
var ( CancellationState_name = map[int32]string{ 0: "executing", 1: "completed", 2: "terminated", 3: "errored", 4: "obsolete", } CancellationState_value = map[string]int32{ "executing": 0, "completed": 1, "terminated": 2, "errored": 3, "obsolete": 4, } )
Enum value maps for CancellationState.
var ( LogSource_name = map[int32]string{ 0: "logSourceEngine", 2: "logSourceWorkflow", 3: "logSourceClient", 4: "logSourceJob", } LogSource_value = map[string]int32{ "logSourceEngine": 0, "logSourceWorkflow": 2, "logSourceClient": 3, "logSourceJob": 4, } )
Enum value maps for LogSource.
var ( RetryStrategy_name = map[int32]string{ 0: "Linear", 1: "Incremental", } RetryStrategy_value = map[string]int32{ "Linear": 0, "Incremental": 1, } )
Enum value maps for RetryStrategy.
var ( RetryErrorAction_name = map[int32]string{ 0: "PauseWorkflow", 1: "ThrowWorkflowError", 2: "SetVariableValue", 3: "FailWorkflow", } RetryErrorAction_value = map[string]int32{ "PauseWorkflow": 0, "ThrowWorkflowError": 1, "SetVariableValue": 2, "FailWorkflow": 3, } )
Enum value maps for RetryErrorAction.
var File_shar_workflow_models_proto protoreflect.FileDescriptor
Functions ¶
func Get ¶ added in v1.0.396
Get takes the desired return type as parameter and safely searches the map and returns the value if it is found and is of the desired type.
Types ¶
type ApiAuthenticationRequest ¶ added in v1.0.362
type ApiAuthenticationRequest struct { Headers map[string]string `` /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ApiAuthenticationRequest) Descriptor
deprecated
added in
v1.0.362
func (*ApiAuthenticationRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApiAuthenticationRequest.ProtoReflect.Descriptor instead.
func (*ApiAuthenticationRequest) GetHeaders ¶ added in v1.0.362
func (x *ApiAuthenticationRequest) GetHeaders() map[string]string
func (*ApiAuthenticationRequest) ProtoMessage ¶ added in v1.0.362
func (*ApiAuthenticationRequest) ProtoMessage()
func (*ApiAuthenticationRequest) ProtoReflect ¶ added in v1.0.362
func (x *ApiAuthenticationRequest) ProtoReflect() protoreflect.Message
func (*ApiAuthenticationRequest) Reset ¶ added in v1.0.362
func (x *ApiAuthenticationRequest) Reset()
func (*ApiAuthenticationRequest) String ¶ added in v1.0.362
func (x *ApiAuthenticationRequest) String() string
type ApiAuthenticationResponse ¶ added in v1.0.362
type ApiAuthenticationResponse struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Authenticated bool `protobuf:"varint,2,opt,name=Authenticated,proto3" json:"Authenticated,omitempty"` // contains filtered or unexported fields }
func (*ApiAuthenticationResponse) Descriptor
deprecated
added in
v1.0.362
func (*ApiAuthenticationResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApiAuthenticationResponse.ProtoReflect.Descriptor instead.
func (*ApiAuthenticationResponse) GetAuthenticated ¶ added in v1.0.362
func (x *ApiAuthenticationResponse) GetAuthenticated() bool
func (*ApiAuthenticationResponse) GetUser ¶ added in v1.0.362
func (x *ApiAuthenticationResponse) GetUser() string
func (*ApiAuthenticationResponse) ProtoMessage ¶ added in v1.0.362
func (*ApiAuthenticationResponse) ProtoMessage()
func (*ApiAuthenticationResponse) ProtoReflect ¶ added in v1.0.362
func (x *ApiAuthenticationResponse) ProtoReflect() protoreflect.Message
func (*ApiAuthenticationResponse) Reset ¶ added in v1.0.362
func (x *ApiAuthenticationResponse) Reset()
func (*ApiAuthenticationResponse) String ¶ added in v1.0.362
func (x *ApiAuthenticationResponse) String() string
type ApiAuthorizationRequest ¶ added in v1.0.362
type ApiAuthorizationRequest struct { Headers map[string]string `` /* 155-byte string literal not displayed */ Function string `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty"` WorkflowName string `protobuf:"bytes,3,opt,name=workflowName,proto3" json:"workflowName,omitempty"` User string `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"` // contains filtered or unexported fields }
func (*ApiAuthorizationRequest) Descriptor
deprecated
added in
v1.0.362
func (*ApiAuthorizationRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApiAuthorizationRequest.ProtoReflect.Descriptor instead.
func (*ApiAuthorizationRequest) GetFunction ¶ added in v1.0.362
func (x *ApiAuthorizationRequest) GetFunction() string
func (*ApiAuthorizationRequest) GetHeaders ¶ added in v1.0.362
func (x *ApiAuthorizationRequest) GetHeaders() map[string]string
func (*ApiAuthorizationRequest) GetUser ¶ added in v1.0.362
func (x *ApiAuthorizationRequest) GetUser() string
func (*ApiAuthorizationRequest) GetWorkflowName ¶ added in v1.0.362
func (x *ApiAuthorizationRequest) GetWorkflowName() string
func (*ApiAuthorizationRequest) ProtoMessage ¶ added in v1.0.362
func (*ApiAuthorizationRequest) ProtoMessage()
func (*ApiAuthorizationRequest) ProtoReflect ¶ added in v1.0.362
func (x *ApiAuthorizationRequest) ProtoReflect() protoreflect.Message
func (*ApiAuthorizationRequest) Reset ¶ added in v1.0.362
func (x *ApiAuthorizationRequest) Reset()
func (*ApiAuthorizationRequest) String ¶ added in v1.0.362
func (x *ApiAuthorizationRequest) String() string
type ApiAuthorizationResponse ¶ added in v1.0.362
type ApiAuthorizationResponse struct { Authorized bool `protobuf:"varint,1,opt,name=authorized,proto3" json:"authorized,omitempty"` UserId string `protobuf:"bytes,2,opt,name=userId,proto3" json:"userId,omitempty"` // contains filtered or unexported fields }
func (*ApiAuthorizationResponse) Descriptor
deprecated
added in
v1.0.362
func (*ApiAuthorizationResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApiAuthorizationResponse.ProtoReflect.Descriptor instead.
func (*ApiAuthorizationResponse) GetAuthorized ¶ added in v1.0.362
func (x *ApiAuthorizationResponse) GetAuthorized() bool
func (*ApiAuthorizationResponse) GetUserId ¶ added in v1.0.362
func (x *ApiAuthorizationResponse) GetUserId() string
func (*ApiAuthorizationResponse) ProtoMessage ¶ added in v1.0.362
func (*ApiAuthorizationResponse) ProtoMessage()
func (*ApiAuthorizationResponse) ProtoReflect ¶ added in v1.0.362
func (x *ApiAuthorizationResponse) ProtoReflect() protoreflect.Message
func (*ApiAuthorizationResponse) Reset ¶ added in v1.0.362
func (x *ApiAuthorizationResponse) Reset()
func (*ApiAuthorizationResponse) String ¶ added in v1.0.362
func (x *ApiAuthorizationResponse) String() string
type CancelProcessInstanceRequest ¶ added in v1.0.645
type CancelProcessInstanceRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` State CancellationState `protobuf:"varint,2,opt,name=state,proto3,enum=CancellationState" json:"state,omitempty"` Error *Error `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*CancelProcessInstanceRequest) Descriptor
deprecated
added in
v1.0.645
func (*CancelProcessInstanceRequest) Descriptor() ([]byte, []int)
Deprecated: Use CancelProcessInstanceRequest.ProtoReflect.Descriptor instead.
func (*CancelProcessInstanceRequest) GetError ¶ added in v1.0.645
func (x *CancelProcessInstanceRequest) GetError() *Error
func (*CancelProcessInstanceRequest) GetId ¶ added in v1.0.645
func (x *CancelProcessInstanceRequest) GetId() string
func (*CancelProcessInstanceRequest) GetState ¶ added in v1.0.645
func (x *CancelProcessInstanceRequest) GetState() CancellationState
func (*CancelProcessInstanceRequest) ProtoMessage ¶ added in v1.0.645
func (*CancelProcessInstanceRequest) ProtoMessage()
func (*CancelProcessInstanceRequest) ProtoReflect ¶ added in v1.0.645
func (x *CancelProcessInstanceRequest) ProtoReflect() protoreflect.Message
func (*CancelProcessInstanceRequest) Reset ¶ added in v1.0.645
func (x *CancelProcessInstanceRequest) Reset()
func (*CancelProcessInstanceRequest) String ¶ added in v1.0.645
func (x *CancelProcessInstanceRequest) String() string
type CancelProcessInstanceResponse ¶ added in v1.1.725
type CancelProcessInstanceResponse struct {
// contains filtered or unexported fields
}
func (*CancelProcessInstanceResponse) Descriptor
deprecated
added in
v1.1.725
func (*CancelProcessInstanceResponse) Descriptor() ([]byte, []int)
Deprecated: Use CancelProcessInstanceResponse.ProtoReflect.Descriptor instead.
func (*CancelProcessInstanceResponse) ProtoMessage ¶ added in v1.1.725
func (*CancelProcessInstanceResponse) ProtoMessage()
func (*CancelProcessInstanceResponse) ProtoReflect ¶ added in v1.1.725
func (x *CancelProcessInstanceResponse) ProtoReflect() protoreflect.Message
func (*CancelProcessInstanceResponse) Reset ¶ added in v1.1.725
func (x *CancelProcessInstanceResponse) Reset()
func (*CancelProcessInstanceResponse) String ¶ added in v1.1.725
func (x *CancelProcessInstanceResponse) String() string
type CancellationState ¶ added in v0.1.134
type CancellationState int32
const ( CancellationState_executing CancellationState = 0 // CancellationState_executing - the state machine is executing CancellationState_completed CancellationState = 1 // CancellationState_completed - the state machine has completed successfully CancellationState_terminated CancellationState = 2 // CancellationState_terminated - the state machine instance was terminated CancellationState_errored CancellationState = 3 // CancellationState_errored - an error occured during state machine execution CancellationState_obsolete CancellationState = 4 // CancellationState_obsolete - this state is obsolete due to an alternate flow )
func (CancellationState) Descriptor ¶ added in v0.1.134
func (CancellationState) Descriptor() protoreflect.EnumDescriptor
func (CancellationState) Enum ¶ added in v0.1.134
func (x CancellationState) Enum() *CancellationState
func (CancellationState) EnumDescriptor
deprecated
added in
v0.1.134
func (CancellationState) EnumDescriptor() ([]byte, []int)
Deprecated: Use CancellationState.Descriptor instead.
func (CancellationState) Number ¶ added in v0.1.134
func (x CancellationState) Number() protoreflect.EnumNumber
func (CancellationState) String ¶ added in v0.1.134
func (x CancellationState) String() string
func (CancellationState) Type ¶ added in v0.1.134
func (CancellationState) Type() protoreflect.EnumType
type CatchError ¶ added in v0.1.134
type CatchError struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Id - the unique id. ErrorId string `protobuf:"bytes,2,opt,name=errorId,proto3" json:"errorId,omitempty"` // Id - the id of the error. Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` // Target ID for the transition. OutputTransform map[string]string `` // OutputTransform - The transformation to apply to variables during the transition. /* 171-byte string literal not displayed */ // contains filtered or unexported fields }
CatchError specifies an error transition to another state.
func (*CatchError) Descriptor
deprecated
added in
v0.1.134
func (*CatchError) Descriptor() ([]byte, []int)
Deprecated: Use CatchError.ProtoReflect.Descriptor instead.
func (*CatchError) GetErrorId ¶ added in v0.1.134
func (x *CatchError) GetErrorId() string
func (*CatchError) GetId ¶ added in v0.1.134
func (x *CatchError) GetId() string
func (*CatchError) GetOutputTransform ¶ added in v1.0.251
func (x *CatchError) GetOutputTransform() map[string]string
func (*CatchError) GetTarget ¶ added in v0.1.134
func (x *CatchError) GetTarget() string
func (*CatchError) ProtoMessage ¶ added in v0.1.134
func (*CatchError) ProtoMessage()
func (*CatchError) ProtoReflect ¶ added in v0.1.134
func (x *CatchError) ProtoReflect() protoreflect.Message
func (*CatchError) Reset ¶ added in v0.1.134
func (x *CatchError) Reset()
func (*CatchError) String ¶ added in v0.1.134
func (x *CatchError) String() string
type Collaboration ¶ added in v1.0.645
type Collaboration struct { Participant []*Participant `protobuf:"bytes,1,rep,name=participant,proto3" json:"participant,omitempty"` // Participant in a collaboration. MessageFlow []*MessageFlow `protobuf:"bytes,2,rep,name=messageFlow,proto3" json:"messageFlow,omitempty"` // MessageFlow describes the collaboration message participants. // contains filtered or unexported fields }
func (*Collaboration) Descriptor
deprecated
added in
v1.0.645
func (*Collaboration) Descriptor() ([]byte, []int)
Deprecated: Use Collaboration.ProtoReflect.Descriptor instead.
func (*Collaboration) GetMessageFlow ¶ added in v1.0.645
func (x *Collaboration) GetMessageFlow() []*MessageFlow
func (*Collaboration) GetParticipant ¶ added in v1.0.645
func (x *Collaboration) GetParticipant() []*Participant
func (*Collaboration) ProtoMessage ¶ added in v1.0.645
func (*Collaboration) ProtoMessage()
func (*Collaboration) ProtoReflect ¶ added in v1.0.645
func (x *Collaboration) ProtoReflect() protoreflect.Message
func (*Collaboration) Reset ¶ added in v1.0.645
func (x *Collaboration) Reset()
func (*Collaboration) String ¶ added in v1.0.645
func (x *Collaboration) String() string
type CompleteManualTaskRequest ¶ added in v0.1.86
type CompleteManualTaskRequest struct { TrackingId string `protobuf:"bytes,1,opt,name=trackingId,proto3" json:"trackingId,omitempty"` Vars []byte `protobuf:"bytes,2,opt,name=vars,proto3" json:"vars,omitempty"` // contains filtered or unexported fields }
func (*CompleteManualTaskRequest) Descriptor
deprecated
added in
v0.1.86
func (*CompleteManualTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use CompleteManualTaskRequest.ProtoReflect.Descriptor instead.
func (*CompleteManualTaskRequest) GetTrackingId ¶ added in v0.1.86
func (x *CompleteManualTaskRequest) GetTrackingId() string
func (*CompleteManualTaskRequest) GetVars ¶ added in v0.1.86
func (x *CompleteManualTaskRequest) GetVars() []byte
func (*CompleteManualTaskRequest) ProtoMessage ¶ added in v0.1.86
func (*CompleteManualTaskRequest) ProtoMessage()
func (*CompleteManualTaskRequest) ProtoReflect ¶ added in v0.1.86
func (x *CompleteManualTaskRequest) ProtoReflect() protoreflect.Message
func (*CompleteManualTaskRequest) Reset ¶ added in v0.1.86
func (x *CompleteManualTaskRequest) Reset()
func (*CompleteManualTaskRequest) String ¶ added in v0.1.86
func (x *CompleteManualTaskRequest) String() string
type CompleteManualTaskResponse ¶ added in v1.1.725
type CompleteManualTaskResponse struct {
// contains filtered or unexported fields
}
func (*CompleteManualTaskResponse) Descriptor
deprecated
added in
v1.1.725
func (*CompleteManualTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use CompleteManualTaskResponse.ProtoReflect.Descriptor instead.
func (*CompleteManualTaskResponse) ProtoMessage ¶ added in v1.1.725
func (*CompleteManualTaskResponse) ProtoMessage()
func (*CompleteManualTaskResponse) ProtoReflect ¶ added in v1.1.725
func (x *CompleteManualTaskResponse) ProtoReflect() protoreflect.Message
func (*CompleteManualTaskResponse) Reset ¶ added in v1.1.725
func (x *CompleteManualTaskResponse) Reset()
func (*CompleteManualTaskResponse) String ¶ added in v1.1.725
func (x *CompleteManualTaskResponse) String() string
type CompleteSendMessageRequest ¶ added in v0.1.185
type CompleteSendMessageRequest struct { TrackingId string `protobuf:"bytes,1,opt,name=trackingId,proto3" json:"trackingId,omitempty"` Vars []byte `protobuf:"bytes,2,opt,name=vars,proto3" json:"vars,omitempty"` // contains filtered or unexported fields }
func (*CompleteSendMessageRequest) Descriptor
deprecated
added in
v0.1.185
func (*CompleteSendMessageRequest) Descriptor() ([]byte, []int)
Deprecated: Use CompleteSendMessageRequest.ProtoReflect.Descriptor instead.
func (*CompleteSendMessageRequest) GetTrackingId ¶ added in v0.1.185
func (x *CompleteSendMessageRequest) GetTrackingId() string
func (*CompleteSendMessageRequest) GetVars ¶ added in v0.1.185
func (x *CompleteSendMessageRequest) GetVars() []byte
func (*CompleteSendMessageRequest) ProtoMessage ¶ added in v0.1.185
func (*CompleteSendMessageRequest) ProtoMessage()
func (*CompleteSendMessageRequest) ProtoReflect ¶ added in v0.1.185
func (x *CompleteSendMessageRequest) ProtoReflect() protoreflect.Message
func (*CompleteSendMessageRequest) Reset ¶ added in v0.1.185
func (x *CompleteSendMessageRequest) Reset()
func (*CompleteSendMessageRequest) String ¶ added in v0.1.185
func (x *CompleteSendMessageRequest) String() string
type CompleteSendMessageResponse ¶ added in v1.1.725
type CompleteSendMessageResponse struct {
// contains filtered or unexported fields
}
func (*CompleteSendMessageResponse) Descriptor
deprecated
added in
v1.1.725
func (*CompleteSendMessageResponse) Descriptor() ([]byte, []int)
Deprecated: Use CompleteSendMessageResponse.ProtoReflect.Descriptor instead.
func (*CompleteSendMessageResponse) ProtoMessage ¶ added in v1.1.725
func (*CompleteSendMessageResponse) ProtoMessage()
func (*CompleteSendMessageResponse) ProtoReflect ¶ added in v1.1.725
func (x *CompleteSendMessageResponse) ProtoReflect() protoreflect.Message
func (*CompleteSendMessageResponse) Reset ¶ added in v1.1.725
func (x *CompleteSendMessageResponse) Reset()
func (*CompleteSendMessageResponse) String ¶ added in v1.1.725
func (x *CompleteSendMessageResponse) String() string
type CompleteServiceTaskRequest ¶ added in v0.1.86
type CompleteServiceTaskRequest struct { TrackingId string `protobuf:"bytes,1,opt,name=trackingId,proto3" json:"trackingId,omitempty"` Vars []byte `protobuf:"bytes,2,opt,name=vars,proto3" json:"vars,omitempty"` // contains filtered or unexported fields }
func (*CompleteServiceTaskRequest) Descriptor
deprecated
added in
v0.1.86
func (*CompleteServiceTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use CompleteServiceTaskRequest.ProtoReflect.Descriptor instead.
func (*CompleteServiceTaskRequest) GetTrackingId ¶ added in v0.1.86
func (x *CompleteServiceTaskRequest) GetTrackingId() string
func (*CompleteServiceTaskRequest) GetVars ¶ added in v0.1.86
func (x *CompleteServiceTaskRequest) GetVars() []byte
func (*CompleteServiceTaskRequest) ProtoMessage ¶ added in v0.1.86
func (*CompleteServiceTaskRequest) ProtoMessage()
func (*CompleteServiceTaskRequest) ProtoReflect ¶ added in v0.1.86
func (x *CompleteServiceTaskRequest) ProtoReflect() protoreflect.Message
func (*CompleteServiceTaskRequest) Reset ¶ added in v0.1.86
func (x *CompleteServiceTaskRequest) Reset()
func (*CompleteServiceTaskRequest) String ¶ added in v0.1.86
func (x *CompleteServiceTaskRequest) String() string
type CompleteServiceTaskResponse ¶ added in v1.1.725
type CompleteServiceTaskResponse struct {
// contains filtered or unexported fields
}
func (*CompleteServiceTaskResponse) Descriptor
deprecated
added in
v1.1.725
func (*CompleteServiceTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use CompleteServiceTaskResponse.ProtoReflect.Descriptor instead.
func (*CompleteServiceTaskResponse) ProtoMessage ¶ added in v1.1.725
func (*CompleteServiceTaskResponse) ProtoMessage()
func (*CompleteServiceTaskResponse) ProtoReflect ¶ added in v1.1.725
func (x *CompleteServiceTaskResponse) ProtoReflect() protoreflect.Message
func (*CompleteServiceTaskResponse) Reset ¶ added in v1.1.725
func (x *CompleteServiceTaskResponse) Reset()
func (*CompleteServiceTaskResponse) String ¶ added in v1.1.725
func (x *CompleteServiceTaskResponse) String() string
type CompleteUserTaskRequest ¶ added in v0.1.86
type CompleteUserTaskRequest struct { TrackingId string `protobuf:"bytes,1,opt,name=trackingId,proto3" json:"trackingId,omitempty"` Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"` Vars []byte `protobuf:"bytes,3,opt,name=vars,proto3" json:"vars,omitempty"` // contains filtered or unexported fields }
func (*CompleteUserTaskRequest) Descriptor
deprecated
added in
v0.1.86
func (*CompleteUserTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use CompleteUserTaskRequest.ProtoReflect.Descriptor instead.
func (*CompleteUserTaskRequest) GetOwner ¶ added in v0.1.86
func (x *CompleteUserTaskRequest) GetOwner() string
func (*CompleteUserTaskRequest) GetTrackingId ¶ added in v0.1.86
func (x *CompleteUserTaskRequest) GetTrackingId() string
func (*CompleteUserTaskRequest) GetVars ¶ added in v0.1.86
func (x *CompleteUserTaskRequest) GetVars() []byte
func (*CompleteUserTaskRequest) ProtoMessage ¶ added in v0.1.86
func (*CompleteUserTaskRequest) ProtoMessage()
func (*CompleteUserTaskRequest) ProtoReflect ¶ added in v0.1.86
func (x *CompleteUserTaskRequest) ProtoReflect() protoreflect.Message
func (*CompleteUserTaskRequest) Reset ¶ added in v0.1.86
func (x *CompleteUserTaskRequest) Reset()
func (*CompleteUserTaskRequest) String ¶ added in v0.1.86
func (x *CompleteUserTaskRequest) String() string
type CompleteUserTaskResponse ¶ added in v1.1.725
type CompleteUserTaskResponse struct {
// contains filtered or unexported fields
}
func (*CompleteUserTaskResponse) Descriptor
deprecated
added in
v1.1.725
func (*CompleteUserTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use CompleteUserTaskResponse.ProtoReflect.Descriptor instead.
func (*CompleteUserTaskResponse) ProtoMessage ¶ added in v1.1.725
func (*CompleteUserTaskResponse) ProtoMessage()
func (*CompleteUserTaskResponse) ProtoReflect ¶ added in v1.1.725
func (x *CompleteUserTaskResponse) ProtoReflect() protoreflect.Message
func (*CompleteUserTaskResponse) Reset ¶ added in v1.1.725
func (x *CompleteUserTaskResponse) Reset()
func (*CompleteUserTaskResponse) String ¶ added in v1.1.725
func (x *CompleteUserTaskResponse) String() string
type DefaultRetryExceededBehaviour ¶ added in v1.0.623
type DefaultRetryExceededBehaviour struct { Action RetryErrorAction `protobuf:"varint,1,opt,name=action,proto3,enum=RetryErrorAction" json:"action,omitempty"` // Action to take when retries are exceeded. Variable string `protobuf:"bytes,2,opt,name=variable,proto3" json:"variable,omitempty"` // Variable - name of variable to set for the SetVariableValue action. VariableType string `protobuf:"bytes,3,opt,name=variableType,proto3" json:"variableType,omitempty"` // VariableType - type of the variable "string", "int", "float", "bool" for the SetVariableValue action. VariableValue string `protobuf:"bytes,4,opt,name=variableValue,proto3" json:"variableValue,omitempty"` // Variable value to set for the SetVariableValue action. ErrorCode string `protobuf:"bytes,5,opt,name=errorCode,proto3" json:"errorCode,omitempty"` // ErrorCode for the ThrowWorkflowError action // contains filtered or unexported fields }
func (*DefaultRetryExceededBehaviour) Descriptor
deprecated
added in
v1.0.623
func (*DefaultRetryExceededBehaviour) Descriptor() ([]byte, []int)
Deprecated: Use DefaultRetryExceededBehaviour.ProtoReflect.Descriptor instead.
func (*DefaultRetryExceededBehaviour) GetAction ¶ added in v1.0.623
func (x *DefaultRetryExceededBehaviour) GetAction() RetryErrorAction
func (*DefaultRetryExceededBehaviour) GetErrorCode ¶ added in v1.0.623
func (x *DefaultRetryExceededBehaviour) GetErrorCode() string
func (*DefaultRetryExceededBehaviour) GetVariable ¶ added in v1.0.623
func (x *DefaultRetryExceededBehaviour) GetVariable() string
func (*DefaultRetryExceededBehaviour) GetVariableType ¶ added in v1.0.623
func (x *DefaultRetryExceededBehaviour) GetVariableType() string
func (*DefaultRetryExceededBehaviour) GetVariableValue ¶ added in v1.0.623
func (x *DefaultRetryExceededBehaviour) GetVariableValue() string
func (*DefaultRetryExceededBehaviour) ProtoMessage ¶ added in v1.0.623
func (*DefaultRetryExceededBehaviour) ProtoMessage()
func (*DefaultRetryExceededBehaviour) ProtoReflect ¶ added in v1.0.623
func (x *DefaultRetryExceededBehaviour) ProtoReflect() protoreflect.Message
func (*DefaultRetryExceededBehaviour) Reset ¶ added in v1.0.623
func (x *DefaultRetryExceededBehaviour) Reset()
func (*DefaultRetryExceededBehaviour) String ¶ added in v1.0.623
func (x *DefaultRetryExceededBehaviour) String() string
type DefaultTaskRetry ¶ added in v1.0.623
type DefaultTaskRetry struct { Number uint32 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"` // Retry - the recommended number of retries for the task. Strategy RetryStrategy `protobuf:"varint,2,opt,name=strategy,proto3,enum=RetryStrategy" json:"strategy,omitempty"` // Strategy for retrying the task. InitMilli int64 `protobuf:"varint,3,opt,name=initMilli,proto3" json:"initMilli,omitempty"` // InitMilli - initial backoff delay in milliseconds (Static, Linear, Incremental) IntervalMilli int64 `protobuf:"varint,4,opt,name=intervalMilli,proto3" json:"intervalMilli,omitempty"` // IntervalMilli - delay interval (Linear) amount to add each attempt (Incremental) MaxMilli int64 `protobuf:"varint,5,opt,name=maxMilli,proto3" json:"maxMilli,omitempty"` // MaxMilli - delay ceiling (Static, Linear, Incremental) DefaultExceeded *DefaultRetryExceededBehaviour `protobuf:"bytes,6,opt,name=defaultExceeded,proto3" json:"defaultExceeded,omitempty"` // DefaultExceeded - specifies what to do by default when the attempts have been exhausted. This only specifies the strategy, and doesn't contain runtime parameters. // contains filtered or unexported fields }
func (*DefaultTaskRetry) Descriptor
deprecated
added in
v1.0.623
func (*DefaultTaskRetry) Descriptor() ([]byte, []int)
Deprecated: Use DefaultTaskRetry.ProtoReflect.Descriptor instead.
func (*DefaultTaskRetry) GetDefaultExceeded ¶ added in v1.0.623
func (x *DefaultTaskRetry) GetDefaultExceeded() *DefaultRetryExceededBehaviour
func (*DefaultTaskRetry) GetInitMilli ¶ added in v1.0.623
func (x *DefaultTaskRetry) GetInitMilli() int64
func (*DefaultTaskRetry) GetIntervalMilli ¶ added in v1.0.623
func (x *DefaultTaskRetry) GetIntervalMilli() int64
func (*DefaultTaskRetry) GetMaxMilli ¶ added in v1.0.623
func (x *DefaultTaskRetry) GetMaxMilli() int64
func (*DefaultTaskRetry) GetNumber ¶ added in v1.0.623
func (x *DefaultTaskRetry) GetNumber() uint32
func (*DefaultTaskRetry) GetStrategy ¶ added in v1.0.623
func (x *DefaultTaskRetry) GetStrategy() RetryStrategy
func (*DefaultTaskRetry) ProtoMessage ¶ added in v1.0.623
func (*DefaultTaskRetry) ProtoMessage()
func (*DefaultTaskRetry) ProtoReflect ¶ added in v1.0.623
func (x *DefaultTaskRetry) ProtoReflect() protoreflect.Message
func (*DefaultTaskRetry) Reset ¶ added in v1.0.623
func (x *DefaultTaskRetry) Reset()
func (*DefaultTaskRetry) String ¶ added in v1.0.623
func (x *DefaultTaskRetry) String() string
type DeprecateServiceTaskRequest ¶ added in v1.1.670
type DeprecateServiceTaskRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Name of the task specification. // contains filtered or unexported fields }
DeleteServiceTaskRequest contains the UID of a registered task.
func (*DeprecateServiceTaskRequest) Descriptor
deprecated
added in
v1.1.670
func (*DeprecateServiceTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeprecateServiceTaskRequest.ProtoReflect.Descriptor instead.
func (*DeprecateServiceTaskRequest) GetName ¶ added in v1.1.670
func (x *DeprecateServiceTaskRequest) GetName() string
func (*DeprecateServiceTaskRequest) ProtoMessage ¶ added in v1.1.670
func (*DeprecateServiceTaskRequest) ProtoMessage()
func (*DeprecateServiceTaskRequest) ProtoReflect ¶ added in v1.1.670
func (x *DeprecateServiceTaskRequest) ProtoReflect() protoreflect.Message
func (*DeprecateServiceTaskRequest) Reset ¶ added in v1.1.670
func (x *DeprecateServiceTaskRequest) Reset()
func (*DeprecateServiceTaskRequest) String ¶ added in v1.1.670
func (x *DeprecateServiceTaskRequest) String() string
type DeprecateServiceTaskResponse ¶ added in v1.1.670
type DeprecateServiceTaskResponse struct { Usage *TaskSpecUsageReport `protobuf:"bytes,1,opt,name=usage,proto3,oneof" json:"usage,omitempty"` Success bool `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"` // contains filtered or unexported fields }
DeleteServiceTaskResponse is the result of unregistering a task.
func (*DeprecateServiceTaskResponse) Descriptor
deprecated
added in
v1.1.670
func (*DeprecateServiceTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeprecateServiceTaskResponse.ProtoReflect.Descriptor instead.
func (*DeprecateServiceTaskResponse) GetSuccess ¶ added in v1.1.670
func (x *DeprecateServiceTaskResponse) GetSuccess() bool
func (*DeprecateServiceTaskResponse) GetUsage ¶ added in v1.1.670
func (x *DeprecateServiceTaskResponse) GetUsage() *TaskSpecUsageReport
func (*DeprecateServiceTaskResponse) ProtoMessage ¶ added in v1.1.670
func (*DeprecateServiceTaskResponse) ProtoMessage()
func (*DeprecateServiceTaskResponse) ProtoReflect ¶ added in v1.1.670
func (x *DeprecateServiceTaskResponse) ProtoReflect() protoreflect.Message
func (*DeprecateServiceTaskResponse) Reset ¶ added in v1.1.670
func (x *DeprecateServiceTaskResponse) Reset()
func (*DeprecateServiceTaskResponse) String ¶ added in v1.1.670
func (x *DeprecateServiceTaskResponse) String() string
type Element ¶
type Element struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Id - the unique identifier for the workflow state machine element. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Name - the name of the state machine element. Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` // Type - the type of state machine element Documentation string `protobuf:"bytes,4,opt,name=documentation,proto3" json:"documentation,omitempty"` // Documentation - any documentation describing the state machine element. Execute string `protobuf:"bytes,5,opt,name=execute,proto3" json:"execute,omitempty"` // Execute - describes the execution parameter, This is used for diffrerent purposes depending on the type. Outbound *Targets `protobuf:"bytes,6,opt,name=outbound,proto3" json:"outbound,omitempty"` // Outbound - a number of possible transitions to other state machine state elements.s Process *Process `protobuf:"bytes,7,opt,name=process,proto3" json:"process,omitempty"` // Process - defines any subprocesses contained within this state machine. Msg string `protobuf:"bytes,8,opt,name=msg,proto3" json:"msg,omitempty"` // TODO: Document Candidates string `protobuf:"bytes,10,opt,name=candidates,proto3" json:"candidates,omitempty"` // Candidates - used for user related state machgine types to define users that may complete the task. CandidateGroups string `protobuf:"bytes,11,opt,name=candidateGroups,proto3" json:"candidateGroups,omitempty"` // CandidateGroups - used for user related state machine types to define groups that may complete a task. Errors []*CatchError `protobuf:"bytes,12,rep,name=errors,proto3" json:"errors,omitempty"` // Errors - a number of catchable errors for this state machine element. Error *Error `protobuf:"bytes,13,opt,name=error,proto3" json:"error,omitempty"` // Error - an error that may be thrown. InputTransform map[string]string `` // InputTransform - a transformation to poerform between variable names when calling a state machine task. /* 170-byte string literal not displayed */ OutputTransform map[string]string `` // OutputTransform - a transformation to poerform between variable names when exiting a state machine task. /* 172-byte string literal not displayed */ Timer *WorkflowTimerDefinition `protobuf:"bytes,16,opt,name=timer,proto3" json:"timer,omitempty"` // Timer - a time to wait before execution for timer tasks. BoundaryTimer []*Timer `protobuf:"bytes,17,rep,name=boundaryTimer,proto3" json:"boundaryTimer,omitempty"` // BoundaryTimer - a number of timed transitions between this and another state. Gateway *GatewaySpec `protobuf:"bytes,18,opt,name=gateway,proto3,oneof" json:"gateway,omitempty"` // GatewaySpec - if this element is a gateway, this contains the type specification for it. Iteration *Iteration `protobuf:"bytes,19,opt,name=iteration,proto3,oneof" json:"iteration,omitempty"` // Iteration - gives any instructions for multi instance execution. Version *string `protobuf:"bytes,20,opt,name=version,proto3,oneof" json:"version,omitempty"` // Version - provides version information about a resource such as a task. RetryBehaviour *DefaultTaskRetry `protobuf:"bytes,21,opt,name=retryBehaviour,proto3,oneof" json:"retryBehaviour,omitempty"` // RetryBehaviour - the style and type of retry associated with a service task. // contains filtered or unexported fields }
Element describes a single state machine state.
func (*Element) Descriptor
deprecated
func (*Element) GetBoundaryTimer ¶ added in v1.0.235
func (*Element) GetCandidateGroups ¶ added in v0.1.86
func (*Element) GetCandidates ¶ added in v0.1.86
func (*Element) GetDocumentation ¶
func (*Element) GetErrors ¶ added in v0.1.134
func (x *Element) GetErrors() []*CatchError
func (*Element) GetExecute ¶
func (*Element) GetGateway ¶ added in v1.0.446
func (x *Element) GetGateway() *GatewaySpec
func (*Element) GetInputTransform ¶ added in v0.1.175
func (*Element) GetIteration ¶ added in v1.0.485
func (*Element) GetOutbound ¶
func (*Element) GetOutputTransform ¶ added in v0.1.175
func (*Element) GetProcess ¶
func (*Element) GetRetryBehaviour ¶ added in v1.0.623
func (x *Element) GetRetryBehaviour() *DefaultTaskRetry
func (*Element) GetTimer ¶ added in v0.1.181
func (x *Element) GetTimer() *WorkflowTimerDefinition
func (*Element) GetVersion ¶ added in v1.0.623
func (*Element) ProtoMessage ¶
func (*Element) ProtoMessage()
func (*Element) ProtoReflect ¶
func (x *Element) ProtoReflect() protoreflect.Message
type Error ¶ added in v0.1.134
type Error struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Id - the unique id for the error. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Name - the error unique name. Code string `protobuf:"bytes,3,opt,name=code,proto3" json:"code,omitempty"` // Code - the unique code for the error. // contains filtered or unexported fields }
Error represents a known error name and code which may be thrown by the state machine.
func (*Error) Descriptor
deprecated
added in
v0.1.134
func (*Error) ProtoMessage ¶ added in v0.1.134
func (*Error) ProtoMessage()
func (*Error) ProtoReflect ¶ added in v0.1.134
func (x *Error) ProtoReflect() protoreflect.Message
type Exchange ¶ added in v1.1.725
type Exchange struct { Sender *Sender `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` // Sender - the sender side of the exchange Receivers map[string]*Receiver `` // Receivers - the receiver sides of the exchange /* 159-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Exchange) Descriptor
deprecated
added in
v1.1.725
func (*Exchange) GetReceivers ¶ added in v1.1.725
func (*Exchange) ProtoMessage ¶ added in v1.1.725
func (*Exchange) ProtoMessage()
func (*Exchange) ProtoReflect ¶ added in v1.1.725
func (x *Exchange) ProtoReflect() protoreflect.Message
type Execution ¶ added in v1.0.645
type Execution struct { ExecutionId string `protobuf:"bytes,1,opt,name=executionId,proto3" json:"executionId,omitempty"` // executionId - The id of this particular BPMExecution WorkflowId string `protobuf:"bytes,2,opt,name=workflowId,proto3" json:"workflowId,omitempty"` // WorkflowId - the workflow version ID that this instance is executing. WorkflowName string `protobuf:"bytes,5,opt,name=workflowName,proto3" json:"workflowName,omitempty"` // WorkflowName - name of this workflow to avoid lookups. ProcessInstanceId []string `protobuf:"bytes,6,rep,name=processInstanceId,proto3" json:"processInstanceId,omitempty"` // ProcessInstance - process instances berlonging to this workflow instance. // contains filtered or unexported fields }
Execution contains all of the metadata for a currently running workflow.
func (*Execution) Descriptor
deprecated
added in
v1.0.645
func (*Execution) GetExecutionId ¶ added in v1.0.645
func (*Execution) GetProcessInstanceId ¶ added in v1.0.645
func (*Execution) GetWorkflowId ¶ added in v1.0.645
func (*Execution) GetWorkflowName ¶ added in v1.0.645
func (*Execution) ProtoMessage ¶ added in v1.0.645
func (*Execution) ProtoMessage()
func (*Execution) ProtoReflect ¶ added in v1.0.645
func (x *Execution) ProtoReflect() protoreflect.Message
type Gateway ¶ added in v1.0.446
type Gateway struct { MetExpectations map[string]string `` // MetExpectations - a list of expectations that were met for the gateway. /* 171-byte string literal not displayed */ Vars [][]byte `protobuf:"bytes,2,rep,name=vars,proto3" json:"vars,omitempty"` // Vars - A go binary encoded map[string]interface{} of variables. Visits int64 `protobuf:"varint,3,opt,name=visits,proto3" json:"visits,omitempty"` // Visits - The number of visits this gateway has recieved // contains filtered or unexported fields }
func (*Gateway) Descriptor
deprecated
added in
v1.0.446
func (*Gateway) GetMetExpectations ¶ added in v1.0.446
func (*Gateway) ProtoMessage ¶ added in v1.0.446
func (*Gateway) ProtoMessage()
func (*Gateway) ProtoReflect ¶ added in v1.0.446
func (x *Gateway) ProtoReflect() protoreflect.Message
type GatewayDirection ¶ added in v1.0.446
type GatewayDirection int32
const ( GatewayDirection_divergent GatewayDirection = 0 GatewayDirection_convergent GatewayDirection = 1 )
func (GatewayDirection) Descriptor ¶ added in v1.0.446
func (GatewayDirection) Descriptor() protoreflect.EnumDescriptor
func (GatewayDirection) Enum ¶ added in v1.0.446
func (x GatewayDirection) Enum() *GatewayDirection
func (GatewayDirection) EnumDescriptor
deprecated
added in
v1.0.446
func (GatewayDirection) EnumDescriptor() ([]byte, []int)
Deprecated: Use GatewayDirection.Descriptor instead.
func (GatewayDirection) Number ¶ added in v1.0.446
func (x GatewayDirection) Number() protoreflect.EnumNumber
func (GatewayDirection) String ¶ added in v1.0.446
func (x GatewayDirection) String() string
func (GatewayDirection) Type ¶ added in v1.0.446
func (GatewayDirection) Type() protoreflect.EnumType
type GatewayExpectations ¶ added in v1.0.446
type GatewayExpectations struct { ExpectedPaths []string `protobuf:"bytes,1,rep,name=expectedPaths,proto3" json:"expectedPaths,omitempty"` // ExpectedPaths - a list of paths that compose a gatew's expectaions // contains filtered or unexported fields }
func (*GatewayExpectations) Descriptor
deprecated
added in
v1.0.446
func (*GatewayExpectations) Descriptor() ([]byte, []int)
Deprecated: Use GatewayExpectations.ProtoReflect.Descriptor instead.
func (*GatewayExpectations) GetExpectedPaths ¶ added in v1.0.446
func (x *GatewayExpectations) GetExpectedPaths() []string
func (*GatewayExpectations) ProtoMessage ¶ added in v1.0.446
func (*GatewayExpectations) ProtoMessage()
func (*GatewayExpectations) ProtoReflect ¶ added in v1.0.446
func (x *GatewayExpectations) ProtoReflect() protoreflect.Message
func (*GatewayExpectations) Reset ¶ added in v1.0.446
func (x *GatewayExpectations) Reset()
func (*GatewayExpectations) String ¶ added in v1.0.446
func (x *GatewayExpectations) String() string
type GatewaySpec ¶ added in v1.0.446
type GatewaySpec struct { Type GatewayType `protobuf:"varint,1,opt,name=type,proto3,enum=GatewayType" json:"type,omitempty"` Direction GatewayDirection `protobuf:"varint,2,opt,name=direction,proto3,enum=GatewayDirection" json:"direction,omitempty"` ReciprocalId string `protobuf:"bytes,3,opt,name=reciprocalId,proto3" json:"reciprocalId,omitempty"` FixedExpectations []string `protobuf:"bytes,4,rep,name=fixedExpectations,proto3" json:"fixedExpectations,omitempty"` // contains filtered or unexported fields }
func (*GatewaySpec) Descriptor
deprecated
added in
v1.0.446
func (*GatewaySpec) Descriptor() ([]byte, []int)
Deprecated: Use GatewaySpec.ProtoReflect.Descriptor instead.
func (*GatewaySpec) GetDirection ¶ added in v1.0.446
func (x *GatewaySpec) GetDirection() GatewayDirection
func (*GatewaySpec) GetFixedExpectations ¶ added in v1.0.446
func (x *GatewaySpec) GetFixedExpectations() []string
func (*GatewaySpec) GetReciprocalId ¶ added in v1.0.446
func (x *GatewaySpec) GetReciprocalId() string
func (*GatewaySpec) GetType ¶ added in v1.0.446
func (x *GatewaySpec) GetType() GatewayType
func (*GatewaySpec) ProtoMessage ¶ added in v1.0.446
func (*GatewaySpec) ProtoMessage()
func (*GatewaySpec) ProtoReflect ¶ added in v1.0.446
func (x *GatewaySpec) ProtoReflect() protoreflect.Message
func (*GatewaySpec) Reset ¶ added in v1.0.446
func (x *GatewaySpec) Reset()
func (*GatewaySpec) String ¶ added in v1.0.446
func (x *GatewaySpec) String() string
type GatewayType ¶ added in v1.0.446
type GatewayType int32
const ( GatewayType_exclusive GatewayType = 0 // Exclusive - When splitting, it routes the sequence flow to exactly one of the outgoing branches. When merging, it awaits one incoming branch to complete before triggering the outgoing flow. GatewayType_inclusive GatewayType = 1 // Inclusive - When splitting, one or more branches are activated. All active incoming branches must complete before merging. GatewayType_parallel GatewayType = 2 // Parralel - When used to split the sequence flow, all outgoing branches are activated simultaneously. When merging parallel branches it waits for all incoming branches to complete before triggering the outgoing flow. )
func (GatewayType) Descriptor ¶ added in v1.0.446
func (GatewayType) Descriptor() protoreflect.EnumDescriptor
func (GatewayType) Enum ¶ added in v1.0.446
func (x GatewayType) Enum() *GatewayType
func (GatewayType) EnumDescriptor
deprecated
added in
v1.0.446
func (GatewayType) EnumDescriptor() ([]byte, []int)
Deprecated: Use GatewayType.Descriptor instead.
func (GatewayType) Number ¶ added in v1.0.446
func (x GatewayType) Number() protoreflect.EnumNumber
func (GatewayType) String ¶ added in v1.0.446
func (x GatewayType) String() string
func (GatewayType) Type ¶ added in v1.0.446
func (GatewayType) Type() protoreflect.EnumType
type GetProcessHistoryRequest ¶ added in v1.0.477
type GetProcessHistoryRequest struct { Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` // contains filtered or unexported fields }
func (*GetProcessHistoryRequest) Descriptor
deprecated
added in
v1.0.477
func (*GetProcessHistoryRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetProcessHistoryRequest.ProtoReflect.Descriptor instead.
func (*GetProcessHistoryRequest) GetId ¶ added in v1.0.477
func (x *GetProcessHistoryRequest) GetId() string
func (*GetProcessHistoryRequest) ProtoMessage ¶ added in v1.0.477
func (*GetProcessHistoryRequest) ProtoMessage()
func (*GetProcessHistoryRequest) ProtoReflect ¶ added in v1.0.477
func (x *GetProcessHistoryRequest) ProtoReflect() protoreflect.Message
func (*GetProcessHistoryRequest) Reset ¶ added in v1.0.477
func (x *GetProcessHistoryRequest) Reset()
func (*GetProcessHistoryRequest) String ¶ added in v1.0.477
func (x *GetProcessHistoryRequest) String() string
type GetProcessHistoryResponse ¶ added in v1.0.477
type GetProcessHistoryResponse struct { Entry []*ProcessHistoryEntry `protobuf:"bytes,1,rep,name=entry,proto3" json:"entry,omitempty"` // contains filtered or unexported fields }
func (*GetProcessHistoryResponse) Descriptor
deprecated
added in
v1.0.477
func (*GetProcessHistoryResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetProcessHistoryResponse.ProtoReflect.Descriptor instead.
func (*GetProcessHistoryResponse) GetEntry ¶ added in v1.0.477
func (x *GetProcessHistoryResponse) GetEntry() []*ProcessHistoryEntry
func (*GetProcessHistoryResponse) ProtoMessage ¶ added in v1.0.477
func (*GetProcessHistoryResponse) ProtoMessage()
func (*GetProcessHistoryResponse) ProtoReflect ¶ added in v1.0.477
func (x *GetProcessHistoryResponse) ProtoReflect() protoreflect.Message
func (*GetProcessHistoryResponse) Reset ¶ added in v1.0.477
func (x *GetProcessHistoryResponse) Reset()
func (*GetProcessHistoryResponse) String ¶ added in v1.0.477
func (x *GetProcessHistoryResponse) String() string
type GetProcessInstanceStatusRequest ¶ added in v1.0.427
type GetProcessInstanceStatusRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetProcessInstanceStatusRequest) Descriptor
deprecated
added in
v1.0.427
func (*GetProcessInstanceStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetProcessInstanceStatusRequest.ProtoReflect.Descriptor instead.
func (*GetProcessInstanceStatusRequest) GetId ¶ added in v1.0.427
func (x *GetProcessInstanceStatusRequest) GetId() string
func (*GetProcessInstanceStatusRequest) ProtoMessage ¶ added in v1.0.427
func (*GetProcessInstanceStatusRequest) ProtoMessage()
func (*GetProcessInstanceStatusRequest) ProtoReflect ¶ added in v1.0.427
func (x *GetProcessInstanceStatusRequest) ProtoReflect() protoreflect.Message
func (*GetProcessInstanceStatusRequest) Reset ¶ added in v1.0.427
func (x *GetProcessInstanceStatusRequest) Reset()
func (*GetProcessInstanceStatusRequest) String ¶ added in v1.0.427
func (x *GetProcessInstanceStatusRequest) String() string
type GetProcessInstanceStatusResponse ¶ added in v1.1.725
type GetProcessInstanceStatusResponse struct {
// contains filtered or unexported fields
}
func (*GetProcessInstanceStatusResponse) Descriptor
deprecated
added in
v1.1.725
func (*GetProcessInstanceStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetProcessInstanceStatusResponse.ProtoReflect.Descriptor instead.
func (*GetProcessInstanceStatusResponse) ProtoMessage ¶ added in v1.1.725
func (*GetProcessInstanceStatusResponse) ProtoMessage()
func (*GetProcessInstanceStatusResponse) ProtoReflect ¶ added in v1.1.725
func (x *GetProcessInstanceStatusResponse) ProtoReflect() protoreflect.Message
func (*GetProcessInstanceStatusResponse) Reset ¶ added in v1.1.725
func (x *GetProcessInstanceStatusResponse) Reset()
func (*GetProcessInstanceStatusResponse) String ¶ added in v1.1.725
func (x *GetProcessInstanceStatusResponse) String() string
type GetProcessInstanceStatusResult ¶ added in v1.0.427
type GetProcessInstanceStatusResult struct { ProcessState []*WorkflowState `protobuf:"bytes,1,rep,name=processState,proto3" json:"processState,omitempty"` // ProcessInstance - process instances belonging to this workflow instance. // contains filtered or unexported fields }
func (*GetProcessInstanceStatusResult) Descriptor
deprecated
added in
v1.0.427
func (*GetProcessInstanceStatusResult) Descriptor() ([]byte, []int)
Deprecated: Use GetProcessInstanceStatusResult.ProtoReflect.Descriptor instead.
func (*GetProcessInstanceStatusResult) GetProcessState ¶ added in v1.0.427
func (x *GetProcessInstanceStatusResult) GetProcessState() []*WorkflowState
func (*GetProcessInstanceStatusResult) ProtoMessage ¶ added in v1.0.427
func (*GetProcessInstanceStatusResult) ProtoMessage()
func (*GetProcessInstanceStatusResult) ProtoReflect ¶ added in v1.0.427
func (x *GetProcessInstanceStatusResult) ProtoReflect() protoreflect.Message
func (*GetProcessInstanceStatusResult) Reset ¶ added in v1.0.427
func (x *GetProcessInstanceStatusResult) Reset()
func (*GetProcessInstanceStatusResult) String ¶ added in v1.0.427
func (x *GetProcessInstanceStatusResult) String() string
type GetServiceTaskRoutingIDRequest ¶ added in v1.0.514
type GetServiceTaskRoutingIDRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` RequestedId string `protobuf:"bytes,2,opt,name=requestedId,proto3" json:"requestedId,omitempty"` // contains filtered or unexported fields }
func (*GetServiceTaskRoutingIDRequest) Descriptor
deprecated
added in
v1.0.514
func (*GetServiceTaskRoutingIDRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetServiceTaskRoutingIDRequest.ProtoReflect.Descriptor instead.
func (*GetServiceTaskRoutingIDRequest) GetName ¶ added in v1.0.514
func (x *GetServiceTaskRoutingIDRequest) GetName() string
func (*GetServiceTaskRoutingIDRequest) GetRequestedId ¶ added in v1.0.514
func (x *GetServiceTaskRoutingIDRequest) GetRequestedId() string
func (*GetServiceTaskRoutingIDRequest) ProtoMessage ¶ added in v1.0.514
func (*GetServiceTaskRoutingIDRequest) ProtoMessage()
func (*GetServiceTaskRoutingIDRequest) ProtoReflect ¶ added in v1.0.514
func (x *GetServiceTaskRoutingIDRequest) ProtoReflect() protoreflect.Message
func (*GetServiceTaskRoutingIDRequest) Reset ¶ added in v1.0.514
func (x *GetServiceTaskRoutingIDRequest) Reset()
func (*GetServiceTaskRoutingIDRequest) String ¶ added in v1.0.514
func (x *GetServiceTaskRoutingIDRequest) String() string
type GetServiceTaskRoutingIDResponse ¶ added in v1.0.514
type GetServiceTaskRoutingIDResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetServiceTaskRoutingIDResponse) Descriptor
deprecated
added in
v1.0.514
func (*GetServiceTaskRoutingIDResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetServiceTaskRoutingIDResponse.ProtoReflect.Descriptor instead.
func (*GetServiceTaskRoutingIDResponse) GetId ¶ added in v1.0.514
func (x *GetServiceTaskRoutingIDResponse) GetId() string
func (*GetServiceTaskRoutingIDResponse) ProtoMessage ¶ added in v1.0.514
func (*GetServiceTaskRoutingIDResponse) ProtoMessage()
func (*GetServiceTaskRoutingIDResponse) ProtoReflect ¶ added in v1.0.514
func (x *GetServiceTaskRoutingIDResponse) ProtoReflect() protoreflect.Message
func (*GetServiceTaskRoutingIDResponse) Reset ¶ added in v1.0.514
func (x *GetServiceTaskRoutingIDResponse) Reset()
func (*GetServiceTaskRoutingIDResponse) String ¶ added in v1.0.514
func (x *GetServiceTaskRoutingIDResponse) String() string
type GetTaskSpecRequest ¶ added in v1.0.623
type GetTaskSpecRequest struct { Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"` // Uid of the registered task. // contains filtered or unexported fields }
GetTaskSpecRequest contains the UID of a registered task.
func (*GetTaskSpecRequest) Descriptor
deprecated
added in
v1.0.623
func (*GetTaskSpecRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTaskSpecRequest.ProtoReflect.Descriptor instead.
func (*GetTaskSpecRequest) GetUid ¶ added in v1.0.623
func (x *GetTaskSpecRequest) GetUid() string
func (*GetTaskSpecRequest) ProtoMessage ¶ added in v1.0.623
func (*GetTaskSpecRequest) ProtoMessage()
func (*GetTaskSpecRequest) ProtoReflect ¶ added in v1.0.623
func (x *GetTaskSpecRequest) ProtoReflect() protoreflect.Message
func (*GetTaskSpecRequest) Reset ¶ added in v1.0.623
func (x *GetTaskSpecRequest) Reset()
func (*GetTaskSpecRequest) String ¶ added in v1.0.623
func (x *GetTaskSpecRequest) String() string
type GetTaskSpecResponse ¶ added in v1.0.623
type GetTaskSpecResponse struct { Spec *TaskSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` // Spec - the task specification. // contains filtered or unexported fields }
GetTaskSpecResponse returns a task spec.
func (*GetTaskSpecResponse) Descriptor
deprecated
added in
v1.0.623
func (*GetTaskSpecResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTaskSpecResponse.ProtoReflect.Descriptor instead.
func (*GetTaskSpecResponse) GetSpec ¶ added in v1.0.623
func (x *GetTaskSpecResponse) GetSpec() *TaskSpec
func (*GetTaskSpecResponse) ProtoMessage ¶ added in v1.0.623
func (*GetTaskSpecResponse) ProtoMessage()
func (*GetTaskSpecResponse) ProtoReflect ¶ added in v1.0.623
func (x *GetTaskSpecResponse) ProtoReflect() protoreflect.Message
func (*GetTaskSpecResponse) Reset ¶ added in v1.0.623
func (x *GetTaskSpecResponse) Reset()
func (*GetTaskSpecResponse) String ¶ added in v1.0.623
func (x *GetTaskSpecResponse) String() string
type GetTaskSpecUsageRequest ¶ added in v1.1.670
type GetTaskSpecUsageRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetTaskSpecUsageRequest) Descriptor
deprecated
added in
v1.1.670
func (*GetTaskSpecUsageRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTaskSpecUsageRequest.ProtoReflect.Descriptor instead.
func (*GetTaskSpecUsageRequest) GetId ¶ added in v1.1.670
func (x *GetTaskSpecUsageRequest) GetId() string
func (*GetTaskSpecUsageRequest) ProtoMessage ¶ added in v1.1.670
func (*GetTaskSpecUsageRequest) ProtoMessage()
func (*GetTaskSpecUsageRequest) ProtoReflect ¶ added in v1.1.670
func (x *GetTaskSpecUsageRequest) ProtoReflect() protoreflect.Message
func (*GetTaskSpecUsageRequest) Reset ¶ added in v1.1.670
func (x *GetTaskSpecUsageRequest) Reset()
func (*GetTaskSpecUsageRequest) String ¶ added in v1.1.670
func (x *GetTaskSpecUsageRequest) String() string
type GetTaskSpecUsageResponse ¶ added in v1.1.725
type GetTaskSpecUsageResponse struct {
// contains filtered or unexported fields
}
func (*GetTaskSpecUsageResponse) Descriptor
deprecated
added in
v1.1.725
func (*GetTaskSpecUsageResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTaskSpecUsageResponse.ProtoReflect.Descriptor instead.
func (*GetTaskSpecUsageResponse) ProtoMessage ¶ added in v1.1.725
func (*GetTaskSpecUsageResponse) ProtoMessage()
func (*GetTaskSpecUsageResponse) ProtoReflect ¶ added in v1.1.725
func (x *GetTaskSpecUsageResponse) ProtoReflect() protoreflect.Message
func (*GetTaskSpecUsageResponse) Reset ¶ added in v1.1.725
func (x *GetTaskSpecUsageResponse) Reset()
func (*GetTaskSpecUsageResponse) String ¶ added in v1.1.725
func (x *GetTaskSpecUsageResponse) String() string
type GetTaskSpecVersionsRequest ¶ added in v1.1.670
type GetTaskSpecVersionsRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Name of the task specification. // contains filtered or unexported fields }
func (*GetTaskSpecVersionsRequest) Descriptor
deprecated
added in
v1.1.670
func (*GetTaskSpecVersionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTaskSpecVersionsRequest.ProtoReflect.Descriptor instead.
func (*GetTaskSpecVersionsRequest) GetName ¶ added in v1.1.670
func (x *GetTaskSpecVersionsRequest) GetName() string
func (*GetTaskSpecVersionsRequest) ProtoMessage ¶ added in v1.1.670
func (*GetTaskSpecVersionsRequest) ProtoMessage()
func (*GetTaskSpecVersionsRequest) ProtoReflect ¶ added in v1.1.670
func (x *GetTaskSpecVersionsRequest) ProtoReflect() protoreflect.Message
func (*GetTaskSpecVersionsRequest) Reset ¶ added in v1.1.670
func (x *GetTaskSpecVersionsRequest) Reset()
func (*GetTaskSpecVersionsRequest) String ¶ added in v1.1.670
func (x *GetTaskSpecVersionsRequest) String() string
type GetTaskSpecVersionsResponse ¶ added in v1.1.725
type GetTaskSpecVersionsResponse struct { Versions *TaskSpecVersions `protobuf:"bytes,1,opt,name=versions,proto3" json:"versions,omitempty"` // contains filtered or unexported fields }
func (*GetTaskSpecVersionsResponse) Descriptor
deprecated
added in
v1.1.725
func (*GetTaskSpecVersionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTaskSpecVersionsResponse.ProtoReflect.Descriptor instead.
func (*GetTaskSpecVersionsResponse) GetVersions ¶ added in v1.1.725
func (x *GetTaskSpecVersionsResponse) GetVersions() *TaskSpecVersions
func (*GetTaskSpecVersionsResponse) ProtoMessage ¶ added in v1.1.725
func (*GetTaskSpecVersionsResponse) ProtoMessage()
func (*GetTaskSpecVersionsResponse) ProtoReflect ¶ added in v1.1.725
func (x *GetTaskSpecVersionsResponse) ProtoReflect() protoreflect.Message
func (*GetTaskSpecVersionsResponse) Reset ¶ added in v1.1.725
func (x *GetTaskSpecVersionsResponse) Reset()
func (*GetTaskSpecVersionsResponse) String ¶ added in v1.1.725
func (x *GetTaskSpecVersionsResponse) String() string
type GetUserTaskRequest ¶ added in v0.1.88
type GetUserTaskRequest struct { Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"` TrackingId string `protobuf:"bytes,2,opt,name=trackingId,proto3" json:"trackingId,omitempty"` // contains filtered or unexported fields }
func (*GetUserTaskRequest) Descriptor
deprecated
added in
v0.1.88
func (*GetUserTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetUserTaskRequest.ProtoReflect.Descriptor instead.
func (*GetUserTaskRequest) GetOwner ¶ added in v0.1.88
func (x *GetUserTaskRequest) GetOwner() string
func (*GetUserTaskRequest) GetTrackingId ¶ added in v0.1.88
func (x *GetUserTaskRequest) GetTrackingId() string
func (*GetUserTaskRequest) ProtoMessage ¶ added in v0.1.88
func (*GetUserTaskRequest) ProtoMessage()
func (*GetUserTaskRequest) ProtoReflect ¶ added in v0.1.88
func (x *GetUserTaskRequest) ProtoReflect() protoreflect.Message
func (*GetUserTaskRequest) Reset ¶ added in v0.1.88
func (x *GetUserTaskRequest) Reset()
func (*GetUserTaskRequest) String ¶ added in v0.1.88
func (x *GetUserTaskRequest) String() string
type GetUserTaskResponse ¶ added in v0.1.134
type GetUserTaskResponse struct { TrackingId string `protobuf:"bytes,1,opt,name=trackingId,proto3" json:"trackingId,omitempty"` Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"` Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` Vars []byte `protobuf:"bytes,5,opt,name=vars,proto3" json:"vars,omitempty"` // contains filtered or unexported fields }
func (*GetUserTaskResponse) Descriptor
deprecated
added in
v0.1.134
func (*GetUserTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetUserTaskResponse.ProtoReflect.Descriptor instead.
func (*GetUserTaskResponse) GetDescription ¶ added in v0.1.134
func (x *GetUserTaskResponse) GetDescription() string
func (*GetUserTaskResponse) GetName ¶ added in v0.1.134
func (x *GetUserTaskResponse) GetName() string
func (*GetUserTaskResponse) GetOwner ¶ added in v0.1.134
func (x *GetUserTaskResponse) GetOwner() string
func (*GetUserTaskResponse) GetTrackingId ¶ added in v0.1.134
func (x *GetUserTaskResponse) GetTrackingId() string
func (*GetUserTaskResponse) GetVars ¶ added in v0.1.134
func (x *GetUserTaskResponse) GetVars() []byte
func (*GetUserTaskResponse) ProtoMessage ¶ added in v0.1.134
func (*GetUserTaskResponse) ProtoMessage()
func (*GetUserTaskResponse) ProtoReflect ¶ added in v0.1.134
func (x *GetUserTaskResponse) ProtoReflect() protoreflect.Message
func (*GetUserTaskResponse) Reset ¶ added in v0.1.134
func (x *GetUserTaskResponse) Reset()
func (*GetUserTaskResponse) String ¶ added in v0.1.134
func (x *GetUserTaskResponse) String() string
type GetVersionInfoRequest ¶ added in v1.0.514
type GetVersionInfoRequest struct { ClientVersion string `protobuf:"bytes,1,opt,name=clientVersion,proto3" json:"clientVersion,omitempty"` CompatibleVersion string `protobuf:"bytes,2,opt,name=compatibleVersion,proto3" json:"compatibleVersion,omitempty"` // contains filtered or unexported fields }
func (*GetVersionInfoRequest) Descriptor
deprecated
added in
v1.0.514
func (*GetVersionInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetVersionInfoRequest.ProtoReflect.Descriptor instead.
func (*GetVersionInfoRequest) GetClientVersion ¶ added in v1.0.514
func (x *GetVersionInfoRequest) GetClientVersion() string
func (*GetVersionInfoRequest) GetCompatibleVersion ¶ added in v1.1.677
func (x *GetVersionInfoRequest) GetCompatibleVersion() string
func (*GetVersionInfoRequest) ProtoMessage ¶ added in v1.0.514
func (*GetVersionInfoRequest) ProtoMessage()
func (*GetVersionInfoRequest) ProtoReflect ¶ added in v1.0.514
func (x *GetVersionInfoRequest) ProtoReflect() protoreflect.Message
func (*GetVersionInfoRequest) Reset ¶ added in v1.0.514
func (x *GetVersionInfoRequest) Reset()
func (*GetVersionInfoRequest) String ¶ added in v1.0.514
func (x *GetVersionInfoRequest) String() string
type GetVersionInfoResponse ¶ added in v1.0.514
type GetVersionInfoResponse struct { ServerVersion string `protobuf:"bytes,1,opt,name=serverVersion,proto3" json:"serverVersion,omitempty"` MinCompatibleVersion string `protobuf:"bytes,2,opt,name=minCompatibleVersion,proto3" json:"minCompatibleVersion,omitempty"` Connect bool `protobuf:"varint,3,opt,name=connect,proto3" json:"connect,omitempty"` // contains filtered or unexported fields }
func (*GetVersionInfoResponse) Descriptor
deprecated
added in
v1.0.514
func (*GetVersionInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetVersionInfoResponse.ProtoReflect.Descriptor instead.
func (*GetVersionInfoResponse) GetConnect ¶ added in v1.0.514
func (x *GetVersionInfoResponse) GetConnect() bool
func (*GetVersionInfoResponse) GetMinCompatibleVersion ¶ added in v1.0.514
func (x *GetVersionInfoResponse) GetMinCompatibleVersion() string
func (*GetVersionInfoResponse) GetServerVersion ¶ added in v1.0.514
func (x *GetVersionInfoResponse) GetServerVersion() string
func (*GetVersionInfoResponse) ProtoMessage ¶ added in v1.0.514
func (*GetVersionInfoResponse) ProtoMessage()
func (*GetVersionInfoResponse) ProtoReflect ¶ added in v1.0.514
func (x *GetVersionInfoResponse) ProtoReflect() protoreflect.Message
func (*GetVersionInfoResponse) Reset ¶ added in v1.0.514
func (x *GetVersionInfoResponse) Reset()
func (*GetVersionInfoResponse) String ¶ added in v1.0.514
func (x *GetVersionInfoResponse) String() string
type GetWorkflowRequest ¶ added in v1.0.366
type GetWorkflowRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowRequest) Descriptor
deprecated
added in
v1.0.366
func (*GetWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowRequest.ProtoReflect.Descriptor instead.
func (*GetWorkflowRequest) GetId ¶ added in v1.0.366
func (x *GetWorkflowRequest) GetId() string
func (*GetWorkflowRequest) ProtoMessage ¶ added in v1.0.366
func (*GetWorkflowRequest) ProtoMessage()
func (*GetWorkflowRequest) ProtoReflect ¶ added in v1.0.366
func (x *GetWorkflowRequest) ProtoReflect() protoreflect.Message
func (*GetWorkflowRequest) Reset ¶ added in v1.0.366
func (x *GetWorkflowRequest) Reset()
func (*GetWorkflowRequest) String ¶ added in v1.0.366
func (x *GetWorkflowRequest) String() string
type GetWorkflowResponse ¶ added in v1.0.366
type GetWorkflowResponse struct { Definition *Workflow `protobuf:"bytes,1,opt,name=definition,proto3" json:"definition,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowResponse) Descriptor
deprecated
added in
v1.0.366
func (*GetWorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowResponse.ProtoReflect.Descriptor instead.
func (*GetWorkflowResponse) GetDefinition ¶ added in v1.0.366
func (x *GetWorkflowResponse) GetDefinition() *Workflow
func (*GetWorkflowResponse) ProtoMessage ¶ added in v1.0.366
func (*GetWorkflowResponse) ProtoMessage()
func (*GetWorkflowResponse) ProtoReflect ¶ added in v1.0.366
func (x *GetWorkflowResponse) ProtoReflect() protoreflect.Message
func (*GetWorkflowResponse) Reset ¶ added in v1.0.366
func (x *GetWorkflowResponse) Reset()
func (*GetWorkflowResponse) String ¶ added in v1.0.366
func (x *GetWorkflowResponse) String() string
type GetWorkflowVersionsRequest ¶ added in v1.0.366
type GetWorkflowVersionsRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowVersionsRequest) Descriptor
deprecated
added in
v1.0.366
func (*GetWorkflowVersionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowVersionsRequest.ProtoReflect.Descriptor instead.
func (*GetWorkflowVersionsRequest) GetName ¶ added in v1.0.366
func (x *GetWorkflowVersionsRequest) GetName() string
func (*GetWorkflowVersionsRequest) ProtoMessage ¶ added in v1.0.366
func (*GetWorkflowVersionsRequest) ProtoMessage()
func (*GetWorkflowVersionsRequest) ProtoReflect ¶ added in v1.0.366
func (x *GetWorkflowVersionsRequest) ProtoReflect() protoreflect.Message
func (*GetWorkflowVersionsRequest) Reset ¶ added in v1.0.366
func (x *GetWorkflowVersionsRequest) Reset()
func (*GetWorkflowVersionsRequest) String ¶ added in v1.0.366
func (x *GetWorkflowVersionsRequest) String() string
type GetWorkflowVersionsResponse ¶ added in v1.0.366
type GetWorkflowVersionsResponse struct { Versions *WorkflowVersions `protobuf:"bytes,1,opt,name=versions,proto3" json:"versions,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowVersionsResponse) Descriptor
deprecated
added in
v1.0.366
func (*GetWorkflowVersionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowVersionsResponse.ProtoReflect.Descriptor instead.
func (*GetWorkflowVersionsResponse) GetVersions ¶ added in v1.0.366
func (x *GetWorkflowVersionsResponse) GetVersions() *WorkflowVersions
func (*GetWorkflowVersionsResponse) ProtoMessage ¶ added in v1.0.366
func (*GetWorkflowVersionsResponse) ProtoMessage()
func (*GetWorkflowVersionsResponse) ProtoReflect ¶ added in v1.0.366
func (x *GetWorkflowVersionsResponse) ProtoReflect() protoreflect.Message
func (*GetWorkflowVersionsResponse) Reset ¶ added in v1.0.366
func (x *GetWorkflowVersionsResponse) Reset()
func (*GetWorkflowVersionsResponse) String ¶ added in v1.0.366
func (x *GetWorkflowVersionsResponse) String() string
type HandleWorkflowErrorRequest ¶ added in v0.1.134
type HandleWorkflowErrorRequest struct { TrackingId string `protobuf:"bytes,1,opt,name=trackingId,proto3" json:"trackingId,omitempty"` ErrorCode string `protobuf:"bytes,2,opt,name=errorCode,proto3" json:"errorCode,omitempty"` Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` Vars []byte `protobuf:"bytes,4,opt,name=vars,proto3" json:"vars,omitempty"` // contains filtered or unexported fields }
func (*HandleWorkflowErrorRequest) Descriptor
deprecated
added in
v0.1.134
func (*HandleWorkflowErrorRequest) Descriptor() ([]byte, []int)
Deprecated: Use HandleWorkflowErrorRequest.ProtoReflect.Descriptor instead.
func (*HandleWorkflowErrorRequest) GetErrorCode ¶ added in v0.1.134
func (x *HandleWorkflowErrorRequest) GetErrorCode() string
func (*HandleWorkflowErrorRequest) GetMessage ¶ added in v0.1.134
func (x *HandleWorkflowErrorRequest) GetMessage() string
func (*HandleWorkflowErrorRequest) GetTrackingId ¶ added in v0.1.134
func (x *HandleWorkflowErrorRequest) GetTrackingId() string
func (*HandleWorkflowErrorRequest) GetVars ¶ added in v1.0.251
func (x *HandleWorkflowErrorRequest) GetVars() []byte
func (*HandleWorkflowErrorRequest) ProtoMessage ¶ added in v0.1.134
func (*HandleWorkflowErrorRequest) ProtoMessage()
func (*HandleWorkflowErrorRequest) ProtoReflect ¶ added in v0.1.134
func (x *HandleWorkflowErrorRequest) ProtoReflect() protoreflect.Message
func (*HandleWorkflowErrorRequest) Reset ¶ added in v0.1.134
func (x *HandleWorkflowErrorRequest) Reset()
func (*HandleWorkflowErrorRequest) String ¶ added in v0.1.134
func (x *HandleWorkflowErrorRequest) String() string
type HandleWorkflowErrorResponse ¶ added in v0.1.134
type HandleWorkflowErrorResponse struct { Handled bool `protobuf:"varint,1,opt,name=handled,proto3" json:"handled,omitempty"` // contains filtered or unexported fields }
func (*HandleWorkflowErrorResponse) Descriptor
deprecated
added in
v0.1.134
func (*HandleWorkflowErrorResponse) Descriptor() ([]byte, []int)
Deprecated: Use HandleWorkflowErrorResponse.ProtoReflect.Descriptor instead.
func (*HandleWorkflowErrorResponse) GetHandled ¶ added in v0.1.134
func (x *HandleWorkflowErrorResponse) GetHandled() bool
func (*HandleWorkflowErrorResponse) ProtoMessage ¶ added in v0.1.134
func (*HandleWorkflowErrorResponse) ProtoMessage()
func (*HandleWorkflowErrorResponse) ProtoReflect ¶ added in v0.1.134
func (x *HandleWorkflowErrorResponse) ProtoReflect() protoreflect.Message
func (*HandleWorkflowErrorResponse) Reset ¶ added in v0.1.134
func (x *HandleWorkflowErrorResponse) Reset()
func (*HandleWorkflowErrorResponse) String ¶ added in v0.1.134
func (x *HandleWorkflowErrorResponse) String() string
type Iteration ¶ added in v1.0.485
type Iteration struct { Collection string `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"` Iterator string `protobuf:"bytes,2,opt,name=iterator,proto3" json:"iterator,omitempty"` CollateAs string `protobuf:"bytes,3,opt,name=collateAs,proto3" json:"collateAs,omitempty"` CollateFrom string `protobuf:"bytes,4,opt,name=collateFrom,proto3" json:"collateFrom,omitempty"` Until *string `protobuf:"bytes,5,opt,name=until,proto3,oneof" json:"until,omitempty"` Execute ThreadingType `protobuf:"varint,6,opt,name=execute,proto3,enum=ThreadingType" json:"execute,omitempty"` // contains filtered or unexported fields }
func (*Iteration) Descriptor
deprecated
added in
v1.0.485
func (*Iteration) GetCollateAs ¶ added in v1.0.485
func (*Iteration) GetCollateFrom ¶ added in v1.0.485
func (*Iteration) GetCollection ¶ added in v1.0.485
func (*Iteration) GetExecute ¶ added in v1.0.485
func (x *Iteration) GetExecute() ThreadingType
func (*Iteration) GetIterator ¶ added in v1.0.485
func (*Iteration) ProtoMessage ¶ added in v1.0.485
func (*Iteration) ProtoMessage()
func (*Iteration) ProtoReflect ¶ added in v1.0.485
func (x *Iteration) ProtoReflect() protoreflect.Message
type Iterator ¶ added in v1.0.498
type Iterator struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Value [][]byte `protobuf:"bytes,2,rep,name=value,proto3" json:"value,omitempty"` Collated [][]byte `protobuf:"bytes,3,rep,name=collated,proto3" json:"collated,omitempty"` // contains filtered or unexported fields }
func (*Iterator) Descriptor
deprecated
added in
v1.0.498
func (*Iterator) GetCollated ¶ added in v1.0.498
func (*Iterator) ProtoMessage ¶ added in v1.0.498
func (*Iterator) ProtoMessage()
func (*Iterator) ProtoReflect ¶ added in v1.0.498
func (x *Iterator) ProtoReflect() protoreflect.Message
type LaunchWorkflowRequest ¶
type LaunchWorkflowRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Vars []byte `protobuf:"bytes,2,opt,name=vars,proto3" json:"vars,omitempty"` // contains filtered or unexported fields }
func (*LaunchWorkflowRequest) Descriptor
deprecated
func (*LaunchWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use LaunchWorkflowRequest.ProtoReflect.Descriptor instead.
func (*LaunchWorkflowRequest) GetName ¶
func (x *LaunchWorkflowRequest) GetName() string
func (*LaunchWorkflowRequest) GetVars ¶
func (x *LaunchWorkflowRequest) GetVars() []byte
func (*LaunchWorkflowRequest) ProtoMessage ¶
func (*LaunchWorkflowRequest) ProtoMessage()
func (*LaunchWorkflowRequest) ProtoReflect ¶
func (x *LaunchWorkflowRequest) ProtoReflect() protoreflect.Message
func (*LaunchWorkflowRequest) Reset ¶
func (x *LaunchWorkflowRequest) Reset()
func (*LaunchWorkflowRequest) String ¶
func (x *LaunchWorkflowRequest) String() string
type LaunchWorkflowResponse ¶ added in v1.0.366
type LaunchWorkflowResponse struct { InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"` WorkflowId string `protobuf:"bytes,2,opt,name=workflowId,proto3" json:"workflowId,omitempty"` // contains filtered or unexported fields }
func (*LaunchWorkflowResponse) Descriptor
deprecated
added in
v1.0.366
func (*LaunchWorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use LaunchWorkflowResponse.ProtoReflect.Descriptor instead.
func (*LaunchWorkflowResponse) GetInstanceId ¶ added in v1.0.366
func (x *LaunchWorkflowResponse) GetInstanceId() string
func (*LaunchWorkflowResponse) GetWorkflowId ¶ added in v1.0.366
func (x *LaunchWorkflowResponse) GetWorkflowId() string
func (*LaunchWorkflowResponse) ProtoMessage ¶ added in v1.0.366
func (*LaunchWorkflowResponse) ProtoMessage()
func (*LaunchWorkflowResponse) ProtoReflect ¶ added in v1.0.366
func (x *LaunchWorkflowResponse) ProtoReflect() protoreflect.Message
func (*LaunchWorkflowResponse) Reset ¶ added in v1.0.366
func (x *LaunchWorkflowResponse) Reset()
func (*LaunchWorkflowResponse) String ¶ added in v1.0.366
func (x *LaunchWorkflowResponse) String() string
type ListExecutionItem ¶ added in v1.1.725
type ListExecutionItem struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Version int32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*ListExecutionItem) Descriptor
deprecated
added in
v1.1.725
func (*ListExecutionItem) Descriptor() ([]byte, []int)
Deprecated: Use ListExecutionItem.ProtoReflect.Descriptor instead.
func (*ListExecutionItem) GetId ¶ added in v1.1.725
func (x *ListExecutionItem) GetId() string
func (*ListExecutionItem) GetVersion ¶ added in v1.1.725
func (x *ListExecutionItem) GetVersion() int32
func (*ListExecutionItem) ProtoMessage ¶ added in v1.1.725
func (*ListExecutionItem) ProtoMessage()
func (*ListExecutionItem) ProtoReflect ¶ added in v1.1.725
func (x *ListExecutionItem) ProtoReflect() protoreflect.Message
func (*ListExecutionItem) Reset ¶ added in v1.1.725
func (x *ListExecutionItem) Reset()
func (*ListExecutionItem) String ¶ added in v1.1.725
func (x *ListExecutionItem) String() string
type ListExecutionProcessesRequest ¶ added in v1.0.645
type ListExecutionProcessesRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*ListExecutionProcessesRequest) Descriptor
deprecated
added in
v1.0.645
func (*ListExecutionProcessesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListExecutionProcessesRequest.ProtoReflect.Descriptor instead.
func (*ListExecutionProcessesRequest) GetId ¶ added in v1.0.645
func (x *ListExecutionProcessesRequest) GetId() string
func (*ListExecutionProcessesRequest) ProtoMessage ¶ added in v1.0.645
func (*ListExecutionProcessesRequest) ProtoMessage()
func (*ListExecutionProcessesRequest) ProtoReflect ¶ added in v1.0.645
func (x *ListExecutionProcessesRequest) ProtoReflect() protoreflect.Message
func (*ListExecutionProcessesRequest) Reset ¶ added in v1.0.645
func (x *ListExecutionProcessesRequest) Reset()
func (*ListExecutionProcessesRequest) String ¶ added in v1.0.645
func (x *ListExecutionProcessesRequest) String() string
type ListExecutionProcessesResponse ¶ added in v1.1.725
type ListExecutionProcessesResponse struct { ProcessInstanceId []string `protobuf:"bytes,1,rep,name=processInstanceId,proto3" json:"processInstanceId,omitempty"` // ProcessInstance - process instances belonging to this workflow instance. // contains filtered or unexported fields }
func (*ListExecutionProcessesResponse) Descriptor
deprecated
added in
v1.1.725
func (*ListExecutionProcessesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListExecutionProcessesResponse.ProtoReflect.Descriptor instead.
func (*ListExecutionProcessesResponse) GetProcessInstanceId ¶ added in v1.1.725
func (x *ListExecutionProcessesResponse) GetProcessInstanceId() []string
func (*ListExecutionProcessesResponse) ProtoMessage ¶ added in v1.1.725
func (*ListExecutionProcessesResponse) ProtoMessage()
func (*ListExecutionProcessesResponse) ProtoReflect ¶ added in v1.1.725
func (x *ListExecutionProcessesResponse) ProtoReflect() protoreflect.Message
func (*ListExecutionProcessesResponse) Reset ¶ added in v1.1.725
func (x *ListExecutionProcessesResponse) Reset()
func (*ListExecutionProcessesResponse) String ¶ added in v1.1.725
func (x *ListExecutionProcessesResponse) String() string
type ListExecutionRequest ¶ added in v1.0.645
type ListExecutionRequest struct { WorkflowName string `protobuf:"bytes,1,opt,name=workflowName,proto3" json:"workflowName,omitempty"` // contains filtered or unexported fields }
func (*ListExecutionRequest) Descriptor
deprecated
added in
v1.0.645
func (*ListExecutionRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListExecutionRequest.ProtoReflect.Descriptor instead.
func (*ListExecutionRequest) GetWorkflowName ¶ added in v1.0.645
func (x *ListExecutionRequest) GetWorkflowName() string
func (*ListExecutionRequest) ProtoMessage ¶ added in v1.0.645
func (*ListExecutionRequest) ProtoMessage()
func (*ListExecutionRequest) ProtoReflect ¶ added in v1.0.645
func (x *ListExecutionRequest) ProtoReflect() protoreflect.Message
func (*ListExecutionRequest) Reset ¶ added in v1.0.645
func (x *ListExecutionRequest) Reset()
func (*ListExecutionRequest) String ¶ added in v1.0.645
func (x *ListExecutionRequest) String() string
type ListExecutionResponse ¶ added in v1.0.645
type ListExecutionResponse struct { Result []*ListExecutionItem `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*ListExecutionResponse) Descriptor
deprecated
added in
v1.0.645
func (*ListExecutionResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListExecutionResponse.ProtoReflect.Descriptor instead.
func (*ListExecutionResponse) GetResult ¶ added in v1.0.645
func (x *ListExecutionResponse) GetResult() []*ListExecutionItem
func (*ListExecutionResponse) ProtoMessage ¶ added in v1.0.645
func (*ListExecutionResponse) ProtoMessage()
func (*ListExecutionResponse) ProtoReflect ¶ added in v1.0.645
func (x *ListExecutionResponse) ProtoReflect() protoreflect.Message
func (*ListExecutionResponse) Reset ¶ added in v1.0.645
func (x *ListExecutionResponse) Reset()
func (*ListExecutionResponse) String ¶ added in v1.0.645
func (x *ListExecutionResponse) String() string
type ListTaskSpecUIDsRequest ¶ added in v1.1.725
type ListTaskSpecUIDsRequest struct { IncludeDeprecated bool `protobuf:"varint,1,opt,name=IncludeDeprecated,proto3" json:"IncludeDeprecated,omitempty"` // contains filtered or unexported fields }
func (*ListTaskSpecUIDsRequest) Descriptor
deprecated
added in
v1.1.725
func (*ListTaskSpecUIDsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListTaskSpecUIDsRequest.ProtoReflect.Descriptor instead.
func (*ListTaskSpecUIDsRequest) GetIncludeDeprecated ¶ added in v1.1.725
func (x *ListTaskSpecUIDsRequest) GetIncludeDeprecated() bool
func (*ListTaskSpecUIDsRequest) ProtoMessage ¶ added in v1.1.725
func (*ListTaskSpecUIDsRequest) ProtoMessage()
func (*ListTaskSpecUIDsRequest) ProtoReflect ¶ added in v1.1.725
func (x *ListTaskSpecUIDsRequest) ProtoReflect() protoreflect.Message
func (*ListTaskSpecUIDsRequest) Reset ¶ added in v1.1.725
func (x *ListTaskSpecUIDsRequest) Reset()
func (*ListTaskSpecUIDsRequest) String ¶ added in v1.1.725
func (x *ListTaskSpecUIDsRequest) String() string
type ListTaskSpecUIDsResponse ¶ added in v1.1.725
type ListTaskSpecUIDsResponse struct { Uid []string `protobuf:"bytes,1,rep,name=uid,proto3" json:"uid,omitempty"` // contains filtered or unexported fields }
func (*ListTaskSpecUIDsResponse) Descriptor
deprecated
added in
v1.1.725
func (*ListTaskSpecUIDsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListTaskSpecUIDsResponse.ProtoReflect.Descriptor instead.
func (*ListTaskSpecUIDsResponse) GetUid ¶ added in v1.1.725
func (x *ListTaskSpecUIDsResponse) GetUid() []string
func (*ListTaskSpecUIDsResponse) ProtoMessage ¶ added in v1.1.725
func (*ListTaskSpecUIDsResponse) ProtoMessage()
func (*ListTaskSpecUIDsResponse) ProtoReflect ¶ added in v1.1.725
func (x *ListTaskSpecUIDsResponse) ProtoReflect() protoreflect.Message
func (*ListTaskSpecUIDsResponse) Reset ¶ added in v1.1.725
func (x *ListTaskSpecUIDsResponse) Reset()
func (*ListTaskSpecUIDsResponse) String ¶ added in v1.1.725
func (x *ListTaskSpecUIDsResponse) String() string
type ListUserTasksRequest ¶ added in v0.1.86
type ListUserTasksRequest struct { Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"` // contains filtered or unexported fields }
func (*ListUserTasksRequest) Descriptor
deprecated
added in
v0.1.86
func (*ListUserTasksRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListUserTasksRequest.ProtoReflect.Descriptor instead.
func (*ListUserTasksRequest) GetOwner ¶ added in v0.1.86
func (x *ListUserTasksRequest) GetOwner() string
func (*ListUserTasksRequest) ProtoMessage ¶ added in v0.1.86
func (*ListUserTasksRequest) ProtoMessage()
func (*ListUserTasksRequest) ProtoReflect ¶ added in v0.1.86
func (x *ListUserTasksRequest) ProtoReflect() protoreflect.Message
func (*ListUserTasksRequest) Reset ¶ added in v0.1.86
func (x *ListUserTasksRequest) Reset()
func (*ListUserTasksRequest) String ¶ added in v0.1.86
func (x *ListUserTasksRequest) String() string
type ListUserTasksResponse ¶ added in v1.1.725
type ListUserTasksResponse struct {
// contains filtered or unexported fields
}
func (*ListUserTasksResponse) Descriptor
deprecated
added in
v1.1.725
func (*ListUserTasksResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListUserTasksResponse.ProtoReflect.Descriptor instead.
func (*ListUserTasksResponse) ProtoMessage ¶ added in v1.1.725
func (*ListUserTasksResponse) ProtoMessage()
func (*ListUserTasksResponse) ProtoReflect ¶ added in v1.1.725
func (x *ListUserTasksResponse) ProtoReflect() protoreflect.Message
func (*ListUserTasksResponse) Reset ¶ added in v1.1.725
func (x *ListUserTasksResponse) Reset()
func (*ListUserTasksResponse) String ¶ added in v1.1.725
func (x *ListUserTasksResponse) String() string
type ListWorkflowResponse ¶ added in v1.1.725
type ListWorkflowResponse struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Version int32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*ListWorkflowResponse) Descriptor
deprecated
added in
v1.1.725
func (*ListWorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListWorkflowResponse.ProtoReflect.Descriptor instead.
func (*ListWorkflowResponse) GetName ¶ added in v1.1.725
func (x *ListWorkflowResponse) GetName() string
func (*ListWorkflowResponse) GetVersion ¶ added in v1.1.725
func (x *ListWorkflowResponse) GetVersion() int32
func (*ListWorkflowResponse) ProtoMessage ¶ added in v1.1.725
func (*ListWorkflowResponse) ProtoMessage()
func (*ListWorkflowResponse) ProtoReflect ¶ added in v1.1.725
func (x *ListWorkflowResponse) ProtoReflect() protoreflect.Message
func (*ListWorkflowResponse) Reset ¶ added in v1.1.725
func (x *ListWorkflowResponse) Reset()
func (*ListWorkflowResponse) String ¶ added in v1.1.725
func (x *ListWorkflowResponse) String() string
type ListWorkflowsRequest ¶ added in v1.1.725
type ListWorkflowsRequest struct {
// contains filtered or unexported fields
}
func (*ListWorkflowsRequest) Descriptor
deprecated
added in
v1.1.725
func (*ListWorkflowsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListWorkflowsRequest.ProtoReflect.Descriptor instead.
func (*ListWorkflowsRequest) ProtoMessage ¶ added in v1.1.725
func (*ListWorkflowsRequest) ProtoMessage()
func (*ListWorkflowsRequest) ProtoReflect ¶ added in v1.1.725
func (x *ListWorkflowsRequest) ProtoReflect() protoreflect.Message
func (*ListWorkflowsRequest) Reset ¶ added in v1.1.725
func (x *ListWorkflowsRequest) Reset()
func (*ListWorkflowsRequest) String ¶ added in v1.1.725
func (x *ListWorkflowsRequest) String() string
type ListWorkflowsResponse ¶
type ListWorkflowsResponse struct { Result []*ListWorkflowResponse `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*ListWorkflowsResponse) Descriptor
deprecated
func (*ListWorkflowsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListWorkflowsResponse.ProtoReflect.Descriptor instead.
func (*ListWorkflowsResponse) GetResult ¶
func (x *ListWorkflowsResponse) GetResult() []*ListWorkflowResponse
func (*ListWorkflowsResponse) ProtoMessage ¶
func (*ListWorkflowsResponse) ProtoMessage()
func (*ListWorkflowsResponse) ProtoReflect ¶
func (x *ListWorkflowsResponse) ProtoReflect() protoreflect.Message
func (*ListWorkflowsResponse) Reset ¶
func (x *ListWorkflowsResponse) Reset()
func (*ListWorkflowsResponse) String ¶
func (x *ListWorkflowsResponse) String() string
type LogSource ¶ added in v1.0.271
type LogSource int32
func (LogSource) Descriptor ¶ added in v1.0.271
func (LogSource) Descriptor() protoreflect.EnumDescriptor
func (LogSource) EnumDescriptor
deprecated
added in
v1.0.271
func (LogSource) Number ¶ added in v1.0.271
func (x LogSource) Number() protoreflect.EnumNumber
func (LogSource) Type ¶ added in v1.0.271
func (LogSource) Type() protoreflect.EnumType
type Message ¶ added in v1.0.514
type Message struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Message name for a workflow message. CorrelationKey string `protobuf:"bytes,2,opt,name=correlationKey,proto3" json:"correlationKey,omitempty"` // CorrelationKey - the workflow message correlation key. Short string `protobuf:"bytes,3,opt,name=short,proto3" json:"short,omitempty"` // Short description of the parameter. Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` // Description - a long description of the parameter. // contains filtered or unexported fields }
func (*Message) Descriptor
deprecated
added in
v1.0.514
func (*Message) GetCorrelationKey ¶ added in v1.0.514
func (*Message) GetDescription ¶ added in v1.0.623
func (*Message) ProtoMessage ¶ added in v1.0.514
func (*Message) ProtoMessage()
func (*Message) ProtoReflect ¶ added in v1.0.514
func (x *Message) ProtoReflect() protoreflect.Message
type MessageFlow ¶ added in v1.0.645
type MessageFlow struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Id for the message flow. Sender string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"` // Source of the message. Recipient string `protobuf:"bytes,3,opt,name=recipient,proto3" json:"recipient,omitempty"` // Recipient of the message. // contains filtered or unexported fields }
func (*MessageFlow) Descriptor
deprecated
added in
v1.0.645
func (*MessageFlow) Descriptor() ([]byte, []int)
Deprecated: Use MessageFlow.ProtoReflect.Descriptor instead.
func (*MessageFlow) GetId ¶ added in v1.0.645
func (x *MessageFlow) GetId() string
func (*MessageFlow) GetRecipient ¶ added in v1.0.645
func (x *MessageFlow) GetRecipient() string
func (*MessageFlow) GetSender ¶ added in v1.0.645
func (x *MessageFlow) GetSender() string
func (*MessageFlow) ProtoMessage ¶ added in v1.0.645
func (*MessageFlow) ProtoMessage()
func (*MessageFlow) ProtoReflect ¶ added in v1.0.645
func (x *MessageFlow) ProtoReflect() protoreflect.Message
func (*MessageFlow) Reset ¶ added in v1.0.645
func (x *MessageFlow) Reset()
func (*MessageFlow) String ¶ added in v1.0.645
func (x *MessageFlow) String() string
type MessageInstance ¶
type MessageInstance struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // MessageId - the unique messageId for the message. CorrelationKey string `protobuf:"bytes,2,opt,name=correlationKey,proto3" json:"correlationKey,omitempty"` // CorrelationKey - a receiving key to correlate this message to. Vars []byte `protobuf:"bytes,3,opt,name=vars,proto3" json:"vars,omitempty"` // Vars - A go binary encoded map[string]interface{} of variables. // contains filtered or unexported fields }
MessageInstance represents a workflow message.
func (*MessageInstance) Descriptor
deprecated
func (*MessageInstance) Descriptor() ([]byte, []int)
Deprecated: Use MessageInstance.ProtoReflect.Descriptor instead.
func (*MessageInstance) GetCorrelationKey ¶
func (x *MessageInstance) GetCorrelationKey() string
func (*MessageInstance) GetName ¶ added in v1.0.477
func (x *MessageInstance) GetName() string
func (*MessageInstance) GetVars ¶ added in v0.1.70
func (x *MessageInstance) GetVars() []byte
func (*MessageInstance) ProtoMessage ¶
func (*MessageInstance) ProtoMessage()
func (*MessageInstance) ProtoReflect ¶
func (x *MessageInstance) ProtoReflect() protoreflect.Message
func (*MessageInstance) Reset ¶
func (x *MessageInstance) Reset()
func (*MessageInstance) String ¶
func (x *MessageInstance) String() string
type MessageReceiver ¶ added in v1.1.725
type MessageReceiver struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` ProcessIdToStart string `protobuf:"bytes,2,opt,name=processIdToStart,proto3" json:"processIdToStart,omitempty"` // contains filtered or unexported fields }
func (*MessageReceiver) Descriptor
deprecated
added in
v1.1.725
func (*MessageReceiver) Descriptor() ([]byte, []int)
Deprecated: Use MessageReceiver.ProtoReflect.Descriptor instead.
func (*MessageReceiver) GetId ¶ added in v1.1.725
func (x *MessageReceiver) GetId() string
func (*MessageReceiver) GetProcessIdToStart ¶ added in v1.1.725
func (x *MessageReceiver) GetProcessIdToStart() string
func (*MessageReceiver) ProtoMessage ¶ added in v1.1.725
func (*MessageReceiver) ProtoMessage()
func (*MessageReceiver) ProtoReflect ¶ added in v1.1.725
func (x *MessageReceiver) ProtoReflect() protoreflect.Message
func (*MessageReceiver) Reset ¶ added in v1.1.725
func (x *MessageReceiver) Reset()
func (*MessageReceiver) String ¶ added in v1.1.725
func (x *MessageReceiver) String() string
type MessageReceivers ¶ added in v1.1.725
type MessageReceivers struct { MessageReceiver []*MessageReceiver `protobuf:"bytes,1,rep,name=messageReceiver,proto3" json:"messageReceiver,omitempty"` //MessageReceiver s are the elements receiving/referencing a message. They could be start events or intermedidate catch events AssociatedWorkflowName string `protobuf:"bytes,2,opt,name=associatedWorkflowName,proto3" json:"associatedWorkflowName,omitempty"` // contains filtered or unexported fields }
func (*MessageReceivers) Descriptor
deprecated
added in
v1.1.725
func (*MessageReceivers) Descriptor() ([]byte, []int)
Deprecated: Use MessageReceivers.ProtoReflect.Descriptor instead.
func (*MessageReceivers) GetAssociatedWorkflowName ¶ added in v1.1.725
func (x *MessageReceivers) GetAssociatedWorkflowName() string
func (*MessageReceivers) GetMessageReceiver ¶ added in v1.1.725
func (x *MessageReceivers) GetMessageReceiver() []*MessageReceiver
func (*MessageReceivers) ProtoMessage ¶ added in v1.1.725
func (*MessageReceivers) ProtoMessage()
func (*MessageReceivers) ProtoReflect ¶ added in v1.1.725
func (x *MessageReceivers) ProtoReflect() protoreflect.Message
func (*MessageReceivers) Reset ¶ added in v1.1.725
func (x *MessageReceivers) Reset()
func (*MessageReceivers) String ¶ added in v1.1.725
func (x *MessageReceivers) String() string
type MessageRecipient ¶ added in v1.0.477
type MessageRecipient struct { Type RecipientType `protobuf:"varint,1,opt,name=type,proto3,enum=RecipientType" json:"type,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` CorrelationKey string `protobuf:"bytes,3,opt,name=CorrelationKey,proto3" json:"CorrelationKey,omitempty"` // contains filtered or unexported fields }
func (*MessageRecipient) Descriptor
deprecated
added in
v1.0.477
func (*MessageRecipient) Descriptor() ([]byte, []int)
Deprecated: Use MessageRecipient.ProtoReflect.Descriptor instead.
func (*MessageRecipient) GetCorrelationKey ¶ added in v1.0.477
func (x *MessageRecipient) GetCorrelationKey() string
func (*MessageRecipient) GetId ¶ added in v1.0.477
func (x *MessageRecipient) GetId() string
func (*MessageRecipient) GetType ¶ added in v1.0.477
func (x *MessageRecipient) GetType() RecipientType
func (*MessageRecipient) ProtoMessage ¶ added in v1.0.477
func (*MessageRecipient) ProtoMessage()
func (*MessageRecipient) ProtoReflect ¶ added in v1.0.477
func (x *MessageRecipient) ProtoReflect() protoreflect.Message
func (*MessageRecipient) Reset ¶ added in v1.0.477
func (x *MessageRecipient) Reset()
func (*MessageRecipient) String ¶ added in v1.0.477
func (x *MessageRecipient) String() string
type Metadata ¶ added in v1.0.427
type Metadata struct { TimedStart bool `protobuf:"varint,1,opt,name=timedStart,proto3" json:"timedStart,omitempty"` // Workflow contains timed start activities that can trigger a process. // contains filtered or unexported fields }
func (*Metadata) Descriptor
deprecated
added in
v1.0.427
func (*Metadata) GetTimedStart ¶ added in v1.0.427
func (*Metadata) ProtoMessage ¶ added in v1.0.427
func (*Metadata) ProtoMessage()
func (*Metadata) ProtoReflect ¶ added in v1.0.427
func (x *Metadata) ProtoReflect() protoreflect.Message
type Parameter ¶ added in v1.0.514
type Parameter struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Name of the parameter. Short string `protobuf:"bytes,2,opt,name=short,proto3" json:"short,omitempty"` // Short description of the parameter. Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` // Description - a long description of the parameter. Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"` // Type of the parameter "string", "int", "float", "bool" CustomTypeExtension *string `protobuf:"bytes,5,opt,name=customTypeExtension,proto3,oneof" json:"customTypeExtension,omitempty"` // Subtype describing the use of the type "IPAddress" etc. Collection bool `protobuf:"varint,6,opt,name=collection,proto3" json:"collection,omitempty"` // Collection specifies the parameter is an array. Group *string `protobuf:"bytes,7,opt,name=group,proto3,oneof" json:"group,omitempty"` // Group declares this parameter as part of a named parameter group. ExtensionData map[string]string `` // ExtensionData - a map of values that can be used by third party tools. /* 167-byte string literal not displayed */ Mandatory bool `protobuf:"varint,9,opt,name=mandatory,proto3" json:"mandatory,omitempty"` // Mandatory specifies that this parameter is required. ValidateExpr string `protobuf:"bytes,10,opt,name=validateExpr,proto3" json:"validateExpr,omitempty"` // ValidateExpr - an EXPR that is used to validate the field value. Example string `protobuf:"bytes,11,opt,name=example,proto3" json:"example,omitempty"` // Example - an example EXPR that is used to provide a hint to a user on the nature of a task. It is also used when the task is being used as a mock before implementation. // contains filtered or unexported fields }
func (*Parameter) Descriptor
deprecated
added in
v1.0.514
func (*Parameter) GetCollection ¶ added in v1.0.623
func (*Parameter) GetCustomTypeExtension ¶ added in v1.0.623
func (*Parameter) GetDescription ¶ added in v1.0.514
func (*Parameter) GetExample ¶ added in v1.0.623
func (*Parameter) GetExtensionData ¶ added in v1.0.514
func (*Parameter) GetMandatory ¶ added in v1.0.548
func (*Parameter) GetValidateExpr ¶ added in v1.0.623
func (*Parameter) ProtoMessage ¶ added in v1.0.514
func (*Parameter) ProtoMessage()
func (*Parameter) ProtoReflect ¶ added in v1.0.514
func (x *Parameter) ProtoReflect() protoreflect.Message
type ParameterGroup ¶ added in v1.0.514
type ParameterGroup struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Name of the parameter group. Short string `protobuf:"bytes,2,opt,name=short,proto3" json:"short,omitempty"` // Short description of the parameter groupp. Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` // Description - a long description of the parameter group. // contains filtered or unexported fields }
func (*ParameterGroup) Descriptor
deprecated
added in
v1.0.514
func (*ParameterGroup) Descriptor() ([]byte, []int)
Deprecated: Use ParameterGroup.ProtoReflect.Descriptor instead.
func (*ParameterGroup) GetDescription ¶ added in v1.0.514
func (x *ParameterGroup) GetDescription() string
func (*ParameterGroup) GetName ¶ added in v1.0.514
func (x *ParameterGroup) GetName() string
func (*ParameterGroup) GetShort ¶ added in v1.0.514
func (x *ParameterGroup) GetShort() string
func (*ParameterGroup) ProtoMessage ¶ added in v1.0.514
func (*ParameterGroup) ProtoMessage()
func (*ParameterGroup) ProtoReflect ¶ added in v1.0.514
func (x *ParameterGroup) ProtoReflect() protoreflect.Message
func (*ParameterGroup) Reset ¶ added in v1.0.514
func (x *ParameterGroup) Reset()
func (*ParameterGroup) String ¶ added in v1.0.514
func (x *ParameterGroup) String() string
type Participant ¶ added in v1.0.645
type Participant struct { Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // Id - participation ID. ProcessId string `protobuf:"bytes,1,opt,name=processId,proto3" json:"processId,omitempty"` // ProcessId of the participating process. // contains filtered or unexported fields }
func (*Participant) Descriptor
deprecated
added in
v1.0.645
func (*Participant) Descriptor() ([]byte, []int)
Deprecated: Use Participant.ProtoReflect.Descriptor instead.
func (*Participant) GetId ¶ added in v1.0.645
func (x *Participant) GetId() string
func (*Participant) GetProcessId ¶ added in v1.0.645
func (x *Participant) GetProcessId() string
func (*Participant) ProtoMessage ¶ added in v1.0.645
func (*Participant) ProtoMessage()
func (*Participant) ProtoReflect ¶ added in v1.0.645
func (x *Participant) ProtoReflect() protoreflect.Message
func (*Participant) Reset ¶ added in v1.0.645
func (x *Participant) Reset()
func (*Participant) String ¶ added in v1.0.645
func (x *Participant) String() string
type Process ¶
type Process struct { Elements []*Element `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"` // Elements describes each state in the state machine. Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"` // Name - the common name of the state machine. Metadata *Metadata `protobuf:"bytes,6,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"` // Metadata created by SHAR to describe process behavior. // contains filtered or unexported fields }
Process describes a single workflow state machine.
func (*Process) Descriptor
deprecated
func (*Process) GetElements ¶
func (*Process) GetMetadata ¶ added in v1.0.427
func (*Process) ProtoMessage ¶
func (*Process) ProtoMessage()
func (*Process) ProtoReflect ¶
func (x *Process) ProtoReflect() protoreflect.Message
type ProcessHistory ¶ added in v1.0.477
type ProcessHistory struct { Item []*ProcessHistoryEntry `protobuf:"bytes,1,rep,name=item,proto3" json:"item,omitempty"` // contains filtered or unexported fields }
func (*ProcessHistory) Descriptor
deprecated
added in
v1.0.477
func (*ProcessHistory) Descriptor() ([]byte, []int)
Deprecated: Use ProcessHistory.ProtoReflect.Descriptor instead.
func (*ProcessHistory) GetItem ¶ added in v1.0.477
func (x *ProcessHistory) GetItem() []*ProcessHistoryEntry
func (*ProcessHistory) ProtoMessage ¶ added in v1.0.477
func (*ProcessHistory) ProtoMessage()
func (*ProcessHistory) ProtoReflect ¶ added in v1.0.477
func (x *ProcessHistory) ProtoReflect() protoreflect.Message
func (*ProcessHistory) Reset ¶ added in v1.0.477
func (x *ProcessHistory) Reset()
func (*ProcessHistory) String ¶ added in v1.0.477
func (x *ProcessHistory) String() string
type ProcessHistoryEntry ¶ added in v1.0.477
type ProcessHistoryEntry struct { ItemType ProcessHistoryType `protobuf:"varint,1,opt,name=itemType,proto3,enum=ProcessHistoryType" json:"itemType,omitempty"` WorkflowId *string `protobuf:"bytes,2,opt,name=workflowId,proto3,oneof" json:"workflowId,omitempty"` ExecutionId *string `protobuf:"bytes,3,opt,name=executionId,proto3,oneof" json:"executionId,omitempty"` ElementId *string `protobuf:"bytes,4,opt,name=elementId,proto3,oneof" json:"elementId,omitempty"` ProcessInstanceId *string `protobuf:"bytes,5,opt,name=processInstanceId,proto3,oneof" json:"processInstanceId,omitempty"` CancellationState *CancellationState `protobuf:"varint,6,opt,name=cancellationState,proto3,enum=CancellationState,oneof" json:"cancellationState,omitempty"` Vars []byte `protobuf:"bytes,7,opt,name=vars,proto3" json:"vars,omitempty"` Timer *WorkflowTimer `protobuf:"bytes,8,opt,name=timer,proto3,oneof" json:"timer,omitempty"` Error *Error `protobuf:"bytes,9,opt,name=error,proto3,oneof" json:"error,omitempty"` UnixTimeNano int64 `protobuf:"varint,10,opt,name=unixTimeNano,proto3" json:"unixTimeNano,omitempty"` Execute *string `protobuf:"bytes,11,opt,name=execute,proto3,oneof" json:"execute,omitempty"` // contains filtered or unexported fields }
func (*ProcessHistoryEntry) Descriptor
deprecated
added in
v1.0.477
func (*ProcessHistoryEntry) Descriptor() ([]byte, []int)
Deprecated: Use ProcessHistoryEntry.ProtoReflect.Descriptor instead.
func (*ProcessHistoryEntry) GetCancellationState ¶ added in v1.0.477
func (x *ProcessHistoryEntry) GetCancellationState() CancellationState
func (*ProcessHistoryEntry) GetElementId ¶ added in v1.0.477
func (x *ProcessHistoryEntry) GetElementId() string
func (*ProcessHistoryEntry) GetError ¶ added in v1.0.477
func (x *ProcessHistoryEntry) GetError() *Error
func (*ProcessHistoryEntry) GetExecute ¶ added in v1.0.477
func (x *ProcessHistoryEntry) GetExecute() string
func (*ProcessHistoryEntry) GetExecutionId ¶ added in v1.0.645
func (x *ProcessHistoryEntry) GetExecutionId() string
func (*ProcessHistoryEntry) GetItemType ¶ added in v1.0.477
func (x *ProcessHistoryEntry) GetItemType() ProcessHistoryType
func (*ProcessHistoryEntry) GetProcessInstanceId ¶ added in v1.0.477
func (x *ProcessHistoryEntry) GetProcessInstanceId() string
func (*ProcessHistoryEntry) GetTimer ¶ added in v1.0.477
func (x *ProcessHistoryEntry) GetTimer() *WorkflowTimer
func (*ProcessHistoryEntry) GetUnixTimeNano ¶ added in v1.0.477
func (x *ProcessHistoryEntry) GetUnixTimeNano() int64
func (*ProcessHistoryEntry) GetVars ¶ added in v1.0.477
func (x *ProcessHistoryEntry) GetVars() []byte
func (*ProcessHistoryEntry) GetWorkflowId ¶ added in v1.0.477
func (x *ProcessHistoryEntry) GetWorkflowId() string
func (*ProcessHistoryEntry) ProtoMessage ¶ added in v1.0.477
func (*ProcessHistoryEntry) ProtoMessage()
func (*ProcessHistoryEntry) ProtoReflect ¶ added in v1.0.477
func (x *ProcessHistoryEntry) ProtoReflect() protoreflect.Message
func (*ProcessHistoryEntry) Reset ¶ added in v1.0.477
func (x *ProcessHistoryEntry) Reset()
func (*ProcessHistoryEntry) String ¶ added in v1.0.477
func (x *ProcessHistoryEntry) String() string
type ProcessHistoryType ¶ added in v1.0.477
type ProcessHistoryType int32
const ( ProcessHistoryType_processExecute ProcessHistoryType = 0 ProcessHistoryType_activityExecute ProcessHistoryType = 1 ProcessHistoryType_activityComplete ProcessHistoryType = 2 ProcessHistoryType_processSpawnSync ProcessHistoryType = 3 ProcessHistoryType_processComplete ProcessHistoryType = 4 ProcessHistoryType_processAbort ProcessHistoryType = 5 ProcessHistoryType_activityAbort ProcessHistoryType = 6 )
func (ProcessHistoryType) Descriptor ¶ added in v1.0.477
func (ProcessHistoryType) Descriptor() protoreflect.EnumDescriptor
func (ProcessHistoryType) Enum ¶ added in v1.0.477
func (x ProcessHistoryType) Enum() *ProcessHistoryType
func (ProcessHistoryType) EnumDescriptor
deprecated
added in
v1.0.477
func (ProcessHistoryType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ProcessHistoryType.Descriptor instead.
func (ProcessHistoryType) Number ¶ added in v1.0.477
func (x ProcessHistoryType) Number() protoreflect.EnumNumber
func (ProcessHistoryType) String ¶ added in v1.0.477
func (x ProcessHistoryType) String() string
func (ProcessHistoryType) Type ¶ added in v1.0.477
func (ProcessHistoryType) Type() protoreflect.EnumType
type ProcessInstance ¶ added in v1.0.427
type ProcessInstance struct { ProcessInstanceId string `protobuf:"bytes,1,opt,name=processInstanceId,proto3" json:"processInstanceId,omitempty"` // ProcessInstanceId - the unique ID for the process instance. ExecutionId string `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"` // executionId - The id of this particular BPMExecution ParentProcessId *string `protobuf:"bytes,3,opt,name=parentProcessId,proto3,oneof" json:"parentProcessId,omitempty"` // ParentProcessInstanceId - the parent process instance that launched this process - if nil, the workflow instance launched the process instance. ParentElementId *string `protobuf:"bytes,4,opt,name=parentElementId,proto3,oneof" json:"parentElementId,omitempty"` // ParentElementId - the ID of the element in the parent process that triggered the launch of this process instance. WorkflowId string `protobuf:"bytes,5,opt,name=workflowId,proto3" json:"workflowId,omitempty"` // WorkflowId - the workflow version ID that this instance is executing. WorkflowName string `protobuf:"bytes,6,opt,name=workflowName,proto3" json:"workflowName,omitempty"` // WorkflowName - name of this workflow to avoid lookups. ProcessName string `protobuf:"bytes,7,opt,name=processName,proto3" json:"processName,omitempty"` // ProcessName - name of this process to avoid lookups. GatewayComplete map[string]bool `` // GatewayComplete - completed gateway instances register /* 172-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ProcessInstance) Descriptor
deprecated
added in
v1.0.427
func (*ProcessInstance) Descriptor() ([]byte, []int)
Deprecated: Use ProcessInstance.ProtoReflect.Descriptor instead.
func (*ProcessInstance) GetExecutionId ¶ added in v1.0.645
func (x *ProcessInstance) GetExecutionId() string
func (*ProcessInstance) GetGatewayComplete ¶ added in v1.0.446
func (x *ProcessInstance) GetGatewayComplete() map[string]bool
func (*ProcessInstance) GetParentElementId ¶ added in v1.0.427
func (x *ProcessInstance) GetParentElementId() string
func (*ProcessInstance) GetParentProcessId ¶ added in v1.0.427
func (x *ProcessInstance) GetParentProcessId() string
func (*ProcessInstance) GetProcessInstanceId ¶ added in v1.0.427
func (x *ProcessInstance) GetProcessInstanceId() string
func (*ProcessInstance) GetProcessName ¶ added in v1.0.427
func (x *ProcessInstance) GetProcessName() string
func (*ProcessInstance) GetWorkflowId ¶ added in v1.0.427
func (x *ProcessInstance) GetWorkflowId() string
func (*ProcessInstance) GetWorkflowName ¶ added in v1.0.427
func (x *ProcessInstance) GetWorkflowName() string
func (*ProcessInstance) ProtoMessage ¶ added in v1.0.427
func (*ProcessInstance) ProtoMessage()
func (*ProcessInstance) ProtoReflect ¶ added in v1.0.427
func (x *ProcessInstance) ProtoReflect() protoreflect.Message
func (*ProcessInstance) Reset ¶ added in v1.0.427
func (x *ProcessInstance) Reset()
func (*ProcessInstance) String ¶ added in v1.0.427
func (x *ProcessInstance) String() string
type Receiver ¶ added in v1.1.725
type Receiver struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Id - a uuid identifying the job associated with the receiver CorrelationKey string `protobuf:"bytes,2,opt,name=correlationKey,proto3" json:"correlationKey,omitempty"` // CorrelationKey - the workflow message correlation key. // contains filtered or unexported fields }
Receiver is the receiver side of a BPMN message. It contains a reference to the job which receivers the vars from the sender
func (*Receiver) Descriptor
deprecated
added in
v1.1.725
func (*Receiver) GetCorrelationKey ¶ added in v1.1.725
func (*Receiver) ProtoMessage ¶ added in v1.1.725
func (*Receiver) ProtoMessage()
func (*Receiver) ProtoReflect ¶ added in v1.1.725
func (x *Receiver) ProtoReflect() protoreflect.Message
type RecipientType ¶ added in v1.0.477
type RecipientType int32
const (
RecipientType_job RecipientType = 0
)
func (RecipientType) Descriptor ¶ added in v1.0.477
func (RecipientType) Descriptor() protoreflect.EnumDescriptor
func (RecipientType) Enum ¶ added in v1.0.477
func (x RecipientType) Enum() *RecipientType
func (RecipientType) EnumDescriptor
deprecated
added in
v1.0.477
func (RecipientType) EnumDescriptor() ([]byte, []int)
Deprecated: Use RecipientType.Descriptor instead.
func (RecipientType) Number ¶ added in v1.0.477
func (x RecipientType) Number() protoreflect.EnumNumber
func (RecipientType) String ¶ added in v1.0.477
func (x RecipientType) String() string
func (RecipientType) Type ¶ added in v1.0.477
func (RecipientType) Type() protoreflect.EnumType
type RegisterTaskRequest ¶ added in v1.0.623
type RegisterTaskRequest struct { Spec *TaskSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` // Spec - the task specification. // contains filtered or unexported fields }
RegisterTaskRequest registers a task in SHAR.
func (*RegisterTaskRequest) Descriptor
deprecated
added in
v1.0.623
func (*RegisterTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterTaskRequest.ProtoReflect.Descriptor instead.
func (*RegisterTaskRequest) GetSpec ¶ added in v1.0.623
func (x *RegisterTaskRequest) GetSpec() *TaskSpec
func (*RegisterTaskRequest) ProtoMessage ¶ added in v1.0.623
func (*RegisterTaskRequest) ProtoMessage()
func (*RegisterTaskRequest) ProtoReflect ¶ added in v1.0.623
func (x *RegisterTaskRequest) ProtoReflect() protoreflect.Message
func (*RegisterTaskRequest) Reset ¶ added in v1.0.623
func (x *RegisterTaskRequest) Reset()
func (*RegisterTaskRequest) String ¶ added in v1.0.623
func (x *RegisterTaskRequest) String() string
type RegisterTaskResponse ¶ added in v1.0.623
type RegisterTaskResponse struct { Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"` // Uid of the registered task. // contains filtered or unexported fields }
RegisterTaskResponse contains the UID of a registered task.
func (*RegisterTaskResponse) Descriptor
deprecated
added in
v1.0.623
func (*RegisterTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterTaskResponse.ProtoReflect.Descriptor instead.
func (*RegisterTaskResponse) GetUid ¶ added in v1.0.623
func (x *RegisterTaskResponse) GetUid() string
func (*RegisterTaskResponse) ProtoMessage ¶ added in v1.0.623
func (*RegisterTaskResponse) ProtoMessage()
func (*RegisterTaskResponse) ProtoReflect ¶ added in v1.0.623
func (x *RegisterTaskResponse) ProtoReflect() protoreflect.Message
func (*RegisterTaskResponse) Reset ¶ added in v1.0.623
func (x *RegisterTaskResponse) Reset()
func (*RegisterTaskResponse) String ¶ added in v1.0.623
func (x *RegisterTaskResponse) String() string
type RetryErrorAction ¶ added in v1.0.623
type RetryErrorAction int32
const ( RetryErrorAction_PauseWorkflow RetryErrorAction = 0 // PauseWorkflow - exhausting retries will pause the workflow and send a shar operational message. RetryErrorAction_ThrowWorkflowError RetryErrorAction = 1 // ThrowWorkflowError - throw a workflow error. RetryErrorAction_SetVariableValue RetryErrorAction = 2 // SetVariableValue - set a workflow variable value. RetryErrorAction_FailWorkflow RetryErrorAction = 3 // FailWorkflow - exhausting retries will fail the workflow. )
func (RetryErrorAction) Descriptor ¶ added in v1.0.623
func (RetryErrorAction) Descriptor() protoreflect.EnumDescriptor
func (RetryErrorAction) Enum ¶ added in v1.0.623
func (x RetryErrorAction) Enum() *RetryErrorAction
func (RetryErrorAction) EnumDescriptor
deprecated
added in
v1.0.623
func (RetryErrorAction) EnumDescriptor() ([]byte, []int)
Deprecated: Use RetryErrorAction.Descriptor instead.
func (RetryErrorAction) Number ¶ added in v1.0.623
func (x RetryErrorAction) Number() protoreflect.EnumNumber
func (RetryErrorAction) String ¶ added in v1.0.623
func (x RetryErrorAction) String() string
func (RetryErrorAction) Type ¶ added in v1.0.623
func (RetryErrorAction) Type() protoreflect.EnumType
type RetryStrategy ¶ added in v1.0.623
type RetryStrategy int32
const ( RetryStrategy_Linear RetryStrategy = 0 // Retry at regular intervals. RetryStrategy_Incremental RetryStrategy = 1 // Retry at increasingly large intervals. )
func (RetryStrategy) Descriptor ¶ added in v1.0.623
func (RetryStrategy) Descriptor() protoreflect.EnumDescriptor
func (RetryStrategy) Enum ¶ added in v1.0.623
func (x RetryStrategy) Enum() *RetryStrategy
func (RetryStrategy) EnumDescriptor
deprecated
added in
v1.0.623
func (RetryStrategy) EnumDescriptor() ([]byte, []int)
Deprecated: Use RetryStrategy.Descriptor instead.
func (RetryStrategy) Number ¶ added in v1.0.623
func (x RetryStrategy) Number() protoreflect.EnumNumber
func (RetryStrategy) String ¶ added in v1.0.623
func (x RetryStrategy) String() string
func (RetryStrategy) Type ¶ added in v1.0.623
func (RetryStrategy) Type() protoreflect.EnumType
type SatisfiesGateway ¶ added in v1.0.446
type SatisfiesGateway struct { InstanceTracking []string `protobuf:"bytes,1,rep,name=instanceTracking,proto3" json:"instanceTracking,omitempty"` // instanceTracking - a list of paths that satisfy the gateway. // contains filtered or unexported fields }
func (*SatisfiesGateway) Descriptor
deprecated
added in
v1.0.446
func (*SatisfiesGateway) Descriptor() ([]byte, []int)
Deprecated: Use SatisfiesGateway.ProtoReflect.Descriptor instead.
func (*SatisfiesGateway) GetInstanceTracking ¶ added in v1.0.446
func (x *SatisfiesGateway) GetInstanceTracking() []string
func (*SatisfiesGateway) ProtoMessage ¶ added in v1.0.446
func (*SatisfiesGateway) ProtoMessage()
func (*SatisfiesGateway) ProtoReflect ¶ added in v1.0.446
func (x *SatisfiesGateway) ProtoReflect() protoreflect.Message
func (*SatisfiesGateway) Reset ¶ added in v1.0.446
func (x *SatisfiesGateway) Reset()
func (*SatisfiesGateway) String ¶ added in v1.0.446
func (x *SatisfiesGateway) String() string
type SendMessageRequest ¶
type SendMessageRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` CorrelationKey string `protobuf:"bytes,2,opt,name=correlationKey,proto3" json:"correlationKey,omitempty"` Vars []byte `protobuf:"bytes,3,opt,name=vars,proto3" json:"vars,omitempty"` // contains filtered or unexported fields }
func (*SendMessageRequest) Descriptor
deprecated
func (*SendMessageRequest) Descriptor() ([]byte, []int)
Deprecated: Use SendMessageRequest.ProtoReflect.Descriptor instead.
func (*SendMessageRequest) GetCorrelationKey ¶ added in v1.0.477
func (x *SendMessageRequest) GetCorrelationKey() string
func (*SendMessageRequest) GetName ¶
func (x *SendMessageRequest) GetName() string
func (*SendMessageRequest) GetVars ¶ added in v0.1.70
func (x *SendMessageRequest) GetVars() []byte
func (*SendMessageRequest) ProtoMessage ¶
func (*SendMessageRequest) ProtoMessage()
func (*SendMessageRequest) ProtoReflect ¶
func (x *SendMessageRequest) ProtoReflect() protoreflect.Message
func (*SendMessageRequest) Reset ¶
func (x *SendMessageRequest) Reset()
func (*SendMessageRequest) String ¶
func (x *SendMessageRequest) String() string
type SendMessageResponse ¶ added in v1.1.725
type SendMessageResponse struct { ExecutionId string `protobuf:"bytes,1,opt,name=executionId,proto3" json:"executionId,omitempty"` WorkflowId string `protobuf:"bytes,2,opt,name=workflowId,proto3" json:"workflowId,omitempty"` // contains filtered or unexported fields }
func (*SendMessageResponse) Descriptor
deprecated
added in
v1.1.725
func (*SendMessageResponse) Descriptor() ([]byte, []int)
Deprecated: Use SendMessageResponse.ProtoReflect.Descriptor instead.
func (*SendMessageResponse) GetExecutionId ¶ added in v1.1.725
func (x *SendMessageResponse) GetExecutionId() string
func (*SendMessageResponse) GetWorkflowId ¶ added in v1.1.725
func (x *SendMessageResponse) GetWorkflowId() string
func (*SendMessageResponse) ProtoMessage ¶ added in v1.1.725
func (*SendMessageResponse) ProtoMessage()
func (*SendMessageResponse) ProtoReflect ¶ added in v1.1.725
func (x *SendMessageResponse) ProtoReflect() protoreflect.Message
func (*SendMessageResponse) Reset ¶ added in v1.1.725
func (x *SendMessageResponse) Reset()
func (*SendMessageResponse) String ¶ added in v1.1.725
func (x *SendMessageResponse) String() string
type Sender ¶ added in v1.1.725
type Sender struct { Vars []byte `protobuf:"bytes,1,opt,name=vars,proto3" json:"vars,omitempty"` // Vars - A go binary encoded map[string]interface{} of variables. CorrelationKey string `protobuf:"bytes,2,opt,name=correlationKey,proto3" json:"correlationKey,omitempty"` // CorrelationKey - the workflow message correlation key. // contains filtered or unexported fields }
Sender is the sender side of a BPMN message. It contains a byte array of vars destined for the receiver
func (*Sender) Descriptor
deprecated
added in
v1.1.725
func (*Sender) GetCorrelationKey ¶ added in v1.1.725
func (*Sender) ProtoMessage ¶ added in v1.1.725
func (*Sender) ProtoMessage()
func (*Sender) ProtoReflect ¶ added in v1.1.725
func (x *Sender) ProtoReflect() protoreflect.Message
type StoreWorkflowRequest ¶ added in v1.1.725
type StoreWorkflowRequest struct { Workflow string `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"` // contains filtered or unexported fields }
func (*StoreWorkflowRequest) Descriptor
deprecated
added in
v1.1.725
func (*StoreWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use StoreWorkflowRequest.ProtoReflect.Descriptor instead.
func (*StoreWorkflowRequest) GetWorkflow ¶ added in v1.1.725
func (x *StoreWorkflowRequest) GetWorkflow() string
func (*StoreWorkflowRequest) ProtoMessage ¶ added in v1.1.725
func (*StoreWorkflowRequest) ProtoMessage()
func (*StoreWorkflowRequest) ProtoReflect ¶ added in v1.1.725
func (x *StoreWorkflowRequest) ProtoReflect() protoreflect.Message
func (*StoreWorkflowRequest) Reset ¶ added in v1.1.725
func (x *StoreWorkflowRequest) Reset()
func (*StoreWorkflowRequest) String ¶ added in v1.1.725
func (x *StoreWorkflowRequest) String() string
type StoreWorkflowResponse ¶ added in v1.1.725
type StoreWorkflowResponse struct {
// contains filtered or unexported fields
}
func (*StoreWorkflowResponse) Descriptor
deprecated
added in
v1.1.725
func (*StoreWorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use StoreWorkflowResponse.ProtoReflect.Descriptor instead.
func (*StoreWorkflowResponse) ProtoMessage ¶ added in v1.1.725
func (*StoreWorkflowResponse) ProtoMessage()
func (*StoreWorkflowResponse) ProtoReflect ¶ added in v1.1.725
func (x *StoreWorkflowResponse) ProtoReflect() protoreflect.Message
func (*StoreWorkflowResponse) Reset ¶ added in v1.1.725
func (x *StoreWorkflowResponse) Reset()
func (*StoreWorkflowResponse) String ¶ added in v1.1.725
func (x *StoreWorkflowResponse) String() string
type Target ¶
type Target struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Id for the transition. Conditions []string `protobuf:"bytes,2,rep,name=conditions,proto3" json:"conditions,omitempty"` // Conditions -to apply to the transition specified as Expr. Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` // Target ID for the transition. // contains filtered or unexported fields }
Target specifies the target for a state transition.
func (*Target) Descriptor
deprecated
func (*Target) GetConditions ¶
func (*Target) ProtoMessage ¶
func (*Target) ProtoMessage()
func (*Target) ProtoReflect ¶
func (x *Target) ProtoReflect() protoreflect.Message
type Targets ¶
type Targets struct { Target []*Target `protobuf:"bytes,1,rep,name=target,proto3" json:"target,omitempty"` // Target - the target for a state transition. DefaultTarget int64 `protobuf:"varint,2,opt,name=defaultTarget,proto3" json:"defaultTarget,omitempty"` // DefaultTarget - the ordinal for a default target. // contains filtered or unexported fields }
Targets defines a set of targets for transition and as to whether only the first match should be executed.
func (*Targets) Descriptor
deprecated
func (*Targets) GetDefaultTarget ¶ added in v1.1.697
func (*Targets) ProtoMessage ¶
func (*Targets) ProtoMessage()
func (*Targets) ProtoReflect ¶
func (x *Targets) ProtoReflect() protoreflect.Message
type TaskBehaviour ¶ added in v1.0.514
type TaskBehaviour struct { DefaultRetry *DefaultTaskRetry `protobuf:"bytes,1,opt,name=defaultRetry,proto3" json:"defaultRetry,omitempty"` // Retry - the recommended retry behavior for the task, this could be overriden by a workflow. Unsafe bool `protobuf:"varint,2,opt,name=unsafe,proto3" json:"unsafe,omitempty"` // Unsafe labels the task as non-idempotent. Non-idempotent tasks are highly unrecommended. Mock bool `protobuf:"varint,3,opt,name=mock,proto3" json:"mock,omitempty"` // Mock this task as it has no concrete implementation. Deprecated bool `protobuf:"varint,4,opt,name=deprecated,proto3" json:"deprecated,omitempty"` // Deprecated task. Workflows can not be executed that include this task. // contains filtered or unexported fields }
func (*TaskBehaviour) Descriptor
deprecated
added in
v1.0.514
func (*TaskBehaviour) Descriptor() ([]byte, []int)
Deprecated: Use TaskBehaviour.ProtoReflect.Descriptor instead.
func (*TaskBehaviour) GetDefaultRetry ¶ added in v1.0.623
func (x *TaskBehaviour) GetDefaultRetry() *DefaultTaskRetry
func (*TaskBehaviour) GetDeprecated ¶ added in v1.1.670
func (x *TaskBehaviour) GetDeprecated() bool
func (*TaskBehaviour) GetMock ¶ added in v1.0.623
func (x *TaskBehaviour) GetMock() bool
func (*TaskBehaviour) GetUnsafe ¶ added in v1.0.514
func (x *TaskBehaviour) GetUnsafe() bool
func (*TaskBehaviour) ProtoMessage ¶ added in v1.0.514
func (*TaskBehaviour) ProtoMessage()
func (*TaskBehaviour) ProtoReflect ¶ added in v1.0.514
func (x *TaskBehaviour) ProtoReflect() protoreflect.Message
func (*TaskBehaviour) Reset ¶ added in v1.0.514
func (x *TaskBehaviour) Reset()
func (*TaskBehaviour) String ¶ added in v1.0.514
func (x *TaskBehaviour) String() string
type TaskError ¶ added in v1.0.514
type TaskError struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Name of the error. Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"` // Code a unique code for the error. Short string `protobuf:"bytes,3,opt,name=short,proto3" json:"short,omitempty"` // Short description of the parameter. Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` // Description - a long description of the parameter. // contains filtered or unexported fields }
Error represents a known error name and code which may be thrown by the state machine.
func (*TaskError) Descriptor
deprecated
added in
v1.0.514
func (*TaskError) GetDescription ¶ added in v1.0.623
func (*TaskError) ProtoMessage ¶ added in v1.0.514
func (*TaskError) ProtoMessage()
func (*TaskError) ProtoReflect ¶ added in v1.0.514
func (x *TaskError) ProtoReflect() protoreflect.Message
type TaskEvents ¶ added in v1.0.514
type TaskEvents struct { Error []*Error `protobuf:"bytes,1,rep,name=error,proto3" json:"error,omitempty"` // Error workflow events that can be returned from the task. Message []*Message `protobuf:"bytes,2,rep,name=Message,proto3" json:"Message,omitempty"` // Message workflow events that can be returned from the task. // contains filtered or unexported fields }
func (*TaskEvents) Descriptor
deprecated
added in
v1.0.514
func (*TaskEvents) Descriptor() ([]byte, []int)
Deprecated: Use TaskEvents.ProtoReflect.Descriptor instead.
func (*TaskEvents) GetError ¶ added in v1.0.514
func (x *TaskEvents) GetError() []*Error
func (*TaskEvents) GetMessage ¶ added in v1.0.514
func (x *TaskEvents) GetMessage() []*Message
func (*TaskEvents) ProtoMessage ¶ added in v1.0.514
func (*TaskEvents) ProtoMessage()
func (*TaskEvents) ProtoReflect ¶ added in v1.0.514
func (x *TaskEvents) ProtoReflect() protoreflect.Message
func (*TaskEvents) Reset ¶ added in v1.0.514
func (x *TaskEvents) Reset()
func (*TaskEvents) String ¶ added in v1.0.514
func (x *TaskEvents) String() string
type TaskMetadata ¶ added in v1.0.514
type TaskMetadata struct { Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"` // Uid of the task as a KSUID. Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // Type - the name for the task when referred to by process. Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` // Version - the task version number. This is useful to describe that the task has internally changed without modifying the input/outout parameters. Short string `protobuf:"bytes,4,opt,name=short,proto3" json:"short,omitempty"` // Short description of the task. Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"` // Description - a long description of the task. Labels []string `protobuf:"bytes,6,rep,name=labels,proto3" json:"labels,omitempty"` // Labels - a comma seperated list of searchable tags for the task. EstimatedMaxDuration uint64 `protobuf:"varint,7,opt,name=estimatedMaxDuration,proto3" json:"estimatedMaxDuration,omitempty"` // EstimatedMaxDuration documents how long the task is expected to run for. ExtensionData map[string]string `` // ExtensionData - a map of values that can be used by third party tools. /* 167-byte string literal not displayed */ // contains filtered or unexported fields }
func (*TaskMetadata) Descriptor
deprecated
added in
v1.0.514
func (*TaskMetadata) Descriptor() ([]byte, []int)
Deprecated: Use TaskMetadata.ProtoReflect.Descriptor instead.
func (*TaskMetadata) GetDescription ¶ added in v1.0.514
func (x *TaskMetadata) GetDescription() string
func (*TaskMetadata) GetEstimatedMaxDuration ¶ added in v1.0.514
func (x *TaskMetadata) GetEstimatedMaxDuration() uint64
func (*TaskMetadata) GetExtensionData ¶ added in v1.0.623
func (x *TaskMetadata) GetExtensionData() map[string]string
func (*TaskMetadata) GetLabels ¶ added in v1.0.514
func (x *TaskMetadata) GetLabels() []string
func (*TaskMetadata) GetShort ¶ added in v1.0.514
func (x *TaskMetadata) GetShort() string
func (*TaskMetadata) GetType ¶ added in v1.0.514
func (x *TaskMetadata) GetType() string
func (*TaskMetadata) GetUid ¶ added in v1.0.514
func (x *TaskMetadata) GetUid() string
func (*TaskMetadata) GetVersion ¶ added in v1.0.514
func (x *TaskMetadata) GetVersion() string
func (*TaskMetadata) ProtoMessage ¶ added in v1.0.514
func (*TaskMetadata) ProtoMessage()
func (*TaskMetadata) ProtoReflect ¶ added in v1.0.514
func (x *TaskMetadata) ProtoReflect() protoreflect.Message
func (*TaskMetadata) Reset ¶ added in v1.0.514
func (x *TaskMetadata) Reset()
func (*TaskMetadata) String ¶ added in v1.0.514
func (x *TaskMetadata) String() string
type TaskParameters ¶ added in v1.0.514
type TaskParameters struct { ParameterGroup []*ParameterGroup `protobuf:"bytes,1,rep,name=parameterGroup,proto3" json:"parameterGroup,omitempty"` // ParameterGroup is a list of parameters with their categorization. This is useful for display. Input []*Parameter `protobuf:"bytes,2,rep,name=input,proto3" json:"input,omitempty"` // Input documents input parameters to the task. Output []*Parameter `protobuf:"bytes,3,rep,name=output,proto3" json:"output,omitempty"` // Output documents output parameters for the task. // contains filtered or unexported fields }
func (*TaskParameters) Descriptor
deprecated
added in
v1.0.514
func (*TaskParameters) Descriptor() ([]byte, []int)
Deprecated: Use TaskParameters.ProtoReflect.Descriptor instead.
func (*TaskParameters) GetInput ¶ added in v1.0.514
func (x *TaskParameters) GetInput() []*Parameter
func (*TaskParameters) GetOutput ¶ added in v1.0.514
func (x *TaskParameters) GetOutput() []*Parameter
func (*TaskParameters) GetParameterGroup ¶ added in v1.0.514
func (x *TaskParameters) GetParameterGroup() []*ParameterGroup
func (*TaskParameters) ProtoMessage ¶ added in v1.0.514
func (*TaskParameters) ProtoMessage()
func (*TaskParameters) ProtoReflect ¶ added in v1.0.514
func (x *TaskParameters) ProtoReflect() protoreflect.Message
func (*TaskParameters) Reset ¶ added in v1.0.514
func (x *TaskParameters) Reset()
func (*TaskParameters) String ¶ added in v1.0.514
func (x *TaskParameters) String() string
type TaskSpec ¶ added in v1.0.514
type TaskSpec struct { Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` // Version of task specification. Kind string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"` // Kind of task specification, may be "ServiceTask" or "UserTask". Metadata *TaskMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"` // Metadata document any non functional information regarding the TaskSpec. Behaviour *TaskBehaviour `protobuf:"bytes,4,opt,name=behaviour,proto3" json:"behaviour,omitempty"` // Behaviour documents instance behaviour. Parameters *TaskParameters `protobuf:"bytes,5,opt,name=parameters,proto3" json:"parameters,omitempty"` // Parameters document input and output parameters for the task. Events *TaskEvents `protobuf:"bytes,6,opt,name=events,proto3" json:"events,omitempty"` // Events document errors and messages that can be emitted from the task. // contains filtered or unexported fields }
Task specification
func (*TaskSpec) Descriptor
deprecated
added in
v1.0.514
func (*TaskSpec) GetBehaviour ¶ added in v1.0.514
func (x *TaskSpec) GetBehaviour() *TaskBehaviour
func (*TaskSpec) GetEvents ¶ added in v1.0.514
func (x *TaskSpec) GetEvents() *TaskEvents
func (*TaskSpec) GetMetadata ¶ added in v1.0.514
func (x *TaskSpec) GetMetadata() *TaskMetadata
func (*TaskSpec) GetParameters ¶ added in v1.0.514
func (x *TaskSpec) GetParameters() *TaskParameters
func (*TaskSpec) GetVersion ¶ added in v1.0.514
func (*TaskSpec) ProtoMessage ¶ added in v1.0.514
func (*TaskSpec) ProtoMessage()
func (*TaskSpec) ProtoReflect ¶ added in v1.0.514
func (x *TaskSpec) ProtoReflect() protoreflect.Message
type TaskSpecUsageReport ¶ added in v1.1.670
type TaskSpecUsageReport struct { Workflow []string `protobuf:"bytes,1,rep,name=workflow,proto3" json:"workflow,omitempty"` Process []string `protobuf:"bytes,2,rep,name=process,proto3" json:"process,omitempty"` ExecutingWorkflow []string `protobuf:"bytes,3,rep,name=executingWorkflow,proto3" json:"executingWorkflow,omitempty"` ExecutingProcessInstance []string `protobuf:"bytes,4,rep,name=executingProcessInstance,proto3" json:"executingProcessInstance,omitempty"` // contains filtered or unexported fields }
func (*TaskSpecUsageReport) Descriptor
deprecated
added in
v1.1.670
func (*TaskSpecUsageReport) Descriptor() ([]byte, []int)
Deprecated: Use TaskSpecUsageReport.ProtoReflect.Descriptor instead.
func (*TaskSpecUsageReport) GetExecutingProcessInstance ¶ added in v1.1.670
func (x *TaskSpecUsageReport) GetExecutingProcessInstance() []string
func (*TaskSpecUsageReport) GetExecutingWorkflow ¶ added in v1.1.670
func (x *TaskSpecUsageReport) GetExecutingWorkflow() []string
func (*TaskSpecUsageReport) GetProcess ¶ added in v1.1.670
func (x *TaskSpecUsageReport) GetProcess() []string
func (*TaskSpecUsageReport) GetWorkflow ¶ added in v1.1.670
func (x *TaskSpecUsageReport) GetWorkflow() []string
func (*TaskSpecUsageReport) ProtoMessage ¶ added in v1.1.670
func (*TaskSpecUsageReport) ProtoMessage()
func (*TaskSpecUsageReport) ProtoReflect ¶ added in v1.1.670
func (x *TaskSpecUsageReport) ProtoReflect() protoreflect.Message
func (*TaskSpecUsageReport) Reset ¶ added in v1.1.670
func (x *TaskSpecUsageReport) Reset()
func (*TaskSpecUsageReport) String ¶ added in v1.1.670
func (x *TaskSpecUsageReport) String() string
type TaskSpecVersions ¶ added in v1.0.623
type TaskSpecVersions struct { Id []string `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*TaskSpecVersions) Descriptor
deprecated
added in
v1.0.623
func (*TaskSpecVersions) Descriptor() ([]byte, []int)
Deprecated: Use TaskSpecVersions.ProtoReflect.Descriptor instead.
func (*TaskSpecVersions) GetId ¶ added in v1.0.623
func (x *TaskSpecVersions) GetId() []string
func (*TaskSpecVersions) ProtoMessage ¶ added in v1.0.623
func (*TaskSpecVersions) ProtoMessage()
func (*TaskSpecVersions) ProtoReflect ¶ added in v1.0.623
func (x *TaskSpecVersions) ProtoReflect() protoreflect.Message
func (*TaskSpecVersions) Reset ¶ added in v1.0.623
func (x *TaskSpecVersions) Reset()
func (*TaskSpecVersions) String ¶ added in v1.0.623
func (x *TaskSpecVersions) String() string
type TelemetryLogEntry ¶ added in v1.0.240
type TelemetryLogEntry struct { TrackingID string `protobuf:"bytes,1,opt,name=trackingID,proto3" json:"trackingID,omitempty"` Source LogSource `protobuf:"varint,2,opt,name=source,proto3,enum=LogSource" json:"source,omitempty"` Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` Code int32 `protobuf:"varint,4,opt,name=code,proto3" json:"code,omitempty"` Attributes map[string]string `` /* 161-byte string literal not displayed */ // contains filtered or unexported fields }
func (*TelemetryLogEntry) Descriptor
deprecated
added in
v1.0.240
func (*TelemetryLogEntry) Descriptor() ([]byte, []int)
Deprecated: Use TelemetryLogEntry.ProtoReflect.Descriptor instead.
func (*TelemetryLogEntry) GetAttributes ¶ added in v1.0.240
func (x *TelemetryLogEntry) GetAttributes() map[string]string
func (*TelemetryLogEntry) GetCode ¶ added in v1.0.271
func (x *TelemetryLogEntry) GetCode() int32
func (*TelemetryLogEntry) GetMessage ¶ added in v1.0.240
func (x *TelemetryLogEntry) GetMessage() string
func (*TelemetryLogEntry) GetSource ¶ added in v1.0.271
func (x *TelemetryLogEntry) GetSource() LogSource
func (*TelemetryLogEntry) GetTrackingID ¶ added in v1.0.271
func (x *TelemetryLogEntry) GetTrackingID() string
func (*TelemetryLogEntry) ProtoMessage ¶ added in v1.0.240
func (*TelemetryLogEntry) ProtoMessage()
func (*TelemetryLogEntry) ProtoReflect ¶ added in v1.0.240
func (x *TelemetryLogEntry) ProtoReflect() protoreflect.Message
func (*TelemetryLogEntry) Reset ¶ added in v1.0.240
func (x *TelemetryLogEntry) Reset()
func (*TelemetryLogEntry) String ¶ added in v1.0.240
func (x *TelemetryLogEntry) String() string
type TelemetryState ¶ added in v1.0.240
type TelemetryState struct { State *WorkflowState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"` Log map[int64]*TelemetryLogEntry `` /* 148-byte string literal not displayed */ // contains filtered or unexported fields }
func (*TelemetryState) Descriptor
deprecated
added in
v1.0.240
func (*TelemetryState) Descriptor() ([]byte, []int)
Deprecated: Use TelemetryState.ProtoReflect.Descriptor instead.
func (*TelemetryState) GetLog ¶ added in v1.0.240
func (x *TelemetryState) GetLog() map[int64]*TelemetryLogEntry
func (*TelemetryState) GetState ¶ added in v1.0.240
func (x *TelemetryState) GetState() *WorkflowState
func (*TelemetryState) ProtoMessage ¶ added in v1.0.240
func (*TelemetryState) ProtoMessage()
func (*TelemetryState) ProtoReflect ¶ added in v1.0.240
func (x *TelemetryState) ProtoReflect() protoreflect.Message
func (*TelemetryState) Reset ¶ added in v1.0.240
func (x *TelemetryState) Reset()
func (*TelemetryState) String ¶ added in v1.0.240
func (x *TelemetryState) String() string
type ThreadingType ¶ added in v1.0.485
type ThreadingType int32
const ( ThreadingType_Sequential ThreadingType = 0 ThreadingType_Parallel ThreadingType = 2 )
func (ThreadingType) Descriptor ¶ added in v1.0.485
func (ThreadingType) Descriptor() protoreflect.EnumDescriptor
func (ThreadingType) Enum ¶ added in v1.0.485
func (x ThreadingType) Enum() *ThreadingType
func (ThreadingType) EnumDescriptor
deprecated
added in
v1.0.485
func (ThreadingType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ThreadingType.Descriptor instead.
func (ThreadingType) Number ¶ added in v1.0.485
func (x ThreadingType) Number() protoreflect.EnumNumber
func (ThreadingType) String ¶ added in v1.0.485
func (x ThreadingType) String() string
func (ThreadingType) Type ¶ added in v1.0.485
func (ThreadingType) Type() protoreflect.EnumType
type Timer ¶ added in v1.0.235
type Timer struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Id - the unique identifier for the timer. Duration string `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"` // Duration - the duration of the timer. Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` // Target - state machine element ID to transition to. OutputTransform map[string]string `` // OutputTransform - The transformation to apply to variables during the transition. /* 171-byte string literal not displayed */ // contains filtered or unexported fields }
Timer specifies a timed transition to another state.
func (*Timer) Descriptor
deprecated
added in
v1.0.235
func (*Timer) GetDuration ¶ added in v1.0.235
func (*Timer) GetOutputTransform ¶ added in v1.0.251
func (*Timer) ProtoMessage ¶ added in v1.0.235
func (*Timer) ProtoMessage()
func (*Timer) ProtoReflect ¶ added in v1.0.235
func (x *Timer) ProtoReflect() protoreflect.Message
type UserTasks ¶ added in v0.1.86
type UserTasks struct { Id []string `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*UserTasks) Descriptor
deprecated
added in
v0.1.86
func (*UserTasks) ProtoMessage ¶ added in v0.1.86
func (*UserTasks) ProtoMessage()
func (*UserTasks) ProtoReflect ¶ added in v0.1.86
func (x *UserTasks) ProtoReflect() protoreflect.Message
type Vars ¶
Vars is a map of variables. The variables must be primitive go types.
func (Vars) GetBool ¶ added in v1.0.396
GetBool validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetByte ¶ added in v1.0.396
GetByte validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetBytes ¶ added in v1.0.396
GetBytes validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetFloat32 ¶ added in v1.0.396
GetFloat32 validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetFloat64 ¶ added in v1.0.396
GetFloat64 validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetInt ¶ added in v1.0.396
GetInt validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetInt16 ¶ added in v1.0.396
GetInt16 validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetInt32 ¶ added in v1.0.396
GetInt32 validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetInt64 ¶ added in v1.0.396
GetInt64 validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetInt8 ¶ added in v1.0.396
GetInt8 validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetString ¶ added in v1.0.396
GetString validates that a key has an underlying value in the map[string]interface{} vars and safely returns the result.
func (Vars) GetUint16 ¶ added in v1.0.503
GetUint16 validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetUint32 ¶ added in v1.0.503
GetUint32 validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
type Workflow ¶
type Workflow struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Name defines the common name that describes the workflow. Process map[string]*Process `` // Process is a map of process names to workflow state machines. /* 155-byte string literal not displayed */ Messages []*Element `protobuf:"bytes,3,rep,name=messages,proto3" json:"messages,omitempty"` // Messages define the messages that can be sent by the workflow. Errors []*Error `protobuf:"bytes,4,rep,name=errors,proto3" json:"errors,omitempty"` // Errors define the errors used by the workflow. GzipSource []byte `protobuf:"bytes,5,opt,name=gzipSource,proto3" json:"gzipSource,omitempty"` // Source for round tripping. Collaboration *Collaboration `protobuf:"bytes,6,opt,name=collaboration,proto3" json:"collaboration,omitempty"` // Collaboration between processes. MessageReceivers map[string]*MessageReceivers `` //MessageReceivers are the activity ids that receive a given messgae /* 173-byte string literal not displayed */ // contains filtered or unexported fields }
Workflow describes a number of processes that interact together. It also contains all messages and errors used by the processes.
func (*Workflow) Descriptor
deprecated
func (*Workflow) GetCollaboration ¶ added in v1.0.645
func (x *Workflow) GetCollaboration() *Collaboration
func (*Workflow) GetGzipSource ¶ added in v1.0.366
func (*Workflow) GetMessageReceivers ¶ added in v1.1.725
func (x *Workflow) GetMessageReceivers() map[string]*MessageReceivers
func (*Workflow) GetMessages ¶
func (*Workflow) GetProcess ¶
func (*Workflow) ProtoMessage ¶
func (*Workflow) ProtoMessage()
func (*Workflow) ProtoReflect ¶
func (x *Workflow) ProtoReflect() protoreflect.Message
type WorkflowInstanceComplete ¶ added in v0.1.66
type WorkflowInstanceComplete struct { WorkflowName string `protobuf:"bytes,1,opt,name=workflowName,proto3" json:"workflowName,omitempty"` WorkflowId string `protobuf:"bytes,2,opt,name=workflowId,proto3" json:"workflowId,omitempty"` WorkflowInstanceId string `protobuf:"bytes,3,opt,name=workflowInstanceId,proto3" json:"workflowInstanceId,omitempty"` WorkflowState CancellationState `protobuf:"varint,4,opt,name=workflowState,proto3,enum=CancellationState" json:"workflowState,omitempty"` Error *Error `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*WorkflowInstanceComplete) Descriptor
deprecated
added in
v0.1.66
func (*WorkflowInstanceComplete) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowInstanceComplete.ProtoReflect.Descriptor instead.
func (*WorkflowInstanceComplete) GetError ¶ added in v0.1.134
func (x *WorkflowInstanceComplete) GetError() *Error
func (*WorkflowInstanceComplete) GetWorkflowId ¶ added in v0.1.66
func (x *WorkflowInstanceComplete) GetWorkflowId() string
func (*WorkflowInstanceComplete) GetWorkflowInstanceId ¶ added in v0.1.66
func (x *WorkflowInstanceComplete) GetWorkflowInstanceId() string
func (*WorkflowInstanceComplete) GetWorkflowName ¶ added in v0.1.66
func (x *WorkflowInstanceComplete) GetWorkflowName() string
func (*WorkflowInstanceComplete) GetWorkflowState ¶ added in v0.1.134
func (x *WorkflowInstanceComplete) GetWorkflowState() CancellationState
func (*WorkflowInstanceComplete) ProtoMessage ¶ added in v0.1.66
func (*WorkflowInstanceComplete) ProtoMessage()
func (*WorkflowInstanceComplete) ProtoReflect ¶ added in v0.1.66
func (x *WorkflowInstanceComplete) ProtoReflect() protoreflect.Message
func (*WorkflowInstanceComplete) Reset ¶ added in v0.1.66
func (x *WorkflowInstanceComplete) Reset()
func (*WorkflowInstanceComplete) String ¶ added in v0.1.66
func (x *WorkflowInstanceComplete) String() string
type WorkflowInstanceInfo ¶
type WorkflowInstanceInfo struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` WorkflowId string `protobuf:"bytes,2,opt,name=workflowId,proto3" json:"workflowId,omitempty"` // contains filtered or unexported fields }
func (*WorkflowInstanceInfo) Descriptor
deprecated
func (*WorkflowInstanceInfo) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowInstanceInfo.ProtoReflect.Descriptor instead.
func (*WorkflowInstanceInfo) GetId ¶
func (x *WorkflowInstanceInfo) GetId() string
func (*WorkflowInstanceInfo) GetWorkflowId ¶
func (x *WorkflowInstanceInfo) GetWorkflowId() string
func (*WorkflowInstanceInfo) ProtoMessage ¶
func (*WorkflowInstanceInfo) ProtoMessage()
func (*WorkflowInstanceInfo) ProtoReflect ¶
func (x *WorkflowInstanceInfo) ProtoReflect() protoreflect.Message
func (*WorkflowInstanceInfo) Reset ¶
func (x *WorkflowInstanceInfo) Reset()
func (*WorkflowInstanceInfo) String ¶
func (x *WorkflowInstanceInfo) String() string
type WorkflowInstanceStatus ¶
type WorkflowInstanceStatus struct { State []*WorkflowState `protobuf:"bytes,1,rep,name=state,proto3" json:"state,omitempty"` // contains filtered or unexported fields }
func (*WorkflowInstanceStatus) Descriptor
deprecated
func (*WorkflowInstanceStatus) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowInstanceStatus.ProtoReflect.Descriptor instead.
func (*WorkflowInstanceStatus) GetState ¶
func (x *WorkflowInstanceStatus) GetState() []*WorkflowState
func (*WorkflowInstanceStatus) ProtoMessage ¶
func (*WorkflowInstanceStatus) ProtoMessage()
func (*WorkflowInstanceStatus) ProtoReflect ¶
func (x *WorkflowInstanceStatus) ProtoReflect() protoreflect.Message
func (*WorkflowInstanceStatus) Reset ¶
func (x *WorkflowInstanceStatus) Reset()
func (*WorkflowInstanceStatus) String ¶
func (x *WorkflowInstanceStatus) String() string
type WorkflowState ¶
type WorkflowState struct { WorkflowId string `protobuf:"bytes,1,opt,name=workflowId,proto3" json:"workflowId,omitempty"` // WorkflowId - the ID of the workflow version that provides the template for execution. ExecutionId string `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"` // executionId - The id of the Execution this workflow state is for ElementId string `protobuf:"bytes,3,opt,name=elementId,proto3" json:"elementId,omitempty"` // ElementId - the currently executing element withing the workflow state machine. ElementType string `protobuf:"bytes,4,opt,name=elementType,proto3" json:"elementType,omitempty"` // ElementType - the currently executing element type, cached here to reduce lookups. Id []string `protobuf:"bytes,5,rep,name=id,proto3" json:"id,omitempty"` // Id - a stack of IDs that descibe the state and its parents up to the original workflow instance ID. ExecuteVersion string `protobuf:"bytes,22,opt,name=executeVersion,proto3" json:"executeVersion,omitempty"` // ExecuteVersion specifies a particular version to execute. Execute *string `protobuf:"bytes,7,opt,name=execute,proto3,oneof" json:"execute,omitempty"` // Execute - additional information required to execute depending on the element type. State CancellationState `protobuf:"varint,8,opt,name=state,proto3,enum=CancellationState" json:"state,omitempty"` // State - the current execution state of the state machine. Condition *string `protobuf:"bytes,9,opt,name=condition,proto3,oneof" json:"condition,omitempty"` // Condition - a message condition that needs to be fulfilled before proceeding. UnixTimeNano int64 `protobuf:"varint,10,opt,name=unixTimeNano,proto3" json:"unixTimeNano,omitempty"` // UnixTimeNano - the time this state was observed. Vars []byte `protobuf:"bytes,11,opt,name=vars,proto3" json:"vars,omitempty"` // Vars - A go binary encoded map[string]interface{} of variables. Owners []string `protobuf:"bytes,12,rep,name=owners,proto3" json:"owners,omitempty"` // Owners - a list of user owners for this state that may be responsible for completing tasks Groups []string `protobuf:"bytes,13,rep,name=groups,proto3" json:"groups,omitempty"` // Groups - a list of user groups for this state that may be responsible for completing tasks Error *Error `protobuf:"bytes,14,opt,name=error,proto3" json:"error,omitempty"` // Error - an error being carried by the state if it has faulted. Timer *WorkflowTimer `protobuf:"bytes,16,opt,name=timer,proto3" json:"timer,omitempty"` // Timer - a time needed to transition to the next state. WorkflowName string `protobuf:"bytes,17,opt,name=workflowName,proto3" json:"workflowName,omitempty"` // WorkflowName - name of this workflow to avoid lookups. ProcessName string `protobuf:"bytes,18,opt,name=processName,proto3" json:"processName,omitempty"` // ProcessName - name of this process to avoid lookups. ProcessInstanceId string `protobuf:"bytes,19,opt,name=processInstanceId,proto3" json:"processInstanceId,omitempty"` // ProcessInstanceId - the unique ID for the process instance. SatisfiesGatewayExpectation map[string]*SatisfiesGateway `` // SatisfiesGatewayExpectation - a list of gateways, and pathway covered that satisfy their expectations. /* 196-byte string literal not displayed */ GatewayExpectations map[string]*GatewayExpectations `` // GatewayExpectations - a list of dynamic gateway expectations set during traversing from a divergent gateway with a reciprocal. /* 180-byte string literal not displayed */ // contains filtered or unexported fields }
WorkflowState describes a current executing state inside a workflow state machine.
func (*WorkflowState) Descriptor
deprecated
func (*WorkflowState) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowState.ProtoReflect.Descriptor instead.
func (*WorkflowState) GetCondition ¶
func (x *WorkflowState) GetCondition() string
func (*WorkflowState) GetElementId ¶
func (x *WorkflowState) GetElementId() string
func (*WorkflowState) GetElementType ¶
func (x *WorkflowState) GetElementType() string
func (*WorkflowState) GetError ¶ added in v0.1.134
func (x *WorkflowState) GetError() *Error
func (*WorkflowState) GetExecute ¶
func (x *WorkflowState) GetExecute() string
func (*WorkflowState) GetExecuteVersion ¶ added in v1.0.623
func (x *WorkflowState) GetExecuteVersion() string
func (*WorkflowState) GetExecutionId ¶ added in v1.0.645
func (x *WorkflowState) GetExecutionId() string
func (*WorkflowState) GetGatewayExpectations ¶ added in v1.0.446
func (x *WorkflowState) GetGatewayExpectations() map[string]*GatewayExpectations
func (*WorkflowState) GetGroups ¶ added in v0.1.86
func (x *WorkflowState) GetGroups() []string
func (*WorkflowState) GetId ¶ added in v0.1.78
func (x *WorkflowState) GetId() []string
func (*WorkflowState) GetOwners ¶ added in v0.1.86
func (x *WorkflowState) GetOwners() []string
func (*WorkflowState) GetProcessInstanceId ¶ added in v1.0.427
func (x *WorkflowState) GetProcessInstanceId() string
func (*WorkflowState) GetProcessName ¶ added in v1.0.427
func (x *WorkflowState) GetProcessName() string
func (*WorkflowState) GetSatisfiesGatewayExpectation ¶ added in v1.0.446
func (x *WorkflowState) GetSatisfiesGatewayExpectation() map[string]*SatisfiesGateway
func (*WorkflowState) GetState ¶
func (x *WorkflowState) GetState() CancellationState
func (*WorkflowState) GetTimer ¶ added in v0.1.181
func (x *WorkflowState) GetTimer() *WorkflowTimer
func (*WorkflowState) GetUnixTimeNano ¶
func (x *WorkflowState) GetUnixTimeNano() int64
func (*WorkflowState) GetVars ¶
func (x *WorkflowState) GetVars() []byte
func (*WorkflowState) GetWorkflowId ¶
func (x *WorkflowState) GetWorkflowId() string
func (*WorkflowState) GetWorkflowName ¶ added in v1.0.362
func (x *WorkflowState) GetWorkflowName() string
func (*WorkflowState) ProtoMessage ¶
func (*WorkflowState) ProtoMessage()
func (*WorkflowState) ProtoReflect ¶
func (x *WorkflowState) ProtoReflect() protoreflect.Message
func (*WorkflowState) Reset ¶
func (x *WorkflowState) Reset()
func (*WorkflowState) String ¶
func (x *WorkflowState) String() string
type WorkflowStateSummary ¶ added in v1.0.512
type WorkflowStateSummary struct { WorkflowId string `protobuf:"bytes,1,opt,name=workflowId,proto3" json:"workflowId,omitempty"` // WorkflowId - the ID of the workflow version that provides the template for execution. ExecutionId string `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"` // ExecutionId - the execution that this state belongs to. ElementId string `protobuf:"bytes,3,opt,name=elementId,proto3" json:"elementId,omitempty"` // ElementId - the currently executing element withing the workflow state machine. ElementType string `protobuf:"bytes,4,opt,name=elementType,proto3" json:"elementType,omitempty"` // ElementType - the currently executing element type, cached here to reduce lookups. Id []string `protobuf:"bytes,5,rep,name=id,proto3" json:"id,omitempty"` // Id - a stack of IDs that describe the state and its parents up to the original workflow instance ID. Execute *string `protobuf:"bytes,7,opt,name=execute,proto3,oneof" json:"execute,omitempty"` // Execute - additional information required to execute depending on the element type. State CancellationState `protobuf:"varint,8,opt,name=state,proto3,enum=CancellationState" json:"state,omitempty"` // State - the current execution state of the state machine. Condition *string `protobuf:"bytes,9,opt,name=condition,proto3,oneof" json:"condition,omitempty"` // Condition - a message condition that needs to be fulfilled before proceeding. UnixTimeNano int64 `protobuf:"varint,10,opt,name=unixTimeNano,proto3" json:"unixTimeNano,omitempty"` // UnixTimeNano - the time this state was observed. Vars []byte `protobuf:"bytes,11,opt,name=vars,proto3" json:"vars,omitempty"` // Vars - A go binary encoded map[string]interface{} of variables. Error *Error `protobuf:"bytes,14,opt,name=error,proto3" json:"error,omitempty"` // Error - an error being carried by the state if it has faulted. Timer *WorkflowTimer `protobuf:"bytes,16,opt,name=timer,proto3" json:"timer,omitempty"` // Timer - a time needed to transition to the next state. ProcessInstanceId string `protobuf:"bytes,19,opt,name=processInstanceId,proto3" json:"processInstanceId,omitempty"` // ProcessInstanceId - the unique ID for the process instance. // contains filtered or unexported fields }
func (*WorkflowStateSummary) Descriptor
deprecated
added in
v1.0.512
func (*WorkflowStateSummary) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowStateSummary.ProtoReflect.Descriptor instead.
func (*WorkflowStateSummary) GetCondition ¶ added in v1.0.512
func (x *WorkflowStateSummary) GetCondition() string
func (*WorkflowStateSummary) GetElementId ¶ added in v1.0.512
func (x *WorkflowStateSummary) GetElementId() string
func (*WorkflowStateSummary) GetElementType ¶ added in v1.0.512
func (x *WorkflowStateSummary) GetElementType() string
func (*WorkflowStateSummary) GetError ¶ added in v1.0.512
func (x *WorkflowStateSummary) GetError() *Error
func (*WorkflowStateSummary) GetExecute ¶ added in v1.0.512
func (x *WorkflowStateSummary) GetExecute() string
func (*WorkflowStateSummary) GetExecutionId ¶ added in v1.0.645
func (x *WorkflowStateSummary) GetExecutionId() string
func (*WorkflowStateSummary) GetId ¶ added in v1.0.512
func (x *WorkflowStateSummary) GetId() []string
func (*WorkflowStateSummary) GetProcessInstanceId ¶ added in v1.0.512
func (x *WorkflowStateSummary) GetProcessInstanceId() string
func (*WorkflowStateSummary) GetState ¶ added in v1.0.512
func (x *WorkflowStateSummary) GetState() CancellationState
func (*WorkflowStateSummary) GetTimer ¶ added in v1.0.512
func (x *WorkflowStateSummary) GetTimer() *WorkflowTimer
func (*WorkflowStateSummary) GetUnixTimeNano ¶ added in v1.0.512
func (x *WorkflowStateSummary) GetUnixTimeNano() int64
func (*WorkflowStateSummary) GetVars ¶ added in v1.0.512
func (x *WorkflowStateSummary) GetVars() []byte
func (*WorkflowStateSummary) GetWorkflowId ¶ added in v1.0.512
func (x *WorkflowStateSummary) GetWorkflowId() string
func (*WorkflowStateSummary) ProtoMessage ¶ added in v1.0.512
func (*WorkflowStateSummary) ProtoMessage()
func (*WorkflowStateSummary) ProtoReflect ¶ added in v1.0.512
func (x *WorkflowStateSummary) ProtoReflect() protoreflect.Message
func (*WorkflowStateSummary) Reset ¶ added in v1.0.512
func (x *WorkflowStateSummary) Reset()
func (*WorkflowStateSummary) String ¶ added in v1.0.512
func (x *WorkflowStateSummary) String() string
type WorkflowStats ¶ added in v0.1.134
type WorkflowStats struct { Workflows int64 `protobuf:"varint,1,opt,name=Workflows,proto3" json:"Workflows,omitempty"` InstancesStarted int64 `protobuf:"varint,2,opt,name=InstancesStarted,proto3" json:"InstancesStarted,omitempty"` InstancesComplete int64 `protobuf:"varint,3,opt,name=InstancesComplete,proto3" json:"InstancesComplete,omitempty"` // contains filtered or unexported fields }
func (*WorkflowStats) Descriptor
deprecated
added in
v0.1.134
func (*WorkflowStats) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowStats.ProtoReflect.Descriptor instead.
func (*WorkflowStats) GetInstancesComplete ¶ added in v0.1.134
func (x *WorkflowStats) GetInstancesComplete() int64
func (*WorkflowStats) GetInstancesStarted ¶ added in v0.1.134
func (x *WorkflowStats) GetInstancesStarted() int64
func (*WorkflowStats) GetWorkflows ¶ added in v0.1.134
func (x *WorkflowStats) GetWorkflows() int64
func (*WorkflowStats) ProtoMessage ¶ added in v0.1.134
func (*WorkflowStats) ProtoMessage()
func (*WorkflowStats) ProtoReflect ¶ added in v0.1.134
func (x *WorkflowStats) ProtoReflect() protoreflect.Message
func (*WorkflowStats) Reset ¶ added in v0.1.134
func (x *WorkflowStats) Reset()
func (*WorkflowStats) String ¶ added in v0.1.134
func (x *WorkflowStats) String() string
type WorkflowTimer ¶ added in v0.1.181
type WorkflowTimer struct { LastFired int64 `protobuf:"varint,1,opt,name=lastFired,proto3" json:"lastFired,omitempty"` // LastFired - the time in UNIX nanoseconds since the timer was last executed. Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` // Count - the number of times the timer has fired. // contains filtered or unexported fields }
WorkflowTimer holds the last execution state of a timer.
func (*WorkflowTimer) Descriptor
deprecated
added in
v0.1.181
func (*WorkflowTimer) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowTimer.ProtoReflect.Descriptor instead.
func (*WorkflowTimer) GetCount ¶ added in v0.1.181
func (x *WorkflowTimer) GetCount() int64
func (*WorkflowTimer) GetLastFired ¶ added in v0.1.181
func (x *WorkflowTimer) GetLastFired() int64
func (*WorkflowTimer) ProtoMessage ¶ added in v0.1.181
func (*WorkflowTimer) ProtoMessage()
func (*WorkflowTimer) ProtoReflect ¶ added in v0.1.181
func (x *WorkflowTimer) ProtoReflect() protoreflect.Message
func (*WorkflowTimer) Reset ¶ added in v0.1.181
func (x *WorkflowTimer) Reset()
func (*WorkflowTimer) String ¶ added in v0.1.181
func (x *WorkflowTimer) String() string
type WorkflowTimerDefinition ¶ added in v0.1.181
type WorkflowTimerDefinition struct { Type WorkflowTimerType `protobuf:"varint,1,opt,name=type,proto3,enum=WorkflowTimerType" json:"type,omitempty"` // Type - whether the workflow timer is relative or absolute. Value int64 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"` // Value - the time parameter. Repeat int64 `protobuf:"varint,3,opt,name=repeat,proto3" json:"repeat,omitempty"` // Repeat - the repeat interval for the timer. DropEvents bool `protobuf:"varint,4,opt,name=dropEvents,proto3" json:"dropEvents,omitempty"` // DropEvents - unused. // contains filtered or unexported fields }
WorkflowTimerDefinition defines a workflow timer that can be used to trigger an event.
func (*WorkflowTimerDefinition) Descriptor
deprecated
added in
v0.1.181
func (*WorkflowTimerDefinition) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowTimerDefinition.ProtoReflect.Descriptor instead.
func (*WorkflowTimerDefinition) GetDropEvents ¶ added in v0.1.181
func (x *WorkflowTimerDefinition) GetDropEvents() bool
func (*WorkflowTimerDefinition) GetRepeat ¶ added in v0.1.181
func (x *WorkflowTimerDefinition) GetRepeat() int64
func (*WorkflowTimerDefinition) GetType ¶ added in v0.1.181
func (x *WorkflowTimerDefinition) GetType() WorkflowTimerType
func (*WorkflowTimerDefinition) GetValue ¶ added in v0.1.181
func (x *WorkflowTimerDefinition) GetValue() int64
func (*WorkflowTimerDefinition) ProtoMessage ¶ added in v0.1.181
func (*WorkflowTimerDefinition) ProtoMessage()
func (*WorkflowTimerDefinition) ProtoReflect ¶ added in v0.1.181
func (x *WorkflowTimerDefinition) ProtoReflect() protoreflect.Message
func (*WorkflowTimerDefinition) Reset ¶ added in v0.1.181
func (x *WorkflowTimerDefinition) Reset()
func (*WorkflowTimerDefinition) String ¶ added in v0.1.181
func (x *WorkflowTimerDefinition) String() string
type WorkflowTimerType ¶ added in v0.1.181
type WorkflowTimerType int32
WorkflowTimerType describes whether a timer is relative or absolute
const ( WorkflowTimerType_duration WorkflowTimerType = 0 // Duration - a relative timer WorkflowTimerType_fixed WorkflowTimerType = 1 // Fixed - an absolute timer )
func (WorkflowTimerType) Descriptor ¶ added in v0.1.181
func (WorkflowTimerType) Descriptor() protoreflect.EnumDescriptor
func (WorkflowTimerType) Enum ¶ added in v0.1.181
func (x WorkflowTimerType) Enum() *WorkflowTimerType
func (WorkflowTimerType) EnumDescriptor
deprecated
added in
v0.1.181
func (WorkflowTimerType) EnumDescriptor() ([]byte, []int)
Deprecated: Use WorkflowTimerType.Descriptor instead.
func (WorkflowTimerType) Number ¶ added in v0.1.181
func (x WorkflowTimerType) Number() protoreflect.EnumNumber
func (WorkflowTimerType) String ¶ added in v0.1.181
func (x WorkflowTimerType) String() string
func (WorkflowTimerType) Type ¶ added in v0.1.181
func (WorkflowTimerType) Type() protoreflect.EnumType
type WorkflowVersion ¶
type WorkflowVersion struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Id - the launchable ID for the workflow. Sha256 []byte `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"` // Sha256 - the hash of the workflow configuration. Number int32 `protobuf:"varint,3,opt,name=number,proto3" json:"number,omitempty"` // Number - the version number of the workflow // contains filtered or unexported fields }
WorkflowVersion contains the metadata for a single workflow version
func (*WorkflowVersion) Descriptor
deprecated
func (*WorkflowVersion) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowVersion.ProtoReflect.Descriptor instead.
func (*WorkflowVersion) GetId ¶
func (x *WorkflowVersion) GetId() string
func (*WorkflowVersion) GetNumber ¶
func (x *WorkflowVersion) GetNumber() int32
func (*WorkflowVersion) GetSha256 ¶
func (x *WorkflowVersion) GetSha256() []byte
func (*WorkflowVersion) ProtoMessage ¶
func (*WorkflowVersion) ProtoMessage()
func (*WorkflowVersion) ProtoReflect ¶
func (x *WorkflowVersion) ProtoReflect() protoreflect.Message
func (*WorkflowVersion) Reset ¶
func (x *WorkflowVersion) Reset()
func (*WorkflowVersion) String ¶
func (x *WorkflowVersion) String() string
type WorkflowVersions ¶
type WorkflowVersions struct { Version []*WorkflowVersion `protobuf:"bytes,1,rep,name=version,proto3" json:"version,omitempty"` // WorkflowVersion - a single version of a workflow // contains filtered or unexported fields }
WorkflowVersions describes the version history.
func (*WorkflowVersions) Descriptor
deprecated
func (*WorkflowVersions) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowVersions.ProtoReflect.Descriptor instead.
func (*WorkflowVersions) GetVersion ¶
func (x *WorkflowVersions) GetVersion() []*WorkflowVersion
func (*WorkflowVersions) ProtoMessage ¶
func (*WorkflowVersions) ProtoMessage()
func (*WorkflowVersions) ProtoReflect ¶
func (x *WorkflowVersions) ProtoReflect() protoreflect.Message
func (*WorkflowVersions) Reset ¶
func (x *WorkflowVersions) Reset()
func (*WorkflowVersions) String ¶
func (x *WorkflowVersions) String() string