model

package
v1.0.396 Latest Latest
Warning

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

Go to latest
Published: Jan 11, 2023 License: MIT Imports: 5 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

func Get added in v1.0.396

func Get[V any](vars Vars, key string) (V, error)

Get takes the desired return type as parameter and safely searches the map and returns the value if it is found and is of the desired type.

Types

type ApiAuthenticationRequest added in v1.0.362

type ApiAuthenticationRequest struct {
	Headers map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ApiAuthenticationRequest) Descriptor deprecated added in v1.0.362

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

Deprecated: Use ApiAuthenticationRequest.ProtoReflect.Descriptor instead.

func (*ApiAuthenticationRequest) GetHeaders added in v1.0.362

func (x *ApiAuthenticationRequest) GetHeaders() map[string]string

func (*ApiAuthenticationRequest) ProtoMessage added in v1.0.362

func (*ApiAuthenticationRequest) ProtoMessage()

func (*ApiAuthenticationRequest) ProtoReflect added in v1.0.362

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

func (*ApiAuthenticationRequest) Reset added in v1.0.362

func (x *ApiAuthenticationRequest) Reset()

func (*ApiAuthenticationRequest) String added in v1.0.362

func (x *ApiAuthenticationRequest) String() string

type ApiAuthenticationResponse added in v1.0.362

type ApiAuthenticationResponse struct {
	User          string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Authenticated bool   `protobuf:"varint,2,opt,name=Authenticated,proto3" json:"Authenticated,omitempty"`
	// contains filtered or unexported fields
}

func (*ApiAuthenticationResponse) Descriptor deprecated added in v1.0.362

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

Deprecated: Use ApiAuthenticationResponse.ProtoReflect.Descriptor instead.

func (*ApiAuthenticationResponse) GetAuthenticated added in v1.0.362

func (x *ApiAuthenticationResponse) GetAuthenticated() bool

func (*ApiAuthenticationResponse) GetUser added in v1.0.362

func (x *ApiAuthenticationResponse) GetUser() string

func (*ApiAuthenticationResponse) ProtoMessage added in v1.0.362

func (*ApiAuthenticationResponse) ProtoMessage()

func (*ApiAuthenticationResponse) ProtoReflect added in v1.0.362

func (*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 (*CancelWorkflowInstanceRequest) GetState added in v0.1.134

func (*CancelWorkflowInstanceRequest) ProtoMessage

func (*CancelWorkflowInstanceRequest) ProtoMessage()

func (*CancelWorkflowInstanceRequest) ProtoReflect

func (*CancelWorkflowInstanceRequest) Reset

func (x *CancelWorkflowInstanceRequest) Reset()

func (*CancelWorkflowInstanceRequest) 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) Enum added in v0.1.134

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 (CancellationState) String added in v0.1.134

func (x CancellationState) String() string

func (CancellationState) Type added in v0.1.134

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 (*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 (*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 (*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 (*GetMessageSenderRoutingIdRequest) Reset added in v0.1.167

func (*GetMessageSenderRoutingIdRequest) String added in v0.1.167

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 (*GetWorkflowInstanceStatusRequest) ProtoMessage

func (*GetWorkflowInstanceStatusRequest) ProtoMessage()

func (*GetWorkflowInstanceStatusRequest) ProtoReflect

func (*GetWorkflowInstanceStatusRequest) Reset

func (*GetWorkflowInstanceStatusRequest) 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 (*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 (*GetWorkflowVersionsResponse) ProtoMessage added in v1.0.366

func (*GetWorkflowVersionsResponse) ProtoMessage()

func (*GetWorkflowVersionsResponse) ProtoReflect added in v1.0.366

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 (*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 (*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 (*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 (*ListWorkflowInstanceResponse) ProtoMessage

func (*ListWorkflowInstanceResponse) ProtoMessage()

func (*ListWorkflowInstanceResponse) ProtoReflect

func (*ListWorkflowInstanceResponse) Reset

func (x *ListWorkflowInstanceResponse) Reset()

func (*ListWorkflowInstanceResponse) 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 (*ListWorkflowInstanceResult) GetVersion

func (x *ListWorkflowInstanceResult) GetVersion() int32

func (*ListWorkflowInstanceResult) ProtoMessage

func (*ListWorkflowInstanceResult) ProtoMessage()

func (*ListWorkflowInstanceResult) ProtoReflect

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

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 primitive go types.

func (Vars) GetBool added in v1.0.396

func (vars Vars) GetBool(key string) (bool, error)

GetBool validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.

func (Vars) GetByte added in v1.0.396

func (vars Vars) GetByte(key string) ([]byte, error)

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

func (vars Vars) GetBytes(key string) ([]byte, error)

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

func (vars Vars) GetFloat32(key string) (float32, error)

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

func (vars Vars) GetFloat64(key string) (float64, error)

GetFloat64 validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.

func (Vars) GetInt added in v1.0.396

func (vars Vars) GetInt(key string) (int, error)

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

func (vars Vars) GetInt16(key string) (int16, error)

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

func (vars Vars) GetInt32(key string) (int32, error)

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

func (vars Vars) GetInt64(key string) (int64, error)

GetInt64 validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.

func (Vars) GetInt8 added in v1.0.396

func (vars Vars) GetInt8(key string) (int8, error)

GetInt8 validates that a key has an underlying value in the map[int]interface{} vars and safely returns the result.

func (Vars) GetString added in v1.0.396

func (vars Vars) GetString(key string) (string, error)

GetString validates that a key has an underlying value in the map[string]interface{} vars and safely returns the result.

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

Deprecated: Use Workflow.ProtoReflect.Descriptor instead.

func (*Workflow) GetErrors added in v0.1.134

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

func (*Workflow) GetGzipSource added in v1.0.366

func (x *Workflow) GetGzipSource() []byte

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 */
	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 (*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 (*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) Enum added in v0.1.181

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 (WorkflowTimerType) String added in v0.1.181

func (x WorkflowTimerType) String() string

func (WorkflowTimerType) Type added in v0.1.181

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL