model

package
v1.0.312 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 30, 2022 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	WorkflowTimerType_name = map[int32]string{
		0: "duration",
		1: "fixed",
	}
	WorkflowTimerType_value = map[string]int32{
		"duration": 0,
		"fixed":    1,
	}
)

Enum value maps for WorkflowTimerType.

View Source 
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.

View Source 
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.

View Source 
var File_shar_workflow_models_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

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) Descriptor() ([]byte, []int)

Deprecated: Use Element.ProtoReflect.Descriptor instead.

func (*Element) GetBoundaryTimer added in v1.0.235 

func (x *Element) GetBoundaryTimer() []*Timer

func (*Element) GetCandidateGroups added in v0.1.86 

func (x *Element) GetCandidateGroups() string

func (*Element) GetCandidates added in v0.1.86 

func (x *Element) GetCandidates() string

func (*Element) GetDocumentation 

func (x *Element) GetDocumentation() string

func (*Element) GetError added in v0.1.134 

func (x *Element) GetError() *Error

func (*Element) GetErrors added in v0.1.134 

func (x *Element) GetErrors() []*CatchError

func (*Element) GetExecute 

func (x *Element) GetExecute() string

func (*Element) GetId 

func (x *Element) GetId() string

func (*Element) GetInputTransform added in v0.1.175 

func (x *Element) GetInputTransform() map[string]string

func (*Element) GetMsg 

func (x *Element) GetMsg() string

func (*Element) GetName 

func (x *Element) GetName() string

func (*Element) GetOutbound 

func (x *Element) GetOutbound() *Targets

func (*Element) GetOutputTransform added in v0.1.175 

func (x *Element) GetOutputTransform() map[string]string

func (*Element) GetProcess 

func (x *Element) GetProcess() *Process

func (*Element) GetRetries added in v0.1.74 

func (x *Element) GetRetries() string

func (*Element) GetTimer added in v0.1.181 

func (x *Element) GetTimer() *WorkflowTimerDefinition

func (*Element) GetType 

func (x *Element) GetType() string

func (*Element) ProtoMessage 

func (*Element) ProtoMessage()

func (*Element) ProtoReflect 

func (x *Element) ProtoReflect() protoreflect.Message

func (*Element) Reset 

func (x *Element) Reset()

func (*Element) String 

func (x *Element) String() string

type Error added in v0.1.134 

type Error struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`     // Id - the unique id for the error.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Name - the error unique name.
	Code string `protobuf:"bytes,3,opt,name=code,proto3" json:"code,omitempty"` // Code - the unique code for the error.
	// contains filtered or unexported fields
}

Error represents a known error name and code which may be thrown by the state machine.

func (*Error) Descriptor deprecated added in v0.1.134 

func (*Error) Descriptor() ([]byte, []int)

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetCode added in v0.1.134 

func (x *Error) GetCode() string

func (*Error) GetId added in v0.1.134 

func (x *Error) GetId() string

func (*Error) GetName added in v0.1.134 

func (x *Error) GetName() string

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

func (*Error) Reset added in v0.1.134 

func (x *Error) Reset()

func (*Error) String added in v0.1.134 

func (x *Error) String() string

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 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 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
const (
	LogSource_logSourceEngine   LogSource = 0
	LogSource_logSourceWorkflow LogSource = 2
	LogSource_logSourceClient   LogSource = 3
	LogSource_logSourceJob      LogSource = 4
)

func (LogSource) Descriptor added in v1.0.271 

func (LogSource) Descriptor() protoreflect.EnumDescriptor

func (LogSource) Enum added in v1.0.271 

func (x LogSource) Enum() *LogSource

func (LogSource) EnumDescriptor deprecated added in v1.0.271 

func (LogSource) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogSource.Descriptor instead.

func (LogSource) Number added in v1.0.271 

func (x LogSource) Number() protoreflect.EnumNumber

func (LogSource) String added in v1.0.271 

func (x LogSource) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Process.ProtoReflect.Descriptor instead.

func (*Process) GetElements 

func (x *Process) GetElements() []*Element

func (*Process) GetName 

func (x *Process) GetName() string

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) ProtoReflect 

func (x *Process) ProtoReflect() protoreflect.Message

func (*Process) Reset 

func (x *Process) Reset()

func (*Process) String 

func (x *Process) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Target.ProtoReflect.Descriptor instead.

func (*Target) GetConditions 

func (x *Target) GetConditions() []string

func (*Target) GetId 

func (x *Target) GetId() string

func (*Target) GetTarget 

func (x *Target) GetTarget() string

func (*Target) ProtoMessage 

func (*Target) ProtoMessage()

func (*Target) ProtoReflect 

func (x *Target) ProtoReflect() protoreflect.Message

func (*Target) Reset 

func (x *Target) Reset()

func (*Target) String 

func (x *Target) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Targets.ProtoReflect.Descriptor instead.

func (*Targets) GetExclusive 

func (x *Targets) GetExclusive() bool

func (*Targets) GetTarget 

func (x *Targets) GetTarget() []*Target

func (*Targets) ProtoMessage 

func (*Targets) ProtoMessage()

func (*Targets) ProtoReflect 

func (x *Targets) ProtoReflect() protoreflect.Message

func (*Targets) Reset 

func (x *Targets) Reset()

func (*Targets) String 

func (x *Targets) String() string

type TelemetryLogEntry added in v1.0.240 

type TelemetryLogEntry struct {
	TrackingID string            `protobuf:"bytes,1,opt,name=trackingID,proto3" json:"trackingID,omitempty"`
	Source     LogSource         `protobuf:"varint,2,opt,name=source,proto3,enum=LogSource" json:"source,omitempty"`
	Message    string            `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Code       int32             `protobuf:"varint,4,opt,name=code,proto3" json:"code,omitempty"`
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TelemetryLogEntry) Descriptor deprecated added in v1.0.240 

