Documentation ¶
Index ¶
- Variables
- func Get[V any](vars Vars, key string) (V, error)
- type ApiAuthenticationRequest
- func (*ApiAuthenticationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApiAuthenticationRequest) GetHeaders() map[string]string
- func (*ApiAuthenticationRequest) ProtoMessage()
- func (x *ApiAuthenticationRequest) ProtoReflect() protoreflect.Message
- func (x *ApiAuthenticationRequest) Reset()
- func (x *ApiAuthenticationRequest) String() string
- type ApiAuthenticationResponse
- func (*ApiAuthenticationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApiAuthenticationResponse) GetAuthenticated() bool
- func (x *ApiAuthenticationResponse) GetUser() string
- func (*ApiAuthenticationResponse) ProtoMessage()
- func (x *ApiAuthenticationResponse) ProtoReflect() protoreflect.Message
- func (x *ApiAuthenticationResponse) Reset()
- func (x *ApiAuthenticationResponse) String() string
- type ApiAuthorizationRequest
- func (*ApiAuthorizationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApiAuthorizationRequest) GetFunction() string
- func (x *ApiAuthorizationRequest) GetHeaders() map[string]string
- func (x *ApiAuthorizationRequest) GetUser() string
- func (x *ApiAuthorizationRequest) GetWorkflowName() string
- func (*ApiAuthorizationRequest) ProtoMessage()
- func (x *ApiAuthorizationRequest) ProtoReflect() protoreflect.Message
- func (x *ApiAuthorizationRequest) Reset()
- func (x *ApiAuthorizationRequest) String() string
- type ApiAuthorizationResponse
- func (*ApiAuthorizationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApiAuthorizationResponse) GetAuthorized() bool
- func (x *ApiAuthorizationResponse) GetUserId() string
- func (*ApiAuthorizationResponse) ProtoMessage()
- func (x *ApiAuthorizationResponse) ProtoReflect() protoreflect.Message
- func (x *ApiAuthorizationResponse) Reset()
- func (x *ApiAuthorizationResponse) String() string
- type CancelWorkflowInstanceRequest
- func (*CancelWorkflowInstanceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CancelWorkflowInstanceRequest) GetError() *Error
- func (x *CancelWorkflowInstanceRequest) GetId() string
- func (x *CancelWorkflowInstanceRequest) GetState() CancellationState
- func (*CancelWorkflowInstanceRequest) ProtoMessage()
- func (x *CancelWorkflowInstanceRequest) ProtoReflect() protoreflect.Message
- func (x *CancelWorkflowInstanceRequest) Reset()
- func (x *CancelWorkflowInstanceRequest) 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 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 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 CompleteServiceTaskRequest
- func (*CompleteServiceTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CompleteServiceTaskRequest) GetTrackingId() string
- func (x *CompleteServiceTaskRequest) GetVars() []byte
- func (*CompleteServiceTaskRequest) ProtoMessage()
- func (x *CompleteServiceTaskRequest) ProtoReflect() protoreflect.Message
- func (x *CompleteServiceTaskRequest) Reset()
- func (x *CompleteServiceTaskRequest) String() string
- type CompleteUserTaskRequest
- func (*CompleteUserTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CompleteUserTaskRequest) GetOwner() string
- func (x *CompleteUserTaskRequest) GetTrackingId() string
- func (x *CompleteUserTaskRequest) GetVars() []byte
- func (*CompleteUserTaskRequest) ProtoMessage()
- func (x *CompleteUserTaskRequest) ProtoReflect() protoreflect.Message
- func (x *CompleteUserTaskRequest) Reset()
- func (x *CompleteUserTaskRequest) String() string
- type Element
- func (*Element) Descriptor() ([]byte, []int)deprecated
- func (x *Element) GetBoundaryTimer() []*Timer
- func (x *Element) GetCandidateGroups() string
- func (x *Element) GetCandidates() string
- func (x *Element) GetDocumentation() string
- func (x *Element) GetError() *Error
- func (x *Element) GetErrors() []*CatchError
- func (x *Element) GetExecute() string
- func (x *Element) GetId() string
- func (x *Element) GetInputTransform() map[string]string
- func (x *Element) GetMsg() string
- func (x *Element) GetName() string
- func (x *Element) GetOutbound() *Targets
- func (x *Element) GetOutputTransform() map[string]string
- func (x *Element) GetProcess() *Process
- func (x *Element) GetRetries() string
- func (x *Element) GetTimer() *WorkflowTimerDefinition
- func (x *Element) GetType() string
- func (*Element) ProtoMessage()
- func (x *Element) ProtoReflect() protoreflect.Message
- func (x *Element) Reset()
- func (x *Element) String() string
- type Error
- type GetMessageSenderRoutingIdRequest
- func (*GetMessageSenderRoutingIdRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetMessageSenderRoutingIdRequest) GetMessageName() string
- func (x *GetMessageSenderRoutingIdRequest) GetWorkflowName() string
- func (*GetMessageSenderRoutingIdRequest) ProtoMessage()
- func (x *GetMessageSenderRoutingIdRequest) ProtoReflect() protoreflect.Message
- func (x *GetMessageSenderRoutingIdRequest) Reset()
- func (x *GetMessageSenderRoutingIdRequest) 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 GetWorkflowInstanceStatusRequest
- func (*GetWorkflowInstanceStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowInstanceStatusRequest) GetId() string
- func (*GetWorkflowInstanceStatusRequest) ProtoMessage()
- func (x *GetWorkflowInstanceStatusRequest) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowInstanceStatusRequest) Reset()
- func (x *GetWorkflowInstanceStatusRequest) String() string
- type GetWorkflowRequest
- type GetWorkflowResponse
- func (*GetWorkflowResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowResponse) GetDefinition() *Workflow
- func (*GetWorkflowResponse) ProtoMessage()
- func (x *GetWorkflowResponse) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowResponse) Reset()
- func (x *GetWorkflowResponse) String() string
- type GetWorkflowVersionsRequest
- func (*GetWorkflowVersionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowVersionsRequest) GetName() string
- func (*GetWorkflowVersionsRequest) ProtoMessage()
- func (x *GetWorkflowVersionsRequest) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowVersionsRequest) Reset()
- func (x *GetWorkflowVersionsRequest) String() string
- type GetWorkflowVersionsResponse
- func (*GetWorkflowVersionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowVersionsResponse) GetVersions() *WorkflowVersions
- func (*GetWorkflowVersionsResponse) ProtoMessage()
- func (x *GetWorkflowVersionsResponse) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowVersionsResponse) Reset()
- func (x *GetWorkflowVersionsResponse) String() string
- type HandleWorkflowErrorRequest
- func (*HandleWorkflowErrorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HandleWorkflowErrorRequest) GetErrorCode() string
- func (x *HandleWorkflowErrorRequest) GetMessage() string
- func (x *HandleWorkflowErrorRequest) GetTrackingId() string
- func (x *HandleWorkflowErrorRequest) GetVars() []byte
- func (*HandleWorkflowErrorRequest) ProtoMessage()
- func (x *HandleWorkflowErrorRequest) ProtoReflect() protoreflect.Message
- func (x *HandleWorkflowErrorRequest) Reset()
- func (x *HandleWorkflowErrorRequest) String() string
- type HandleWorkflowErrorResponse
- func (*HandleWorkflowErrorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HandleWorkflowErrorResponse) GetHandled() bool
- func (*HandleWorkflowErrorResponse) ProtoMessage()
- func (x *HandleWorkflowErrorResponse) ProtoReflect() protoreflect.Message
- func (x *HandleWorkflowErrorResponse) Reset()
- func (x *HandleWorkflowErrorResponse) String() string
- type LaunchWorkflowRequest
- func (*LaunchWorkflowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LaunchWorkflowRequest) GetName() string
- func (x *LaunchWorkflowRequest) GetVars() []byte
- func (*LaunchWorkflowRequest) ProtoMessage()
- func (x *LaunchWorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *LaunchWorkflowRequest) Reset()
- func (x *LaunchWorkflowRequest) String() string
- type LaunchWorkflowResponse
- func (*LaunchWorkflowResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LaunchWorkflowResponse) GetInstanceId() string
- func (x *LaunchWorkflowResponse) GetWorkflowId() string
- func (*LaunchWorkflowResponse) ProtoMessage()
- func (x *LaunchWorkflowResponse) ProtoReflect() protoreflect.Message
- func (x *LaunchWorkflowResponse) Reset()
- func (x *LaunchWorkflowResponse) String() string
- type ListUserTasksRequest
- func (*ListUserTasksRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListUserTasksRequest) GetOwner() string
- func (*ListUserTasksRequest) ProtoMessage()
- func (x *ListUserTasksRequest) ProtoReflect() protoreflect.Message
- func (x *ListUserTasksRequest) Reset()
- func (x *ListUserTasksRequest) String() string
- type ListWorkflowInstanceRequest
- func (*ListWorkflowInstanceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListWorkflowInstanceRequest) GetWorkflowName() string
- func (*ListWorkflowInstanceRequest) ProtoMessage()
- func (x *ListWorkflowInstanceRequest) ProtoReflect() protoreflect.Message
- func (x *ListWorkflowInstanceRequest) Reset()
- func (x *ListWorkflowInstanceRequest) String() string
- type ListWorkflowInstanceResponse
- func (*ListWorkflowInstanceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListWorkflowInstanceResponse) GetResult() []*ListWorkflowInstanceResult
- func (*ListWorkflowInstanceResponse) ProtoMessage()
- func (x *ListWorkflowInstanceResponse) ProtoReflect() protoreflect.Message
- func (x *ListWorkflowInstanceResponse) Reset()
- func (x *ListWorkflowInstanceResponse) String() string
- type ListWorkflowInstanceResult
- func (*ListWorkflowInstanceResult) Descriptor() ([]byte, []int)deprecated
- func (x *ListWorkflowInstanceResult) GetId() string
- func (x *ListWorkflowInstanceResult) GetVersion() int32
- func (*ListWorkflowInstanceResult) ProtoMessage()
- func (x *ListWorkflowInstanceResult) ProtoReflect() protoreflect.Message
- func (x *ListWorkflowInstanceResult) Reset()
- func (x *ListWorkflowInstanceResult) String() string
- type ListWorkflowResult
- func (*ListWorkflowResult) Descriptor() ([]byte, []int)deprecated
- func (x *ListWorkflowResult) GetName() string
- func (x *ListWorkflowResult) GetVersion() int32
- func (*ListWorkflowResult) ProtoMessage()
- func (x *ListWorkflowResult) ProtoReflect() protoreflect.Message
- func (x *ListWorkflowResult) Reset()
- func (x *ListWorkflowResult) String() string
- type ListWorkflowsResponse
- func (*ListWorkflowsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListWorkflowsResponse) GetResult() []*ListWorkflowResult
- func (*ListWorkflowsResponse) ProtoMessage()
- func (x *ListWorkflowsResponse) ProtoReflect() protoreflect.Message
- func (x *ListWorkflowsResponse) Reset()
- func (x *ListWorkflowsResponse) String() string
- type LogSource
- type MessageInstance
- func (*MessageInstance) Descriptor() ([]byte, []int)deprecated
- func (x *MessageInstance) GetCorrelationKey() string
- func (x *MessageInstance) GetMessageId() 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 Process
- type SendMessageRequest
- func (*SendMessageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SendMessageRequest) GetKey() string
- func (x *SendMessageRequest) GetName() string
- func (x *SendMessageRequest) GetVars() []byte
- func (x *SendMessageRequest) GetWorkflowInstanceId() string
- func (*SendMessageRequest) ProtoMessage()
- func (x *SendMessageRequest) ProtoReflect() protoreflect.Message
- func (x *SendMessageRequest) Reset()
- func (x *SendMessageRequest) 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 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 Timer
- func (*Timer) Descriptor() ([]byte, []int)deprecated
- func (x *Timer) GetDuration() string
- func (x *Timer) GetId() string
- func (x *Timer) GetOutputTransform() map[string]string
- func (x *Timer) GetTarget() string
- func (*Timer) ProtoMessage()
- func (x *Timer) ProtoReflect() protoreflect.Message
- func (x *Timer) Reset()
- func (x *Timer) String() string
- type UserTasks
- type Vars
- func (vars Vars) GetBool(key string) (bool, error)
- func (vars Vars) GetByte(key string) ([]byte, error)
- func (vars Vars) GetBytes(key string) ([]byte, error)
- func (vars Vars) GetFloat32(key string) (float32, error)
- func (vars Vars) GetFloat64(key string) (float64, error)
- func (vars Vars) GetInt(key string) (int, error)
- func (vars Vars) GetInt16(key string) (int16, error)
- func (vars Vars) GetInt32(key string) (int32, error)
- func (vars Vars) GetInt64(key string) (int64, error)
- func (vars Vars) GetInt8(key string) (int8, error)
- func (vars Vars) GetString(key string) (string, error)
- type Workflow
- func (*Workflow) Descriptor() ([]byte, []int)deprecated
- func (x *Workflow) GetErrors() []*Error
- func (x *Workflow) GetGzipSource() []byte
- 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 WorkflowInstance
- func (*WorkflowInstance) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowInstance) GetInFlight() map[string]bool
- func (x *WorkflowInstance) GetParentElementId() string
- func (x *WorkflowInstance) GetParentWorkflowInstanceId() string
- func (x *WorkflowInstance) GetWorkflowId() string
- func (x *WorkflowInstance) GetWorkflowInstanceId() string
- func (x *WorkflowInstance) GetWorkflowName() string
- func (*WorkflowInstance) ProtoMessage()
- func (x *WorkflowInstance) ProtoReflect() protoreflect.Message
- func (x *WorkflowInstance) Reset()
- func (x *WorkflowInstance) String() string
- type WorkflowInstanceComplete
- func (*WorkflowInstanceComplete) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowInstanceComplete) GetError() *Error
- func (x *WorkflowInstanceComplete) GetWorkflowId() string
- func (x *WorkflowInstanceComplete) GetWorkflowInstanceId() string
- func (x *WorkflowInstanceComplete) GetWorkflowName() string
- func (x *WorkflowInstanceComplete) GetWorkflowState() CancellationState
- func (*WorkflowInstanceComplete) ProtoMessage()
- func (x *WorkflowInstanceComplete) ProtoReflect() protoreflect.Message
- func (x *WorkflowInstanceComplete) Reset()
- func (x *WorkflowInstanceComplete) String() string
- type WorkflowInstanceInfo
- func (*WorkflowInstanceInfo) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowInstanceInfo) GetId() string
- func (x *WorkflowInstanceInfo) GetWorkflowId() string
- func (*WorkflowInstanceInfo) ProtoMessage()
- func (x *WorkflowInstanceInfo) ProtoReflect() protoreflect.Message
- func (x *WorkflowInstanceInfo) Reset()
- func (x *WorkflowInstanceInfo) String() string
- type WorkflowInstanceStatus
- func (*WorkflowInstanceStatus) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowInstanceStatus) GetState() []*WorkflowState
- func (*WorkflowInstanceStatus) ProtoMessage()
- func (x *WorkflowInstanceStatus) ProtoReflect() protoreflect.Message
- func (x *WorkflowInstanceStatus) Reset()
- func (x *WorkflowInstanceStatus) String() string
- type WorkflowInstanceSubscribers
- func (*WorkflowInstanceSubscribers) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowInstanceSubscribers) GetList() []string
- func (*WorkflowInstanceSubscribers) ProtoMessage()
- func (x *WorkflowInstanceSubscribers) ProtoReflect() protoreflect.Message
- func (x *WorkflowInstanceSubscribers) Reset()
- func (x *WorkflowInstanceSubscribers) String() string
- type WorkflowState
- func (*WorkflowState) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowState) GetCondition() string
- func (x *WorkflowState) GetElementId() string
- func (x *WorkflowState) GetElementType() string
- func (x *WorkflowState) GetError() *Error
- func (x *WorkflowState) GetExecute() string
- func (x *WorkflowState) GetGroups() []string
- func (x *WorkflowState) GetId() []string
- func (x *WorkflowState) GetOwners() []string
- func (x *WorkflowState) GetState() CancellationState
- func (x *WorkflowState) GetTimer() *WorkflowTimer
- func (x *WorkflowState) GetUnixTimeNano() int64
- func (x *WorkflowState) GetVars() []byte
- func (x *WorkflowState) GetWorkflowId() string
- func (x *WorkflowState) GetWorkflowInstanceId() 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 WorkflowStats
- func (*WorkflowStats) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowStats) GetInstancesComplete() int64
- func (x *WorkflowStats) GetInstancesStarted() int64
- func (x *WorkflowStats) GetWorkflows() int64
- func (*WorkflowStats) ProtoMessage()
- func (x *WorkflowStats) ProtoReflect() protoreflect.Message
- func (x *WorkflowStats) Reset()
- func (x *WorkflowStats) String() string
- type WorkflowTimer
- func (*WorkflowTimer) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowTimer) GetCount() int64
- func (x *WorkflowTimer) GetLastFired() int64
- func (*WorkflowTimer) ProtoMessage()
- func (x *WorkflowTimer) ProtoReflect() protoreflect.Message
- func (x *WorkflowTimer) Reset()
- func (x *WorkflowTimer) String() string
- type WorkflowTimerDefinition
- func (*WorkflowTimerDefinition) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowTimerDefinition) GetDropEvents() bool
- func (x *WorkflowTimerDefinition) GetRepeat() int64
- func (x *WorkflowTimerDefinition) GetType() WorkflowTimerType
- func (x *WorkflowTimerDefinition) GetValue() int64
- func (*WorkflowTimerDefinition) ProtoMessage()
- func (x *WorkflowTimerDefinition) ProtoReflect() protoreflect.Message
- func (x *WorkflowTimerDefinition) Reset()
- func (x *WorkflowTimerDefinition) String() string
- type WorkflowTimerType
- func (WorkflowTimerType) Descriptor() protoreflect.EnumDescriptor
- func (x WorkflowTimerType) Enum() *WorkflowTimerType
- func (WorkflowTimerType) EnumDescriptor() ([]byte, []int)deprecated
- func (x WorkflowTimerType) Number() protoreflect.EnumNumber
- func (x WorkflowTimerType) String() string
- func (WorkflowTimerType) Type() protoreflect.EnumType
- type WorkflowVersion
- func (*WorkflowVersion) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowVersion) GetId() string
- func (x *WorkflowVersion) GetNumber() int32
- func (x *WorkflowVersion) GetSha256() []byte
- func (*WorkflowVersion) ProtoMessage()
- func (x *WorkflowVersion) ProtoReflect() protoreflect.Message
- func (x *WorkflowVersion) Reset()
- func (x *WorkflowVersion) String() string
- type WorkflowVersions
- func (*WorkflowVersions) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowVersions) GetVersion() []*WorkflowVersion
- func (*WorkflowVersions) ProtoMessage()
- func (x *WorkflowVersions) ProtoReflect() protoreflect.Message
- func (x *WorkflowVersions) Reset()
- func (x *WorkflowVersions) String() string
Constants ¶
This section is empty.
Variables ¶
var ( WorkflowTimerType_name = map[int32]string{ 0: "duration", 1: "fixed", } WorkflowTimerType_value = map[string]int32{ "duration": 0, "fixed": 1, } )
Enum value maps for WorkflowTimerType.
var ( CancellationState_name = map[int32]string{ 0: "executing", 1: "completed", 2: "terminated", 3: "errored", 4: "obsolete", } CancellationState_value = map[string]int32{ "executing": 0, "completed": 1, "terminated": 2, "errored": 3, "obsolete": 4, } )
Enum value maps for CancellationState.
var ( LogSource_name = map[int32]string{ 0: "logSourceEngine", 2: "logSourceWorkflow", 3: "logSourceClient", 4: "logSourceJob", } LogSource_value = map[string]int32{ "logSourceEngine": 0, "logSourceWorkflow": 2, "logSourceClient": 3, "logSourceJob": 4, } )
Enum value maps for LogSource.
var File_shar_workflow_models_proto protoreflect.FileDescriptor
Functions ¶
Types ¶
type ApiAuthenticationRequest ¶ added in v1.0.362
type ApiAuthenticationRequest struct { Headers map[string]string `` /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ApiAuthenticationRequest) Descriptor
deprecated
added in
v1.0.362
func (*ApiAuthenticationRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApiAuthenticationRequest.ProtoReflect.Descriptor instead.
func (*ApiAuthenticationRequest) GetHeaders ¶ added in v1.0.362
func (x *ApiAuthenticationRequest) GetHeaders() map[string]string
func (*ApiAuthenticationRequest) ProtoMessage ¶ added in v1.0.362
func (*ApiAuthenticationRequest) ProtoMessage()
func (*ApiAuthenticationRequest) ProtoReflect ¶ added in v1.0.362
func (x *ApiAuthenticationRequest) ProtoReflect() protoreflect.Message
func (*ApiAuthenticationRequest) Reset ¶ added in v1.0.362
func (x *ApiAuthenticationRequest) Reset()
func (*ApiAuthenticationRequest) String ¶ added in v1.0.362
func (x *ApiAuthenticationRequest) String() string
type ApiAuthenticationResponse ¶ added in v1.0.362
type ApiAuthenticationResponse struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Authenticated bool `protobuf:"varint,2,opt,name=Authenticated,proto3" json:"Authenticated,omitempty"` // contains filtered or unexported fields }
func (*ApiAuthenticationResponse) Descriptor
deprecated
added in
v1.0.362
func (*ApiAuthenticationResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApiAuthenticationResponse.ProtoReflect.Descriptor instead.
func (*ApiAuthenticationResponse) GetAuthenticated ¶ added in v1.0.362
func (x *ApiAuthenticationResponse) GetAuthenticated() bool
func (*ApiAuthenticationResponse) GetUser ¶ added in v1.0.362
func (x *ApiAuthenticationResponse) GetUser() string
func (*ApiAuthenticationResponse) ProtoMessage ¶ added in v1.0.362
func (*ApiAuthenticationResponse) ProtoMessage()
func (*ApiAuthenticationResponse) ProtoReflect ¶ added in v1.0.362
func (x *ApiAuthenticationResponse) ProtoReflect() protoreflect.Message
func (*ApiAuthenticationResponse) Reset ¶ added in v1.0.362
func (x *ApiAuthenticationResponse) Reset()
func (*ApiAuthenticationResponse) String ¶ added in v1.0.362
func (x *ApiAuthenticationResponse) String() string
type ApiAuthorizationRequest ¶ added in v1.0.362
type ApiAuthorizationRequest struct { Headers map[string]string `` /* 155-byte string literal not displayed */ Function string `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty"` WorkflowName string `protobuf:"bytes,3,opt,name=workflowName,proto3" json:"workflowName,omitempty"` User string `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"` // contains filtered or unexported fields }
func (*ApiAuthorizationRequest) Descriptor
deprecated
added in
v1.0.362
func (*ApiAuthorizationRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApiAuthorizationRequest.ProtoReflect.Descriptor instead.
func (*ApiAuthorizationRequest) GetFunction ¶ added in v1.0.362
func (x *ApiAuthorizationRequest) GetFunction() string
func (*ApiAuthorizationRequest) GetHeaders ¶ added in v1.0.362
func (x *ApiAuthorizationRequest) GetHeaders() map[string]string
func (*ApiAuthorizationRequest) GetUser ¶ added in v1.0.362
func (x *ApiAuthorizationRequest) GetUser() string
func (*ApiAuthorizationRequest) GetWorkflowName ¶ added in v1.0.362
func (x *ApiAuthorizationRequest) GetWorkflowName() string
func (*ApiAuthorizationRequest) ProtoMessage ¶ added in v1.0.362
func (*ApiAuthorizationRequest) ProtoMessage()
func (*ApiAuthorizationRequest) ProtoReflect ¶ added in v1.0.362
func (x *ApiAuthorizationRequest) ProtoReflect() protoreflect.Message
func (*ApiAuthorizationRequest) Reset ¶ added in v1.0.362
func (x *ApiAuthorizationRequest) Reset()
func (*ApiAuthorizationRequest) String ¶ added in v1.0.362
func (x *ApiAuthorizationRequest) String() string
type ApiAuthorizationResponse ¶ added in v1.0.362
type ApiAuthorizationResponse struct { Authorized bool `protobuf:"varint,1,opt,name=authorized,proto3" json:"authorized,omitempty"` UserId string `protobuf:"bytes,2,opt,name=userId,proto3" json:"userId,omitempty"` // contains filtered or unexported fields }
func (*ApiAuthorizationResponse) Descriptor
deprecated
added in
v1.0.362
func (*ApiAuthorizationResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApiAuthorizationResponse.ProtoReflect.Descriptor instead.
func (*ApiAuthorizationResponse) GetAuthorized ¶ added in v1.0.362
func (x *ApiAuthorizationResponse) GetAuthorized() bool
func (*ApiAuthorizationResponse) GetUserId ¶ added in v1.0.362
func (x *ApiAuthorizationResponse) GetUserId() string
func (*ApiAuthorizationResponse) ProtoMessage ¶ added in v1.0.362
func (*ApiAuthorizationResponse) ProtoMessage()
func (*ApiAuthorizationResponse) ProtoReflect ¶ added in v1.0.362
func (x *ApiAuthorizationResponse) ProtoReflect() protoreflect.Message
func (*ApiAuthorizationResponse) Reset ¶ added in v1.0.362
func (x *ApiAuthorizationResponse) Reset()
func (*ApiAuthorizationResponse) String ¶ added in v1.0.362
func (x *ApiAuthorizationResponse) String() string
type CancelWorkflowInstanceRequest ¶
type CancelWorkflowInstanceRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` State CancellationState `protobuf:"varint,2,opt,name=state,proto3,enum=CancellationState" json:"state,omitempty"` Error *Error `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*CancelWorkflowInstanceRequest) Descriptor
deprecated
func (*CancelWorkflowInstanceRequest) Descriptor() ([]byte, []int)
Deprecated: Use CancelWorkflowInstanceRequest.ProtoReflect.Descriptor instead.
func (*CancelWorkflowInstanceRequest) GetError ¶ added in v0.1.134
func (x *CancelWorkflowInstanceRequest) GetError() *Error
func (*CancelWorkflowInstanceRequest) GetId ¶
func (x *CancelWorkflowInstanceRequest) GetId() string
func (*CancelWorkflowInstanceRequest) GetState ¶ added in v0.1.134
func (x *CancelWorkflowInstanceRequest) GetState() CancellationState
func (*CancelWorkflowInstanceRequest) ProtoMessage ¶
func (*CancelWorkflowInstanceRequest) ProtoMessage()
func (*CancelWorkflowInstanceRequest) ProtoReflect ¶
func (x *CancelWorkflowInstanceRequest) ProtoReflect() protoreflect.Message
func (*CancelWorkflowInstanceRequest) Reset ¶
func (x *CancelWorkflowInstanceRequest) Reset()
func (*CancelWorkflowInstanceRequest) String ¶
func (x *CancelWorkflowInstanceRequest) String() string
type CancellationState ¶ added in v0.1.134
type CancellationState int32
const ( CancellationState_executing CancellationState = 0 // CancellationState_executing - the state machine is executing CancellationState_completed CancellationState = 1 // CancellationState_completed - the state machine has completed successfully CancellationState_terminated CancellationState = 2 // CancellationState_terminated - the state machine instance was terminated CancellationState_errored CancellationState = 3 // CancellationState_errored - an error occured during state machine execution CancellationState_obsolete CancellationState = 4 // CancellationState_obsolete - this state is obsolete due to an alternate flow )
func (CancellationState) Descriptor ¶ added in v0.1.134
func (CancellationState) Descriptor() protoreflect.EnumDescriptor
func (CancellationState) Enum ¶ added in v0.1.134
func (x CancellationState) Enum() *CancellationState
func (CancellationState) EnumDescriptor
deprecated
added in
v0.1.134
func (CancellationState) EnumDescriptor() ([]byte, []int)
Deprecated: Use CancellationState.Descriptor instead.
func (CancellationState) Number ¶ added in v0.1.134
func (x CancellationState) Number() protoreflect.EnumNumber
func (CancellationState) String ¶ added in v0.1.134
func (x CancellationState) String() string
func (CancellationState) Type ¶ added in v0.1.134
func (CancellationState) Type() protoreflect.EnumType
type CatchError ¶ added in v0.1.134
type CatchError struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Id - the unique id. ErrorId string `protobuf:"bytes,2,opt,name=errorId,proto3" json:"errorId,omitempty"` // Id - the id of the error. Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` // Target ID for the transition. OutputTransform map[string]string `` // OutputTransform - The transformation to apply to variables during the transition. /* 171-byte string literal not displayed */ // contains filtered or unexported fields }
CatchError specifies an error transition to another state.
func (*CatchError) Descriptor
deprecated
added in
v0.1.134
func (*CatchError) Descriptor() ([]byte, []int)
Deprecated: Use CatchError.ProtoReflect.Descriptor instead.
func (*CatchError) GetErrorId ¶ added in v0.1.134
func (x *CatchError) GetErrorId() string
func (*CatchError) GetId ¶ added in v0.1.134
func (x *CatchError) GetId() string
func (*CatchError) GetOutputTransform ¶ added in v1.0.251
func (x *CatchError) GetOutputTransform() map[string]string
func (*CatchError) GetTarget ¶ added in v0.1.134
func (x *CatchError) GetTarget() string
func (*CatchError) ProtoMessage ¶ added in v0.1.134
func (*CatchError) ProtoMessage()
func (*CatchError) ProtoReflect ¶ added in v0.1.134
func (x *CatchError) ProtoReflect() protoreflect.Message
func (*CatchError) Reset ¶ added in v0.1.134
func (x *CatchError) Reset()
func (*CatchError) String ¶ added in v0.1.134
func (x *CatchError) String() string
type 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 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 CompleteServiceTaskRequest ¶ added in v0.1.86
type CompleteServiceTaskRequest struct { TrackingId string `protobuf:"bytes,1,opt,name=trackingId,proto3" json:"trackingId,omitempty"` Vars []byte `protobuf:"bytes,2,opt,name=vars,proto3" json:"vars,omitempty"` // contains filtered or unexported fields }
func (*CompleteServiceTaskRequest) Descriptor
deprecated
added in
v0.1.86
func (*CompleteServiceTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use CompleteServiceTaskRequest.ProtoReflect.Descriptor instead.
func (*CompleteServiceTaskRequest) GetTrackingId ¶ added in v0.1.86
func (x *CompleteServiceTaskRequest) GetTrackingId() string
func (*CompleteServiceTaskRequest) GetVars ¶ added in v0.1.86
func (x *CompleteServiceTaskRequest) GetVars() []byte
func (*CompleteServiceTaskRequest) ProtoMessage ¶ added in v0.1.86
func (*CompleteServiceTaskRequest) ProtoMessage()
func (*CompleteServiceTaskRequest) ProtoReflect ¶ added in v0.1.86
func (x *CompleteServiceTaskRequest) ProtoReflect() protoreflect.Message
func (*CompleteServiceTaskRequest) Reset ¶ added in v0.1.86
func (x *CompleteServiceTaskRequest) Reset()
func (*CompleteServiceTaskRequest) String ¶ added in v0.1.86
func (x *CompleteServiceTaskRequest) String() string
type CompleteUserTaskRequest ¶ added in v0.1.86
type CompleteUserTaskRequest struct { TrackingId string `protobuf:"bytes,1,opt,name=trackingId,proto3" json:"trackingId,omitempty"` Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"` Vars []byte `protobuf:"bytes,3,opt,name=vars,proto3" json:"vars,omitempty"` // contains filtered or unexported fields }
func (*CompleteUserTaskRequest) Descriptor
deprecated
added in
v0.1.86
func (*CompleteUserTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use CompleteUserTaskRequest.ProtoReflect.Descriptor instead.
func (*CompleteUserTaskRequest) GetOwner ¶ added in v0.1.86
func (x *CompleteUserTaskRequest) GetOwner() string
func (*CompleteUserTaskRequest) GetTrackingId ¶ added in v0.1.86
func (x *CompleteUserTaskRequest) GetTrackingId() string
func (*CompleteUserTaskRequest) GetVars ¶ added in v0.1.86
func (x *CompleteUserTaskRequest) GetVars() []byte
func (*CompleteUserTaskRequest) ProtoMessage ¶ added in v0.1.86
func (*CompleteUserTaskRequest) ProtoMessage()
func (*CompleteUserTaskRequest) ProtoReflect ¶ added in v0.1.86
func (x *CompleteUserTaskRequest) ProtoReflect() protoreflect.Message
func (*CompleteUserTaskRequest) Reset ¶ added in v0.1.86
func (x *CompleteUserTaskRequest) Reset()
func (*CompleteUserTaskRequest) String ¶ added in v0.1.86
func (x *CompleteUserTaskRequest) String() string
type Element ¶
type Element struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Id - the unique identifier for the workflow state machine element. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Name - the name of the state machine element. Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` // Type - the type of state machine element Documentation string `protobuf:"bytes,4,opt,name=documentation,proto3" json:"documentation,omitempty"` // Documentation - any documentation describing the state machine element. Execute string `protobuf:"bytes,5,opt,name=execute,proto3" json:"execute,omitempty"` // Execute - describes the execution parameter, This is used for diffrerent purposes depending on the type. Outbound *Targets `protobuf:"bytes,6,opt,name=outbound,proto3" json:"outbound,omitempty"` // Outbound - a number of possible transitions to other state machine state elements.s Process *Process `protobuf:"bytes,7,opt,name=process,proto3" json:"process,omitempty"` // Process - defines any subprocesses contained within this state machine. Msg string `protobuf:"bytes,8,opt,name=msg,proto3" json:"msg,omitempty"` // TODO: Document Retries string `protobuf:"bytes,9,opt,name=retries,proto3" json:"retries,omitempty"` // Retries - how many times this state machine element should retry in the case of a non-workflow error. Candidates string `protobuf:"bytes,10,opt,name=candidates,proto3" json:"candidates,omitempty"` // Candidates - used for user related state machgine types to define users that may complete the task. CandidateGroups string `protobuf:"bytes,11,opt,name=candidateGroups,proto3" json:"candidateGroups,omitempty"` // CandidateGroups - used for user related state machine types to define groups that may complete a task. Errors []*CatchError `protobuf:"bytes,12,rep,name=errors,proto3" json:"errors,omitempty"` // Errors - a number of catchable errors for this state machine element. Error *Error `protobuf:"bytes,13,opt,name=error,proto3" json:"error,omitempty"` // Error - an error that may be thrown. InputTransform map[string]string `` // InputTransform - a transformation to poerform between variable names when calling a state machine task. /* 170-byte string literal not displayed */ OutputTransform map[string]string `` // OutputTransform - a transformation to poerform between variable names when exiting a state machine task. /* 172-byte string literal not displayed */ Timer *WorkflowTimerDefinition `protobuf:"bytes,16,opt,name=timer,proto3" json:"timer,omitempty"` // Timer - a time to wait before execution for timer tasks. BoundaryTimer []*Timer `protobuf:"bytes,17,rep,name=boundaryTimer,proto3" json:"boundaryTimer,omitempty"` // BoundaryTimer - a number of timed transitions between this and another state. // contains filtered or unexported fields }
Element describes a single state machine state.
func (*Element) Descriptor
deprecated
func (*Element) GetBoundaryTimer ¶ added in v1.0.235
func (*Element) GetCandidateGroups ¶ added in v0.1.86
func (*Element) GetCandidates ¶ added in v0.1.86
func (*Element) GetDocumentation ¶
func (*Element) GetErrors ¶ added in v0.1.134
func (x *Element) GetErrors() []*CatchError
func (*Element) GetExecute ¶
func (*Element) GetInputTransform ¶ added in v0.1.175
func (*Element) GetOutbound ¶
func (*Element) GetOutputTransform ¶ added in v0.1.175
func (*Element) GetProcess ¶
func (*Element) GetRetries ¶ added in v0.1.74
func (*Element) GetTimer ¶ added in v0.1.181
func (x *Element) GetTimer() *WorkflowTimerDefinition
func (*Element) ProtoMessage ¶
func (*Element) ProtoMessage()
func (*Element) ProtoReflect ¶
func (x *Element) ProtoReflect() protoreflect.Message
type Error ¶ added in v0.1.134
type Error struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Id - the unique id for the error. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Name - the error unique name. Code string `protobuf:"bytes,3,opt,name=code,proto3" json:"code,omitempty"` // Code - the unique code for the error. // contains filtered or unexported fields }
Error represents a known error name and code which may be thrown by the state machine.
func (*Error) Descriptor
deprecated
added in
v0.1.134
func (*Error) ProtoMessage ¶ added in v0.1.134
func (*Error) ProtoMessage()
func (*Error) ProtoReflect ¶ added in v0.1.134
func (x *Error) ProtoReflect() protoreflect.Message
type GetMessageSenderRoutingIdRequest ¶ added in v0.1.167
type GetMessageSenderRoutingIdRequest struct { WorkflowName string `protobuf:"bytes,1,opt,name=workflowName,proto3" json:"workflowName,omitempty"` MessageName string `protobuf:"bytes,2,opt,name=messageName,proto3" json:"messageName,omitempty"` // contains filtered or unexported fields }
func (*GetMessageSenderRoutingIdRequest) Descriptor
deprecated
added in
v0.1.167
func (*GetMessageSenderRoutingIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetMessageSenderRoutingIdRequest.ProtoReflect.Descriptor instead.
func (*GetMessageSenderRoutingIdRequest) GetMessageName ¶ added in v0.1.167
func (x *GetMessageSenderRoutingIdRequest) GetMessageName() string
func (*GetMessageSenderRoutingIdRequest) GetWorkflowName ¶ added in v0.1.167
func (x *GetMessageSenderRoutingIdRequest) GetWorkflowName() string
func (*GetMessageSenderRoutingIdRequest) ProtoMessage ¶ added in v0.1.167
func (*GetMessageSenderRoutingIdRequest) ProtoMessage()
func (*GetMessageSenderRoutingIdRequest) ProtoReflect ¶ added in v0.1.167
func (x *GetMessageSenderRoutingIdRequest) ProtoReflect() protoreflect.Message
func (*GetMessageSenderRoutingIdRequest) Reset ¶ added in v0.1.167
func (x *GetMessageSenderRoutingIdRequest) Reset()
func (*GetMessageSenderRoutingIdRequest) String ¶ added in v0.1.167
func (x *GetMessageSenderRoutingIdRequest) 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 GetWorkflowInstanceStatusRequest ¶
type GetWorkflowInstanceStatusRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowInstanceStatusRequest) Descriptor
deprecated
func (*GetWorkflowInstanceStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowInstanceStatusRequest.ProtoReflect.Descriptor instead.
func (*GetWorkflowInstanceStatusRequest) GetId ¶
func (x *GetWorkflowInstanceStatusRequest) GetId() string
func (*GetWorkflowInstanceStatusRequest) ProtoMessage ¶
func (*GetWorkflowInstanceStatusRequest) ProtoMessage()
func (*GetWorkflowInstanceStatusRequest) ProtoReflect ¶
func (x *GetWorkflowInstanceStatusRequest) ProtoReflect() protoreflect.Message
func (*GetWorkflowInstanceStatusRequest) Reset ¶
func (x *GetWorkflowInstanceStatusRequest) Reset()
func (*GetWorkflowInstanceStatusRequest) String ¶
func (x *GetWorkflowInstanceStatusRequest) String() string
type GetWorkflowRequest ¶ added in v1.0.366
type GetWorkflowRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowRequest) Descriptor
deprecated
added in
v1.0.366
func (*GetWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowRequest.ProtoReflect.Descriptor instead.
func (*GetWorkflowRequest) GetId ¶ added in v1.0.366
func (x *GetWorkflowRequest) GetId() string
func (*GetWorkflowRequest) ProtoMessage ¶ added in v1.0.366
func (*GetWorkflowRequest) ProtoMessage()
func (*GetWorkflowRequest) ProtoReflect ¶ added in v1.0.366
func (x *GetWorkflowRequest) ProtoReflect() protoreflect.Message
func (*GetWorkflowRequest) Reset ¶ added in v1.0.366
func (x *GetWorkflowRequest) Reset()
func (*GetWorkflowRequest) String ¶ added in v1.0.366
func (x *GetWorkflowRequest) String() string
type GetWorkflowResponse ¶ added in v1.0.366
type GetWorkflowResponse struct { Definition *Workflow `protobuf:"bytes,1,opt,name=definition,proto3" json:"definition,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowResponse) Descriptor
deprecated
added in
v1.0.366
func (*GetWorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowResponse.ProtoReflect.Descriptor instead.
func (*GetWorkflowResponse) GetDefinition ¶ added in v1.0.366
func (x *GetWorkflowResponse) GetDefinition() *Workflow
func (*GetWorkflowResponse) ProtoMessage ¶ added in v1.0.366
func (*GetWorkflowResponse) ProtoMessage()
func (*GetWorkflowResponse) ProtoReflect ¶ added in v1.0.366
func (x *GetWorkflowResponse) ProtoReflect() protoreflect.Message
func (*GetWorkflowResponse) Reset ¶ added in v1.0.366
func (x *GetWorkflowResponse) Reset()
func (*GetWorkflowResponse) String ¶ added in v1.0.366
func (x *GetWorkflowResponse) String() string
type GetWorkflowVersionsRequest ¶ added in v1.0.366
type GetWorkflowVersionsRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowVersionsRequest) Descriptor
deprecated
added in
v1.0.366
func (*GetWorkflowVersionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowVersionsRequest.ProtoReflect.Descriptor instead.
func (*GetWorkflowVersionsRequest) GetName ¶ added in v1.0.366
func (x *GetWorkflowVersionsRequest) GetName() string
func (*GetWorkflowVersionsRequest) ProtoMessage ¶ added in v1.0.366
func (*GetWorkflowVersionsRequest) ProtoMessage()
func (*GetWorkflowVersionsRequest) ProtoReflect ¶ added in v1.0.366
func (x *GetWorkflowVersionsRequest) ProtoReflect() protoreflect.Message
func (*GetWorkflowVersionsRequest) Reset ¶ added in v1.0.366
func (x *GetWorkflowVersionsRequest) Reset()
func (*GetWorkflowVersionsRequest) String ¶ added in v1.0.366
func (x *GetWorkflowVersionsRequest) String() string
type GetWorkflowVersionsResponse ¶ added in v1.0.366
type GetWorkflowVersionsResponse struct { Versions *WorkflowVersions `protobuf:"bytes,1,opt,name=versions,proto3" json:"versions,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowVersionsResponse) Descriptor
deprecated
added in
v1.0.366
func (*GetWorkflowVersionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowVersionsResponse.ProtoReflect.Descriptor instead.
func (*GetWorkflowVersionsResponse) GetVersions ¶ added in v1.0.366
func (x *GetWorkflowVersionsResponse) GetVersions() *WorkflowVersions
func (*GetWorkflowVersionsResponse) ProtoMessage ¶ added in v1.0.366
func (*GetWorkflowVersionsResponse) ProtoMessage()
func (*GetWorkflowVersionsResponse) ProtoReflect ¶ added in v1.0.366
func (x *GetWorkflowVersionsResponse) ProtoReflect() protoreflect.Message
func (*GetWorkflowVersionsResponse) Reset ¶ added in v1.0.366
func (x *GetWorkflowVersionsResponse) Reset()
func (*GetWorkflowVersionsResponse) String ¶ added in v1.0.366
func (x *GetWorkflowVersionsResponse) String() string
type HandleWorkflowErrorRequest ¶ added in v0.1.134
type HandleWorkflowErrorRequest struct { TrackingId string `protobuf:"bytes,1,opt,name=trackingId,proto3" json:"trackingId,omitempty"` ErrorCode string `protobuf:"bytes,2,opt,name=errorCode,proto3" json:"errorCode,omitempty"` Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` Vars []byte `protobuf:"bytes,4,opt,name=vars,proto3" json:"vars,omitempty"` // contains filtered or unexported fields }
func (*HandleWorkflowErrorRequest) Descriptor
deprecated
added in
v0.1.134
func (*HandleWorkflowErrorRequest) Descriptor() ([]byte, []int)
Deprecated: Use HandleWorkflowErrorRequest.ProtoReflect.Descriptor instead.
func (*HandleWorkflowErrorRequest) GetErrorCode ¶ added in v0.1.134
func (x *HandleWorkflowErrorRequest) GetErrorCode() string
func (*HandleWorkflowErrorRequest) GetMessage ¶ added in v0.1.134
func (x *HandleWorkflowErrorRequest) GetMessage() string
func (*HandleWorkflowErrorRequest) GetTrackingId ¶ added in v0.1.134
func (x *HandleWorkflowErrorRequest) GetTrackingId() string
func (*HandleWorkflowErrorRequest) GetVars ¶ added in v1.0.251
func (x *HandleWorkflowErrorRequest) GetVars() []byte
func (*HandleWorkflowErrorRequest) ProtoMessage ¶ added in v0.1.134
func (*HandleWorkflowErrorRequest) ProtoMessage()
func (*HandleWorkflowErrorRequest) ProtoReflect ¶ added in v0.1.134
func (x *HandleWorkflowErrorRequest) ProtoReflect() protoreflect.Message
func (*HandleWorkflowErrorRequest) Reset ¶ added in v0.1.134
func (x *HandleWorkflowErrorRequest) Reset()
func (*HandleWorkflowErrorRequest) String ¶ added in v0.1.134
func (x *HandleWorkflowErrorRequest) String() string
type HandleWorkflowErrorResponse ¶ added in v0.1.134
type HandleWorkflowErrorResponse struct { Handled bool `protobuf:"varint,1,opt,name=handled,proto3" json:"handled,omitempty"` // contains filtered or unexported fields }
func (*HandleWorkflowErrorResponse) Descriptor
deprecated
added in
v0.1.134
func (*HandleWorkflowErrorResponse) Descriptor() ([]byte, []int)
Deprecated: Use HandleWorkflowErrorResponse.ProtoReflect.Descriptor instead.
func (*HandleWorkflowErrorResponse) GetHandled ¶ added in v0.1.134
func (x *HandleWorkflowErrorResponse) GetHandled() bool
func (*HandleWorkflowErrorResponse) ProtoMessage ¶ added in v0.1.134
func (*HandleWorkflowErrorResponse) ProtoMessage()
func (*HandleWorkflowErrorResponse) ProtoReflect ¶ added in v0.1.134
func (x *HandleWorkflowErrorResponse) ProtoReflect() protoreflect.Message
func (*HandleWorkflowErrorResponse) Reset ¶ added in v0.1.134
func (x *HandleWorkflowErrorResponse) Reset()
func (*HandleWorkflowErrorResponse) String ¶ added in v0.1.134
func (x *HandleWorkflowErrorResponse) String() string
type LaunchWorkflowRequest ¶
type LaunchWorkflowRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Vars []byte `protobuf:"bytes,2,opt,name=vars,proto3" json:"vars,omitempty"` // contains filtered or unexported fields }
func (*LaunchWorkflowRequest) Descriptor
deprecated
func (*LaunchWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use LaunchWorkflowRequest.ProtoReflect.Descriptor instead.
func (*LaunchWorkflowRequest) GetName ¶
func (x *LaunchWorkflowRequest) GetName() string
func (*LaunchWorkflowRequest) GetVars ¶
func (x *LaunchWorkflowRequest) GetVars() []byte
func (*LaunchWorkflowRequest) ProtoMessage ¶
func (*LaunchWorkflowRequest) ProtoMessage()
func (*LaunchWorkflowRequest) ProtoReflect ¶
func (x *LaunchWorkflowRequest) ProtoReflect() protoreflect.Message
func (*LaunchWorkflowRequest) Reset ¶
func (x *LaunchWorkflowRequest) Reset()
func (*LaunchWorkflowRequest) String ¶
func (x *LaunchWorkflowRequest) String() string
type LaunchWorkflowResponse ¶ added in v1.0.366
type LaunchWorkflowResponse struct { InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"` WorkflowId string `protobuf:"bytes,2,opt,name=workflowId,proto3" json:"workflowId,omitempty"` // contains filtered or unexported fields }
func (*LaunchWorkflowResponse) Descriptor
deprecated
added in
v1.0.366
func (*LaunchWorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use LaunchWorkflowResponse.ProtoReflect.Descriptor instead.
func (*LaunchWorkflowResponse) GetInstanceId ¶ added in v1.0.366
func (x *LaunchWorkflowResponse) GetInstanceId() string
func (*LaunchWorkflowResponse) GetWorkflowId ¶ added in v1.0.366
func (x *LaunchWorkflowResponse) GetWorkflowId() string
func (*LaunchWorkflowResponse) ProtoMessage ¶ added in v1.0.366
func (*LaunchWorkflowResponse) ProtoMessage()
func (*LaunchWorkflowResponse) ProtoReflect ¶ added in v1.0.366
func (x *LaunchWorkflowResponse) ProtoReflect() protoreflect.Message
func (*LaunchWorkflowResponse) Reset ¶ added in v1.0.366
func (x *LaunchWorkflowResponse) Reset()
func (*LaunchWorkflowResponse) String ¶ added in v1.0.366
func (x *LaunchWorkflowResponse) String() string
type ListUserTasksRequest ¶ added in v0.1.86
type ListUserTasksRequest struct { Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"` // contains filtered or unexported fields }
func (*ListUserTasksRequest) Descriptor
deprecated
added in
v0.1.86
func (*ListUserTasksRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListUserTasksRequest.ProtoReflect.Descriptor instead.
func (*ListUserTasksRequest) GetOwner ¶ added in v0.1.86
func (x *ListUserTasksRequest) GetOwner() string
func (*ListUserTasksRequest) ProtoMessage ¶ added in v0.1.86
func (*ListUserTasksRequest) ProtoMessage()
func (*ListUserTasksRequest) ProtoReflect ¶ added in v0.1.86
func (x *ListUserTasksRequest) ProtoReflect() protoreflect.Message
func (*ListUserTasksRequest) Reset ¶ added in v0.1.86
func (x *ListUserTasksRequest) Reset()
func (*ListUserTasksRequest) String ¶ added in v0.1.86
func (x *ListUserTasksRequest) String() string
type ListWorkflowInstanceRequest ¶
type ListWorkflowInstanceRequest struct { WorkflowName string `protobuf:"bytes,1,opt,name=workflowName,proto3" json:"workflowName,omitempty"` // contains filtered or unexported fields }
func (*ListWorkflowInstanceRequest) Descriptor
deprecated
func (*ListWorkflowInstanceRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListWorkflowInstanceRequest.ProtoReflect.Descriptor instead.
func (*ListWorkflowInstanceRequest) GetWorkflowName ¶
func (x *ListWorkflowInstanceRequest) GetWorkflowName() string
func (*ListWorkflowInstanceRequest) ProtoMessage ¶
func (*ListWorkflowInstanceRequest) ProtoMessage()
func (*ListWorkflowInstanceRequest) ProtoReflect ¶
func (x *ListWorkflowInstanceRequest) ProtoReflect() protoreflect.Message
func (*ListWorkflowInstanceRequest) Reset ¶
func (x *ListWorkflowInstanceRequest) Reset()
func (*ListWorkflowInstanceRequest) String ¶
func (x *ListWorkflowInstanceRequest) String() string
type ListWorkflowInstanceResponse ¶
type ListWorkflowInstanceResponse struct { Result []*ListWorkflowInstanceResult `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*ListWorkflowInstanceResponse) Descriptor
deprecated
func (*ListWorkflowInstanceResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListWorkflowInstanceResponse.ProtoReflect.Descriptor instead.
func (*ListWorkflowInstanceResponse) GetResult ¶
func (x *ListWorkflowInstanceResponse) GetResult() []*ListWorkflowInstanceResult
func (*ListWorkflowInstanceResponse) ProtoMessage ¶
func (*ListWorkflowInstanceResponse) ProtoMessage()
func (*ListWorkflowInstanceResponse) ProtoReflect ¶
func (x *ListWorkflowInstanceResponse) ProtoReflect() protoreflect.Message
func (*ListWorkflowInstanceResponse) Reset ¶
func (x *ListWorkflowInstanceResponse) Reset()
func (*ListWorkflowInstanceResponse) String ¶
func (x *ListWorkflowInstanceResponse) String() string
type ListWorkflowInstanceResult ¶
type ListWorkflowInstanceResult 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 (*ListWorkflowInstanceResult) Descriptor
deprecated
func (*ListWorkflowInstanceResult) Descriptor() ([]byte, []int)
Deprecated: Use ListWorkflowInstanceResult.ProtoReflect.Descriptor instead.
func (*ListWorkflowInstanceResult) GetId ¶
func (x *ListWorkflowInstanceResult) GetId() string
func (*ListWorkflowInstanceResult) GetVersion ¶
func (x *ListWorkflowInstanceResult) GetVersion() int32
func (*ListWorkflowInstanceResult) ProtoMessage ¶
func (*ListWorkflowInstanceResult) ProtoMessage()
func (*ListWorkflowInstanceResult) ProtoReflect ¶
func (x *ListWorkflowInstanceResult) ProtoReflect() protoreflect.Message
func (*ListWorkflowInstanceResult) Reset ¶
func (x *ListWorkflowInstanceResult) Reset()
func (*ListWorkflowInstanceResult) String ¶
func (x *ListWorkflowInstanceResult) String() string
type ListWorkflowResult ¶
type ListWorkflowResult 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 (*ListWorkflowResult) Descriptor
deprecated
func (*ListWorkflowResult) Descriptor() ([]byte, []int)
Deprecated: Use ListWorkflowResult.ProtoReflect.Descriptor instead.
func (*ListWorkflowResult) GetName ¶
func (x *ListWorkflowResult) GetName() string
func (*ListWorkflowResult) GetVersion ¶
func (x *ListWorkflowResult) GetVersion() int32
func (*ListWorkflowResult) ProtoMessage ¶
func (*ListWorkflowResult) ProtoMessage()
func (*ListWorkflowResult) ProtoReflect ¶
func (x *ListWorkflowResult) ProtoReflect() protoreflect.Message
func (*ListWorkflowResult) Reset ¶
func (x *ListWorkflowResult) Reset()
func (*ListWorkflowResult) String ¶
func (x *ListWorkflowResult) String() string
type ListWorkflowsResponse ¶
type ListWorkflowsResponse struct { Result []*ListWorkflowResult `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() []*ListWorkflowResult
func (*ListWorkflowsResponse) ProtoMessage ¶
func (*ListWorkflowsResponse) ProtoMessage()
func (*ListWorkflowsResponse) ProtoReflect ¶
func (x *ListWorkflowsResponse) ProtoReflect() protoreflect.Message
func (*ListWorkflowsResponse) Reset ¶
func (x *ListWorkflowsResponse) Reset()
func (*ListWorkflowsResponse) String ¶
func (x *ListWorkflowsResponse) String() string
type LogSource ¶ added in v1.0.271
type LogSource int32
func (LogSource) Descriptor ¶ added in v1.0.271
func (LogSource) Descriptor() protoreflect.EnumDescriptor
func (LogSource) EnumDescriptor
deprecated
added in
v1.0.271
func (LogSource) Number ¶ added in v1.0.271
func (x LogSource) Number() protoreflect.EnumNumber
func (LogSource) Type ¶ added in v1.0.271
func (LogSource) Type() protoreflect.EnumType
type MessageInstance ¶
type MessageInstance struct { MessageId string `protobuf:"bytes,1,opt,name=messageId,proto3" json:"messageId,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) GetMessageId ¶
func (x *MessageInstance) GetMessageId() 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 Process ¶
type Process struct { Elements []*Element `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"` // Elements describes each state in the state machine. Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"` // Name - the common name of the state machine. // contains filtered or unexported fields }
Process describes a single workflow state machine.
func (*Process) Descriptor
deprecated
func (*Process) GetElements ¶
func (*Process) ProtoMessage ¶
func (*Process) ProtoMessage()
func (*Process) ProtoReflect ¶
func (x *Process) ProtoReflect() protoreflect.Message
type SendMessageRequest ¶
type SendMessageRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` WorkflowInstanceId string `protobuf:"bytes,3,opt,name=workflowInstanceId,proto3" json:"workflowInstanceId,omitempty"` Vars []byte `protobuf:"bytes,4,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) GetKey ¶
func (x *SendMessageRequest) GetKey() string
func (*SendMessageRequest) GetName ¶
func (x *SendMessageRequest) GetName() string
func (*SendMessageRequest) GetVars ¶ added in v0.1.70
func (x *SendMessageRequest) GetVars() []byte
func (*SendMessageRequest) GetWorkflowInstanceId ¶
func (x *SendMessageRequest) GetWorkflowInstanceId() string
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 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. Exclusive bool `protobuf:"varint,2,opt,name=exclusive,proto3" json:"exclusive,omitempty"` // Exclusive - specifies that only the first match should be traversed. // 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) GetExclusive ¶
func (*Targets) ProtoMessage ¶
func (*Targets) ProtoMessage()
func (*Targets) ProtoReflect ¶
func (x *Targets) ProtoReflect() protoreflect.Message
type TelemetryLogEntry ¶ added in v1.0.240
type TelemetryLogEntry struct { TrackingID string `protobuf:"bytes,1,opt,name=trackingID,proto3" json:"trackingID,omitempty"` Source LogSource `protobuf:"varint,2,opt,name=source,proto3,enum=LogSource" json:"source,omitempty"` Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` Code int32 `protobuf:"varint,4,opt,name=code,proto3" json:"code,omitempty"` Attributes map[string]string `` /* 161-byte string literal not displayed */ // contains filtered or unexported fields }
func (*TelemetryLogEntry) Descriptor
deprecated
added in
v1.0.240
func (*TelemetryLogEntry) Descriptor() ([]byte, []int)
Deprecated: Use TelemetryLogEntry.ProtoReflect.Descriptor instead.
func (*TelemetryLogEntry) GetAttributes ¶ added in v1.0.240
func (x *TelemetryLogEntry) GetAttributes() map[string]string
func (*TelemetryLogEntry) GetCode ¶ added in v1.0.271
func (x *TelemetryLogEntry) GetCode() int32
func (*TelemetryLogEntry) GetMessage ¶ added in v1.0.240
func (x *TelemetryLogEntry) GetMessage() string
func (*TelemetryLogEntry) GetSource ¶ added in v1.0.271
func (x *TelemetryLogEntry) GetSource() LogSource
func (*TelemetryLogEntry) GetTrackingID ¶ added in v1.0.271
func (x *TelemetryLogEntry) GetTrackingID() string
func (*TelemetryLogEntry) ProtoMessage ¶ added in v1.0.240
func (*TelemetryLogEntry) ProtoMessage()
func (*TelemetryLogEntry) ProtoReflect ¶ added in v1.0.240
func (x *TelemetryLogEntry) ProtoReflect() protoreflect.Message
func (*TelemetryLogEntry) Reset ¶ added in v1.0.240
func (x *TelemetryLogEntry) Reset()
func (*TelemetryLogEntry) String ¶ added in v1.0.240
func (x *TelemetryLogEntry) String() string
type TelemetryState ¶ added in v1.0.240
type TelemetryState struct { State *WorkflowState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"` Log map[int64]*TelemetryLogEntry `` /* 148-byte string literal not displayed */ // contains filtered or unexported fields }
func (*TelemetryState) Descriptor
deprecated
added in
v1.0.240
func (*TelemetryState) Descriptor() ([]byte, []int)
Deprecated: Use TelemetryState.ProtoReflect.Descriptor instead.
func (*TelemetryState) GetLog ¶ added in v1.0.240
func (x *TelemetryState) GetLog() map[int64]*TelemetryLogEntry
func (*TelemetryState) GetState ¶ added in v1.0.240
func (x *TelemetryState) GetState() *WorkflowState
func (*TelemetryState) ProtoMessage ¶ added in v1.0.240
func (*TelemetryState) ProtoMessage()
func (*TelemetryState) ProtoReflect ¶ added in v1.0.240
func (x *TelemetryState) ProtoReflect() protoreflect.Message
func (*TelemetryState) Reset ¶ added in v1.0.240
func (x *TelemetryState) Reset()
func (*TelemetryState) String ¶ added in v1.0.240
func (x *TelemetryState) String() string
type Timer ¶ added in v1.0.235
type Timer struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Id - the unique identifier for the timer. Duration string `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"` // Duration - the duration of the timer. Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` // Target - state machine element ID to transition to. OutputTransform map[string]string `` // OutputTransform - The transformation to apply to variables during the transition. /* 171-byte string literal not displayed */ // contains filtered or unexported fields }
Timer specifies a timed transition to another state.
func (*Timer) Descriptor
deprecated
added in
v1.0.235
func (*Timer) GetDuration ¶ added in v1.0.235
func (*Timer) GetOutputTransform ¶ added in v1.0.251
func (*Timer) ProtoMessage ¶ added in v1.0.235
func (*Timer) ProtoMessage()
func (*Timer) ProtoReflect ¶ added in v1.0.235
func (x *Timer) ProtoReflect() protoreflect.Message
type UserTasks ¶ added in v0.1.86
type UserTasks struct { Id []string `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*UserTasks) Descriptor
deprecated
added in
v0.1.86
func (*UserTasks) ProtoMessage ¶ added in v0.1.86
func (*UserTasks) ProtoMessage()
func (*UserTasks) ProtoReflect ¶ added in v0.1.86
func (x *UserTasks) ProtoReflect() protoreflect.Message
type Vars ¶
Vars is a map of variables. The variables must be primitive go types.
func (Vars) GetBool ¶ added in v1.0.396
GetBool validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetByte ¶ added in v1.0.396
GetByte validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetBytes ¶ added in v1.0.396
GetBytes validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetFloat32 ¶ added in v1.0.396
GetFloat32 validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetFloat64 ¶ added in v1.0.396
GetFloat64 validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetInt ¶ added in v1.0.396
GetInt validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetInt16 ¶ added in v1.0.396
GetInt16 validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetInt32 ¶ added in v1.0.396
GetInt32 validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
func (Vars) GetInt64 ¶ added in v1.0.396
GetInt64 validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.
type Workflow ¶
type Workflow struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Name defines the common name that describes the workflow. Process map[string]*Process `` // Process is a map of process names to workflow state machines. /* 155-byte string literal not displayed */ Messages []*Element `protobuf:"bytes,3,rep,name=messages,proto3" json:"messages,omitempty"` // Messages define the messages that can be sent by the workflow. Errors []*Error `protobuf:"bytes,4,rep,name=errors,proto3" json:"errors,omitempty"` // Errors define the errors used by the workflow. GzipSource []byte `protobuf:"bytes,5,opt,name=gzipSource,proto3" json:"gzipSource,omitempty"` // Source for round tripping. // 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) GetGzipSource ¶ added in v1.0.366
func (*Workflow) GetMessages ¶
func (*Workflow) GetProcess ¶
func (*Workflow) ProtoMessage ¶
func (*Workflow) ProtoMessage()
func (*Workflow) ProtoReflect ¶
func (x *Workflow) ProtoReflect() protoreflect.Message
type WorkflowInstance ¶
type WorkflowInstance struct { WorkflowInstanceId string `protobuf:"bytes,1,opt,name=workflowInstanceId,proto3" json:"workflowInstanceId,omitempty"` // WorkflowInstanceId - the unique ID for the workflow instance. ParentWorkflowInstanceId *string `protobuf:"bytes,2,opt,name=parentWorkflowInstanceId,proto3,oneof" json:"parentWorkflowInstanceId,omitempty"` // ParentWorkflowInstanceId - the workflow instance ID of the workflow that launched this instance. ParentElementId *string `protobuf:"bytes,3,opt,name=parentElementId,proto3,oneof" json:"parentElementId,omitempty"` // ParentElementId - the ID of the element in the parent workflow that triggered the launch of this instance. WorkflowId string `protobuf:"bytes,4,opt,name=workflowId,proto3" json:"workflowId,omitempty"` // WorkflowId - the workflow version ID that this instance is executing. InFlight map[string]bool `` // InFlight - active state machine states inside the workflow instance. /* 158-byte string literal not displayed */ WorkflowName string `protobuf:"bytes,7,opt,name=workflowName,proto3" json:"workflowName,omitempty"` // WorkflowName - name of this workflow to avoid lookups. // contains filtered or unexported fields }
WorkflowInstance contains all of the metadata for a currently running workflow instance.
func (*WorkflowInstance) Descriptor
deprecated
func (*WorkflowInstance) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowInstance.ProtoReflect.Descriptor instead.
func (*WorkflowInstance) GetInFlight ¶ added in v1.0.235
func (x *WorkflowInstance) GetInFlight() map[string]bool
func (*WorkflowInstance) GetParentElementId ¶
func (x *WorkflowInstance) GetParentElementId() string
func (*WorkflowInstance) GetParentWorkflowInstanceId ¶
func (x *WorkflowInstance) GetParentWorkflowInstanceId() string
func (*WorkflowInstance) GetWorkflowId ¶
func (x *WorkflowInstance) GetWorkflowId() string
func (*WorkflowInstance) GetWorkflowInstanceId ¶
func (x *WorkflowInstance) GetWorkflowInstanceId() string
func (*WorkflowInstance) GetWorkflowName ¶ added in v1.0.362
func (x *WorkflowInstance) GetWorkflowName() string
func (*WorkflowInstance) ProtoMessage ¶
func (*WorkflowInstance) ProtoMessage()
func (*WorkflowInstance) ProtoReflect ¶
func (x *WorkflowInstance) ProtoReflect() protoreflect.Message
func (*WorkflowInstance) Reset ¶
func (x *WorkflowInstance) Reset()
func (*WorkflowInstance) String ¶
func (x *WorkflowInstance) String() string
type WorkflowInstanceComplete ¶ added in v0.1.66
type WorkflowInstanceComplete struct { WorkflowName string `protobuf:"bytes,1,opt,name=workflowName,proto3" json:"workflowName,omitempty"` WorkflowId string `protobuf:"bytes,2,opt,name=workflowId,proto3" json:"workflowId,omitempty"` WorkflowInstanceId string `protobuf:"bytes,3,opt,name=workflowInstanceId,proto3" json:"workflowInstanceId,omitempty"` WorkflowState CancellationState `protobuf:"varint,4,opt,name=workflowState,proto3,enum=CancellationState" json:"workflowState,omitempty"` Error *Error `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*WorkflowInstanceComplete) Descriptor
deprecated
added in
v0.1.66
func (*WorkflowInstanceComplete) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowInstanceComplete.ProtoReflect.Descriptor instead.
func (*WorkflowInstanceComplete) GetError ¶ added in v0.1.134
func (x *WorkflowInstanceComplete) GetError() *Error
func (*WorkflowInstanceComplete) GetWorkflowId ¶ added in v0.1.66
func (x *WorkflowInstanceComplete) GetWorkflowId() string
func (*WorkflowInstanceComplete) GetWorkflowInstanceId ¶ added in v0.1.66
func (x *WorkflowInstanceComplete) GetWorkflowInstanceId() string
func (*WorkflowInstanceComplete) GetWorkflowName ¶ added in v0.1.66
func (x *WorkflowInstanceComplete) GetWorkflowName() string
func (*WorkflowInstanceComplete) GetWorkflowState ¶ added in v0.1.134
func (x *WorkflowInstanceComplete) GetWorkflowState() CancellationState
func (*WorkflowInstanceComplete) ProtoMessage ¶ added in v0.1.66
func (*WorkflowInstanceComplete) ProtoMessage()
func (*WorkflowInstanceComplete) ProtoReflect ¶ added in v0.1.66
func (x *WorkflowInstanceComplete) ProtoReflect() protoreflect.Message
func (*WorkflowInstanceComplete) Reset ¶ added in v0.1.66
func (x *WorkflowInstanceComplete) Reset()
func (*WorkflowInstanceComplete) String ¶ added in v0.1.66
func (x *WorkflowInstanceComplete) String() string
type WorkflowInstanceInfo ¶
type WorkflowInstanceInfo struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` WorkflowId string `protobuf:"bytes,2,opt,name=workflowId,proto3" json:"workflowId,omitempty"` // contains filtered or unexported fields }
func (*WorkflowInstanceInfo) Descriptor
deprecated
func (*WorkflowInstanceInfo) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowInstanceInfo.ProtoReflect.Descriptor instead.
func (*WorkflowInstanceInfo) GetId ¶
func (x *WorkflowInstanceInfo) GetId() string
func (*WorkflowInstanceInfo) GetWorkflowId ¶
func (x *WorkflowInstanceInfo) GetWorkflowId() string
func (*WorkflowInstanceInfo) ProtoMessage ¶
func (*WorkflowInstanceInfo) ProtoMessage()
func (*WorkflowInstanceInfo) ProtoReflect ¶
func (x *WorkflowInstanceInfo) ProtoReflect() protoreflect.Message
func (*WorkflowInstanceInfo) Reset ¶
func (x *WorkflowInstanceInfo) Reset()
func (*WorkflowInstanceInfo) String ¶
func (x *WorkflowInstanceInfo) String() string
type WorkflowInstanceStatus ¶
type WorkflowInstanceStatus struct { State []*WorkflowState `protobuf:"bytes,1,rep,name=state,proto3" json:"state,omitempty"` // contains filtered or unexported fields }
func (*WorkflowInstanceStatus) Descriptor
deprecated
func (*WorkflowInstanceStatus) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowInstanceStatus.ProtoReflect.Descriptor instead.
func (*WorkflowInstanceStatus) GetState ¶
func (x *WorkflowInstanceStatus) GetState() []*WorkflowState
func (*WorkflowInstanceStatus) ProtoMessage ¶
func (*WorkflowInstanceStatus) ProtoMessage()
func (*WorkflowInstanceStatus) ProtoReflect ¶
func (x *WorkflowInstanceStatus) ProtoReflect() protoreflect.Message
func (*WorkflowInstanceStatus) Reset ¶
func (x *WorkflowInstanceStatus) Reset()
func (*WorkflowInstanceStatus) String ¶
func (x *WorkflowInstanceStatus) String() string
type WorkflowInstanceSubscribers ¶
type WorkflowInstanceSubscribers struct { List []string `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"` // contains filtered or unexported fields }
func (*WorkflowInstanceSubscribers) Descriptor
deprecated
func (*WorkflowInstanceSubscribers) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowInstanceSubscribers.ProtoReflect.Descriptor instead.
func (*WorkflowInstanceSubscribers) GetList ¶
func (x *WorkflowInstanceSubscribers) GetList() []string
func (*WorkflowInstanceSubscribers) ProtoMessage ¶
func (*WorkflowInstanceSubscribers) ProtoMessage()
func (*WorkflowInstanceSubscribers) ProtoReflect ¶
func (x *WorkflowInstanceSubscribers) ProtoReflect() protoreflect.Message
func (*WorkflowInstanceSubscribers) Reset ¶
func (x *WorkflowInstanceSubscribers) Reset()
func (*WorkflowInstanceSubscribers) String ¶
func (x *WorkflowInstanceSubscribers) 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. WorkflowInstanceId string `protobuf:"bytes,2,opt,name=workflowInstanceId,proto3" json:"workflowInstanceId,omitempty"` // WorkflowInstanceId - the workflow instance 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 descibe the state and its parents up to the original workflow instance ID. Execute *string `protobuf:"bytes,7,opt,name=execute,proto3,oneof" json:"execute,omitempty"` // Execute - additional information required to execute depending on the element type. State CancellationState `protobuf:"varint,8,opt,name=state,proto3,enum=CancellationState" json:"state,omitempty"` // State - the current execution state of the state machine. Condition *string `protobuf:"bytes,9,opt,name=condition,proto3,oneof" json:"condition,omitempty"` // Condition - a message condition that needs to be fulfilled before proceeding. UnixTimeNano int64 `protobuf:"varint,10,opt,name=unixTimeNano,proto3" json:"unixTimeNano,omitempty"` // UnixTimeNano - the time this state was observed. Vars []byte `protobuf:"bytes,11,opt,name=vars,proto3" json:"vars,omitempty"` // Vars - A go binary encoded map[string]interface{} of variables. 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. // contains filtered or unexported fields }
WorkflowState describes a current executing state inside a workflow state machine.
func (*WorkflowState) Descriptor
deprecated
func (*WorkflowState) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowState.ProtoReflect.Descriptor instead.
func (*WorkflowState) GetCondition ¶
func (x *WorkflowState) GetCondition() string
func (*WorkflowState) GetElementId ¶
func (x *WorkflowState) GetElementId() string
func (*WorkflowState) GetElementType ¶
func (x *WorkflowState) GetElementType() string
func (*WorkflowState) GetError ¶ added in v0.1.134
func (x *WorkflowState) GetError() *Error
func (*WorkflowState) GetExecute ¶
func (x *WorkflowState) GetExecute() string
func (*WorkflowState) GetGroups ¶ added in v0.1.86
func (x *WorkflowState) GetGroups() []string
func (*WorkflowState) GetId ¶ added in v0.1.78
func (x *WorkflowState) GetId() []string
func (*WorkflowState) GetOwners ¶ added in v0.1.86
func (x *WorkflowState) GetOwners() []string
func (*WorkflowState) GetState ¶
func (x *WorkflowState) GetState() CancellationState
func (*WorkflowState) GetTimer ¶ added in v0.1.181
func (x *WorkflowState) GetTimer() *WorkflowTimer
func (*WorkflowState) GetUnixTimeNano ¶
func (x *WorkflowState) GetUnixTimeNano() int64
func (*WorkflowState) GetVars ¶
func (x *WorkflowState) GetVars() []byte
func (*WorkflowState) GetWorkflowId ¶
func (x *WorkflowState) GetWorkflowId() string
func (*WorkflowState) GetWorkflowInstanceId ¶
func (x *WorkflowState) GetWorkflowInstanceId() 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 WorkflowStats ¶ added in v0.1.134
type WorkflowStats struct { Workflows int64 `protobuf:"varint,1,opt,name=Workflows,proto3" json:"Workflows,omitempty"` InstancesStarted int64 `protobuf:"varint,2,opt,name=InstancesStarted,proto3" json:"InstancesStarted,omitempty"` InstancesComplete int64 `protobuf:"varint,3,opt,name=InstancesComplete,proto3" json:"InstancesComplete,omitempty"` // contains filtered or unexported fields }
func (*WorkflowStats) Descriptor
deprecated
added in
v0.1.134
func (*WorkflowStats) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowStats.ProtoReflect.Descriptor instead.
func (*WorkflowStats) GetInstancesComplete ¶ added in v0.1.134
func (x *WorkflowStats) GetInstancesComplete() int64
func (*WorkflowStats) GetInstancesStarted ¶ added in v0.1.134
func (x *WorkflowStats) GetInstancesStarted() int64
func (*WorkflowStats) GetWorkflows ¶ added in v0.1.134
func (x *WorkflowStats) GetWorkflows() int64
func (*WorkflowStats) ProtoMessage ¶ added in v0.1.134
func (*WorkflowStats) ProtoMessage()
func (*WorkflowStats) ProtoReflect ¶ added in v0.1.134
func (x *WorkflowStats) ProtoReflect() protoreflect.Message
func (*WorkflowStats) Reset ¶ added in v0.1.134
func (x *WorkflowStats) Reset()
func (*WorkflowStats) String ¶ added in v0.1.134
func (x *WorkflowStats) String() string
type WorkflowTimer ¶ added in v0.1.181
type WorkflowTimer struct { LastFired int64 `protobuf:"varint,1,opt,name=lastFired,proto3" json:"lastFired,omitempty"` // LastFired - the time in UNIX nanoseconds since the timer was last executed. Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` // Count - the number of times the timer has fired. // contains filtered or unexported fields }
WorkflowTimer holds the last execution state of a timer.
func (*WorkflowTimer) Descriptor
deprecated
added in
v0.1.181
func (*WorkflowTimer) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowTimer.ProtoReflect.Descriptor instead.
func (*WorkflowTimer) GetCount ¶ added in v0.1.181
func (x *WorkflowTimer) GetCount() int64
func (*WorkflowTimer) GetLastFired ¶ added in v0.1.181
func (x *WorkflowTimer) GetLastFired() int64
func (*WorkflowTimer) ProtoMessage ¶ added in v0.1.181
func (*WorkflowTimer) ProtoMessage()
func (*WorkflowTimer) ProtoReflect ¶ added in v0.1.181
func (x *WorkflowTimer) ProtoReflect() protoreflect.Message
func (*WorkflowTimer) Reset ¶ added in v0.1.181
func (x *WorkflowTimer) Reset()
func (*WorkflowTimer) String ¶ added in v0.1.181
func (x *WorkflowTimer) String() string
type WorkflowTimerDefinition ¶ added in v0.1.181
type WorkflowTimerDefinition struct { Type WorkflowTimerType `protobuf:"varint,1,opt,name=type,proto3,enum=WorkflowTimerType" json:"type,omitempty"` // Type - whether the workflow timer is relative or absolute. Value int64 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"` // Value - the time parameter. Repeat int64 `protobuf:"varint,3,opt,name=repeat,proto3" json:"repeat,omitempty"` // Repeat - the repeat interval for the timer. DropEvents bool `protobuf:"varint,4,opt,name=dropEvents,proto3" json:"dropEvents,omitempty"` // DropEvents - unused. // contains filtered or unexported fields }
WorkflowTimerDefinition defines a workflow timer that can be used to trigger an event.
func (*WorkflowTimerDefinition) Descriptor
deprecated
added in
v0.1.181
func (*WorkflowTimerDefinition) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowTimerDefinition.ProtoReflect.Descriptor instead.
func (*WorkflowTimerDefinition) GetDropEvents ¶ added in v0.1.181
func (x *WorkflowTimerDefinition) GetDropEvents() bool
func (*WorkflowTimerDefinition) GetRepeat ¶ added in v0.1.181
func (x *WorkflowTimerDefinition) GetRepeat() int64
func (*WorkflowTimerDefinition) GetType ¶ added in v0.1.181
func (x *WorkflowTimerDefinition) GetType() WorkflowTimerType
func (*WorkflowTimerDefinition) GetValue ¶ added in v0.1.181
func (x *WorkflowTimerDefinition) GetValue() int64
func (*WorkflowTimerDefinition) ProtoMessage ¶ added in v0.1.181
func (*WorkflowTimerDefinition) ProtoMessage()
func (*WorkflowTimerDefinition) ProtoReflect ¶ added in v0.1.181
func (x *WorkflowTimerDefinition) ProtoReflect() protoreflect.Message
func (*WorkflowTimerDefinition) Reset ¶ added in v0.1.181
func (x *WorkflowTimerDefinition) Reset()
func (*WorkflowTimerDefinition) String ¶ added in v0.1.181
func (x *WorkflowTimerDefinition) String() string
type WorkflowTimerType ¶ added in v0.1.181
type WorkflowTimerType int32
WorkflowTimerType describes whether a timer is relative or absolute
const ( WorkflowTimerType_duration WorkflowTimerType = 0 // Duration - a relative timer WorkflowTimerType_fixed WorkflowTimerType = 1 // Fixed - an absolute timer )
func (WorkflowTimerType) Descriptor ¶ added in v0.1.181
func (WorkflowTimerType) Descriptor() protoreflect.EnumDescriptor
func (WorkflowTimerType) Enum ¶ added in v0.1.181
func (x WorkflowTimerType) Enum() *WorkflowTimerType
func (WorkflowTimerType) EnumDescriptor
deprecated
added in
v0.1.181
func (WorkflowTimerType) EnumDescriptor() ([]byte, []int)
Deprecated: Use WorkflowTimerType.Descriptor instead.
func (WorkflowTimerType) Number ¶ added in v0.1.181
func (x WorkflowTimerType) Number() protoreflect.EnumNumber
func (WorkflowTimerType) String ¶ added in v0.1.181
func (x WorkflowTimerType) String() string
func (WorkflowTimerType) Type ¶ added in v0.1.181
func (WorkflowTimerType) Type() protoreflect.EnumType
type WorkflowVersion ¶
type WorkflowVersion struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Id - the launchable ID for the workflow. Sha256 []byte `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"` // Sha256 - the hash of the workflow configuration. Number int32 `protobuf:"varint,3,opt,name=number,proto3" json:"number,omitempty"` // Number - the version number of the workflow // contains filtered or unexported fields }
WorkflowVersion contains the metadata for a single workflow version
func (*WorkflowVersion) Descriptor
deprecated
func (*WorkflowVersion) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowVersion.ProtoReflect.Descriptor instead.
func (*WorkflowVersion) GetId ¶
func (x *WorkflowVersion) GetId() string
func (*WorkflowVersion) GetNumber ¶
func (x *WorkflowVersion) GetNumber() int32
func (*WorkflowVersion) GetSha256 ¶
func (x *WorkflowVersion) GetSha256() []byte
func (*WorkflowVersion) ProtoMessage ¶
func (*WorkflowVersion) ProtoMessage()
func (*WorkflowVersion) ProtoReflect ¶
func (x *WorkflowVersion) ProtoReflect() protoreflect.Message
func (*WorkflowVersion) Reset ¶
func (x *WorkflowVersion) Reset()
func (*WorkflowVersion) String ¶
func (x *WorkflowVersion) String() string
type WorkflowVersions ¶
type WorkflowVersions struct { Version []*WorkflowVersion `protobuf:"bytes,1,rep,name=version,proto3" json:"version,omitempty"` // WorkflowVersion - a single version of a workflow // contains filtered or unexported fields }
WorkflowVersions describes the version history.
func (*WorkflowVersions) Descriptor
deprecated
func (*WorkflowVersions) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowVersions.ProtoReflect.Descriptor instead.
func (*WorkflowVersions) GetVersion ¶
func (x *WorkflowVersions) GetVersion() []*WorkflowVersion
func (*WorkflowVersions) ProtoMessage ¶
func (*WorkflowVersions) ProtoMessage()
func (*WorkflowVersions) ProtoReflect ¶
func (x *WorkflowVersions) ProtoReflect() protoreflect.Message
func (*WorkflowVersions) Reset ¶
func (x *WorkflowVersions) Reset()
func (*WorkflowVersions) String ¶
func (x *WorkflowVersions) String() string