Documentation
¶
Index ¶
- Variables
- func GetJson(vars map[string]any, key string) (string, error)
- func GetNestedVal[PT PERMISSABLETYPES](exprEvaluator expression.Engine, pathKey string, vals map[string]any) (PT, error)
- func GetStruct[T any](vars *ClientVars, key string) (*T, error)
- func SetJson(key string, jsonStr string, vals map[string]any) error
- func SetStruct[T any](v *ClientVars, key string, t *T) error
- type AbandonUserTaskRequest
- type AbandonUserTaskResponse
- 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 COMPLEX
- type CallBehavior
- func (*CallBehavior) Descriptor() ([]byte, []int)deprecated
- func (x *CallBehavior) GetReturnAllChildVariables() bool
- func (x *CallBehavior) GetSendAllParentVariables() bool
- func (*CallBehavior) ProtoMessage()
- func (x *CallBehavior) ProtoReflect() protoreflect.Message
- func (x *CallBehavior) Reset()
- func (x *CallBehavior) 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 ClientVars
- func (vars *ClientVars) Decode(ctx context.Context, b []byte) error
- func (vars *ClientVars) Encode(ctx context.Context) ([]byte, error)
- func (vars *ClientVars) GetBool(key string) (bool, error)
- func (vars *ClientVars) GetBools(key string) ([]bool, error)
- func (vars *ClientVars) GetFloat64(key string) (float64, error)
- func (vars *ClientVars) GetFloat64s(key string) ([]float64, error)
- func (vars *ClientVars) GetInt64(key string) (int64, error)
- func (vars *ClientVars) GetInt64s(key string) ([]int64, error)
- func (vars *ClientVars) GetJson(key string) (string, error)
- func (vars *ClientVars) GetNestedBool(pathKey string) (bool, error)
- func (vars *ClientVars) GetNestedFloat64(pathKey string) (float64, error)
- func (vars *ClientVars) GetNestedInt64(pathKey string) (int64, error)
- func (vars *ClientVars) GetNestedMap(pathKey string) (map[string]any, error)
- func (vars *ClientVars) GetNestedSlice(pathKey string) ([]any, error)
- func (vars *ClientVars) GetNestedString(pathKey string) (string, error)
- func (vars *ClientVars) GetString(key string) (string, error)
- func (vars *ClientVars) GetStrings(key string) ([]string, error)
- func (vars *ClientVars) Keys() iter.Seq[string]
- func (vars *ClientVars) Len() int
- func (vars *ClientVars) SetBool(key string, value bool)
- func (vars *ClientVars) SetBools(key string, value []bool)
- func (vars *ClientVars) SetFloat64(key string, value float64)
- func (vars *ClientVars) SetFloat64s(key string, value []float64)
- func (vars *ClientVars) SetInt64(key string, value int64)
- func (vars *ClientVars) SetInt64s(key string, value []int64)
- func (vars *ClientVars) SetJson(key, jsonObj string) error
- func (vars *ClientVars) SetString(key string, value string)
- func (vars *ClientVars) SetStrings(key string, value []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 Compensation
- func (*Compensation) Descriptor() ([]byte, []int)deprecated
- func (x *Compensation) GetForTrackingId() string
- func (x *Compensation) GetStep() int64
- func (x *Compensation) GetTotalSteps() int64
- func (*Compensation) ProtoMessage()
- func (x *Compensation) ProtoReflect() protoreflect.Message
- func (x *Compensation) Reset()
- func (x *Compensation) 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) GetCompensating() bool
- 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) GetId() string
- 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 DisableWorkflowLaunch
- func (*DisableWorkflowLaunch) Descriptor() ([]byte, []int)deprecated
- func (x *DisableWorkflowLaunch) GetTimestamp() int64
- func (x *DisableWorkflowLaunch) GetWorkflowName() string
- func (*DisableWorkflowLaunch) ProtoMessage()
- func (x *DisableWorkflowLaunch) ProtoReflect() protoreflect.Message
- func (x *DisableWorkflowLaunch) Reset()
- func (x *DisableWorkflowLaunch) String() string
- type DisableWorkflowRequest
- func (*DisableWorkflowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DisableWorkflowRequest) GetWorkflowName() string
- func (*DisableWorkflowRequest) ProtoMessage()
- func (x *DisableWorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *DisableWorkflowRequest) Reset()
- func (x *DisableWorkflowRequest) String() string
- type DisableWorkflowResponse
- type Element
- func (*Element) Descriptor() ([]byte, []int)deprecated
- func (x *Element) GetBoundaryTimer() []*Timer
- func (x *Element) GetCallBehavior() *CallBehavior
- func (x *Element) GetCandidateGroups() string
- func (x *Element) GetCandidates() string
- func (x *Element) GetCompensateWith() 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) GetIsForCompensation() bool
- 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) GetRetryBehaviour() *DefaultTaskRetry
- func (x *Element) GetServiceTaskSetName() string
- func (x *Element) GetTimer() *WorkflowTimerDefinition
- func (x *Element) GetType() string
- func (x *Element) GetVersion() string
- func (x *Element) GetWithinGateways() map[string]string
- func (*Element) ProtoMessage()
- func (x *Element) ProtoReflect() protoreflect.Message
- func (x *Element) Reset()
- func (x *Element) String() string
- type EnableWorkflowLaunch
- func (*EnableWorkflowLaunch) Descriptor() ([]byte, []int)deprecated
- func (x *EnableWorkflowLaunch) GetTimestamp() int64
- func (x *EnableWorkflowLaunch) GetWorkflowName() string
- func (*EnableWorkflowLaunch) ProtoMessage()
- func (x *EnableWorkflowLaunch) ProtoReflect() protoreflect.Message
- func (x *EnableWorkflowLaunch) Reset()
- func (x *EnableWorkflowLaunch) String() string
- type EnableWorkflowRequest
- func (*EnableWorkflowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EnableWorkflowRequest) GetWorkflowName() string
- func (*EnableWorkflowRequest) ProtoMessage()
- func (x *EnableWorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *EnableWorkflowRequest) Reset()
- func (x *EnableWorkflowRequest) String() string
- type EnableWorkflowResponse
- type Error
- type Exchange
- type ExecutableStartParameter
- func (*ExecutableStartParameter) Descriptor() ([]byte, []int)deprecated
- func (x *ExecutableStartParameter) GetName() string
- func (*ExecutableStartParameter) ProtoMessage()
- func (x *ExecutableStartParameter) ProtoReflect() protoreflect.Message
- func (x *ExecutableStartParameter) Reset()
- func (x *ExecutableStartParameter) String() string
- type Execution
- func (*Execution) Descriptor() ([]byte, []int)deprecated
- func (x *Execution) GetCompletedProcessInstanceId() []string
- 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 FatalError
- func (*FatalError) Descriptor() ([]byte, []int)deprecated
- func (x *FatalError) GetHandlingStrategy() HandlingStrategy
- func (x *FatalError) GetWorkflowState() *WorkflowState
- func (*FatalError) ProtoMessage()
- func (x *FatalError) ProtoReflect() protoreflect.Message
- func (x *FatalError) Reset()
- func (x *FatalError) 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 GatewayPaths
- 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 GetCompensationInputVariablesRequest
- func (*GetCompensationInputVariablesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetCompensationInputVariablesRequest) GetProcessInstanceId() string
- func (x *GetCompensationInputVariablesRequest) GetTrackingId() string
- func (*GetCompensationInputVariablesRequest) ProtoMessage()
- func (x *GetCompensationInputVariablesRequest) ProtoReflect() protoreflect.Message
- func (x *GetCompensationInputVariablesRequest) Reset()
- func (x *GetCompensationInputVariablesRequest) String() string
- type GetCompensationInputVariablesResponse
- func (*GetCompensationInputVariablesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetCompensationInputVariablesResponse) GetVars() []byte
- func (*GetCompensationInputVariablesResponse) ProtoMessage()
- func (x *GetCompensationInputVariablesResponse) ProtoReflect() protoreflect.Message
- func (x *GetCompensationInputVariablesResponse) Reset()
- func (x *GetCompensationInputVariablesResponse) String() string
- type GetCompensationOutputVariablesRequest
- func (*GetCompensationOutputVariablesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetCompensationOutputVariablesRequest) GetProcessInstanceId() string
- func (x *GetCompensationOutputVariablesRequest) GetTrackingId() string
- func (*GetCompensationOutputVariablesRequest) ProtoMessage()
- func (x *GetCompensationOutputVariablesRequest) ProtoReflect() protoreflect.Message
- func (x *GetCompensationOutputVariablesRequest) Reset()
- func (x *GetCompensationOutputVariablesRequest) String() string
- type GetCompensationOutputVariablesResponse
- func (*GetCompensationOutputVariablesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetCompensationOutputVariablesResponse) GetVars() []byte
- func (*GetCompensationOutputVariablesResponse) ProtoMessage()
- func (x *GetCompensationOutputVariablesResponse) ProtoReflect() protoreflect.Message
- func (x *GetCompensationOutputVariablesResponse) Reset()
- func (x *GetCompensationOutputVariablesResponse) String() string
- type GetFatalErrorRequest
- func (*GetFatalErrorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetFatalErrorRequest) GetExecutionId() string
- func (x *GetFatalErrorRequest) GetProcessInstanceId() string
- func (x *GetFatalErrorRequest) GetWfId() string
- func (x *GetFatalErrorRequest) GetWfName() string
- func (*GetFatalErrorRequest) ProtoMessage()
- func (x *GetFatalErrorRequest) ProtoReflect() protoreflect.Message
- func (x *GetFatalErrorRequest) Reset()
- func (x *GetFatalErrorRequest) String() string
- type GetJobRequest
- type GetJobResponse
- type GetProcessHeadersRequest
- func (*GetProcessHeadersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetProcessHeadersRequest) GetProcessInstanceID() string
- func (*GetProcessHeadersRequest) ProtoMessage()
- func (x *GetProcessHeadersRequest) ProtoReflect() protoreflect.Message
- func (x *GetProcessHeadersRequest) Reset()
- func (x *GetProcessHeadersRequest) String() string
- type GetProcessHeadersResponse
- func (*GetProcessHeadersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetProcessHeadersResponse) GetHeaders() map[string]string
- func (*GetProcessHeadersResponse) ProtoMessage()
- func (x *GetProcessHeadersResponse) ProtoReflect() protoreflect.Message
- func (x *GetProcessHeadersResponse) Reset()
- func (x *GetProcessHeadersResponse) String() string
- 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) GetSource() WorkflowErrorSource
- 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 HandleWorkflowFatalErrorRequest
- func (*HandleWorkflowFatalErrorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HandleWorkflowFatalErrorRequest) GetHandlingStrategy() HandlingStrategy
- func (x *HandleWorkflowFatalErrorRequest) GetMessage() string
- func (x *HandleWorkflowFatalErrorRequest) GetWorkflowState() *WorkflowState
- func (*HandleWorkflowFatalErrorRequest) ProtoMessage()
- func (x *HandleWorkflowFatalErrorRequest) ProtoReflect() protoreflect.Message
- func (x *HandleWorkflowFatalErrorRequest) Reset()
- func (x *HandleWorkflowFatalErrorRequest) String() string
- type HandleWorkflowFatalErrorResponse
- func (*HandleWorkflowFatalErrorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HandleWorkflowFatalErrorResponse) GetHandled() bool
- func (*HandleWorkflowFatalErrorResponse) ProtoMessage()
- func (x *HandleWorkflowFatalErrorResponse) ProtoReflect() protoreflect.Message
- func (x *HandleWorkflowFatalErrorResponse) Reset()
- func (x *HandleWorkflowFatalErrorResponse) String() string
- type HandlingStrategy
- func (HandlingStrategy) Descriptor() protoreflect.EnumDescriptor
- func (x HandlingStrategy) Enum() *HandlingStrategy
- func (HandlingStrategy) EnumDescriptor() ([]byte, []int)deprecated
- func (x HandlingStrategy) Number() protoreflect.EnumNumber
- func (x HandlingStrategy) String() string
- func (HandlingStrategy) Type() protoreflect.EnumType
- type HeartbeatRequest
- func (*HeartbeatRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HeartbeatRequest) GetHost() string
- func (x *HeartbeatRequest) GetId() string
- func (x *HeartbeatRequest) GetTime() int64
- func (*HeartbeatRequest) ProtoMessage()
- func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message
- func (x *HeartbeatRequest) Reset()
- func (x *HeartbeatRequest) String() string
- type HeartbeatResponse
- 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) GetHeaders() []byte
- func (x *LaunchWorkflowRequest) GetProcessId() 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) GetExecutionId() 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 ListExecutableProcessesItem
- func (*ListExecutableProcessesItem) Descriptor() ([]byte, []int)deprecated
- func (x *ListExecutableProcessesItem) GetParameter() []*ExecutableStartParameter
- func (x *ListExecutableProcessesItem) GetProcessId() string
- func (x *ListExecutableProcessesItem) GetWorkflowName() string
- func (*ListExecutableProcessesItem) ProtoMessage()
- func (x *ListExecutableProcessesItem) ProtoReflect() protoreflect.Message
- func (x *ListExecutableProcessesItem) Reset()
- func (x *ListExecutableProcessesItem) String() string
- type ListExecutableProcessesRequest
- func (*ListExecutableProcessesRequest) Descriptor() ([]byte, []int)deprecated
- func (*ListExecutableProcessesRequest) ProtoMessage()
- func (x *ListExecutableProcessesRequest) ProtoReflect() protoreflect.Message
- func (x *ListExecutableProcessesRequest) Reset()
- func (x *ListExecutableProcessesRequest) 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) GetGroup() string
- 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
- func (*ListUserTasksResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListUserTasksResponse) GetId() string
- func (x *ListUserTasksResponse) GetLockedBy() string
- func (x *ListUserTasksResponse) GetSpecUid() string
- func (x *ListUserTasksResponse) GetState() []byte
- func (*ListUserTasksResponse) ProtoMessage()
- func (x *ListUserTasksResponse) ProtoReflect() protoreflect.Message
- func (x *ListUserTasksResponse) Reset()
- func (x *ListUserTasksResponse) String() string
- 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 LogRequest
- func (*LogRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LogRequest) GetAttributes() map[string]string
- func (x *LogRequest) GetClientId() string
- func (x *LogRequest) GetHostname() string
- func (x *LogRequest) GetLevel() int64
- func (x *LogRequest) GetMessage() string
- func (x *LogRequest) GetSource() LogSource
- func (x *LogRequest) GetTime() int64
- func (x *LogRequest) GetTrackingId() []byte
- func (*LogRequest) ProtoMessage()
- func (x *LogRequest) ProtoReflect() protoreflect.Message
- func (x *LogRequest) Reset()
- func (x *LogRequest) String() string
- type LogResponse
- 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 OpenUserTaskRequest
- func (*OpenUserTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OpenUserTaskRequest) GetId() string
- func (*OpenUserTaskRequest) ProtoMessage()
- func (x *OpenUserTaskRequest) ProtoReflect() protoreflect.Message
- func (x *OpenUserTaskRequest) Reset()
- func (x *OpenUserTaskRequest) String() string
- type OpenUserTaskResponse
- func (*OpenUserTaskResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OpenUserTaskResponse) GetState() []byte
- func (*OpenUserTaskResponse) ProtoMessage()
- func (x *OpenUserTaskResponse) ProtoReflect() protoreflect.Message
- func (x *OpenUserTaskResponse) Reset()
- func (x *OpenUserTaskResponse) String() string
- type PERMISSABLETYPES
- 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 PauseServiceTaskRequest
- func (*PauseServiceTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PauseServiceTaskRequest) GetUid() string
- func (*PauseServiceTaskRequest) ProtoMessage()
- func (x *PauseServiceTaskRequest) ProtoReflect() protoreflect.Message
- func (x *PauseServiceTaskRequest) Reset()
- func (x *PauseServiceTaskRequest) String() string
- type PauseServiceTaskResponse
- type Process
- func (*Process) Descriptor() ([]byte, []int)deprecated
- func (x *Process) GetElements() []*Element
- func (x *Process) GetExecutable() bool
- func (x *Process) GetId() string
- func (x *Process) GetMetadata() *Metadata
- func (x *Process) GetSubProcess() bool
- 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) GetCompensating() bool
- func (x *ProcessHistoryEntry) GetItemType() ProcessHistoryType
- func (x *ProcessHistoryEntry) GetWorkflowState() *WorkflowState
- 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) GetHeaders() []byte
- func (x *ProcessInstance) GetParentElementId() string
- func (x *ProcessInstance) GetParentProcessId() string
- func (x *ProcessInstance) GetProcessId() string
- func (x *ProcessInstance) GetProcessInstanceId() 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 ResolveWorkflowRequest
- func (*ResolveWorkflowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResolveWorkflowRequest) GetWorkflow() *Workflow
- func (*ResolveWorkflowRequest) ProtoMessage()
- func (x *ResolveWorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *ResolveWorkflowRequest) Reset()
- func (x *ResolveWorkflowRequest) String() string
- type ResolveWorkflowResponse
- func (*ResolveWorkflowResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ResolveWorkflowResponse) GetWorkflow() *Workflow
- func (*ResolveWorkflowResponse) ProtoMessage()
- func (x *ResolveWorkflowResponse) ProtoReflect() protoreflect.Message
- func (x *ResolveWorkflowResponse) Reset()
- func (x *ResolveWorkflowResponse) String() string
- type ResumeServiceTaskRequest
- func (*ResumeServiceTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResumeServiceTaskRequest) GetUid() string
- func (*ResumeServiceTaskRequest) ProtoMessage()
- func (x *ResumeServiceTaskRequest) ProtoReflect() protoreflect.Message
- func (x *ResumeServiceTaskRequest) Reset()
- func (x *ResumeServiceTaskRequest) String() string
- type ResumeServiceTaskResponse
- type RetryActivityRequest
- func (*RetryActivityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RetryActivityRequest) GetElementId() string
- func (x *RetryActivityRequest) GetPriorElementId() string
- func (x *RetryActivityRequest) GetProcessInstanceId() string
- func (x *RetryActivityRequest) GetVars() []byte
- func (*RetryActivityRequest) ProtoMessage()
- func (x *RetryActivityRequest) ProtoReflect() protoreflect.Message
- func (x *RetryActivityRequest) Reset()
- func (x *RetryActivityRequest) String() string
- type RetryActivityResponse
- 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 SaveUserTaskRequest
- func (*SaveUserTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SaveUserTaskRequest) GetId() string
- func (x *SaveUserTaskRequest) GetOverwrite() bool
- func (x *SaveUserTaskRequest) GetVars() []byte
- func (*SaveUserTaskRequest) ProtoMessage()
- func (x *SaveUserTaskRequest) ProtoReflect() protoreflect.Message
- func (x *SaveUserTaskRequest) Reset()
- func (x *SaveUserTaskRequest) String() string
- type SaveUserTaskResponse
- 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() *Workflow
- func (*StoreWorkflowRequest) ProtoMessage()
- func (x *StoreWorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *StoreWorkflowRequest) Reset()
- func (x *StoreWorkflowRequest) String() string
- type StoreWorkflowResponse
- func (*StoreWorkflowResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StoreWorkflowResponse) GetWorkflowId() string
- func (*StoreWorkflowResponse) ProtoMessage()
- func (x *StoreWorkflowResponse) ProtoReflect() protoreflect.Message
- func (x *StoreWorkflowResponse) Reset()
- func (x *StoreWorkflowResponse) String() string
- 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) GetEstimatedMaxDuration() uint64
- func (x *TaskBehaviour) GetGlobal() bool
- func (x *TaskBehaviour) GetMock() bool
- func (x *TaskBehaviour) GetMockBehaviour() *TaskMockBehaviours
- 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() []*TaskError
- 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) GetExtensionData() map[string]string
- func (x *TaskMetadata) GetLabels() []string
- func (x *TaskMetadata) GetServiceTaskSetName() 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 TaskMockBehaviours
- func (*TaskMockBehaviours) Descriptor() ([]byte, []int)deprecated
- func (x *TaskMockBehaviours) GetErrorCodeExpr() string
- func (x *TaskMockBehaviours) GetFatalErrorExpr() string
- func (*TaskMockBehaviours) ProtoMessage()
- func (x *TaskMockBehaviours) ProtoReflect() protoreflect.Message
- func (x *TaskMockBehaviours) Reset()
- func (x *TaskMockBehaviours) 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 TaskPaused
- type TaskResumed
- func (*TaskResumed) Descriptor() ([]byte, []int)deprecated
- func (x *TaskResumed) GetTaskUid() string
- func (x *TaskResumed) GetTimestamp() int64
- func (*TaskResumed) ProtoMessage()
- func (x *TaskResumed) ProtoReflect() protoreflect.Message
- func (x *TaskResumed) Reset()
- func (x *TaskResumed) 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 TaskState
- func (*TaskState) Descriptor() ([]byte, []int)deprecated
- func (x *TaskState) GetId() string
- func (x *TaskState) GetOwner() string
- func (x *TaskState) GetVars() []byte
- func (*TaskState) ProtoMessage()
- func (x *TaskState) ProtoReflect() protoreflect.Message
- func (x *TaskState) Reset()
- func (x *TaskState) String() string
- type TelemetryClients
- 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 TestMessage
- 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 TraversedGatewayPath
- func (*TraversedGatewayPath) Descriptor() ([]byte, []int)deprecated
- func (x *TraversedGatewayPath) GetConvergentGatewayElementId() string
- func (x *TraversedGatewayPath) GetGatewayInstanceId() string
- func (x *TraversedGatewayPath) GetPathId() string
- func (*TraversedGatewayPath) ProtoMessage()
- func (x *TraversedGatewayPath) ProtoReflect() protoreflect.Message
- func (x *TraversedGatewayPath) Reset()
- func (x *TraversedGatewayPath) String() string
- type UserTasks
- type Vars
- type Workflow
- func (*Workflow) Descriptor() ([]byte, []int)deprecated
- func (x *Workflow) GetAutoLaunchHeaders() []byte
- 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 WorkflowErrorSource
- func (WorkflowErrorSource) Descriptor() protoreflect.EnumDescriptor
- func (x WorkflowErrorSource) Enum() *WorkflowErrorSource
- func (WorkflowErrorSource) EnumDescriptor() ([]byte, []int)deprecated
- func (x WorkflowErrorSource) Number() protoreflect.EnumNumber
- func (x WorkflowErrorSource) String() string
- func (WorkflowErrorSource) Type() protoreflect.EnumType
- 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) GetCompensation() *Compensation
- func (x *WorkflowState) GetCondition() string
- func (x *WorkflowState) GetElementId() string
- func (x *WorkflowState) GetElementName() 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) GetGatewayInstancePaths() map[string]*GatewayPaths
- func (x *WorkflowState) GetGroups() []string
- func (x *WorkflowState) GetId() []string
- func (x *WorkflowState) GetIsCompensable() bool
- func (x *WorkflowState) GetOwners() []string
- func (x *WorkflowState) GetPreviousActivity() string
- func (x *WorkflowState) GetPreviousElement() string
- func (x *WorkflowState) GetProcessId() string
- func (x *WorkflowState) GetProcessInstanceId() string
- func (x *WorkflowState) GetState() CancellationState
- func (x *WorkflowState) GetTimer() *WorkflowTimer
- func (x *WorkflowState) GetTraceParent() string
- func (x *WorkflowState) GetTraversedGatewayPaths() map[string]*TraversedGatewayPath
- 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) GetIsExecutionDisabled() bool
- 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", 7: "jobAbort", 8: "jobExecute", 9: "jobComplete", 10: "compensationCheckpoint", } ProcessHistoryType_value = map[string]int32{ "processExecute": 0, "activityExecute": 1, "activityComplete": 2, "processSpawnSync": 3, "processComplete": 4, "processAbort": 5, "activityAbort": 6, "jobAbort": 7, "jobExecute": 8, "jobComplete": 9, "compensationCheckpoint": 10, } )
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", 5: "compensating", } CancellationState_value = map[string]int32{ "executing": 0, "completed": 1, "terminated": 2, "errored": 3, "obsolete": 4, "compensating": 5, } )
Enum value maps for CancellationState.
var ( WorkflowErrorSource_name = map[int32]string{ 0: "processJob", 1: "retryFramework", } WorkflowErrorSource_value = map[string]int32{ "processJob": 0, "retryFramework": 1, } )
Enum value maps for WorkflowErrorSource.
var ( LogSource_name = map[int32]string{ 0: "logSourceEngine", 2: "logSourceWorkflow", 3: "logSourceClient", 4: "logSourceJob", 5: "logSourceTelemetry", } LogSource_value = map[string]int32{ "logSourceEngine": 0, "logSourceWorkflow": 2, "logSourceClient": 3, "logSourceJob": 4, "logSourceTelemetry": 5, } )
Enum value maps for LogSource.
var ( RetryStrategy_name = map[int32]string{ 0: "Linear", 1: "Exponential", } RetryStrategy_value = map[string]int32{ "Linear": 0, "Exponential": 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 ( HandlingStrategy_name = map[int32]string{ 0: "Pause", 1: "TearDown", } HandlingStrategy_value = map[string]int32{ "Pause": 0, "TearDown": 1, } )
Enum value maps for HandlingStrategy.
var ErrVarNotFound = errors.New("variable not found")
ErrVarNotFound is returned when a variable is not found in the provided Vars map.
var File_shar_workflow_models_proto protoreflect.FileDescriptor
Functions ¶
func GetJson ¶ added in v1.1.1692
GetJson retrieves the named variable and marshals it to a json representation
func GetNestedVal ¶ added in v1.1.1687
func GetNestedVal[PT PERMISSABLETYPES](exprEvaluator expression.Engine, pathKey string, vals map[string]any) (PT, error)
GetNestedVal accepts a dot delimited pathKey to traverse a nested data structure and retrieve the value in the field at the end of the pathKey. The path key can also traverse into a specific element of a slice with the sliceField[index] notation
func GetStruct ¶ added in v1.1.1409
func GetStruct[T any](vars *ClientVars, key string) (*T, error)
GetStruct unmarshals a SHAR variable into a struct.
Types ¶
type AbandonUserTaskRequest ¶ added in v1.1.1492
type AbandonUserTaskRequest struct {
// contains filtered or unexported fields
}
func (*AbandonUserTaskRequest) Descriptor
deprecated
added in
v1.1.1492
func (*AbandonUserTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use AbandonUserTaskRequest.ProtoReflect.Descriptor instead.
func (*AbandonUserTaskRequest) ProtoMessage ¶ added in v1.1.1492
func (*AbandonUserTaskRequest) ProtoMessage()
func (*AbandonUserTaskRequest) ProtoReflect ¶ added in v1.1.1492
func (x *AbandonUserTaskRequest) ProtoReflect() protoreflect.Message
func (*AbandonUserTaskRequest) Reset ¶ added in v1.1.1492
func (x *AbandonUserTaskRequest) Reset()
func (*AbandonUserTaskRequest) String ¶ added in v1.1.1492
func (x *AbandonUserTaskRequest) String() string
type AbandonUserTaskResponse ¶ added in v1.1.1492
type AbandonUserTaskResponse struct {
// contains filtered or unexported fields
}
func (*AbandonUserTaskResponse) Descriptor
deprecated
added in
v1.1.1492
func (*AbandonUserTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use AbandonUserTaskResponse.ProtoReflect.Descriptor instead.
func (*AbandonUserTaskResponse) ProtoMessage ¶ added in v1.1.1492
func (*AbandonUserTaskResponse) ProtoMessage()
func (*AbandonUserTaskResponse) ProtoReflect ¶ added in v1.1.1492
func (x *AbandonUserTaskResponse) ProtoReflect() protoreflect.Message
func (*AbandonUserTaskResponse) Reset ¶ added in v1.1.1492
func (x *AbandonUserTaskResponse) Reset()
func (*AbandonUserTaskResponse) String ¶ added in v1.1.1492
func (x *AbandonUserTaskResponse) String() string
type ApiAuthenticationRequest ¶ added in v1.0.362
type ApiAuthenticationRequest struct { Headers map[string]string `` /* 141-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 `` /* 141-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 COMPLEX ¶ added in v1.1.1687
COMPLEX is a type restriction of complex types used in conjunction with Set/GetJson
type CallBehavior ¶ added in v1.1.1921
type CallBehavior struct { SendAllParentVariables bool `protobuf:"varint,1,opt,name=sendAllParentVariables,proto3" json:"sendAllParentVariables,omitempty"` // SendAllParentVariables specifies that parent variables should be sent as-is. ReturnAllChildVariables bool `protobuf:"varint,2,opt,name=returnAllChildVariables,proto3" json:"returnAllChildVariables,omitempty"` // ReturnAllChildVariables specifies that child variables should be returned as-is. // contains filtered or unexported fields }
func (*CallBehavior) Descriptor
deprecated
added in
v1.1.1921
func (*CallBehavior) Descriptor() ([]byte, []int)
Deprecated: Use CallBehavior.ProtoReflect.Descriptor instead.
func (*CallBehavior) GetReturnAllChildVariables ¶ added in v1.1.1921
func (x *CallBehavior) GetReturnAllChildVariables() bool
func (*CallBehavior) GetSendAllParentVariables ¶ added in v1.1.1921
func (x *CallBehavior) GetSendAllParentVariables() bool
func (*CallBehavior) ProtoMessage ¶ added in v1.1.1921
func (*CallBehavior) ProtoMessage()
func (*CallBehavior) ProtoReflect ¶ added in v1.1.1921
func (x *CallBehavior) ProtoReflect() protoreflect.Message
func (*CallBehavior) Reset ¶ added in v1.1.1921
func (x *CallBehavior) Reset()
func (*CallBehavior) String ¶ added in v1.1.1921
func (x *CallBehavior) 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=shar.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 occurred during state machine execution. CancellationState_obsolete CancellationState = 4 // CancellationState_obsolete - this state is obsolete due to an alternate flow. CancellationState_compensating CancellationState = 5 // CancellationState_compensating - this state is currently compensating. )
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. /* 157-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 ClientVars ¶ added in v1.1.1409
type ClientVars struct {
// contains filtered or unexported fields
}
ClientVars holds a map of client-defined variables with string keys and values of workflow variables.
func NewVars ¶ added in v1.1.1409
func NewVars() *ClientVars
NewVars creates and returns a new instance of ClientVars.
func NewVarsFromMap ¶ added in v1.1.1442
func NewVarsFromMap(vars map[string]any) (*ClientVars, error)
NewVarsFromMap creates and returns a new instance of ClientVars populated with the given map of vars.
func (*ClientVars) Decode ¶ added in v1.1.1409
func (vars *ClientVars) Decode(ctx context.Context, b []byte) error
Decode decodes a go binary object containing workflow variables.
func (*ClientVars) Encode ¶ added in v1.1.1409
func (vars *ClientVars) Encode(ctx context.Context) ([]byte, error)
Encode encodes the map of workflow variables into a go binary to be sent across the wire.
func (*ClientVars) GetBool ¶ added in v1.1.1409
func (vars *ClientVars) GetBool(key string) (bool, error)
GetBool validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (*ClientVars) GetBools ¶ added in v1.1.1563
func (vars *ClientVars) GetBools(key string) ([]bool, error)
GetBools validates that a key has an underlying value in the map[string]interface{} vars and safely returns the result.
func (*ClientVars) GetFloat64 ¶ added in v1.1.1409
func (vars *ClientVars) GetFloat64(key string) (float64, error)
GetFloat64 validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (*ClientVars) GetFloat64s ¶ added in v1.1.1563
func (vars *ClientVars) GetFloat64s(key string) ([]float64, error)
GetFloat64s validates that a key has an underlying value in the map[string]interface{} vars and safely returns the result.
func (*ClientVars) GetInt64 ¶ added in v1.1.1409
func (vars *ClientVars) GetInt64(key string) (int64, error)
GetInt64 validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (*ClientVars) GetInt64s ¶ added in v1.1.1563
func (vars *ClientVars) GetInt64s(key string) ([]int64, error)
GetInt64s validates that a key has an underlying value in the map[string]interface{} vars and safely returns the result.
func (*ClientVars) GetJson ¶ added in v1.1.1692
func (vars *ClientVars) GetJson(key string) (string, error)
GetJson returns a json formatted string for the complex data keyed by key
func (*ClientVars) GetNestedBool ¶ added in v1.1.1687
func (vars *ClientVars) GetNestedBool(pathKey string) (bool, error)
GetNestedBool accepts a dot delimited pathKey to traverse a nested data structure and retrieve the value in the field at the end of the pathKey. The path key can also traverse into a specific element of a slice with the sliceField[index] notation
func (*ClientVars) GetNestedFloat64 ¶ added in v1.1.1687
func (vars *ClientVars) GetNestedFloat64(pathKey string) (float64, error)
GetNestedFloat64 accepts a dot delimited pathKey to traverse a nested data structure and retrieve the value in the field at the end of the pathKey. The path key can also traverse into a specific element of a slice with the sliceField[index] notation
func (*ClientVars) GetNestedInt64 ¶ added in v1.1.1687
func (vars *ClientVars) GetNestedInt64(pathKey string) (int64, error)
GetNestedInt64 accepts a dot delimited pathKey to traverse a nested data structure and retrieve the value in the field at the end of the pathKey. The path key can also traverse into a specific element of a slice with the sliceField[index] notation
func (*ClientVars) GetNestedMap ¶ added in v1.1.1687
func (vars *ClientVars) GetNestedMap(pathKey string) (map[string]any, error)
GetNestedMap accepts a dot delimited pathKey to traverse a nested data structure and retrieve the value in the field at the end of the pathKey. The path key can also traverse into a specific element of a slice with the sliceField[index] notation
func (*ClientVars) GetNestedSlice ¶ added in v1.1.1687
func (vars *ClientVars) GetNestedSlice(pathKey string) ([]any, error)
GetNestedSlice accepts a dot delimited pathKey to traverse a nested data structure and retrieve the value in the field at the end of the pathKey. The path key can also traverse into a specific element of a slice with the sliceField[index] notation
func (*ClientVars) GetNestedString ¶ added in v1.1.1687
func (vars *ClientVars) GetNestedString(pathKey string) (string, error)
GetNestedString accepts a dot delimited pathKey to traverse a nested data structure and retrieve the value in the field at the end of the pathKey. The path key can also traverse into a specific element of a slice with the sliceField[index] notation
func (*ClientVars) GetString ¶ added in v1.1.1409
func (vars *ClientVars) GetString(key string) (string, error)
GetString validates that a key has an underlying value in the map[string]interface{} vars and safely returns the result.
func (*ClientVars) GetStrings ¶ added in v1.1.1563
func (vars *ClientVars) GetStrings(key string) ([]string, error)
GetStrings validates that a key has an underlying value in the map[string]interface{} vars and safely returns the result.
func (*ClientVars) Keys ¶ added in v1.1.1409
func (vars *ClientVars) Keys() iter.Seq[string]
Keys returns an iterator sequence of all the keys in the ClientVars map.
func (*ClientVars) Len ¶ added in v1.1.1409
func (vars *ClientVars) Len() int
Len returns the number of key-value pairs in ClientVars.
func (*ClientVars) SetBool ¶ added in v1.1.1409
func (vars *ClientVars) SetBool(key string, value bool)
SetBool sets a boolean value for the specified key in the Vars map.
func (*ClientVars) SetBools ¶ added in v1.1.1563
func (vars *ClientVars) SetBools(key string, value []bool)
SetBools sets a boolean value for the specified key in the Vars map.
func (*ClientVars) SetFloat64 ¶ added in v1.1.1409
func (vars *ClientVars) SetFloat64(key string, value float64)
SetFloat64 sets a float64 value for the specified key in the Vars map.
func (*ClientVars) SetFloat64s ¶ added in v1.1.1563
func (vars *ClientVars) SetFloat64s(key string, value []float64)
SetFloat64s sets a float64 value for the specified key in the Vars map.
func (*ClientVars) SetInt64 ¶ added in v1.1.1409
func (vars *ClientVars) SetInt64(key string, value int64)
SetInt64 sets an int64 value for the specified key in the Vars map.
func (*ClientVars) SetInt64s ¶ added in v1.1.1563
func (vars *ClientVars) SetInt64s(key string, value []int64)
SetInt64s sets an int64 value for the specified key in the Vars map.
func (*ClientVars) SetJson ¶ added in v1.1.1692
func (vars *ClientVars) SetJson(key, jsonObj string) error
SetJson parses the supplied json string into a map[string]any or []any
func (*ClientVars) SetString ¶ added in v1.1.1409
func (vars *ClientVars) SetString(key string, value string)
SetString sets a string value for the specified key in the Vars map.
func (*ClientVars) SetStrings ¶ added in v1.1.1563
func (vars *ClientVars) SetStrings(key string, value []string)
SetStrings sets a string value for the specified key in the Vars map.
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 Compensation ¶ added in v1.1.1099
type Compensation struct { Step int64 `protobuf:"varint,1,opt,name=step,proto3" json:"step,omitempty"` // Step is the currently executing step in a compensation plan TotalSteps int64 `protobuf:"varint,2,opt,name=totalSteps,proto3" json:"totalSteps,omitempty"` // TotalSteps is the total number of steps in the compensation plan. ForTrackingId string `protobuf:"bytes,3,opt,name=forTrackingId,proto3" json:"forTrackingId,omitempty"` // ForTrackingId is the trackingID of the job being compensated. // contains filtered or unexported fields }
func (*Compensation) Descriptor
deprecated
added in
v1.1.1099
func (*Compensation) Descriptor() ([]byte, []int)
Deprecated: Use Compensation.ProtoReflect.Descriptor instead.
func (*Compensation) GetForTrackingId ¶ added in v1.1.1099
func (x *Compensation) GetForTrackingId() string
func (*Compensation) GetStep ¶ added in v1.1.1099
func (x *Compensation) GetStep() int64
func (*Compensation) GetTotalSteps ¶ added in v1.1.1099
func (x *Compensation) GetTotalSteps() int64
func (*Compensation) ProtoMessage ¶ added in v1.1.1099
func (*Compensation) ProtoMessage()
func (*Compensation) ProtoReflect ¶ added in v1.1.1099
func (x *Compensation) ProtoReflect() protoreflect.Message
func (*Compensation) Reset ¶ added in v1.1.1099
func (x *Compensation) Reset()
func (*Compensation) String ¶ added in v1.1.1099
func (x *Compensation) 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"` Compensating bool `protobuf:"varint,3,opt,name=compensating,proto3" json:"compensating,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) GetCompensating ¶ added in v1.1.1099
func (x *CompleteServiceTaskRequest) GetCompensating() bool
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 { Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,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) GetId ¶ added in v1.1.1492
func (x *CompleteUserTaskRequest) GetId() string
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=shar.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. valid-value: shar-variable VariableType string `protobuf:"bytes,3,opt,name=variableType,proto3" json:"variableType,omitempty"` // VariableType - type of the variable for the SetVariableValue action. valid-value: "string", "int", "float", "bool" VariableValue string `protobuf:"bytes,4,opt,name=variableValue,proto3" json:"variableValue,omitempty"` // Variable value to set for the SetVariableValue action. valid-value: arbitrary string representation of a valid value for variableType ErrorCode string `protobuf:"bytes,5,opt,name=errorCode,proto3" json:"errorCode,omitempty"` // ErrorCode for the ThrowWorkflowError action. valid-value: a valid workflow error code for the task. // 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. valid-value: arbitrary positive integer Strategy RetryStrategy `protobuf:"varint,2,opt,name=strategy,proto3,enum=shar.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 for Static, Linear, Incremental. valid-value: positive int IntervalMilli int64 `protobuf:"varint,4,opt,name=intervalMilli,proto3" json:"intervalMilli,omitempty"` // IntervalMilli - delay interval (Linear) amount to add each attempt (Incremental). valid-value: positive int MaxMilli int64 `protobuf:"varint,5,opt,name=maxMilli,proto3" json:"maxMilli,omitempty"` // MaxMilli - delay ceiling (Static, Linear, Incremental). valid-value: positive int 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 DisableWorkflowLaunch ¶ added in v1.1.1484
type DisableWorkflowLaunch struct { Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` WorkflowName string `protobuf:"bytes,2,opt,name=workflowName,proto3" json:"workflowName,omitempty"` // contains filtered or unexported fields }
func (*DisableWorkflowLaunch) Descriptor
deprecated
added in
v1.1.1484
func (*DisableWorkflowLaunch) Descriptor() ([]byte, []int)
Deprecated: Use DisableWorkflowLaunch.ProtoReflect.Descriptor instead.
func (*DisableWorkflowLaunch) GetTimestamp ¶ added in v1.1.1484
func (x *DisableWorkflowLaunch) GetTimestamp() int64
func (*DisableWorkflowLaunch) GetWorkflowName ¶ added in v1.1.1484
func (x *DisableWorkflowLaunch) GetWorkflowName() string
func (*DisableWorkflowLaunch) ProtoMessage ¶ added in v1.1.1484
func (*DisableWorkflowLaunch) ProtoMessage()
func (*DisableWorkflowLaunch) ProtoReflect ¶ added in v1.1.1484
func (x *DisableWorkflowLaunch) ProtoReflect() protoreflect.Message
func (*DisableWorkflowLaunch) Reset ¶ added in v1.1.1484
func (x *DisableWorkflowLaunch) Reset()
func (*DisableWorkflowLaunch) String ¶ added in v1.1.1484
func (x *DisableWorkflowLaunch) String() string
type DisableWorkflowRequest ¶ added in v1.1.1460
type DisableWorkflowRequest struct { WorkflowName string `protobuf:"bytes,1,opt,name=workflowName,proto3" json:"workflowName,omitempty"` // contains filtered or unexported fields }
func (*DisableWorkflowRequest) Descriptor
deprecated
added in
v1.1.1460
func (*DisableWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use DisableWorkflowRequest.ProtoReflect.Descriptor instead.
func (*DisableWorkflowRequest) GetWorkflowName ¶ added in v1.1.1460
func (x *DisableWorkflowRequest) GetWorkflowName() string
func (*DisableWorkflowRequest) ProtoMessage ¶ added in v1.1.1460
func (*DisableWorkflowRequest) ProtoMessage()
func (*DisableWorkflowRequest) ProtoReflect ¶ added in v1.1.1460
func (x *DisableWorkflowRequest) ProtoReflect() protoreflect.Message
func (*DisableWorkflowRequest) Reset ¶ added in v1.1.1460
func (x *DisableWorkflowRequest) Reset()
func (*DisableWorkflowRequest) String ¶ added in v1.1.1460
func (x *DisableWorkflowRequest) String() string
type DisableWorkflowResponse ¶ added in v1.1.1460
type DisableWorkflowResponse struct {
// contains filtered or unexported fields
}
func (*DisableWorkflowResponse) Descriptor
deprecated
added in
v1.1.1460
func (*DisableWorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use DisableWorkflowResponse.ProtoReflect.Descriptor instead.
func (*DisableWorkflowResponse) ProtoMessage ¶ added in v1.1.1460
func (*DisableWorkflowResponse) ProtoMessage()
func (*DisableWorkflowResponse) ProtoReflect ¶ added in v1.1.1460
func (x *DisableWorkflowResponse) ProtoReflect() protoreflect.Message
func (*DisableWorkflowResponse) Reset ¶ added in v1.1.1460
func (x *DisableWorkflowResponse) Reset()
func (*DisableWorkflowResponse) String ¶ added in v1.1.1460
func (x *DisableWorkflowResponse) 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 different 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 CompensateWith *string `protobuf:"bytes,22,opt,name=compensateWith,proto3,oneof" json:"compensateWith,omitempty"` // CompensateWith defines the element used for compensation. 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 machine 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 perform between variable names when calling a state machine task. /* 156-byte string literal not displayed */ OutputTransform map[string]string `` // OutputTransform - a transformation to perform between variable names when exiting a state machine task. /* 158-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. IsForCompensation bool `protobuf:"varint,23,opt,name=isForCompensation,proto3" json:"isForCompensation,omitempty"` // IsForCompensation - this element is used for compensation activities. WithinGateways map[string]string `` // WithinGateways contains the convergentGateway element Ids that this particular element is on a branch of /* 156-byte string literal not displayed */ ServiceTaskSetName *string `protobuf:"bytes,25,opt,name=serviceTaskSetName,proto3,oneof" json:"serviceTaskSetName,omitempty"` // ServiceTaskSetName is the unique identifier for a particular service task set CallBehavior *CallBehavior `protobuf:"bytes,26,opt,name=callBehavior,proto3,oneof" json:"callBehavior,omitempty"` // CallBehavior specifies behaviours of a call // 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) GetCallBehavior ¶ added in v1.1.1921
func (x *Element) GetCallBehavior() *CallBehavior
func (*Element) GetCandidateGroups ¶ added in v0.1.86
func (*Element) GetCandidates ¶ added in v0.1.86
func (*Element) GetCompensateWith ¶ added in v1.1.1099
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) GetIsForCompensation ¶ added in v1.1.1099
func (*Element) GetIteration ¶ added in v1.0.485
func (*Element) GetOutbound ¶
func (*Element) GetOutputTransform ¶ added in v0.1.175
func (*Element) GetRetryBehaviour ¶ added in v1.0.623
func (x *Element) GetRetryBehaviour() *DefaultTaskRetry
func (*Element) GetServiceTaskSetName ¶ added in v1.1.1744
func (*Element) GetTimer ¶ added in v0.1.181
func (x *Element) GetTimer() *WorkflowTimerDefinition
func (*Element) GetVersion ¶ added in v1.0.623
func (*Element) GetWithinGateways ¶ added in v1.1.1687
func (*Element) ProtoMessage ¶
func (*Element) ProtoMessage()
func (*Element) ProtoReflect ¶
func (x *Element) ProtoReflect() protoreflect.Message
type EnableWorkflowLaunch ¶ added in v1.1.1484
type EnableWorkflowLaunch struct { Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` WorkflowName string `protobuf:"bytes,2,opt,name=workflowName,proto3" json:"workflowName,omitempty"` // contains filtered or unexported fields }
func (*EnableWorkflowLaunch) Descriptor
deprecated
added in
v1.1.1484
func (*EnableWorkflowLaunch) Descriptor() ([]byte, []int)
Deprecated: Use EnableWorkflowLaunch.ProtoReflect.Descriptor instead.
func (*EnableWorkflowLaunch) GetTimestamp ¶ added in v1.1.1484
func (x *EnableWorkflowLaunch) GetTimestamp() int64
func (*EnableWorkflowLaunch) GetWorkflowName ¶ added in v1.1.1484
func (x *EnableWorkflowLaunch) GetWorkflowName() string
func (*EnableWorkflowLaunch) ProtoMessage ¶ added in v1.1.1484
func (*EnableWorkflowLaunch) ProtoMessage()
func (*EnableWorkflowLaunch) ProtoReflect ¶ added in v1.1.1484
func (x *EnableWorkflowLaunch) ProtoReflect() protoreflect.Message
func (*EnableWorkflowLaunch) Reset ¶ added in v1.1.1484
func (x *EnableWorkflowLaunch) Reset()
func (*EnableWorkflowLaunch) String ¶ added in v1.1.1484
func (x *EnableWorkflowLaunch) String() string
type EnableWorkflowRequest ¶ added in v1.1.1460
type EnableWorkflowRequest struct { WorkflowName string `protobuf:"bytes,1,opt,name=workflowName,proto3" json:"workflowName,omitempty"` // contains filtered or unexported fields }
func (*EnableWorkflowRequest) Descriptor
deprecated
added in
v1.1.1460
func (*EnableWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use EnableWorkflowRequest.ProtoReflect.Descriptor instead.
func (*EnableWorkflowRequest) GetWorkflowName ¶ added in v1.1.1460
func (x *EnableWorkflowRequest) GetWorkflowName() string
func (*EnableWorkflowRequest) ProtoMessage ¶ added in v1.1.1460
func (*EnableWorkflowRequest) ProtoMessage()
func (*EnableWorkflowRequest) ProtoReflect ¶ added in v1.1.1460
func (x *EnableWorkflowRequest) ProtoReflect() protoreflect.Message
func (*EnableWorkflowRequest) Reset ¶ added in v1.1.1460
func (x *EnableWorkflowRequest) Reset()
func (*EnableWorkflowRequest) String ¶ added in v1.1.1460
func (x *EnableWorkflowRequest) String() string
type EnableWorkflowResponse ¶ added in v1.1.1460
type EnableWorkflowResponse struct {
// contains filtered or unexported fields
}
func (*EnableWorkflowResponse) Descriptor
deprecated
added in
v1.1.1460
func (*EnableWorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use EnableWorkflowResponse.ProtoReflect.Descriptor instead.
func (*EnableWorkflowResponse) ProtoMessage ¶ added in v1.1.1460
func (*EnableWorkflowResponse) ProtoMessage()
func (*EnableWorkflowResponse) ProtoReflect ¶ added in v1.1.1460
func (x *EnableWorkflowResponse) ProtoReflect() protoreflect.Message
func (*EnableWorkflowResponse) Reset ¶ added in v1.1.1460
func (x *EnableWorkflowResponse) Reset()
func (*EnableWorkflowResponse) String ¶ added in v1.1.1460
func (x *EnableWorkflowResponse) String() string
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 /* 145-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 ExecutableStartParameter ¶ added in v1.1.1032
type ExecutableStartParameter struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*ExecutableStartParameter) Descriptor
deprecated
added in
v1.1.1032
func (*ExecutableStartParameter) Descriptor() ([]byte, []int)
Deprecated: Use ExecutableStartParameter.ProtoReflect.Descriptor instead.
func (*ExecutableStartParameter) GetName ¶ added in v1.1.1032
func (x *ExecutableStartParameter) GetName() string
func (*ExecutableStartParameter) ProtoMessage ¶ added in v1.1.1032
func (*ExecutableStartParameter) ProtoMessage()
func (*ExecutableStartParameter) ProtoReflect ¶ added in v1.1.1032
func (x *ExecutableStartParameter) ProtoReflect() protoreflect.Message
func (*ExecutableStartParameter) Reset ¶ added in v1.1.1032
func (x *ExecutableStartParameter) Reset()
func (*ExecutableStartParameter) String ¶ added in v1.1.1032
func (x *ExecutableStartParameter) String() string
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"` // ProcessInstanceId - process instances belonging to this execution. CompletedProcessInstanceId []string `protobuf:"bytes,7,rep,name=completedProcessInstanceId,proto3" json:"completedProcessInstanceId,omitempty"` // CompletedProcessInstanceId - completed process instances belonging to this execution. // 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) GetCompletedProcessInstanceId ¶ added in v1.1.1841
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 FatalError ¶ added in v1.1.1102
type FatalError struct { HandlingStrategy HandlingStrategy `protobuf:"varint,1,opt,name=handlingStrategy,proto3,enum=shar.HandlingStrategy" json:"handlingStrategy,omitempty"` WorkflowState *WorkflowState `protobuf:"bytes,2,opt,name=workflowState,proto3" json:"workflowState,omitempty"` // contains filtered or unexported fields }
func (*FatalError) Descriptor
deprecated
added in
v1.1.1102
func (*FatalError) Descriptor() ([]byte, []int)
Deprecated: Use FatalError.ProtoReflect.Descriptor instead.
func (*FatalError) GetHandlingStrategy ¶ added in v1.1.1102
func (x *FatalError) GetHandlingStrategy() HandlingStrategy
func (*FatalError) GetWorkflowState ¶ added in v1.1.1102
func (x *FatalError) GetWorkflowState() *WorkflowState
func (*FatalError) ProtoMessage ¶ added in v1.1.1102
func (*FatalError) ProtoMessage()
func (*FatalError) ProtoReflect ¶ added in v1.1.1102
func (x *FatalError) ProtoReflect() protoreflect.Message
func (*FatalError) Reset ¶ added in v1.1.1102
func (x *FatalError) Reset()
func (*FatalError) String ¶ added in v1.1.1102
func (x *FatalError) String() string
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. /* 157-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 GatewayPaths ¶ added in v1.1.1687
type GatewayPaths 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 (*GatewayPaths) Descriptor
deprecated
added in
v1.1.1687
func (*GatewayPaths) Descriptor() ([]byte, []int)
Deprecated: Use GatewayPaths.ProtoReflect.Descriptor instead.
func (*GatewayPaths) GetExpectedPaths ¶ added in v1.1.1687
func (x *GatewayPaths) GetExpectedPaths() []string
func (*GatewayPaths) ProtoMessage ¶ added in v1.1.1687
func (*GatewayPaths) ProtoMessage()
func (*GatewayPaths) ProtoReflect ¶ added in v1.1.1687
func (x *GatewayPaths) ProtoReflect() protoreflect.Message
func (*GatewayPaths) Reset ¶ added in v1.1.1687
func (x *GatewayPaths) Reset()
func (*GatewayPaths) String ¶ added in v1.1.1687
func (x *GatewayPaths) String() string
type GatewaySpec ¶ added in v1.0.446
type GatewaySpec struct { Type GatewayType `protobuf:"varint,1,opt,name=type,proto3,enum=shar.GatewayType" json:"type,omitempty"` Direction GatewayDirection `protobuf:"varint,2,opt,name=direction,proto3,enum=shar.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 GetCompensationInputVariablesRequest ¶ added in v1.1.1099
type GetCompensationInputVariablesRequest struct { ProcessInstanceId string `protobuf:"bytes,1,opt,name=processInstanceId,proto3" json:"processInstanceId,omitempty"` TrackingId string `protobuf:"bytes,2,opt,name=trackingId,proto3" json:"trackingId,omitempty"` // contains filtered or unexported fields }
func (*GetCompensationInputVariablesRequest) Descriptor
deprecated
added in
v1.1.1099
func (*GetCompensationInputVariablesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetCompensationInputVariablesRequest.ProtoReflect.Descriptor instead.
func (*GetCompensationInputVariablesRequest) GetProcessInstanceId ¶ added in v1.1.1099
func (x *GetCompensationInputVariablesRequest) GetProcessInstanceId() string
func (*GetCompensationInputVariablesRequest) GetTrackingId ¶ added in v1.1.1099
func (x *GetCompensationInputVariablesRequest) GetTrackingId() string
func (*GetCompensationInputVariablesRequest) ProtoMessage ¶ added in v1.1.1099
func (*GetCompensationInputVariablesRequest) ProtoMessage()
func (*GetCompensationInputVariablesRequest) ProtoReflect ¶ added in v1.1.1099
func (x *GetCompensationInputVariablesRequest) ProtoReflect() protoreflect.Message
func (*GetCompensationInputVariablesRequest) Reset ¶ added in v1.1.1099
func (x *GetCompensationInputVariablesRequest) Reset()
func (*GetCompensationInputVariablesRequest) String ¶ added in v1.1.1099
func (x *GetCompensationInputVariablesRequest) String() string
type GetCompensationInputVariablesResponse ¶ added in v1.1.1099
type GetCompensationInputVariablesResponse struct { Vars []byte `protobuf:"bytes,1,opt,name=vars,proto3" json:"vars,omitempty"` // contains filtered or unexported fields }
func (*GetCompensationInputVariablesResponse) Descriptor
deprecated
added in
v1.1.1099
func (*GetCompensationInputVariablesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetCompensationInputVariablesResponse.ProtoReflect.Descriptor instead.
func (*GetCompensationInputVariablesResponse) GetVars ¶ added in v1.1.1099
func (x *GetCompensationInputVariablesResponse) GetVars() []byte
func (*GetCompensationInputVariablesResponse) ProtoMessage ¶ added in v1.1.1099
func (*GetCompensationInputVariablesResponse) ProtoMessage()
func (*GetCompensationInputVariablesResponse) ProtoReflect ¶ added in v1.1.1099
func (x *GetCompensationInputVariablesResponse) ProtoReflect() protoreflect.Message
func (*GetCompensationInputVariablesResponse) Reset ¶ added in v1.1.1099
func (x *GetCompensationInputVariablesResponse) Reset()
func (*GetCompensationInputVariablesResponse) String ¶ added in v1.1.1099
func (x *GetCompensationInputVariablesResponse) String() string
type GetCompensationOutputVariablesRequest ¶ added in v1.1.1099
type GetCompensationOutputVariablesRequest struct { ProcessInstanceId string `protobuf:"bytes,1,opt,name=processInstanceId,proto3" json:"processInstanceId,omitempty"` TrackingId string `protobuf:"bytes,2,opt,name=trackingId,proto3" json:"trackingId,omitempty"` // contains filtered or unexported fields }
func (*GetCompensationOutputVariablesRequest) Descriptor
deprecated
added in
v1.1.1099
func (*GetCompensationOutputVariablesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetCompensationOutputVariablesRequest.ProtoReflect.Descriptor instead.
func (*GetCompensationOutputVariablesRequest) GetProcessInstanceId ¶ added in v1.1.1099
func (x *GetCompensationOutputVariablesRequest) GetProcessInstanceId() string
func (*GetCompensationOutputVariablesRequest) GetTrackingId ¶ added in v1.1.1099
func (x *GetCompensationOutputVariablesRequest) GetTrackingId() string
func (*GetCompensationOutputVariablesRequest) ProtoMessage ¶ added in v1.1.1099
func (*GetCompensationOutputVariablesRequest) ProtoMessage()
func (*GetCompensationOutputVariablesRequest) ProtoReflect ¶ added in v1.1.1099
func (x *GetCompensationOutputVariablesRequest) ProtoReflect() protoreflect.Message
func (*GetCompensationOutputVariablesRequest) Reset ¶ added in v1.1.1099
func (x *GetCompensationOutputVariablesRequest) Reset()
func (*GetCompensationOutputVariablesRequest) String ¶ added in v1.1.1099
func (x *GetCompensationOutputVariablesRequest) String() string
type GetCompensationOutputVariablesResponse ¶ added in v1.1.1099
type GetCompensationOutputVariablesResponse struct { Vars []byte `protobuf:"bytes,1,opt,name=vars,proto3" json:"vars,omitempty"` // contains filtered or unexported fields }
func (*GetCompensationOutputVariablesResponse) Descriptor
deprecated
added in
v1.1.1099
func (*GetCompensationOutputVariablesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetCompensationOutputVariablesResponse.ProtoReflect.Descriptor instead.
func (*GetCompensationOutputVariablesResponse) GetVars ¶ added in v1.1.1099
func (x *GetCompensationOutputVariablesResponse) GetVars() []byte
func (*GetCompensationOutputVariablesResponse) ProtoMessage ¶ added in v1.1.1099
func (*GetCompensationOutputVariablesResponse) ProtoMessage()
func (*GetCompensationOutputVariablesResponse) ProtoReflect ¶ added in v1.1.1099
func (x *GetCompensationOutputVariablesResponse) ProtoReflect() protoreflect.Message
func (*GetCompensationOutputVariablesResponse) Reset ¶ added in v1.1.1099
func (x *GetCompensationOutputVariablesResponse) Reset()
func (*GetCompensationOutputVariablesResponse) String ¶ added in v1.1.1099
func (x *GetCompensationOutputVariablesResponse) String() string
type GetFatalErrorRequest ¶ added in v1.1.1377
type GetFatalErrorRequest struct { WfName string `protobuf:"bytes,1,opt,name=wfName,proto3" json:"wfName,omitempty"` WfId string `protobuf:"bytes,2,opt,name=wfId,proto3" json:"wfId,omitempty"` ExecutionId string `protobuf:"bytes,3,opt,name=executionId,proto3" json:"executionId,omitempty"` ProcessInstanceId string `protobuf:"bytes,4,opt,name=processInstanceId,proto3" json:"processInstanceId,omitempty"` // contains filtered or unexported fields }
func (*GetFatalErrorRequest) Descriptor
deprecated
added in
v1.1.1377
func (*GetFatalErrorRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetFatalErrorRequest.ProtoReflect.Descriptor instead.
func (*GetFatalErrorRequest) GetExecutionId ¶ added in v1.1.1377
func (x *GetFatalErrorRequest) GetExecutionId() string
func (*GetFatalErrorRequest) GetProcessInstanceId ¶ added in v1.1.1377
func (x *GetFatalErrorRequest) GetProcessInstanceId() string
func (*GetFatalErrorRequest) GetWfId ¶ added in v1.1.1377
func (x *GetFatalErrorRequest) GetWfId() string
func (*GetFatalErrorRequest) GetWfName ¶ added in v1.1.1377
func (x *GetFatalErrorRequest) GetWfName() string
func (*GetFatalErrorRequest) ProtoMessage ¶ added in v1.1.1377
func (*GetFatalErrorRequest) ProtoMessage()
func (*GetFatalErrorRequest) ProtoReflect ¶ added in v1.1.1377
func (x *GetFatalErrorRequest) ProtoReflect() protoreflect.Message
func (*GetFatalErrorRequest) Reset ¶ added in v1.1.1377
func (x *GetFatalErrorRequest) Reset()
func (*GetFatalErrorRequest) String ¶ added in v1.1.1377
func (x *GetFatalErrorRequest) String() string
type GetJobRequest ¶ added in v1.1.797
type GetJobRequest struct { JobId string `protobuf:"bytes,1,opt,name=jobId,proto3" json:"jobId,omitempty"` // contains filtered or unexported fields }
func (*GetJobRequest) Descriptor
deprecated
added in
v1.1.797
func (*GetJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.
func (*GetJobRequest) GetJobId ¶ added in v1.1.797
func (x *GetJobRequest) GetJobId() string
func (*GetJobRequest) ProtoMessage ¶ added in v1.1.797
func (*GetJobRequest) ProtoMessage()
func (*GetJobRequest) ProtoReflect ¶ added in v1.1.797
func (x *GetJobRequest) ProtoReflect() protoreflect.Message
func (*GetJobRequest) Reset ¶ added in v1.1.797
func (x *GetJobRequest) Reset()
func (*GetJobRequest) String ¶ added in v1.1.797
func (x *GetJobRequest) String() string
type GetJobResponse ¶ added in v1.1.797
type GetJobResponse struct { Job *WorkflowState `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` // contains filtered or unexported fields }
func (*GetJobResponse) Descriptor
deprecated
added in
v1.1.797
func (*GetJobResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetJobResponse.ProtoReflect.Descriptor instead.
func (*GetJobResponse) GetJob ¶ added in v1.1.797
func (x *GetJobResponse) GetJob() *WorkflowState
func (*GetJobResponse) ProtoMessage ¶ added in v1.1.797
func (*GetJobResponse) ProtoMessage()
func (*GetJobResponse) ProtoReflect ¶ added in v1.1.797
func (x *GetJobResponse) ProtoReflect() protoreflect.Message
func (*GetJobResponse) Reset ¶ added in v1.1.797
func (x *GetJobResponse) Reset()
func (*GetJobResponse) String ¶ added in v1.1.797
func (x *GetJobResponse) String() string
type GetProcessHeadersRequest ¶ added in v1.1.1323
type GetProcessHeadersRequest struct { ProcessInstanceID string `protobuf:"bytes,1,opt,name=processInstanceID,proto3" json:"processInstanceID,omitempty"` // contains filtered or unexported fields }
func (*GetProcessHeadersRequest) Descriptor
deprecated
added in
v1.1.1323
func (*GetProcessHeadersRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetProcessHeadersRequest.ProtoReflect.Descriptor instead.
func (*GetProcessHeadersRequest) GetProcessInstanceID ¶ added in v1.1.1323
func (x *GetProcessHeadersRequest) GetProcessInstanceID() string
func (*GetProcessHeadersRequest) ProtoMessage ¶ added in v1.1.1323
func (*GetProcessHeadersRequest) ProtoMessage()
func (*GetProcessHeadersRequest) ProtoReflect ¶ added in v1.1.1323
func (x *GetProcessHeadersRequest) ProtoReflect() protoreflect.Message
func (*GetProcessHeadersRequest) Reset ¶ added in v1.1.1323
func (x *GetProcessHeadersRequest) Reset()
func (*GetProcessHeadersRequest) String ¶ added in v1.1.1323
func (x *GetProcessHeadersRequest) String() string
type GetProcessHeadersResponse ¶ added in v1.1.1323
type GetProcessHeadersResponse struct { Headers map[string]string `` /* 141-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetProcessHeadersResponse) Descriptor
deprecated
added in
v1.1.1323
func (*GetProcessHeadersResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetProcessHeadersResponse.ProtoReflect.Descriptor instead.
func (*GetProcessHeadersResponse) GetHeaders ¶ added in v1.1.1323
func (x *GetProcessHeadersResponse) GetHeaders() map[string]string
func (*GetProcessHeadersResponse) ProtoMessage ¶ added in v1.1.1323
func (*GetProcessHeadersResponse) ProtoMessage()
func (*GetProcessHeadersResponse) ProtoReflect ¶ added in v1.1.1323
func (x *GetProcessHeadersResponse) ProtoReflect() protoreflect.Message
func (*GetProcessHeadersResponse) Reset ¶ added in v1.1.1323
func (x *GetProcessHeadersResponse) Reset()
func (*GetProcessHeadersResponse) String ¶ added in v1.1.1323
func (x *GetProcessHeadersResponse) String() string
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 execution. // 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"` Source WorkflowErrorSource `protobuf:"varint,5,opt,name=source,proto3,enum=shar.WorkflowErrorSource" json:"source,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) GetSource ¶ added in v1.1.1921
func (x *HandleWorkflowErrorRequest) GetSource() WorkflowErrorSource
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 HandleWorkflowFatalErrorRequest ¶ added in v1.1.1102
type HandleWorkflowFatalErrorRequest struct { WorkflowState *WorkflowState `protobuf:"bytes,1,opt,name=workflowState,proto3" json:"workflowState,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` HandlingStrategy HandlingStrategy `protobuf:"varint,3,opt,name=handlingStrategy,proto3,enum=shar.HandlingStrategy" json:"handlingStrategy,omitempty"` // contains filtered or unexported fields }
func (*HandleWorkflowFatalErrorRequest) Descriptor
deprecated
added in
v1.1.1102
func (*HandleWorkflowFatalErrorRequest) Descriptor() ([]byte, []int)
Deprecated: Use HandleWorkflowFatalErrorRequest.ProtoReflect.Descriptor instead.
func (*HandleWorkflowFatalErrorRequest) GetHandlingStrategy ¶ added in v1.1.1377
func (x *HandleWorkflowFatalErrorRequest) GetHandlingStrategy() HandlingStrategy
func (*HandleWorkflowFatalErrorRequest) GetMessage ¶ added in v1.1.1102
func (x *HandleWorkflowFatalErrorRequest) GetMessage() string
func (*HandleWorkflowFatalErrorRequest) GetWorkflowState ¶ added in v1.1.1102
func (x *HandleWorkflowFatalErrorRequest) GetWorkflowState() *WorkflowState
func (*HandleWorkflowFatalErrorRequest) ProtoMessage ¶ added in v1.1.1102
func (*HandleWorkflowFatalErrorRequest) ProtoMessage()
func (*HandleWorkflowFatalErrorRequest) ProtoReflect ¶ added in v1.1.1102
func (x *HandleWorkflowFatalErrorRequest) ProtoReflect() protoreflect.Message
func (*HandleWorkflowFatalErrorRequest) Reset ¶ added in v1.1.1102
func (x *HandleWorkflowFatalErrorRequest) Reset()
func (*HandleWorkflowFatalErrorRequest) String ¶ added in v1.1.1102
func (x *HandleWorkflowFatalErrorRequest) String() string
type HandleWorkflowFatalErrorResponse ¶ added in v1.1.1102
type HandleWorkflowFatalErrorResponse struct { Handled bool `protobuf:"varint,1,opt,name=handled,proto3" json:"handled,omitempty"` // contains filtered or unexported fields }
func (*HandleWorkflowFatalErrorResponse) Descriptor
deprecated
added in
v1.1.1102
func (*HandleWorkflowFatalErrorResponse) Descriptor() ([]byte, []int)
Deprecated: Use HandleWorkflowFatalErrorResponse.ProtoReflect.Descriptor instead.
func (*HandleWorkflowFatalErrorResponse) GetHandled ¶ added in v1.1.1102
func (x *HandleWorkflowFatalErrorResponse) GetHandled() bool
func (*HandleWorkflowFatalErrorResponse) ProtoMessage ¶ added in v1.1.1102
func (*HandleWorkflowFatalErrorResponse) ProtoMessage()
func (*HandleWorkflowFatalErrorResponse) ProtoReflect ¶ added in v1.1.1102
func (x *HandleWorkflowFatalErrorResponse) ProtoReflect() protoreflect.Message
func (*HandleWorkflowFatalErrorResponse) Reset ¶ added in v1.1.1102
func (x *HandleWorkflowFatalErrorResponse) Reset()
func (*HandleWorkflowFatalErrorResponse) String ¶ added in v1.1.1102
func (x *HandleWorkflowFatalErrorResponse) String() string
type HandlingStrategy ¶ added in v1.1.1102
type HandlingStrategy int32
const ( HandlingStrategy_Pause HandlingStrategy = 0 HandlingStrategy_TearDown HandlingStrategy = 1 )
func (HandlingStrategy) Descriptor ¶ added in v1.1.1102
func (HandlingStrategy) Descriptor() protoreflect.EnumDescriptor
func (HandlingStrategy) Enum ¶ added in v1.1.1102
func (x HandlingStrategy) Enum() *HandlingStrategy
func (HandlingStrategy) EnumDescriptor
deprecated
added in
v1.1.1102
func (HandlingStrategy) EnumDescriptor() ([]byte, []int)
Deprecated: Use HandlingStrategy.Descriptor instead.
func (HandlingStrategy) Number ¶ added in v1.1.1102
func (x HandlingStrategy) Number() protoreflect.EnumNumber
func (HandlingStrategy) String ¶ added in v1.1.1102
func (x HandlingStrategy) String() string
func (HandlingStrategy) Type ¶ added in v1.1.1102
func (HandlingStrategy) Type() protoreflect.EnumType
type HeartbeatRequest ¶ added in v1.1.731
type HeartbeatRequest struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Time int64 `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*HeartbeatRequest) Descriptor
deprecated
added in
v1.1.731
func (*HeartbeatRequest) Descriptor() ([]byte, []int)
Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.
func (*HeartbeatRequest) GetHost ¶ added in v1.1.731
func (x *HeartbeatRequest) GetHost() string
func (*HeartbeatRequest) GetId ¶ added in v1.1.731
func (x *HeartbeatRequest) GetId() string
func (*HeartbeatRequest) GetTime ¶ added in v1.1.731
func (x *HeartbeatRequest) GetTime() int64
func (*HeartbeatRequest) ProtoMessage ¶ added in v1.1.731
func (*HeartbeatRequest) ProtoMessage()
func (*HeartbeatRequest) ProtoReflect ¶ added in v1.1.731
func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message
func (*HeartbeatRequest) Reset ¶ added in v1.1.731
func (x *HeartbeatRequest) Reset()
func (*HeartbeatRequest) String ¶ added in v1.1.731
func (x *HeartbeatRequest) String() string
type HeartbeatResponse ¶ added in v1.1.731
type HeartbeatResponse struct {
// contains filtered or unexported fields
}
func (*HeartbeatResponse) Descriptor
deprecated
added in
v1.1.731
func (*HeartbeatResponse) Descriptor() ([]byte, []int)
Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.
func (*HeartbeatResponse) ProtoMessage ¶ added in v1.1.731
func (*HeartbeatResponse) ProtoMessage()
func (*HeartbeatResponse) ProtoReflect ¶ added in v1.1.731
func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message
func (*HeartbeatResponse) Reset ¶ added in v1.1.731
func (x *HeartbeatResponse) Reset()
func (*HeartbeatResponse) String ¶ added in v1.1.731
func (x *HeartbeatResponse) 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=shar.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 { ProcessId string `protobuf:"bytes,1,opt,name=processId,proto3" json:"processId,omitempty"` Vars []byte `protobuf:"bytes,2,opt,name=vars,proto3" json:"vars,omitempty"` Headers []byte `protobuf:"bytes,3,opt,name=headers,proto3" json:"headers,omitempty"` // contains filtered or unexported fields }
func (*LaunchWorkflowRequest) Descriptor
deprecated
func (*LaunchWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use LaunchWorkflowRequest.ProtoReflect.Descriptor instead.
func (*LaunchWorkflowRequest) GetHeaders ¶ added in v1.1.1323
func (x *LaunchWorkflowRequest) GetHeaders() []byte
func (*LaunchWorkflowRequest) GetProcessId ¶ added in v1.1.991
func (x *LaunchWorkflowRequest) GetProcessId() 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 { 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 (*LaunchWorkflowResponse) Descriptor
deprecated
added in
v1.0.366
func (*LaunchWorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use LaunchWorkflowResponse.ProtoReflect.Descriptor instead.
func (*LaunchWorkflowResponse) GetExecutionId ¶ added in v1.1.991
func (x *LaunchWorkflowResponse) GetExecutionId() 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 ListExecutableProcessesItem ¶ added in v1.1.1032
type ListExecutableProcessesItem struct { ProcessId string `protobuf:"bytes,1,opt,name=processId,proto3" json:"processId,omitempty"` WorkflowName string `protobuf:"bytes,2,opt,name=workflowName,proto3" json:"workflowName,omitempty"` Parameter []*ExecutableStartParameter `protobuf:"bytes,3,rep,name=parameter,proto3" json:"parameter,omitempty"` // contains filtered or unexported fields }
func (*ListExecutableProcessesItem) Descriptor
deprecated
added in
v1.1.1032
func (*ListExecutableProcessesItem) Descriptor() ([]byte, []int)
Deprecated: Use ListExecutableProcessesItem.ProtoReflect.Descriptor instead.
func (*ListExecutableProcessesItem) GetParameter ¶ added in v1.1.1032
func (x *ListExecutableProcessesItem) GetParameter() []*ExecutableStartParameter
func (*ListExecutableProcessesItem) GetProcessId ¶ added in v1.1.1212
func (x *ListExecutableProcessesItem) GetProcessId() string
func (*ListExecutableProcessesItem) GetWorkflowName ¶ added in v1.1.1032
func (x *ListExecutableProcessesItem) GetWorkflowName() string
func (*ListExecutableProcessesItem) ProtoMessage ¶ added in v1.1.1032
func (*ListExecutableProcessesItem) ProtoMessage()
func (*ListExecutableProcessesItem) ProtoReflect ¶ added in v1.1.1032
func (x *ListExecutableProcessesItem) ProtoReflect() protoreflect.Message
func (*ListExecutableProcessesItem) Reset ¶ added in v1.1.1032
func (x *ListExecutableProcessesItem) Reset()
func (*ListExecutableProcessesItem) String ¶ added in v1.1.1032
func (x *ListExecutableProcessesItem) String() string
type ListExecutableProcessesRequest ¶ added in v1.1.1032
type ListExecutableProcessesRequest struct {
// contains filtered or unexported fields
}
func (*ListExecutableProcessesRequest) Descriptor
deprecated
added in
v1.1.1032
func (*ListExecutableProcessesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListExecutableProcessesRequest.ProtoReflect.Descriptor instead.
func (*ListExecutableProcessesRequest) ProtoMessage ¶ added in v1.1.1032
func (*ListExecutableProcessesRequest) ProtoMessage()
func (*ListExecutableProcessesRequest) ProtoReflect ¶ added in v1.1.1032
func (x *ListExecutableProcessesRequest) ProtoReflect() protoreflect.Message
func (*ListExecutableProcessesRequest) Reset ¶ added in v1.1.1032
func (x *ListExecutableProcessesRequest) Reset()
func (*ListExecutableProcessesRequest) String ¶ added in v1.1.1032
func (x *ListExecutableProcessesRequest) 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 execution. // 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"` Group string `protobuf:"bytes,2,opt,name=group,proto3" json:"group,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) GetGroup ¶ added in v1.1.1492
func (x *ListUserTasksRequest) GetGroup() string
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 { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` SpecUid string `protobuf:"bytes,2,opt,name=specUid,proto3" json:"specUid,omitempty"` State []byte `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"` LockedBy string `protobuf:"bytes,4,opt,name=lockedBy,proto3" json:"lockedBy,omitempty"` // 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) GetId ¶ added in v1.1.1492
func (x *ListUserTasksResponse) GetId() string
func (*ListUserTasksResponse) GetLockedBy ¶ added in v1.1.1492
func (x *ListUserTasksResponse) GetLockedBy() string
func (*ListUserTasksResponse) GetSpecUid ¶ added in v1.1.1492
func (x *ListUserTasksResponse) GetSpecUid() string
func (*ListUserTasksResponse) GetState ¶ added in v1.1.1492
func (x *ListUserTasksResponse) GetState() []byte
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 LogRequest ¶ added in v1.1.754
type LogRequest struct { Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"` ClientId string `protobuf:"bytes,2,opt,name=clientId,proto3" json:"clientId,omitempty"` TrackingId []byte `protobuf:"bytes,3,opt,name=trackingId,proto3" json:"trackingId,omitempty"` Level int64 `protobuf:"varint,4,opt,name=level,proto3" json:"level,omitempty"` Time int64 `protobuf:"varint,5,opt,name=time,proto3" json:"time,omitempty"` Source LogSource `protobuf:"varint,6,opt,name=source,proto3,enum=shar.LogSource" json:"source,omitempty"` Message string `protobuf:"bytes,7,opt,name=message,proto3" json:"message,omitempty"` Attributes map[string]string `` /* 147-byte string literal not displayed */ // contains filtered or unexported fields }
func (*LogRequest) Descriptor
deprecated
added in
v1.1.754
func (*LogRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogRequest.ProtoReflect.Descriptor instead.
func (*LogRequest) GetAttributes ¶ added in v1.1.754
func (x *LogRequest) GetAttributes() map[string]string
func (*LogRequest) GetClientId ¶ added in v1.1.754
func (x *LogRequest) GetClientId() string
func (*LogRequest) GetHostname ¶ added in v1.1.754
func (x *LogRequest) GetHostname() string
func (*LogRequest) GetLevel ¶ added in v1.1.754
func (x *LogRequest) GetLevel() int64
func (*LogRequest) GetMessage ¶ added in v1.1.754
func (x *LogRequest) GetMessage() string
func (*LogRequest) GetSource ¶ added in v1.1.754
func (x *LogRequest) GetSource() LogSource
func (*LogRequest) GetTime ¶ added in v1.1.754
func (x *LogRequest) GetTime() int64
func (*LogRequest) GetTrackingId ¶ added in v1.1.754
func (x *LogRequest) GetTrackingId() []byte
func (*LogRequest) ProtoMessage ¶ added in v1.1.754
func (*LogRequest) ProtoMessage()
func (*LogRequest) ProtoReflect ¶ added in v1.1.754
func (x *LogRequest) ProtoReflect() protoreflect.Message
func (*LogRequest) Reset ¶ added in v1.1.754
func (x *LogRequest) Reset()
func (*LogRequest) String ¶ added in v1.1.754
func (x *LogRequest) String() string
type LogResponse ¶ added in v1.1.754
type LogResponse struct {
// contains filtered or unexported fields
}
func (*LogResponse) Descriptor
deprecated
added in
v1.1.754
func (*LogResponse) Descriptor() ([]byte, []int)
Deprecated: Use LogResponse.ProtoReflect.Descriptor instead.
func (*LogResponse) ProtoMessage ¶ added in v1.1.754
func (*LogResponse) ProtoMessage()
func (*LogResponse) ProtoReflect ¶ added in v1.1.754
func (x *LogResponse) ProtoReflect() protoreflect.Message
func (*LogResponse) Reset ¶ added in v1.1.754
func (x *LogResponse) Reset()
func (*LogResponse) String ¶ added in v1.1.754
func (x *LogResponse) 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"` // Name - Message name for a workflow message. valid-value: arbitrary string CorrelationKey string `protobuf:"bytes,2,opt,name=correlationKey,proto3" json:"correlationKey,omitempty"` // CorrelationKey - the workflow message correlation key. valid-value: NATS-safe identifier Short string `protobuf:"bytes,3,opt,name=short,proto3" json:"short,omitempty"` // Short description of the parameter. valid-value: arbitrary string Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` // Description - a long description of the parameter. valid-value: arbitrary string // 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 intermediate 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=shar.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 OpenUserTaskRequest ¶ added in v1.1.1492
type OpenUserTaskRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*OpenUserTaskRequest) Descriptor
deprecated
added in
v1.1.1492
func (*OpenUserTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use OpenUserTaskRequest.ProtoReflect.Descriptor instead.
func (*OpenUserTaskRequest) GetId ¶ added in v1.1.1492
func (x *OpenUserTaskRequest) GetId() string
func (*OpenUserTaskRequest) ProtoMessage ¶ added in v1.1.1492
func (*OpenUserTaskRequest) ProtoMessage()
func (*OpenUserTaskRequest) ProtoReflect ¶ added in v1.1.1492
func (x *OpenUserTaskRequest) ProtoReflect() protoreflect.Message
func (*OpenUserTaskRequest) Reset ¶ added in v1.1.1492
func (x *OpenUserTaskRequest) Reset()
func (*OpenUserTaskRequest) String ¶ added in v1.1.1492
func (x *OpenUserTaskRequest) String() string
type OpenUserTaskResponse ¶ added in v1.1.1492
type OpenUserTaskResponse struct { State []byte `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"` // contains filtered or unexported fields }
func (*OpenUserTaskResponse) Descriptor
deprecated
added in
v1.1.1492
func (*OpenUserTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use OpenUserTaskResponse.ProtoReflect.Descriptor instead.
func (*OpenUserTaskResponse) GetState ¶ added in v1.1.1492
func (x *OpenUserTaskResponse) GetState() []byte
func (*OpenUserTaskResponse) ProtoMessage ¶ added in v1.1.1492
func (*OpenUserTaskResponse) ProtoMessage()
func (*OpenUserTaskResponse) ProtoReflect ¶ added in v1.1.1492
func (x *OpenUserTaskResponse) ProtoReflect() protoreflect.Message
func (*OpenUserTaskResponse) Reset ¶ added in v1.1.1492
func (x *OpenUserTaskResponse) Reset()
func (*OpenUserTaskResponse) String ¶ added in v1.1.1492
func (x *OpenUserTaskResponse) String() string
type PERMISSABLETYPES ¶ added in v1.1.1687
PERMISSABLETYPES defines what the allowable types of data are in complex nested data
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. valid-value: arbitrary string Short string `protobuf:"bytes,2,opt,name=short,proto3" json:"short,omitempty"` // Short description of the parameter. valid-value: arbitrary string Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` // Description - a long description of the parameter. valid-value: arbitrary string Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"` // Type of the parameter. valid-value: "string", "int", "float", "bool", "complex" CustomTypeExtension *string `protobuf:"bytes,5,opt,name=customTypeExtension,proto3,oneof" json:"customTypeExtension,omitempty"` // Subtype describing the use of the type. valid-value: eg. "IPAddress" Collection bool `protobuf:"varint,6,opt,name=collection,proto3" json:"collection,omitempty"` // Collection specifies the parameter is an array. valid-value: bool Group *string `protobuf:"bytes,7,opt,name=group,proto3,oneof" json:"group,omitempty"` // Group declares this parameter as part of a named parameter group. valid-value: parameter group name. ExtensionData map[string]string `` // ExtensionData - a map of values that can be used by third party tools. valid-value: arbitrary map of string/string /* 153-byte string literal not displayed */ Mandatory bool `protobuf:"varint,9,opt,name=mandatory,proto3" json:"mandatory,omitempty"` // Mandatory specifies that this parameter is required. valid-value: bool ValidateExpr string `protobuf:"bytes,10,opt,name=validateExpr,proto3" json:"validateExpr,omitempty"` // ValidateExpr - an EXPR that is used to validate the field value. valid-value: a valid EXPR expression prefixed by'=' 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. valid-value: a valid EXPR expression prefixed by'=' // 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. valid-value: arbitrary string Short string `protobuf:"bytes,2,opt,name=short,proto3" json:"short,omitempty"` // Short description of the parameter group. valid-value: arbitrary string Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` // Description - a long description of the parameter group. valid-value: arbitrary string // 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 PauseServiceTaskRequest ¶ added in v1.1.1796
type PauseServiceTaskRequest struct { Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"` // contains filtered or unexported fields }
func (*PauseServiceTaskRequest) Descriptor
deprecated
added in
v1.1.1796
func (*PauseServiceTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use PauseServiceTaskRequest.ProtoReflect.Descriptor instead.
func (*PauseServiceTaskRequest) GetUid ¶ added in v1.1.1796
func (x *PauseServiceTaskRequest) GetUid() string
func (*PauseServiceTaskRequest) ProtoMessage ¶ added in v1.1.1796
func (*PauseServiceTaskRequest) ProtoMessage()
func (*PauseServiceTaskRequest) ProtoReflect ¶ added in v1.1.1796
func (x *PauseServiceTaskRequest) ProtoReflect() protoreflect.Message
func (*PauseServiceTaskRequest) Reset ¶ added in v1.1.1796
func (x *PauseServiceTaskRequest) Reset()
func (*PauseServiceTaskRequest) String ¶ added in v1.1.1796
func (x *PauseServiceTaskRequest) String() string
type PauseServiceTaskResponse ¶ added in v1.1.1796
type PauseServiceTaskResponse struct {
// contains filtered or unexported fields
}
func (*PauseServiceTaskResponse) Descriptor
deprecated
added in
v1.1.1796
func (*PauseServiceTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use PauseServiceTaskResponse.ProtoReflect.Descriptor instead.
func (*PauseServiceTaskResponse) ProtoMessage ¶ added in v1.1.1796
func (*PauseServiceTaskResponse) ProtoMessage()
func (*PauseServiceTaskResponse) ProtoReflect ¶ added in v1.1.1796
func (x *PauseServiceTaskResponse) ProtoReflect() protoreflect.Message
func (*PauseServiceTaskResponse) Reset ¶ added in v1.1.1796
func (x *PauseServiceTaskResponse) Reset()
func (*PauseServiceTaskResponse) String ¶ added in v1.1.1796
func (x *PauseServiceTaskResponse) 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. Id string `protobuf:"bytes,2,opt,name=Id,proto3" json:"Id,omitempty"` // Id - the id of the process . Metadata *Metadata `protobuf:"bytes,6,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"` // Metadata created by SHAR to describe process behavior. SubProcess bool `protobuf:"varint,7,opt,name=subProcess,proto3" json:"subProcess,omitempty"` // SubProcess flag identifies sub-processes and prevents direct launch. Executable bool `protobuf:"varint,8,opt,name=executable,proto3" json:"executable,omitempty"` // Executable flag indicates that this process can be started by the engine. // contains filtered or unexported fields }
Process describes a single workflow state machine.
func (*Process) Descriptor
deprecated
func (*Process) GetElements ¶
func (*Process) GetExecutable ¶ added in v1.1.1921
func (*Process) GetMetadata ¶ added in v1.0.427
func (*Process) GetSubProcess ¶ added in v1.1.1921
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=shar.ProcessHistoryType" json:"itemType,omitempty"` WorkflowState *WorkflowState `protobuf:"bytes,2,opt,name=workflowState,proto3" json:"workflowState,omitempty"` Compensating bool `protobuf:"varint,3,opt,name=compensating,proto3" json:"compensating,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) GetCompensating ¶ added in v1.1.1099
func (x *ProcessHistoryEntry) GetCompensating() bool
func (*ProcessHistoryEntry) GetItemType ¶ added in v1.0.477
func (x *ProcessHistoryEntry) GetItemType() ProcessHistoryType
func (*ProcessHistoryEntry) GetWorkflowState ¶ added in v1.1.1547
func (x *ProcessHistoryEntry) GetWorkflowState() *WorkflowState
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 ProcessHistoryType_jobAbort ProcessHistoryType = 7 ProcessHistoryType_jobExecute ProcessHistoryType = 8 ProcessHistoryType_jobComplete ProcessHistoryType = 9 ProcessHistoryType_compensationCheckpoint ProcessHistoryType = 10 )
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 execution 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. ProcessId string `protobuf:"bytes,7,opt,name=processId,proto3" json:"processId,omitempty"` // ProcessId - id of this process to avoid lookups. GatewayComplete map[string]bool `` // GatewayComplete - completed gateway instances register /* 158-byte string literal not displayed */ Headers []byte `protobuf:"bytes,9,opt,name=headers,proto3" json:"headers,omitempty"` // 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) GetHeaders ¶ added in v1.1.1323
func (x *ProcessInstance) GetHeaders() []byte
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) GetProcessId ¶ added in v1.1.1212
func (x *ProcessInstance) GetProcessId() string
func (*ProcessInstance) GetProcessInstanceId ¶ added in v1.0.427
func (x *ProcessInstance) GetProcessInstanceId() 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 ResolveWorkflowRequest ¶ added in v1.1.927
type ResolveWorkflowRequest struct { Workflow *Workflow `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"` // contains filtered or unexported fields }
func (*ResolveWorkflowRequest) Descriptor
deprecated
added in
v1.1.927
func (*ResolveWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResolveWorkflowRequest.ProtoReflect.Descriptor instead.
func (*ResolveWorkflowRequest) GetWorkflow ¶ added in v1.1.927
func (x *ResolveWorkflowRequest) GetWorkflow() *Workflow
func (*ResolveWorkflowRequest) ProtoMessage ¶ added in v1.1.927
func (*ResolveWorkflowRequest) ProtoMessage()
func (*ResolveWorkflowRequest) ProtoReflect ¶ added in v1.1.927
func (x *ResolveWorkflowRequest) ProtoReflect() protoreflect.Message
func (*ResolveWorkflowRequest) Reset ¶ added in v1.1.927
func (x *ResolveWorkflowRequest) Reset()
func (*ResolveWorkflowRequest) String ¶ added in v1.1.927
func (x *ResolveWorkflowRequest) String() string
type ResolveWorkflowResponse ¶ added in v1.1.927
type ResolveWorkflowResponse struct { Workflow *Workflow `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"` // contains filtered or unexported fields }
func (*ResolveWorkflowResponse) Descriptor
deprecated
added in
v1.1.927
func (*ResolveWorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use ResolveWorkflowResponse.ProtoReflect.Descriptor instead.
func (*ResolveWorkflowResponse) GetWorkflow ¶ added in v1.1.927
func (x *ResolveWorkflowResponse) GetWorkflow() *Workflow
func (*ResolveWorkflowResponse) ProtoMessage ¶ added in v1.1.927
func (*ResolveWorkflowResponse) ProtoMessage()
func (*ResolveWorkflowResponse) ProtoReflect ¶ added in v1.1.927
func (x *ResolveWorkflowResponse) ProtoReflect() protoreflect.Message
func (*ResolveWorkflowResponse) Reset ¶ added in v1.1.927
func (x *ResolveWorkflowResponse) Reset()
func (*ResolveWorkflowResponse) String ¶ added in v1.1.927
func (x *ResolveWorkflowResponse) String() string
type ResumeServiceTaskRequest ¶ added in v1.1.1796
type ResumeServiceTaskRequest struct { Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"` // contains filtered or unexported fields }
func (*ResumeServiceTaskRequest) Descriptor
deprecated
added in
v1.1.1796
func (*ResumeServiceTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResumeServiceTaskRequest.ProtoReflect.Descriptor instead.
func (*ResumeServiceTaskRequest) GetUid ¶ added in v1.1.1796
func (x *ResumeServiceTaskRequest) GetUid() string
func (*ResumeServiceTaskRequest) ProtoMessage ¶ added in v1.1.1796
func (*ResumeServiceTaskRequest) ProtoMessage()
func (*ResumeServiceTaskRequest) ProtoReflect ¶ added in v1.1.1796
func (x *ResumeServiceTaskRequest) ProtoReflect() protoreflect.Message
func (*ResumeServiceTaskRequest) Reset ¶ added in v1.1.1796
func (x *ResumeServiceTaskRequest) Reset()
func (*ResumeServiceTaskRequest) String ¶ added in v1.1.1796
func (x *ResumeServiceTaskRequest) String() string
type ResumeServiceTaskResponse ¶ added in v1.1.1796
type ResumeServiceTaskResponse struct {
// contains filtered or unexported fields
}
func (*ResumeServiceTaskResponse) Descriptor
deprecated
added in
v1.1.1796
func (*ResumeServiceTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use ResumeServiceTaskResponse.ProtoReflect.Descriptor instead.
func (*ResumeServiceTaskResponse) ProtoMessage ¶ added in v1.1.1796
func (*ResumeServiceTaskResponse) ProtoMessage()
func (*ResumeServiceTaskResponse) ProtoReflect ¶ added in v1.1.1796
func (x *ResumeServiceTaskResponse) ProtoReflect() protoreflect.Message
func (*ResumeServiceTaskResponse) Reset ¶ added in v1.1.1796
func (x *ResumeServiceTaskResponse) Reset()
func (*ResumeServiceTaskResponse) String ¶ added in v1.1.1796
func (x *ResumeServiceTaskResponse) String() string
type RetryActivityRequest ¶ added in v1.1.1377
type RetryActivityRequest struct { ProcessInstanceId string `protobuf:"bytes,1,opt,name=processInstanceId,proto3" json:"processInstanceId,omitempty"` ElementId string `protobuf:"bytes,2,opt,name=elementId,proto3" json:"elementId,omitempty"` Vars []byte `protobuf:"bytes,3,opt,name=vars,proto3" json:"vars,omitempty"` PriorElementId string `protobuf:"bytes,4,opt,name=priorElementId,proto3" json:"priorElementId,omitempty"` // contains filtered or unexported fields }
func (*RetryActivityRequest) Descriptor
deprecated
added in
v1.1.1377
func (*RetryActivityRequest) Descriptor() ([]byte, []int)
Deprecated: Use RetryActivityRequest.ProtoReflect.Descriptor instead.
func (*RetryActivityRequest) GetElementId ¶ added in v1.1.1547
func (x *RetryActivityRequest) GetElementId() string
func (*RetryActivityRequest) GetPriorElementId ¶ added in v1.1.1547
func (x *RetryActivityRequest) GetPriorElementId() string
func (*RetryActivityRequest) GetProcessInstanceId ¶ added in v1.1.1547
func (x *RetryActivityRequest) GetProcessInstanceId() string
func (*RetryActivityRequest) GetVars ¶ added in v1.1.1547
func (x *RetryActivityRequest) GetVars() []byte
func (*RetryActivityRequest) ProtoMessage ¶ added in v1.1.1377
func (*RetryActivityRequest) ProtoMessage()
func (*RetryActivityRequest) ProtoReflect ¶ added in v1.1.1377
func (x *RetryActivityRequest) ProtoReflect() protoreflect.Message
func (*RetryActivityRequest) Reset ¶ added in v1.1.1377
func (x *RetryActivityRequest) Reset()
func (*RetryActivityRequest) String ¶ added in v1.1.1377
func (x *RetryActivityRequest) String() string
type RetryActivityResponse ¶ added in v1.1.1377
type RetryActivityResponse struct {
// contains filtered or unexported fields
}
func (*RetryActivityResponse) Descriptor
deprecated
added in
v1.1.1377
func (*RetryActivityResponse) Descriptor() ([]byte, []int)
Deprecated: Use RetryActivityResponse.ProtoReflect.Descriptor instead.
func (*RetryActivityResponse) ProtoMessage ¶ added in v1.1.1377
func (*RetryActivityResponse) ProtoMessage()
func (*RetryActivityResponse) ProtoReflect ¶ added in v1.1.1377
func (x *RetryActivityResponse) ProtoReflect() protoreflect.Message
func (*RetryActivityResponse) Reset ¶ added in v1.1.1377
func (x *RetryActivityResponse) Reset()
func (*RetryActivityResponse) String ¶ added in v1.1.1377
func (x *RetryActivityResponse) 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_Exponential 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 SaveUserTaskRequest ¶ added in v1.1.1492
type SaveUserTaskRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Vars []byte `protobuf:"bytes,2,opt,name=vars,proto3" json:"vars,omitempty"` Overwrite bool `protobuf:"varint,3,opt,name=overwrite,proto3" json:"overwrite,omitempty"` // contains filtered or unexported fields }
func (*SaveUserTaskRequest) Descriptor
deprecated
added in
v1.1.1492
func (*SaveUserTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use SaveUserTaskRequest.ProtoReflect.Descriptor instead.
func (*SaveUserTaskRequest) GetId ¶ added in v1.1.1492
func (x *SaveUserTaskRequest) GetId() string
func (*SaveUserTaskRequest) GetOverwrite ¶ added in v1.1.1492
func (x *SaveUserTaskRequest) GetOverwrite() bool
func (*SaveUserTaskRequest) GetVars ¶ added in v1.1.1492
func (x *SaveUserTaskRequest) GetVars() []byte
func (*SaveUserTaskRequest) ProtoMessage ¶ added in v1.1.1492
func (*SaveUserTaskRequest) ProtoMessage()
func (*SaveUserTaskRequest) ProtoReflect ¶ added in v1.1.1492
func (x *SaveUserTaskRequest) ProtoReflect() protoreflect.Message
func (*SaveUserTaskRequest) Reset ¶ added in v1.1.1492
func (x *SaveUserTaskRequest) Reset()
func (*SaveUserTaskRequest) String ¶ added in v1.1.1492
func (x *SaveUserTaskRequest) String() string
type SaveUserTaskResponse ¶ added in v1.1.1492
type SaveUserTaskResponse struct {
// contains filtered or unexported fields
}
func (*SaveUserTaskResponse) Descriptor
deprecated
added in
v1.1.1492
func (*SaveUserTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use SaveUserTaskResponse.ProtoReflect.Descriptor instead.
func (*SaveUserTaskResponse) ProtoMessage ¶ added in v1.1.1492
func (*SaveUserTaskResponse) ProtoMessage()
func (*SaveUserTaskResponse) ProtoReflect ¶ added in v1.1.1492
func (x *SaveUserTaskResponse) ProtoReflect() protoreflect.Message
func (*SaveUserTaskResponse) Reset ¶ added in v1.1.1492
func (x *SaveUserTaskResponse) Reset()
func (*SaveUserTaskResponse) String ¶ added in v1.1.1492
func (x *SaveUserTaskResponse) 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 *Workflow `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"` // Workflow describes the bpmn processes // 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() *Workflow
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 { WorkflowId string `protobuf:"bytes,1,opt,name=WorkflowId,proto3" json:"WorkflowId,omitempty"` // WorkflowId the id of the workflow // 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) GetWorkflowId ¶ added in v1.1.731
func (x *StoreWorkflowResponse) GetWorkflowId() string
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. EstimatedMaxDuration uint64 `protobuf:"varint,7,opt,name=estimatedMaxDuration,proto3" json:"estimatedMaxDuration,omitempty"` // EstimatedMaxDuration documents how long the task is expected to run for. valid-value: a unix millisecond duration 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. valid-value: boolean Mock bool `protobuf:"varint,3,opt,name=mock,proto3" json:"mock,omitempty"` // Mock this task as it has no concrete implementation. valid-value: boolean Deprecated bool `protobuf:"varint,4,opt,name=deprecated,proto3" json:"deprecated,omitempty"` // Deprecated task. Workflows can not be executed that include this task. valid-value: boolean MockBehaviour *TaskMockBehaviours `protobuf:"bytes,5,opt,name=mockBehaviour,proto3" json:"mockBehaviour,omitempty"` // MockBehaviour lists behaviours exhibited by the task when mocked. Global bool `protobuf:"varint,6,opt,name=global,proto3" json:"global,omitempty"` // Global indicates that this task should be available across namespaces. // 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) GetEstimatedMaxDuration ¶ added in v1.1.763
func (x *TaskBehaviour) GetEstimatedMaxDuration() uint64
func (*TaskBehaviour) GetGlobal ¶ added in v1.1.1752
func (x *TaskBehaviour) GetGlobal() bool
func (*TaskBehaviour) GetMock ¶ added in v1.0.623
func (x *TaskBehaviour) GetMock() bool
func (*TaskBehaviour) GetMockBehaviour ¶ added in v1.1.1124
func (x *TaskBehaviour) GetMockBehaviour() *TaskMockBehaviours
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. valid-value: arbitrary string Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"` // Code a unique code for the error. valid-value: NATS-safe identifier Short string `protobuf:"bytes,3,opt,name=short,proto3" json:"short,omitempty"` // Short description of the error. valid-value: arbitrary string Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` // Description - a long description of the error. valid-value: arbitrary string // contains filtered or unexported fields }
TaskError 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 []*TaskError `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() []*TaskError
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. valid-value: 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. valid-value: arbitrary string 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. valid-value: semantic version number Short string `protobuf:"bytes,4,opt,name=short,proto3" json:"short,omitempty"` // Short description of the task. valid-value: arbitrary string Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"` // Description - a long description of the task. valid-value: arbitrary string Labels []string `protobuf:"bytes,6,rep,name=labels,proto3" json:"labels,omitempty"` // Labels - a list of searchable tags for the task. valid-value: arbitrary string ExtensionData map[string]string `` // ExtensionData - a map of values that can be used by third party tools. valid-value: arbitrary string /* 153-byte string literal not displayed */ ServiceTaskSetName *string `protobuf:"bytes,9,opt,name=serviceTaskSetName,proto3,oneof" json:"serviceTaskSetName,omitempty"` // ServiceTaskSetName - the name of the service this task belongs to. Allows a way to group multiple tasks together under the same service name if they are all related to the same service. // 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) 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) GetServiceTaskSetName ¶ added in v1.1.1744
func (x *TaskMetadata) GetServiceTaskSetName() 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 TaskMockBehaviours ¶ added in v1.1.1124
type TaskMockBehaviours struct { ErrorCodeExpr string `protobuf:"bytes,1,opt,name=errorCodeExpr,proto3" json:"errorCodeExpr,omitempty"` // errorCodeExpr generates a workflow error with the code specified by this expression. If this is, or returns an empty string, no error is returned. FatalErrorExpr string `protobuf:"bytes,2,opt,name=fatalErrorExpr,proto3" json:"fatalErrorExpr,omitempty"` // fatalErrorExpr is a boolean expression that if true, will throw a workflow fatal error. // contains filtered or unexported fields }
func (*TaskMockBehaviours) Descriptor
deprecated
added in
v1.1.1124
func (*TaskMockBehaviours) Descriptor() ([]byte, []int)
Deprecated: Use TaskMockBehaviours.ProtoReflect.Descriptor instead.
func (*TaskMockBehaviours) GetErrorCodeExpr ¶ added in v1.1.1124
func (x *TaskMockBehaviours) GetErrorCodeExpr() string
func (*TaskMockBehaviours) GetFatalErrorExpr ¶ added in v1.1.1124
func (x *TaskMockBehaviours) GetFatalErrorExpr() string
func (*TaskMockBehaviours) ProtoMessage ¶ added in v1.1.1124
func (*TaskMockBehaviours) ProtoMessage()
func (*TaskMockBehaviours) ProtoReflect ¶ added in v1.1.1124
func (x *TaskMockBehaviours) ProtoReflect() protoreflect.Message
func (*TaskMockBehaviours) Reset ¶ added in v1.1.1124
func (x *TaskMockBehaviours) Reset()
func (*TaskMockBehaviours) String ¶ added in v1.1.1124
func (x *TaskMockBehaviours) 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. valid-value: arbitrary string 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 TaskPaused ¶ added in v1.1.1796
type TaskPaused struct { Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` TaskUid string `protobuf:"bytes,2,opt,name=taskUid,proto3" json:"taskUid,omitempty"` // contains filtered or unexported fields }
func (*TaskPaused) Descriptor
deprecated
added in
v1.1.1796
func (*TaskPaused) Descriptor() ([]byte, []int)
Deprecated: Use TaskPaused.ProtoReflect.Descriptor instead.
func (*TaskPaused) GetTaskUid ¶ added in v1.1.1796
func (x *TaskPaused) GetTaskUid() string
func (*TaskPaused) GetTimestamp ¶ added in v1.1.1796
func (x *TaskPaused) GetTimestamp() int64
func (*TaskPaused) ProtoMessage ¶ added in v1.1.1796
func (*TaskPaused) ProtoMessage()
func (*TaskPaused) ProtoReflect ¶ added in v1.1.1796
func (x *TaskPaused) ProtoReflect() protoreflect.Message
func (*TaskPaused) Reset ¶ added in v1.1.1796
func (x *TaskPaused) Reset()
func (*TaskPaused) String ¶ added in v1.1.1796
func (x *TaskPaused) String() string
type TaskResumed ¶ added in v1.1.1796
type TaskResumed struct { Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` TaskUid string `protobuf:"bytes,2,opt,name=taskUid,proto3" json:"taskUid,omitempty"` // contains filtered or unexported fields }
func (*TaskResumed) Descriptor
deprecated
added in
v1.1.1796
func (*TaskResumed) Descriptor() ([]byte, []int)
Deprecated: Use TaskResumed.ProtoReflect.Descriptor instead.
func (*TaskResumed) GetTaskUid ¶ added in v1.1.1796
func (x *TaskResumed) GetTaskUid() string
func (*TaskResumed) GetTimestamp ¶ added in v1.1.1796
func (x *TaskResumed) GetTimestamp() int64
func (*TaskResumed) ProtoMessage ¶ added in v1.1.1796
func (*TaskResumed) ProtoMessage()
func (*TaskResumed) ProtoReflect ¶ added in v1.1.1796
func (x *TaskResumed) ProtoReflect() protoreflect.Message
func (*TaskResumed) Reset ¶ added in v1.1.1796
func (x *TaskResumed) Reset()
func (*TaskResumed) String ¶ added in v1.1.1796
func (x *TaskResumed) 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. valid-value: "1.0" Kind string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"` // Kind of task specification. valid-value: "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 TaskState ¶ added in v1.1.1492
type TaskState struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Vars []byte `protobuf:"bytes,2,opt,name=vars,proto3" json:"vars,omitempty"` Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` // contains filtered or unexported fields }
func (*TaskState) Descriptor
deprecated
added in
v1.1.1492
func (*TaskState) ProtoMessage ¶ added in v1.1.1492
func (*TaskState) ProtoMessage()
func (*TaskState) ProtoReflect ¶ added in v1.1.1492
func (x *TaskState) ProtoReflect() protoreflect.Message
type TelemetryClients ¶ added in v1.1.732
type TelemetryClients struct { Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*TelemetryClients) Descriptor
deprecated
added in
v1.1.732
func (*TelemetryClients) Descriptor() ([]byte, []int)
Deprecated: Use TelemetryClients.ProtoReflect.Descriptor instead.
func (*TelemetryClients) GetCount ¶ added in v1.1.732
func (x *TelemetryClients) GetCount() int32
func (*TelemetryClients) ProtoMessage ¶ added in v1.1.732
func (*TelemetryClients) ProtoMessage()
func (*TelemetryClients) ProtoReflect ¶ added in v1.1.732
func (x *TelemetryClients) ProtoReflect() protoreflect.Message
func (*TelemetryClients) Reset ¶ added in v1.1.732
func (x *TelemetryClients) Reset()
func (*TelemetryClients) String ¶ added in v1.1.732
func (x *TelemetryClients) 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=shar.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 `` /* 147-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 `` /* 134-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 TestMessage ¶ added in v1.1.1563
type TestMessage struct { WorkflowNumber string `protobuf:"bytes,1,opt,name=workflowNumber,proto3" json:"workflowNumber,omitempty"` // contains filtered or unexported fields }
func (*TestMessage) Descriptor
deprecated
added in
v1.1.1563
func (*TestMessage) Descriptor() ([]byte, []int)
Deprecated: Use TestMessage.ProtoReflect.Descriptor instead.
func (*TestMessage) GetWorkflowNumber ¶ added in v1.1.1563
func (x *TestMessage) GetWorkflowNumber() string
func (*TestMessage) ProtoMessage ¶ added in v1.1.1563
func (*TestMessage) ProtoMessage()
func (*TestMessage) ProtoReflect ¶ added in v1.1.1563
func (x *TestMessage) ProtoReflect() protoreflect.Message
func (*TestMessage) Reset ¶ added in v1.1.1563
func (x *TestMessage) Reset()
func (*TestMessage) String ¶ added in v1.1.1563
func (x *TestMessage) 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. /* 157-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 TraversedGatewayPath ¶ added in v1.1.1687
type TraversedGatewayPath struct { ConvergentGatewayElementId string `protobuf:"bytes,1,opt,name=convergentGatewayElementId,proto3" json:"convergentGatewayElementId,omitempty"` // convergentGatewayElementId is the gateway elementId this path will eventually arrive at GatewayInstanceId string `protobuf:"bytes,2,opt,name=gatewayInstanceId,proto3" json:"gatewayInstanceId,omitempty"` // gatewayInstanceId for the gateway this path belongs to PathId string `protobuf:"bytes,3,opt,name=pathId,proto3" json:"pathId,omitempty"` // pathId is the unique id of this particular path and is the flowId from bpmn // contains filtered or unexported fields }
func (*TraversedGatewayPath) Descriptor
deprecated
added in
v1.1.1687
func (*TraversedGatewayPath) Descriptor() ([]byte, []int)
Deprecated: Use TraversedGatewayPath.ProtoReflect.Descriptor instead.
func (*TraversedGatewayPath) GetConvergentGatewayElementId ¶ added in v1.1.1687
func (x *TraversedGatewayPath) GetConvergentGatewayElementId() string
func (*TraversedGatewayPath) GetGatewayInstanceId ¶ added in v1.1.1687
func (x *TraversedGatewayPath) GetGatewayInstanceId() string
func (*TraversedGatewayPath) GetPathId ¶ added in v1.1.1687
func (x *TraversedGatewayPath) GetPathId() string
func (*TraversedGatewayPath) ProtoMessage ¶ added in v1.1.1687
func (*TraversedGatewayPath) ProtoMessage()
func (*TraversedGatewayPath) ProtoReflect ¶ added in v1.1.1687
func (x *TraversedGatewayPath) ProtoReflect() protoreflect.Message
func (*TraversedGatewayPath) Reset ¶ added in v1.1.1687
func (x *TraversedGatewayPath) Reset()
func (*TraversedGatewayPath) String ¶ added in v1.1.1687
func (x *TraversedGatewayPath) String() string
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 ¶
type Vars interface { GetString(key string) (string, error) GetStrings(key string) ([]string, error) GetNestedString(key string) (string, error) GetInt64(key string) (int64, error) GetInt64s(key string) ([]int64, error) GetNestedInt64(key string) (int64, error) GetBool(key string) (bool, error) GetBools(key string) ([]bool, error) GetNestedBool(key string) (bool, error) GetFloat64(key string) (float64, error) GetFloat64s(key string) ([]float64, error) GetNestedFloat64(key string) (float64, error) GetNestedMap(key string) (map[string]any, error) GetNestedSlice(key string) ([]any, error) GetJson(key string) (string, error) SetString(key string, value string) SetStrings(key string, value []string) SetInt64(key string, value int64) SetInt64s(key string, value []int64) SetFloat64(key string, value float64) SetFloat64s(key string, value []float64) SetBool(key string, value bool) SetBools(key string, value []bool) SetJson(key, json string) error Decode(ctx context.Context, vars []byte) error Encode(ctx context.Context) ([]byte, error) Keys() iter.Seq[string] Len() int }
Vars is a map of variables. The variables must be primitive go types.
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. /* 141-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 message. /* 159-byte string literal not displayed */ AutoLaunchHeaders []byte `protobuf:"bytes,8,opt,name=autoLaunchHeaders,proto3" json:"autoLaunchHeaders,omitempty"` // AutoLaunchHeaders contains any headers added to processes that are launched non-interactively. // 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) GetAutoLaunchHeaders ¶ added in v1.1.1323
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 WorkflowErrorSource ¶ added in v1.1.1921
type WorkflowErrorSource int32
const ( WorkflowErrorSource_processJob WorkflowErrorSource = 0 WorkflowErrorSource_retryFramework WorkflowErrorSource = 1 )
func (WorkflowErrorSource) Descriptor ¶ added in v1.1.1921
func (WorkflowErrorSource) Descriptor() protoreflect.EnumDescriptor
func (WorkflowErrorSource) Enum ¶ added in v1.1.1921
func (x WorkflowErrorSource) Enum() *WorkflowErrorSource
func (WorkflowErrorSource) EnumDescriptor
deprecated
added in
v1.1.1921
func (WorkflowErrorSource) EnumDescriptor() ([]byte, []int)
Deprecated: Use WorkflowErrorSource.Descriptor instead.
func (WorkflowErrorSource) Number ¶ added in v1.1.1921
func (x WorkflowErrorSource) Number() protoreflect.EnumNumber
func (WorkflowErrorSource) String ¶ added in v1.1.1921
func (x WorkflowErrorSource) String() string
func (WorkflowErrorSource) Type ¶ added in v1.1.1921
func (WorkflowErrorSource) Type() protoreflect.EnumType
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=shar.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 execution 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=shar.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. ProcessId string `protobuf:"bytes,18,opt,name=processId,proto3" json:"processId,omitempty"` // ProcessId - id 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. TraversedGatewayPaths map[string]*TraversedGatewayPath `` // traversedGatewayPaths - each entry is keyed by a convergent gateway id and the value represents one path leading into this convergent gateway id. Each entry represents an inbound path into a convergent gateway /* 170-byte string literal not displayed */ GatewayInstancePaths map[string]*GatewayPaths `` // gatewayInstancePaths - each entry is keyed by a gateway instance id and the value are all paths for the gateway instance /* 168-byte string literal not displayed */ TraceParent string `protobuf:"bytes,23,opt,name=traceParent,proto3" json:"traceParent,omitempty"` // TraceContext holds an OTEL trace context. Compensation *Compensation `protobuf:"bytes,24,opt,name=compensation,proto3" json:"compensation,omitempty"` // Compensation holds compensation state parameters. ElementName string `protobuf:"bytes,25,opt,name=elementName,proto3" json:"elementName,omitempty"` // ElementName - the human readable name of this element PreviousActivity string `protobuf:"bytes,26,opt,name=previousActivity,proto3" json:"previousActivity,omitempty"` // PreviousActivity - the ID of the last activity PreviousElement string `protobuf:"bytes,27,opt,name=previousElement,proto3" json:"previousElement,omitempty"` // PreviousElement - the ID of the last element. IsCompensable bool `protobuf:"varint,28,opt,name=isCompensable,proto3" json:"isCompensable,omitempty"` // IsCompensable - Can this state's activity be compensated // 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) GetCompensation ¶ added in v1.1.1099
func (x *WorkflowState) GetCompensation() *Compensation
func (*WorkflowState) GetCondition ¶
func (x *WorkflowState) GetCondition() string
func (*WorkflowState) GetElementId ¶
func (x *WorkflowState) GetElementId() string
func (*WorkflowState) GetElementName ¶ added in v1.1.1171
func (x *WorkflowState) GetElementName() 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) GetGatewayInstancePaths ¶ added in v1.1.1687
func (x *WorkflowState) GetGatewayInstancePaths() map[string]*GatewayPaths
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) GetIsCompensable ¶ added in v1.1.1687
func (x *WorkflowState) GetIsCompensable() bool
func (*WorkflowState) GetOwners ¶ added in v0.1.86
func (x *WorkflowState) GetOwners() []string
func (*WorkflowState) GetPreviousActivity ¶ added in v1.1.1268
func (x *WorkflowState) GetPreviousActivity() string
func (*WorkflowState) GetPreviousElement ¶ added in v1.1.1268
func (x *WorkflowState) GetPreviousElement() string
func (*WorkflowState) GetProcessId ¶ added in v1.1.1212
func (x *WorkflowState) GetProcessId() string
func (*WorkflowState) GetProcessInstanceId ¶ added in v1.0.427
func (x *WorkflowState) GetProcessInstanceId() string
func (*WorkflowState) GetState ¶
func (x *WorkflowState) GetState() CancellationState
func (*WorkflowState) GetTimer ¶ added in v0.1.181
func (x *WorkflowState) GetTimer() *WorkflowTimer
func (*WorkflowState) GetTraceParent ¶ added in v1.1.848
func (x *WorkflowState) GetTraceParent() string
func (*WorkflowState) GetTraversedGatewayPaths ¶ added in v1.1.1687
func (x *WorkflowState) GetTraversedGatewayPaths() map[string]*TraversedGatewayPath
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 execution 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=shar.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=shar.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 launch 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 IsExecutionDisabled bool `protobuf:"varint,2,opt,name=isExecutionDisabled,proto3" json:"isExecutionDisabled,omitempty"` // isExecutionDisabled - whether this workflow is allowed to be executed // 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) GetIsExecutionDisabled ¶ added in v1.1.1460
func (x *WorkflowVersions) GetIsExecutionDisabled() bool
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