func (*TelemetryLogEntry) Descriptor() ([]byte, []int)

Deprecated: Use TelemetryLogEntry.ProtoReflect.Descriptor instead.

func (*TelemetryLogEntry) GetAttributes added in v1.0.240 

func (x *TelemetryLogEntry) GetAttributes() map[string]string

func (*TelemetryLogEntry) GetCode added in v1.0.271 

func (x *TelemetryLogEntry) GetCode() int32

func (*TelemetryLogEntry) GetMessage added in v1.0.240 

func (x *TelemetryLogEntry) GetMessage() string

func (*TelemetryLogEntry) GetSource added in v1.0.271 

func (x *TelemetryLogEntry) GetSource() LogSource

func (*TelemetryLogEntry) GetTrackingID added in v1.0.271 

func (x *TelemetryLogEntry) GetTrackingID() string

func (*TelemetryLogEntry) ProtoMessage added in v1.0.240 

func (*TelemetryLogEntry) ProtoMessage()

func (*TelemetryLogEntry) ProtoReflect added in v1.0.240 

func (x *TelemetryLogEntry) ProtoReflect() protoreflect.Message

func (*TelemetryLogEntry) Reset added in v1.0.240 

func (x *TelemetryLogEntry) Reset()

func (*TelemetryLogEntry) String added in v1.0.240 

func (x *TelemetryLogEntry) String() string

type TelemetryState added in v1.0.240 

type TelemetryState struct {
	State *WorkflowState               `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	Log   map[int64]*TelemetryLogEntry `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TelemetryState) Descriptor deprecated added in v1.0.240 

func (*TelemetryState) Descriptor() ([]byte, []int)

Deprecated: Use TelemetryState.ProtoReflect.Descriptor instead.

func (*TelemetryState) GetLog added in v1.0.240 

func (x *TelemetryState) GetLog() map[int64]*TelemetryLogEntry

func (*TelemetryState) GetState added in v1.0.240 

func (x *TelemetryState) GetState() *WorkflowState

func (*TelemetryState) ProtoMessage added in v1.0.240 

func (*TelemetryState) ProtoMessage()

func (*TelemetryState) ProtoReflect added in v1.0.240 

func (x *TelemetryState) ProtoReflect() protoreflect.Message

func (*TelemetryState) Reset added in v1.0.240 

func (x *TelemetryState) Reset()

func (*TelemetryState) String added in v1.0.240 

func (x *TelemetryState) String() string

type 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) Descriptor() ([]byte, []int)

Deprecated: Use Timer.ProtoReflect.Descriptor instead.

func (*Timer) GetDuration added in v1.0.235 

func (x *Timer) GetDuration() string

func (*Timer) GetId added in v1.0.235 

func (x *Timer) GetId() string

func (*Timer) GetOutputTransform added in v1.0.251 

func (x *Timer) GetOutputTransform() map[string]string

func (*Timer) GetTarget added in v1.0.235 

func (x *Timer) GetTarget() string

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

func (*Timer) Reset added in v1.0.235 

func (x *Timer) Reset()

func (*Timer) String added in v1.0.235 

func (x *Timer) String() string

type UserTasks added in v0.1.86 

type UserTasks struct {
	Id []string `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*UserTasks) Descriptor deprecated added in v0.1.86 

func (*UserTasks) Descriptor() ([]byte, []int)

Deprecated: Use UserTasks.ProtoReflect.Descriptor instead.

func (*UserTasks) GetId added in v0.1.86 

func (x *UserTasks) GetId() []string

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

func (*UserTasks) Reset added in v0.1.86 

func (x *UserTasks) Reset()

func (*UserTasks) String added in v0.1.86 

func (x *UserTasks) String() string

type Vars 

type Vars map[string]any

Vars is a map of variables. The variables must be primative go types.

type Workflow 

type Workflow struct {
	Name    string              `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` // Name defines the common name that describes the workflow.
	Process map[string]*Process ``                                                              // Process is a map of process names to workflow state machines.
	/* 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.
	// 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) Descriptor() ([]byte, []int)

Deprecated: Use Workflow.ProtoReflect.Descriptor instead.

func (*Workflow) GetErrors added in v0.1.134 

func (x *Workflow) GetErrors() []*Error

func (*Workflow) GetMessages 

func (x *Workflow) GetMessages() []*Element

func (*Workflow) GetName 

func (x *Workflow) GetName() string

func (*Workflow) GetProcess 

func (x *Workflow) GetProcess() map[string]*Process

func (*Workflow) ProtoMessage 

func (*Workflow) ProtoMessage()

func (*Workflow) ProtoReflect 

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

func (*Workflow) Reset 

func (x *Workflow) Reset()

func (*Workflow) String 

func (x *Workflow) String() string

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 */
	// 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) 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.
	// 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) 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.