model

package
v1.0.446 Latest Latest
Warning

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

 Go to latest Published: Mar 2, 2023 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	GatewayType_name = map[int32]string{
		0: "exclusive",
		1: "inclusive",
		2: "parallel",
	}
	GatewayType_value = map[string]int32{
		"exclusive": 0,
		"inclusive": 1,
		"parallel":  2,
	}
)

Enum value maps for GatewayType.

View Source 
var (
	GatewayDirection_name = map[int32]string{
		0: "divergent",
		1: "convergent",
	}
	GatewayDirection_value = map[string]int32{
		"divergent":  0,
		"convergent": 1,
	}
)

Enum value maps for GatewayDirection.

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.

func Marshal added in v1.0.408 

func Marshal[T any](v *Vars, key string, t *T) error

Marshal marshals a struct into a SHAR compatible map-portable (map[string]interface{}) var

func Unmarshal added in v1.0.408 

func Unmarshal[T any](vars Vars, key string) (*T, error)

Unmarshal unmarshals a SHAR compatible map-portable (map[string]interface{}) var into a struct

Types

type ApiAuthenticationRequest added in v1.0.362 

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

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

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

Deprecated: Use ApiAuthenticationRequest.ProtoReflect.Descriptor instead.

func (*ApiAuthenticationRequest) GetHeaders added in v1.0.362 

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

func (*ApiAuthenticationRequest) ProtoMessage added in v1.0.362 

func (*ApiAuthenticationRequest) ProtoMessage()

func (*ApiAuthenticationRequest) ProtoReflect added in v1.0.362 

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

func (*ApiAuthenticationRequest) Reset added in v1.0.362 

func (x *ApiAuthenticationRequest) Reset()

func (*ApiAuthenticationRequest) String added in v1.0.362 

func (x *ApiAuthenticationRequest) String() string

type ApiAuthenticationResponse added in v1.0.362 

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

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

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

Deprecated: Use ApiAuthenticationResponse.ProtoReflect.Descriptor instead.

func (*ApiAuthenticationResponse) GetAuthenticated added in v1.0.362 

func (x *ApiAuthenticationResponse) GetAuthenticated() bool

func (*ApiAuthenticationResponse) GetUser added in v1.0.362 

func (x *ApiAuthenticationResponse) GetUser() string

func (*ApiAuthenticationResponse) ProtoMessage added in v1.0.362 

func (*ApiAuthenticationResponse) ProtoMessage()

func (*ApiAuthenticationResponse) ProtoReflect added in v1.0.362 

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

func (*ApiAuthenticationResponse) Reset added in v1.0.362 

func (x *ApiAuthenticationResponse) Reset()

func (*ApiAuthenticationResponse) String added in v1.0.362 

func (x *ApiAuthenticationResponse) String() string

type ApiAuthorizationRequest added in v1.0.362 

type ApiAuthorizationRequest struct {
	Headers      map[string]string `` /* 155-byte string literal not displayed */
	Function     string            `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty"`
	WorkflowName string            `protobuf:"bytes,3,opt,name=workflowName,proto3" json:"workflowName,omitempty"`
	User         string            `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use ApiAuthorizationRequest.ProtoReflect.Descriptor instead.

func (*ApiAuthorizationRequest) GetFunction added in v1.0.362 

func (x *ApiAuthorizationRequest) GetFunction() string

func (*ApiAuthorizationRequest) GetHeaders added in v1.0.362 

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

func (*ApiAuthorizationRequest) GetUser added in v1.0.362 

func (x *ApiAuthorizationRequest) GetUser() string

func (*ApiAuthorizationRequest) GetWorkflowName added in v1.0.362 

func (x *ApiAuthorizationRequest) GetWorkflowName() string

func (*ApiAuthorizationRequest) ProtoMessage added in v1.0.362 

func (*ApiAuthorizationRequest) ProtoMessage()

func (*ApiAuthorizationRequest) ProtoReflect added in v1.0.362 

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

func (*ApiAuthorizationRequest) Reset added in v1.0.362 

func (x *ApiAuthorizationRequest) Reset()

func (*ApiAuthorizationRequest) String added in v1.0.362 

func (x *ApiAuthorizationRequest) String() string

type ApiAuthorizationResponse added in v1.0.362 

type ApiAuthorizationResponse struct {
	Authorized bool   `protobuf:"varint,1,opt,name=authorized,proto3" json:"authorized,omitempty"`
	UserId     string `protobuf:"bytes,2,opt,name=userId,proto3" json:"userId,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use ApiAuthorizationResponse.ProtoReflect.Descriptor instead.

func (*ApiAuthorizationResponse) GetAuthorized added in v1.0.362 

func (x *ApiAuthorizationResponse) GetAuthorized() bool

func (*ApiAuthorizationResponse) GetUserId added in v1.0.362 

func (x *ApiAuthorizationResponse) GetUserId() string

func (*ApiAuthorizationResponse) ProtoMessage added in v1.0.362 

func (*ApiAuthorizationResponse) ProtoMessage()

func (*ApiAuthorizationResponse) ProtoReflect added in v1.0.362 

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

func (*ApiAuthorizationResponse) Reset added in v1.0.362 

func (x *ApiAuthorizationResponse) Reset()

func (*ApiAuthorizationResponse) String added in v1.0.362 

func (x *ApiAuthorizationResponse) String() string

type CancelWorkflowInstanceRequest 

type CancelWorkflowInstanceRequest struct {
	Id    string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State CancellationState `protobuf:"varint,2,opt,name=state,proto3,enum=CancellationState" json:"state,omitempty"`
	Error *Error            `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelWorkflowInstanceRequest) Descriptor deprecated 

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

Deprecated: Use CancelWorkflowInstanceRequest.ProtoReflect.Descriptor instead.

func (*CancelWorkflowInstanceRequest) GetError added in v0.1.134 

func (x *CancelWorkflowInstanceRequest) GetError() *Error

func (*CancelWorkflowInstanceRequest) GetId 

func (x *CancelWorkflowInstanceRequest) GetId() string

func (*CancelWorkflowInstanceRequest) GetState added in v0.1.134 

func (x *CancelWorkflowInstanceRequest) GetState() CancellationState

func (*CancelWorkflowInstanceRequest) ProtoMessage 

func (*CancelWorkflowInstanceRequest) ProtoMessage()

func (*CancelWorkflowInstanceRequest) ProtoReflect 

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

func (*CancelWorkflowInstanceRequest) Reset 

func (x *CancelWorkflowInstanceRequest) Reset()

func (*CancelWorkflowInstanceRequest) String 

func (x *CancelWorkflowInstanceRequest) String() string

type CancellationState added in v0.1.134 

type CancellationState int32
const (
	CancellationState_executing  CancellationState = 0 // CancellationState_executing - the state machine is executing
	CancellationState_completed  CancellationState = 1 // CancellationState_completed - the state machine has completed successfully
	CancellationState_terminated CancellationState = 2 // CancellationState_terminated - the state machine instance was terminated
	CancellationState_errored    CancellationState = 3 // CancellationState_errored - an error occured during state machine execution
	CancellationState_obsolete   CancellationState = 4 // CancellationState_obsolete - this state is obsolete due to an alternate flow
)

func (CancellationState) Descriptor added in v0.1.134 

func (CancellationState) Descriptor() protoreflect.EnumDescriptor

func (CancellationState) Enum added in v0.1.134 

func (x CancellationState) Enum() *CancellationState

func (CancellationState) EnumDescriptor deprecated added in v0.1.134 

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

Deprecated: Use CancellationState.Descriptor instead.

func (CancellationState) Number added in v0.1.134 

func (x CancellationState) Number() protoreflect.EnumNumber

func (CancellationState) String added in v0.1.134 

func (x CancellationState) String() string

func (CancellationState) Type added in v0.1.134 

func (CancellationState) Type() protoreflect.EnumType

type CatchError added in v0.1.134 

type CatchError struct {
	Id              string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`           // Id - the unique id.
	ErrorId         string            `protobuf:"bytes,2,opt,name=errorId,proto3" json:"errorId,omitempty"` // Id - the id of the error.
	Target          string            `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`   // Target ID for the transition.
	OutputTransform map[string]string ``                                                                    // OutputTransform - The transformation to apply to variables during the transition.
	/* 171-byte string literal not displayed */
	// contains filtered or unexported fields
}

CatchError specifies an error transition to another state.

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

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

Deprecated: Use CatchError.ProtoReflect.Descriptor instead.

func (*CatchError) GetErrorId added in v0.1.134 

func (x *CatchError) GetErrorId() string

func (*CatchError) GetId added in v0.1.134 

func (x *CatchError) GetId() string

func (*CatchError) GetOutputTransform added in v1.0.251 

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

func (*CatchError) GetTarget added in v0.1.134 

func (x *CatchError) GetTarget() string

func (*CatchError) ProtoMessage added in v0.1.134 

func (*CatchError) ProtoMessage()

func (*CatchError) ProtoReflect added in v0.1.134 

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

func (*CatchError) Reset added in v0.1.134 

func (x *CatchError) Reset()

func (*CatchError) String added in v0.1.134 

func (x *CatchError) String() string

type CompleteManualTaskRequest added in v0.1.86 

type CompleteManualTaskRequest struct {
	TrackingId string `protobuf:"bytes,1,opt,name=trackingId,proto3" json:"trackingId,omitempty"`
	Vars       []byte `protobuf:"bytes,2,opt,name=vars,proto3" json:"vars,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use CompleteManualTaskRequest.ProtoReflect.Descriptor instead.

func (*CompleteManualTaskRequest) GetTrackingId added in v0.1.86 

func (x *CompleteManualTaskRequest) GetTrackingId() string

func (*CompleteManualTaskRequest) GetVars added in v0.1.86 

func (x *CompleteManualTaskRequest) GetVars() []byte

func (*CompleteManualTaskRequest) ProtoMessage added in v0.1.86 

func (*CompleteManualTaskRequest) ProtoMessage()

func (*CompleteManualTaskRequest) ProtoReflect added in v0.1.86 

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

func (*CompleteManualTaskRequest) Reset added in v0.1.86 

func (x *CompleteManualTaskRequest) Reset()

func (*CompleteManualTaskRequest) String added in v0.1.86 

func (x *CompleteManualTaskRequest) String() string

type CompleteSendMessageRequest added in v0.1.185 

type CompleteSendMessageRequest struct {
	TrackingId string `protobuf:"bytes,1,opt,name=trackingId,proto3" json:"trackingId,omitempty"`
	Vars       []byte `protobuf:"bytes,2,opt,name=vars,proto3" json:"vars,omitempty"`
	// contains filtered or unexported fields
}

func (*CompleteSendMessageRequest) Descriptor deprecated added in v0.1.185 

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

Deprecated: Use CompleteSendMessageRequest.ProtoReflect.Descriptor instead.

func (*CompleteSendMessageRequest) GetTrackingId added in v0.1.185 

func (x *CompleteSendMessageRequest) GetTrackingId() string

func (*CompleteSendMessageRequest) GetVars added in v0.1.185 

func (x *CompleteSendMessageRequest) GetVars() []byte

func (*CompleteSendMessageRequest) ProtoMessage added in v0.1.185 

func (*CompleteSendMessageRequest) ProtoMessage()

func (*CompleteSendMessageRequest) ProtoReflect added in v0.1.185 

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

func (*CompleteSendMessageRequest) Reset added in v0.1.185 

func (x *CompleteSendMessageRequest) Reset()

func (*CompleteSendMessageRequest) String added in v0.1.185 

func (x *CompleteSendMessageRequest) String() string

type CompleteServiceTaskRequest added in v0.1.86 

type CompleteServiceTaskRequest struct {
	TrackingId string `protobuf:"bytes,1,opt,name=trackingId,proto3" json:"trackingId,omitempty"`
	Vars       []byte `protobuf:"bytes,2,opt,name=vars,proto3" json:"vars,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use CompleteServiceTaskRequest.ProtoReflect.Descriptor instead.

func (*CompleteServiceTaskRequest) GetTrackingId added in v0.1.86 

func (x *CompleteServiceTaskRequest) GetTrackingId() string

func (*CompleteServiceTaskRequest) GetVars added in v0.1.86 

func (x *CompleteServiceTaskRequest) GetVars() []byte

func (*CompleteServiceTaskRequest) ProtoMessage added in v0.1.86 

func (*CompleteServiceTaskRequest) ProtoMessage()

func (*CompleteServiceTaskRequest) ProtoReflect added in v0.1.86 

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

func (*CompleteServiceTaskRequest) Reset added in v0.1.86 

func (x *CompleteServiceTaskRequest) Reset()

func (*CompleteServiceTaskRequest) String added in v0.1.86 

func (x *CompleteServiceTaskRequest) String() string

type CompleteUserTaskRequest added in v0.1.86 

type CompleteUserTaskRequest struct {
	TrackingId string `protobuf:"bytes,1,opt,name=trackingId,proto3" json:"trackingId,omitempty"`
	Owner      string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	Vars       []byte `protobuf:"bytes,3,opt,name=vars,proto3" json:"vars,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use CompleteUserTaskRequest.ProtoReflect.Descriptor instead.

func (*CompleteUserTaskRequest) GetOwner added in v0.1.86 

func (x *CompleteUserTaskRequest) GetOwner() string

func (*CompleteUserTaskRequest) GetTrackingId added in v0.1.86 

func (x *CompleteUserTaskRequest) GetTrackingId() string

func (*CompleteUserTaskRequest) GetVars added in v0.1.86 

func (x *CompleteUserTaskRequest) GetVars() []byte

func (*CompleteUserTaskRequest) ProtoMessage added in v0.1.86 

func (*CompleteUserTaskRequest) ProtoMessage()

func (*CompleteUserTaskRequest) ProtoReflect added in v0.1.86 

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

func (*CompleteUserTaskRequest) Reset added in v0.1.86 

func (x *CompleteUserTaskRequest) Reset()

func (*CompleteUserTaskRequest) String added in v0.1.86 

func (x *CompleteUserTaskRequest) String() string

type Element 

type Element struct {
	Id              string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                            // Id - the unique identifier for the workflow state machine element.
	Name            string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                        // Name - the name of the state machine element.
	Type            string            `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`                        // Type - the type of state machine element
	Documentation   string            `protobuf:"bytes,4,opt,name=documentation,proto3" json:"documentation,omitempty"`      // Documentation - any documentation describing the state machine element.
	Execute         string            `protobuf:"bytes,5,opt,name=execute,proto3" json:"execute,omitempty"`                  // Execute - describes the execution parameter,  This is used for diffrerent purposes depending on the type.
	Outbound        *Targets          `protobuf:"bytes,6,opt,name=outbound,proto3" json:"outbound,omitempty"`                // Outbound - a number of possible transitions to other state machine state elements.s
	Process         *Process          `protobuf:"bytes,7,opt,name=process,proto3" json:"process,omitempty"`                  // Process - defines any subprocesses contained within this state machine.
	Msg             string            `protobuf:"bytes,8,opt,name=msg,proto3" json:"msg,omitempty"`                          // TODO: Document
	Retries         string            `protobuf:"bytes,9,opt,name=retries,proto3" json:"retries,omitempty"`                  // Retries - how many times this state machine element should retry in the case of a non-workflow error.
	Candidates      string            `protobuf:"bytes,10,opt,name=candidates,proto3" json:"candidates,omitempty"`           // Candidates - used for user related state machgine types to define users that may complete the task.
	CandidateGroups string            `protobuf:"bytes,11,opt,name=candidateGroups,proto3" json:"candidateGroups,omitempty"` // CandidateGroups - used for user related state machine types to define groups that may complete a task.
	Errors          []*CatchError     `protobuf:"bytes,12,rep,name=errors,proto3" json:"errors,omitempty"`                   // Errors - a number of catchable errors for this state machine element.
	Error           *Error            `protobuf:"bytes,13,opt,name=error,proto3" json:"error,omitempty"`                     // Error - an error that may be thrown.
	InputTransform  map[string]string ``                                                                                     // InputTransform - a transformation to poerform between variable names when calling a state machine task.
	/* 170-byte string literal not displayed */
	OutputTransform map[string]string `` // OutputTransform - a transformation to poerform between variable names when exiting a state machine task.
	/* 172-byte string literal not displayed */
	Timer         *WorkflowTimerDefinition `protobuf:"bytes,16,opt,name=timer,proto3" json:"timer,omitempty"`                 // Timer - a time to wait before execution for timer tasks.
	BoundaryTimer []*Timer                 `protobuf:"bytes,17,rep,name=boundaryTimer,proto3" json:"boundaryTimer,omitempty"` // BoundaryTimer - a number of timed transitions between this and another state.
	Gateway       *GatewaySpec             `protobuf:"bytes,18,opt,name=gateway,proto3,oneof" json:"gateway,omitempty"`       // GatewaySpec - if this element is a gateway, this contains the type specification for it.
	// 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) GetGateway added in v1.0.446 

func (x *Element) GetGateway() *GatewaySpec

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 Gateway added in v1.0.446 

type Gateway struct {
	MetExpectations map[string]string `` // MetExpectations - a list of expectations that were met for the gateway.
	/* 171-byte string literal not displayed */
	Vars   [][]byte `protobuf:"bytes,2,rep,name=vars,proto3" json:"vars,omitempty"`      // Vars - A go binary encoded map[string]interface{} of variables.
	Visits int64    `protobuf:"varint,3,opt,name=visits,proto3" json:"visits,omitempty"` // Visits - The number of visits this gateway has recieved
	// contains filtered or unexported fields
}

func (*Gateway) Descriptor deprecated added in v1.0.446 

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

Deprecated: Use Gateway.ProtoReflect.Descriptor instead.

func (*Gateway) GetMetExpectations added in v1.0.446 

func (x *Gateway) GetMetExpectations() map[string]string

func (*Gateway) GetVars added in v1.0.446 

func (x *Gateway) GetVars() [][]byte

func (*Gateway) GetVisits added in v1.0.446 

func (x *Gateway) GetVisits() int64

func (*Gateway) ProtoMessage added in v1.0.446 

func (*Gateway) ProtoMessage()

func (*Gateway) ProtoReflect added in v1.0.446 

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

func (*Gateway) Reset added in v1.0.446 

func (x *Gateway) Reset()

func (*Gateway) String added in v1.0.446 

func (x *Gateway) String() string

type GatewayDirection added in v1.0.446 

type GatewayDirection int32
const (
	GatewayDirection_divergent  GatewayDirection = 0
	GatewayDirection_convergent GatewayDirection = 1
)

func (GatewayDirection) Descriptor added in v1.0.446 

func (GatewayDirection) Descriptor() protoreflect.EnumDescriptor

func (GatewayDirection) Enum added in v1.0.446 

func (x GatewayDirection) Enum() *GatewayDirection

func (GatewayDirection) EnumDescriptor deprecated added in v1.0.446 

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

Deprecated: Use GatewayDirection.Descriptor instead.

func (GatewayDirection) Number added in v1.0.446 

func (x GatewayDirection) Number() protoreflect.EnumNumber

func (GatewayDirection) String added in v1.0.446 

func (x GatewayDirection) String() string

func (GatewayDirection) Type added in v1.0.446 

func (GatewayDirection) Type() protoreflect.EnumType

type GatewayExpectations added in v1.0.446 

type GatewayExpectations struct {
	ExpectedPaths []string `protobuf:"bytes,1,rep,name=expectedPaths,proto3" json:"expectedPaths,omitempty"` // ExpectedPaths - a list of paths that compose a gatew's expectaions
	// contains filtered or unexported fields
}

func (*GatewayExpectations) Descriptor deprecated added in v1.0.446 

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

Deprecated: Use GatewayExpectations.ProtoReflect.Descriptor instead.

func (*GatewayExpectations) GetExpectedPaths added in v1.0.446 

func (x *GatewayExpectations) GetExpectedPaths() []string

func (*GatewayExpectations) ProtoMessage added in v1.0.446 

func (*GatewayExpectations) ProtoMessage()

func (*GatewayExpectations) ProtoReflect added in v1.0.446 

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

func (*GatewayExpectations) Reset added in v1.0.446 

func (x *GatewayExpectations) Reset()

func (*GatewayExpectations) String added in v1.0.446 

func (x *GatewayExpectations) String() string

type GatewaySpec added in v1.0.446 

type GatewaySpec struct {
	Type              GatewayType      `protobuf:"varint,1,opt,name=type,proto3,enum=GatewayType" json:"type,omitempty"`
	Direction         GatewayDirection `protobuf:"varint,2,opt,name=direction,proto3,enum=GatewayDirection" json:"direction,omitempty"`
	ReciprocalId      string           `protobuf:"bytes,3,opt,name=reciprocalId,proto3" json:"reciprocalId,omitempty"`
	FixedExpectations []string         `protobuf:"bytes,4,rep,name=fixedExpectations,proto3" json:"fixedExpectations,omitempty"`
	// contains filtered or unexported fields
}

func (*GatewaySpec) Descriptor deprecated added in v1.0.446 

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

Deprecated: Use GatewaySpec.ProtoReflect.Descriptor instead.

func (*GatewaySpec) GetDirection added in v1.0.446 

func (x *GatewaySpec) GetDirection() GatewayDirection

func (*GatewaySpec) GetFixedExpectations added in v1.0.446 

func (x *GatewaySpec) GetFixedExpectations() []string

func (*GatewaySpec) GetReciprocalId added in v1.0.446 

func (x *GatewaySpec) GetReciprocalId() string

func (*GatewaySpec) GetType added in v1.0.446 

func (x *GatewaySpec) GetType() GatewayType

func (*GatewaySpec) ProtoMessage added in v1.0.446 

func (*GatewaySpec) ProtoMessage()

func (*GatewaySpec) ProtoReflect added in v1.0.446 

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

func (*GatewaySpec) Reset added in v1.0.446 

func (x *GatewaySpec) Reset()

func (*GatewaySpec) String added in v1.0.446 

func (x *GatewaySpec) String() string

type GatewayType added in v1.0.446 

type GatewayType int32
const (
	GatewayType_exclusive GatewayType = 0 // Exclusive - When splitting, it routes the sequence flow to exactly one of the outgoing branches. When merging, it awaits one incoming branch to complete before triggering the outgoing flow.
	GatewayType_inclusive GatewayType = 1 // Inclusive - When splitting, one or more branches are activated. All active incoming branches must complete before merging.
	GatewayType_parallel  GatewayType = 2 // Parralel - When used to split the sequence flow, all outgoing branches are activated simultaneously. When merging parallel branches it waits for all incoming branches to complete before triggering the outgoing flow.
)

func (GatewayType) Descriptor added in v1.0.446 

func (GatewayType) Descriptor() protoreflect.EnumDescriptor

func (GatewayType) Enum added in v1.0.446 

func (x GatewayType) Enum() *GatewayType

func (GatewayType) EnumDescriptor deprecated added in v1.0.446 

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

Deprecated: Use GatewayType.Descriptor instead.

func (GatewayType) Number added in v1.0.446 

func (x GatewayType) Number() protoreflect.EnumNumber

func (GatewayType) String added in v1.0.446 

func (x GatewayType) String() string

func (GatewayType) Type added in v1.0.446 

func (GatewayType) Type() protoreflect.EnumType

type 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 GetProcessInstanceStatusRequest added in v1.0.427 

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

func (*GetProcessInstanceStatusRequest) Descriptor deprecated added in v1.0.427 

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

Deprecated: Use GetProcessInstanceStatusRequest.ProtoReflect.Descriptor instead.

func (*GetProcessInstanceStatusRequest) GetId added in v1.0.427 

func (x *GetProcessInstanceStatusRequest) GetId() string

func (*GetProcessInstanceStatusRequest) ProtoMessage added in v1.0.427 

func (*GetProcessInstanceStatusRequest) ProtoMessage()

func (*GetProcessInstanceStatusRequest) ProtoReflect added in v1.0.427 

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

func (*GetProcessInstanceStatusRequest) Reset added in v1.0.427 

func (x *GetProcessInstanceStatusRequest) Reset()

func (*GetProcessInstanceStatusRequest) String added in v1.0.427 

func (x *GetProcessInstanceStatusRequest) String() string

type GetProcessInstanceStatusResult added in v1.0.427 

type GetProcessInstanceStatusResult struct {
	ProcessState []*WorkflowState `protobuf:"bytes,1,rep,name=processState,proto3" json:"processState,omitempty"` // ProcessInstance - process instances berlonging to this workflow instance.
	// contains filtered or unexported fields
}

func (*GetProcessInstanceStatusResult) Descriptor deprecated added in v1.0.427 

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

Deprecated: Use GetProcessInstanceStatusResult.ProtoReflect.Descriptor instead.

func (*GetProcessInstanceStatusResult) GetProcessState added in v1.0.427 

func (x *GetProcessInstanceStatusResult) GetProcessState() []*WorkflowState

func (*GetProcessInstanceStatusResult) ProtoMessage added in v1.0.427 

func (*GetProcessInstanceStatusResult) ProtoMessage()

func (*GetProcessInstanceStatusResult) ProtoReflect added in v1.0.427 

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

func (*GetProcessInstanceStatusResult) Reset added in v1.0.427 

func (x *GetProcessInstanceStatusResult) Reset()

func (*GetProcessInstanceStatusResult) String added in v1.0.427 

func (x *GetProcessInstanceStatusResult) String() string

type 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 GetWorkflowRequest added in v1.0.366 

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

func (*GetWorkflowRequest) Descriptor deprecated added in v1.0.366 

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

Deprecated: Use GetWorkflowRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowRequest) GetId added in v1.0.366 

func (x *GetWorkflowRequest) GetId() string

func (*GetWorkflowRequest) ProtoMessage added in v1.0.366 

func (*GetWorkflowRequest) ProtoMessage()

func (*GetWorkflowRequest) ProtoReflect added in v1.0.366 

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

func (*GetWorkflowRequest) Reset added in v1.0.366 

func (x *GetWorkflowRequest) Reset()

func (*GetWorkflowRequest) String added in v1.0.366 

func (x *GetWorkflowRequest) String() string

type GetWorkflowResponse added in v1.0.366 

type GetWorkflowResponse struct {
	Definition *Workflow `protobuf:"bytes,1,opt,name=definition,proto3" json:"definition,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowResponse) Descriptor deprecated added in v1.0.366 

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

Deprecated: Use GetWorkflowResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowResponse) GetDefinition added in v1.0.366 

func (x *GetWorkflowResponse) GetDefinition() *Workflow

func (*GetWorkflowResponse) ProtoMessage added in v1.0.366 

func (*GetWorkflowResponse) ProtoMessage()

func (*GetWorkflowResponse) ProtoReflect added in v1.0.366 

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

func (*GetWorkflowResponse) Reset added in v1.0.366 

func (x *GetWorkflowResponse) Reset()

func (*GetWorkflowResponse) String added in v1.0.366 

func (x *GetWorkflowResponse) String() string

type GetWorkflowVersionsRequest added in v1.0.366 

type GetWorkflowVersionsRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowVersionsRequest) Descriptor deprecated added in v1.0.366 

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

Deprecated: Use GetWorkflowVersionsRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowVersionsRequest) GetName added in v1.0.366 

func (x *GetWorkflowVersionsRequest) GetName() string

func (*GetWorkflowVersionsRequest) ProtoMessage added in v1.0.366 

func (*GetWorkflowVersionsRequest) ProtoMessage()

func (*GetWorkflowVersionsRequest) ProtoReflect added in v1.0.366 

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

func (*GetWorkflowVersionsRequest) Reset added in v1.0.366 

func (x *GetWorkflowVersionsRequest) Reset()

func (*GetWorkflowVersionsRequest) String added in v1.0.366 

func (x *GetWorkflowVersionsRequest) String() string

type GetWorkflowVersionsResponse added in v1.0.366 

type GetWorkflowVersionsResponse struct {
	Versions *WorkflowVersions `protobuf:"bytes,1,opt,name=versions,proto3" json:"versions,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowVersionsResponse) Descriptor deprecated added in v1.0.366 

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

Deprecated: Use GetWorkflowVersionsResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowVersionsResponse) GetVersions added in v1.0.366 

func (x *GetWorkflowVersionsResponse) GetVersions() *WorkflowVersions

func (*GetWorkflowVersionsResponse) ProtoMessage added in v1.0.366 

func (*GetWorkflowVersionsResponse) ProtoMessage()

func (*GetWorkflowVersionsResponse) ProtoReflect added in v1.0.366 

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

func (*GetWorkflowVersionsResponse) Reset added in v1.0.366 

func (x *GetWorkflowVersionsResponse) Reset()

func (*GetWorkflowVersionsResponse) String added in v1.0.366 

func (x *GetWorkflowVersionsResponse) String() string

type HandleWorkflowErrorRequest added in v0.1.134 

type HandleWorkflowErrorRequest struct {
	TrackingId string `protobuf:"bytes,1,opt,name=trackingId,proto3" json:"trackingId,omitempty"`
	ErrorCode  string `protobuf:"bytes,2,opt,name=errorCode,proto3" json:"errorCode,omitempty"`
	Message    string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Vars       []byte `protobuf:"bytes,4,opt,name=vars,proto3" json:"vars,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use HandleWorkflowErrorRequest.ProtoReflect.Descriptor instead.

func (*HandleWorkflowErrorRequest) GetErrorCode added in v0.1.134 

func (x *HandleWorkflowErrorRequest) GetErrorCode() string

func (*HandleWorkflowErrorRequest) GetMessage added in v0.1.134 

func (x *HandleWorkflowErrorRequest) GetMessage() string

func (*HandleWorkflowErrorRequest) GetTrackingId added in v0.1.134 

func (x *HandleWorkflowErrorRequest) GetTrackingId() string

func (*HandleWorkflowErrorRequest) GetVars added in v1.0.251 

func (x *HandleWorkflowErrorRequest) GetVars() []byte

func (*HandleWorkflowErrorRequest) ProtoMessage added in v0.1.134 

func (*HandleWorkflowErrorRequest) ProtoMessage()

func (*HandleWorkflowErrorRequest) ProtoReflect added in v0.1.134 

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

func (*HandleWorkflowErrorRequest) Reset added in v0.1.134 

func (x *HandleWorkflowErrorRequest) Reset()

func (*HandleWorkflowErrorRequest) String added in v0.1.134 

func (x *HandleWorkflowErrorRequest) String() string

type HandleWorkflowErrorResponse added in v0.1.134 

type HandleWorkflowErrorResponse struct {
	Handled bool `protobuf:"varint,1,opt,name=handled,proto3" json:"handled,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use HandleWorkflowErrorResponse.ProtoReflect.Descriptor instead.

func (*HandleWorkflowErrorResponse) GetHandled added in v0.1.134 

func (x *HandleWorkflowErrorResponse) GetHandled() bool

func (*HandleWorkflowErrorResponse) ProtoMessage added in v0.1.134 

func (*HandleWorkflowErrorResponse) ProtoMessage()

func (*HandleWorkflowErrorResponse) ProtoReflect added in v0.1.134 

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

func (*HandleWorkflowErrorResponse) Reset added in v0.1.134 

func (x *HandleWorkflowErrorResponse) Reset()

func (*HandleWorkflowErrorResponse) String added in v0.1.134 

func (x *HandleWorkflowErrorResponse) String() string

type LaunchWorkflowRequest 

type LaunchWorkflowRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Vars []byte `protobuf:"bytes,2,opt,name=vars,proto3" json:"vars,omitempty"`
	// contains filtered or unexported fields
}

func (*LaunchWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use LaunchWorkflowRequest.ProtoReflect.Descriptor instead.

func (*LaunchWorkflowRequest) GetName 

func (x *LaunchWorkflowRequest) GetName() string

func (*LaunchWorkflowRequest) GetVars 

func (x *LaunchWorkflowRequest) GetVars() []byte

func (*LaunchWorkflowRequest) ProtoMessage 

func (*LaunchWorkflowRequest) ProtoMessage()

func (*LaunchWorkflowRequest) ProtoReflect 

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

func (*LaunchWorkflowRequest) Reset 

func (x *LaunchWorkflowRequest) Reset()

func (*LaunchWorkflowRequest) String 

func (x *LaunchWorkflowRequest) String() string

type LaunchWorkflowResponse added in v1.0.366 

type LaunchWorkflowResponse struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	WorkflowId string `protobuf:"bytes,2,opt,name=workflowId,proto3" json:"workflowId,omitempty"`
	// contains filtered or unexported fields
}

func (*LaunchWorkflowResponse) Descriptor deprecated added in v1.0.366 

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

Deprecated: Use LaunchWorkflowResponse.ProtoReflect.Descriptor instead.

func (*LaunchWorkflowResponse) GetInstanceId added in v1.0.366 

func (x *LaunchWorkflowResponse) GetInstanceId() string

func (*LaunchWorkflowResponse) GetWorkflowId added in v1.0.366 

func (x *LaunchWorkflowResponse) GetWorkflowId() string

func (*LaunchWorkflowResponse) ProtoMessage added in v1.0.366 

func (*LaunchWorkflowResponse) ProtoMessage()

func (*LaunchWorkflowResponse) ProtoReflect added in v1.0.366 

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

func (*LaunchWorkflowResponse) Reset added in v1.0.366 

func (x *LaunchWorkflowResponse) Reset()

func (*LaunchWorkflowResponse) String added in v1.0.366 

func (x *LaunchWorkflowResponse) String() string

type ListUserTasksRequest added in v0.1.86 

type ListUserTasksRequest struct {
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use ListUserTasksRequest.ProtoReflect.Descriptor instead.

func (*ListUserTasksRequest) GetOwner added in v0.1.86 

func (x *ListUserTasksRequest) GetOwner() string

func (*ListUserTasksRequest) ProtoMessage added in v0.1.86 

func (*ListUserTasksRequest) ProtoMessage()

func (*ListUserTasksRequest) ProtoReflect added in v0.1.86 

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

func (*ListUserTasksRequest) Reset added in v0.1.86 

func (x *ListUserTasksRequest) Reset()

func (*ListUserTasksRequest) String added in v0.1.86 

func (x *ListUserTasksRequest) String() string

type ListWorkflowInstanceProcessesRequest added in v1.0.427 

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

func (*ListWorkflowInstanceProcessesRequest) Descriptor deprecated added in v1.0.427 

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

Deprecated: Use ListWorkflowInstanceProcessesRequest.ProtoReflect.Descriptor instead.

func (*ListWorkflowInstanceProcessesRequest) GetId added in v1.0.427 

func (x *ListWorkflowInstanceProcessesRequest) GetId() string

func (*ListWorkflowInstanceProcessesRequest) ProtoMessage added in v1.0.427 

func (*ListWorkflowInstanceProcessesRequest) ProtoMessage()

func (*ListWorkflowInstanceProcessesRequest) ProtoReflect added in v1.0.427 

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

func (*ListWorkflowInstanceProcessesRequest) Reset added in v1.0.427 

func (x *ListWorkflowInstanceProcessesRequest) Reset()

func (*ListWorkflowInstanceProcessesRequest) String added in v1.0.427 

func (x *ListWorkflowInstanceProcessesRequest) String() string

type ListWorkflowInstanceProcessesResult added in v1.0.427 

type ListWorkflowInstanceProcessesResult struct {
	ProcessInstanceId []string `protobuf:"bytes,1,rep,name=processInstanceId,proto3" json:"processInstanceId,omitempty"` // ProcessInstance - process instances berlonging to this workflow instance.
	// contains filtered or unexported fields
}

func (*ListWorkflowInstanceProcessesResult) Descriptor deprecated added in v1.0.427 

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

Deprecated: Use ListWorkflowInstanceProcessesResult.ProtoReflect.Descriptor instead.

func (*ListWorkflowInstanceProcessesResult) GetProcessInstanceId added in v1.0.427 

func (x *ListWorkflowInstanceProcessesResult) GetProcessInstanceId() []string

func (*ListWorkflowInstanceProcessesResult) ProtoMessage added in v1.0.427 

func (*ListWorkflowInstanceProcessesResult) ProtoMessage()

func (*ListWorkflowInstanceProcessesResult) ProtoReflect added in v1.0.427 

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

func (*ListWorkflowInstanceProcessesResult) Reset added in v1.0.427 

func (x *ListWorkflowInstanceProcessesResult) Reset()

func (*ListWorkflowInstanceProcessesResult) String added in v1.0.427 

func (x *ListWorkflowInstanceProcessesResult) 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 Metadata added in v1.0.427 

type Metadata struct {
	TimedStart bool `protobuf:"varint,1,opt,name=timedStart,proto3" json:"timedStart,omitempty"` // Workflow contains timed start activities that can trigger a process.
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated added in v1.0.427 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetTimedStart added in v1.0.427 

func (x *Metadata) GetTimedStart() bool

func (*Metadata) ProtoMessage added in v1.0.427 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect added in v1.0.427 

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

func (*Metadata) Reset added in v1.0.427 

func (x *Metadata) Reset()

func (*Metadata) String added in v1.0.427 

func (x *Metadata) String() string

type Process 

type Process struct {
	Elements []*Element `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`       // Elements describes each state in the state machine.
	Name     string     `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`               // Name - the common name of the state machine.
	Metadata *Metadata  `protobuf:"bytes,6,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"` // Metadata created by SHAR to describe process behavior.
	// contains filtered or unexported fields
}

Process describes a single workflow state machine.

func (*Process) Descriptor deprecated 

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

Deprecated: Use Process.ProtoReflect.Descriptor instead.

func (*Process) GetElements 

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

func (*Process) GetMetadata added in v1.0.427 

func (x *Process) GetMetadata() *Metadata

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 ProcessInstance added in v1.0.427 

type ProcessInstance struct {
	ProcessInstanceId  string          `protobuf:"bytes,1,opt,name=processInstanceId,proto3" json:"processInstanceId,omitempty"`   // ProcessInstanceId - the unique ID for the process instance.
	WorkflowInstanceId string          `protobuf:"bytes,2,opt,name=workflowInstanceId,proto3" json:"workflowInstanceId,omitempty"` // WorkflowInstanceId - the workflow instance this process belongs to.
	ParentProcessId    *string         `protobuf:"bytes,3,opt,name=parentProcessId,proto3,oneof" json:"parentProcessId,omitempty"` // ParentProcessInstanceId - the parent process instance that launched this process - if nil, the workflow instance launched the process instance.
	ParentElementId    *string         `protobuf:"bytes,4,opt,name=parentElementId,proto3,oneof" json:"parentElementId,omitempty"` // ParentElementId - the ID of the element in the parent process that triggered the launch of this process instance.
	WorkflowId         string          `protobuf:"bytes,5,opt,name=workflowId,proto3" json:"workflowId,omitempty"`                 // WorkflowId - the workflow version ID that this instance is executing.
	WorkflowName       string          `protobuf:"bytes,6,opt,name=workflowName,proto3" json:"workflowName,omitempty"`             // WorkflowName - name of this workflow to avoid lookups.
	ProcessName        string          `protobuf:"bytes,7,opt,name=processName,proto3" json:"processName,omitempty"`               // ProcessName - name of this process to avoid lookups.
	GatewayComplete    map[string]bool ``                                                                                          // GatewayComplete - completed gateway instances register
	/* 172-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ProcessInstance) Descriptor deprecated added in v1.0.427 

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

Deprecated: Use ProcessInstance.ProtoReflect.Descriptor instead.

func (*ProcessInstance) GetGatewayComplete added in v1.0.446 

func (x *ProcessInstance) GetGatewayComplete() map[string]bool

func (*ProcessInstance) GetParentElementId added in v1.0.427 

func (x *ProcessInstance) GetParentElementId() string

func (*ProcessInstance) GetParentProcessId added in v1.0.427 

func (x *ProcessInstance) GetParentProcessId() string

func (*ProcessInstance) GetProcessInstanceId added in v1.0.427 

func (x *ProcessInstance) GetProcessInstanceId() string

func (*ProcessInstance) GetProcessName added in v1.0.427 

func (x *ProcessInstance) GetProcessName() string

func (*ProcessInstance) GetWorkflowId added in v1.0.427 

func (x *ProcessInstance) GetWorkflowId() string

func (*ProcessInstance) GetWorkflowInstanceId added in v1.0.427 

func (x *ProcessInstance) GetWorkflowInstanceId() string

func (*ProcessInstance) GetWorkflowName added in v1.0.427 

func (x *ProcessInstance) GetWorkflowName() string

func (*ProcessInstance) ProtoMessage added in v1.0.427 

func (*ProcessInstance) ProtoMessage()

func (*ProcessInstance) ProtoReflect added in v1.0.427 

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

func (*ProcessInstance) Reset added in v1.0.427 

func (x *ProcessInstance) Reset()

func (*ProcessInstance) String added in v1.0.427 

func (x *ProcessInstance) String() string

type SatisfiesGateway added in v1.0.446 

type SatisfiesGateway struct {
	InstanceTracking []string `protobuf:"bytes,1,rep,name=instanceTracking,proto3" json:"instanceTracking,omitempty"` // instanceTracking - a list of paths that satisfy the gateway.
	// contains filtered or unexported fields
}

func (*SatisfiesGateway) Descriptor deprecated added in v1.0.446 

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

Deprecated: Use SatisfiesGateway.ProtoReflect.Descriptor instead.

func (*SatisfiesGateway) GetInstanceTracking added in v1.0.446 

func (x *SatisfiesGateway) GetInstanceTracking() []string

func (*SatisfiesGateway) ProtoMessage added in v1.0.446 

func (*SatisfiesGateway) ProtoMessage()

func (*SatisfiesGateway) ProtoReflect added in v1.0.446 

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

func (*SatisfiesGateway) Reset added in v1.0.446 

func (x *SatisfiesGateway) Reset()

func (*SatisfiesGateway) String added in v1.0.446 

func (x *SatisfiesGateway) String() string

type SendMessageRequest 

type SendMessageRequest struct {
	Name               string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	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.
	// 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) 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.
	WorkflowId              string          `protobuf:"bytes,2,opt,name=workflowId,proto3" json:"workflowId,omitempty"`                                 // WorkflowId - the workflow version ID that this instance is executing.
	ParentProcessInstanceId *string         `protobuf:"bytes,3,opt,name=parentProcessInstanceId,proto3,oneof" json:"parentProcessInstanceId,omitempty"` // ParentProcessInstanceId - the parent process instance that launched this process - if nil, the workflow instance launched the process instance.
	ParentElementId         *string         `protobuf:"bytes,4,opt,name=parentElementId,proto3,oneof" json:"parentElementId,omitempty"`                 // ParentElementId - the ID of the element in the parent process that triggered the launch of this process instance.
	WorkflowName            string          `protobuf:"bytes,5,opt,name=workflowName,proto3" json:"workflowName,omitempty"`                             // WorkflowName - name of this workflow to avoid lookups.
	ProcessInstanceId       []string        `protobuf:"bytes,6,rep,name=processInstanceId,proto3" json:"processInstanceId,omitempty"`                   // ProcessInstance - process instances berlonging to this workflow instance.
	SatisfiedProcesses      map[string]bool ``                                                                                                          // SatisfiedProcesses - a list of event driven processes that have been completed.
	/* 178-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) GetParentElementId 

func (x *WorkflowInstance) GetParentElementId() string

func (*WorkflowInstance) GetParentProcessInstanceId added in v1.0.427 

func (x *WorkflowInstance) GetParentProcessInstanceId() string

func (*WorkflowInstance) GetProcessInstanceId added in v1.0.427 

func (x *WorkflowInstance) GetProcessInstanceId() []string

func (*WorkflowInstance) GetSatisfiedProcesses added in v1.0.427 

func (x *WorkflowInstance) GetSatisfiedProcesses() map[string]bool

func (*WorkflowInstance) GetWorkflowId 

func (x *WorkflowInstance) GetWorkflowId() string

func (*WorkflowInstance) GetWorkflowInstanceId 

func (x *WorkflowInstance) GetWorkflowInstanceId() string

func (*WorkflowInstance) GetWorkflowName added in v1.0.362 

func (x *WorkflowInstance) GetWorkflowName() string

func (*WorkflowInstance) ProtoMessage 

func (*WorkflowInstance) ProtoMessage()

func (*WorkflowInstance) ProtoReflect 

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

func (*WorkflowInstance) Reset 

func (x *WorkflowInstance) Reset()

func (*WorkflowInstance) String 

func (x *WorkflowInstance) String() string

type WorkflowInstanceComplete added in v0.1.66 

type WorkflowInstanceComplete struct {
	WorkflowName       string            `protobuf:"bytes,1,opt,name=workflowName,proto3" json:"workflowName,omitempty"`
	WorkflowId         string            `protobuf:"bytes,2,opt,name=workflowId,proto3" json:"workflowId,omitempty"`
	WorkflowInstanceId string            `protobuf:"bytes,3,opt,name=workflowInstanceId,proto3" json:"workflowInstanceId,omitempty"`
	WorkflowState      CancellationState `protobuf:"varint,4,opt,name=workflowState,proto3,enum=CancellationState" json:"workflowState,omitempty"`
	Error              *Error            `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowInstanceComplete) Descriptor deprecated added in v0.1.66 

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

Deprecated: Use WorkflowInstanceComplete.ProtoReflect.Descriptor instead.

func (*WorkflowInstanceComplete) GetError added in v0.1.134 

func (x *WorkflowInstanceComplete) GetError() *Error

func (*WorkflowInstanceComplete) GetWorkflowId added in v0.1.66 

func (x *WorkflowInstanceComplete) GetWorkflowId() string

func (*WorkflowInstanceComplete) GetWorkflowInstanceId added in v0.1.66 

func (x *WorkflowInstanceComplete) GetWorkflowInstanceId() string

func (*WorkflowInstanceComplete) GetWorkflowName added in v0.1.66 

func (x *WorkflowInstanceComplete) GetWorkflowName() string

func (*WorkflowInstanceComplete) GetWorkflowState added in v0.1.134 

func (x *WorkflowInstanceComplete) GetWorkflowState() CancellationState

func (*WorkflowInstanceComplete) ProtoMessage added in v0.1.66 

func (*WorkflowInstanceComplete) ProtoMessage()

func (*WorkflowInstanceComplete) ProtoReflect added in v0.1.66 

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

func (*WorkflowInstanceComplete) Reset added in v0.1.66 

func (x *WorkflowInstanceComplete) Reset()

func (*WorkflowInstanceComplete) String added in v0.1.66 

func (x *WorkflowInstanceComplete) String() string

type WorkflowInstanceInfo 

type WorkflowInstanceInfo struct {
	Id         string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	WorkflowId string `protobuf:"bytes,2,opt,name=workflowId,proto3" json:"workflowId,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowInstanceInfo) Descriptor deprecated 

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

Deprecated: Use WorkflowInstanceInfo.ProtoReflect.Descriptor instead.

func (*WorkflowInstanceInfo) GetId 

func (x *WorkflowInstanceInfo) GetId() string

func (*WorkflowInstanceInfo) GetWorkflowId 

func (x *WorkflowInstanceInfo) GetWorkflowId() string

func (*WorkflowInstanceInfo) ProtoMessage 

func (*WorkflowInstanceInfo) ProtoMessage()

func (*WorkflowInstanceInfo) ProtoReflect 

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

func (*WorkflowInstanceInfo) Reset 

func (x *WorkflowInstanceInfo) Reset()

func (*WorkflowInstanceInfo) String 

func (x *WorkflowInstanceInfo) String() string

type WorkflowInstanceStatus 

type WorkflowInstanceStatus struct {
	State []*WorkflowState `protobuf:"bytes,1,rep,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowInstanceStatus) Descriptor deprecated 

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

Deprecated: Use WorkflowInstanceStatus.ProtoReflect.Descriptor instead.

func (*WorkflowInstanceStatus) GetState 

func (x *WorkflowInstanceStatus) GetState() []*WorkflowState

func (*WorkflowInstanceStatus) ProtoMessage 

func (*WorkflowInstanceStatus) ProtoMessage()

func (*WorkflowInstanceStatus) ProtoReflect 

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

func (*WorkflowInstanceStatus) Reset 

func (x *WorkflowInstanceStatus) Reset()

func (*WorkflowInstanceStatus) String 

func (x *WorkflowInstanceStatus) String() string

type WorkflowInstanceSubscribers 

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

func (*WorkflowInstanceSubscribers) Descriptor deprecated 

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

Deprecated: Use WorkflowInstanceSubscribers.ProtoReflect.Descriptor instead.

func (*WorkflowInstanceSubscribers) GetList 

func (x *WorkflowInstanceSubscribers) GetList() []string

func (*WorkflowInstanceSubscribers) ProtoMessage 

func (*WorkflowInstanceSubscribers) ProtoMessage()

func (*WorkflowInstanceSubscribers) ProtoReflect 

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

func (*WorkflowInstanceSubscribers) Reset 

func (x *WorkflowInstanceSubscribers) Reset()

func (*WorkflowInstanceSubscribers) String 

func (x *WorkflowInstanceSubscribers) String() string

type WorkflowState 

type WorkflowState struct {
	WorkflowId                  string                       `protobuf:"bytes,1,opt,name=workflowId,proto3" json:"workflowId,omitempty"`                 // WorkflowId - the ID of the workflow version that provides the template for execution.
	WorkflowInstanceId          string                       `protobuf:"bytes,2,opt,name=workflowInstanceId,proto3" json:"workflowInstanceId,omitempty"` // WorkflowInstanceId - the workflow instance that this state belongs to.
	ElementId                   string                       `protobuf:"bytes,3,opt,name=elementId,proto3" json:"elementId,omitempty"`                   // ElementId - the currently executing element withing the workflow state machine.
	ElementType                 string                       `protobuf:"bytes,4,opt,name=elementType,proto3" json:"elementType,omitempty"`               // ElementType - the currently executing element type, cached here to reduce lookups.
	Id                          []string                     `protobuf:"bytes,5,rep,name=id,proto3" json:"id,omitempty"`                                 // Id - a stack of IDs that descibe the state and its parents up to the original workflow instance ID.
	Execute                     *string                      `protobuf:"bytes,7,opt,name=execute,proto3,oneof" json:"execute,omitempty"`                 // Execute - additional information required to execute depending on the element type.
	State                       CancellationState            `protobuf:"varint,8,opt,name=state,proto3,enum=CancellationState" json:"state,omitempty"`   // State - the current execution state of the state machine.
	Condition                   *string                      `protobuf:"bytes,9,opt,name=condition,proto3,oneof" json:"condition,omitempty"`             // Condition - a message condition that needs to be fulfilled before proceeding.
	UnixTimeNano                int64                        `protobuf:"varint,10,opt,name=unixTimeNano,proto3" json:"unixTimeNano,omitempty"`           // UnixTimeNano - the time this state was observed.
	Vars                        []byte                       `protobuf:"bytes,11,opt,name=vars,proto3" json:"vars,omitempty"`                            // Vars - A go binary encoded map[string]interface{} of variables.
	Owners                      []string                     `protobuf:"bytes,12,rep,name=owners,proto3" json:"owners,omitempty"`                        // Owners - a list of user owners for this state that may be responsible for completing tasks
	Groups                      []string                     `protobuf:"bytes,13,rep,name=groups,proto3" json:"groups,omitempty"`                        // Groups - a list of user groups for this state that may be responsible for completing tasks
	Error                       *Error                       `protobuf:"bytes,14,opt,name=error,proto3" json:"error,omitempty"`                          // Error - an error being carried by the state if it has faulted.
	Timer                       *WorkflowTimer               `protobuf:"bytes,16,opt,name=timer,proto3" json:"timer,omitempty"`                          // Timer - a time needed to transition to the next state.
	WorkflowName                string                       `protobuf:"bytes,17,opt,name=workflowName,proto3" json:"workflowName,omitempty"`            // WorkflowName - name of this workflow to avoid lookups.
	ProcessName                 string                       `protobuf:"bytes,18,opt,name=processName,proto3" json:"processName,omitempty"`              // ProcessName - name of this process to avoid lookups.
	ProcessInstanceId           string                       `protobuf:"bytes,19,opt,name=processInstanceId,proto3" json:"processInstanceId,omitempty"`  // ProcessInstanceId - the unique ID for the process instance.
	SatisfiesGatewayExpectation map[string]*SatisfiesGateway ``                                                                                          // SatisfiesGatewayExpectation - a list of gateways, and pathway covered that satisfy their expectations.
	/* 196-byte string literal not displayed */
	GatewayExpectations map[string]*GatewayExpectations `` // GatewayExpectations - a list of dynamic gateway expectations set during traversing from a divergent gateway with a reciprocal.
	/* 180-byte string literal not displayed */
	// contains filtered or unexported fields
}

WorkflowState describes a current executing state inside a workflow state machine.

func (*WorkflowState) Descriptor deprecated 

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

Deprecated: Use WorkflowState.ProtoReflect.Descriptor instead.

func (*WorkflowState) GetCondition 

func (x *WorkflowState) GetCondition() string

func (*WorkflowState) GetElementId 

func (x *WorkflowState) GetElementId() string

func (*WorkflowState) GetElementType 

func (x *WorkflowState) GetElementType() string

func (*WorkflowState) GetError added in v0.1.134 

func (x *WorkflowState) GetError() *Error

func (*WorkflowState) GetExecute 

func (x *WorkflowState) GetExecute() string

func (*WorkflowState) GetGatewayExpectations added in v1.0.446 

func (x *WorkflowState) GetGatewayExpectations() map[string]*GatewayExpectations

func (*WorkflowState) GetGroups added in v0.1.86 

func (x *WorkflowState) GetGroups() []string

func (*WorkflowState) GetId added in v0.1.78 

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

func (*WorkflowState) GetOwners added in v0.1.86 

func (x *WorkflowState) GetOwners() []string

func (*WorkflowState) GetProcessInstanceId added in v1.0.427 

func (x *WorkflowState) GetProcessInstanceId() string

func (*WorkflowState) GetProcessName added in v1.0.427 

func (x *WorkflowState) GetProcessName() string

func (*WorkflowState) GetSatisfiesGatewayExpectation added in v1.0.446 

func (x *WorkflowState) GetSatisfiesGatewayExpectation() map[string]*SatisfiesGateway

func (*WorkflowState) GetState 

func (x *WorkflowState) GetState() CancellationState

func (*WorkflowState) GetTimer added in v0.1.181 

func (x *WorkflowState) GetTimer() *WorkflowTimer

func (*WorkflowState) GetUnixTimeNano 

func (x *WorkflowState) GetUnixTimeNano() int64

func (*WorkflowState) GetVars 

func (x *WorkflowState) GetVars() []byte

func (*WorkflowState) GetWorkflowId 

func (x *WorkflowState) GetWorkflowId() string

func (*WorkflowState) GetWorkflowInstanceId 

func (x *WorkflowState) GetWorkflowInstanceId() string

func (*WorkflowState) GetWorkflowName added in v1.0.362 

func (x *WorkflowState) GetWorkflowName() string

func (*WorkflowState) ProtoMessage 

func (*WorkflowState) ProtoMessage()

func (*WorkflowState) ProtoReflect 

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

func (*WorkflowState) Reset 

func (x *WorkflowState) Reset()

func (*WorkflowState) String 

func (x *WorkflowState) String() string

type WorkflowStats added in v0.1.134 

type WorkflowStats struct {
	Workflows         int64 `protobuf:"varint,1,opt,name=Workflows,proto3" json:"Workflows,omitempty"`
	InstancesStarted  int64 `protobuf:"varint,2,opt,name=InstancesStarted,proto3" json:"InstancesStarted,omitempty"`
	InstancesComplete int64 `protobuf:"varint,3,opt,name=InstancesComplete,proto3" json:"InstancesComplete,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use WorkflowStats.ProtoReflect.Descriptor instead.

func (*WorkflowStats) GetInstancesComplete added in v0.1.134 

func (x *WorkflowStats) GetInstancesComplete() int64

func (*WorkflowStats) GetInstancesStarted added in v0.1.134 

func (x *WorkflowStats) GetInstancesStarted() int64

func (*WorkflowStats) GetWorkflows added in v0.1.134 

func (x *WorkflowStats) GetWorkflows() int64

func (*WorkflowStats) ProtoMessage added in v0.1.134 

func (*WorkflowStats) ProtoMessage()

func (*WorkflowStats) ProtoReflect added in v0.1.134 

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

func (*WorkflowStats) Reset added in v0.1.134 

func (x *WorkflowStats) Reset()

func (*WorkflowStats) String added in v0.1.134 

func (x *WorkflowStats) String() string

type WorkflowTimer added in v0.1.181 

type WorkflowTimer struct {
	LastFired int64 `protobuf:"varint,1,opt,name=lastFired,proto3" json:"lastFired,omitempty"` // LastFired - the time in UNIX nanoseconds since the timer was last executed.
	Count     int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`         // Count - the number of times the timer has fired.
	// contains filtered or unexported fields
}

WorkflowTimer holds the last execution state of a timer.

func (*WorkflowTimer) Descriptor deprecated added in v0.1.181 

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

Deprecated: Use WorkflowTimer.ProtoReflect.Descriptor instead.

func (*WorkflowTimer) GetCount added in v0.1.181 

func (x *WorkflowTimer) GetCount() int64

func (*WorkflowTimer) GetLastFired added in v0.1.181 

func (x *WorkflowTimer) GetLastFired() int64

func (*WorkflowTimer) ProtoMessage added in v0.1.181 

func (*WorkflowTimer) ProtoMessage()

func (*WorkflowTimer) ProtoReflect added in v0.1.181 

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

func (*WorkflowTimer) Reset added in v0.1.181 

func (x *WorkflowTimer) Reset()

func (*WorkflowTimer) String added in v0.1.181 

func (x *WorkflowTimer) String() string

type WorkflowTimerDefinition added in v0.1.181 

type WorkflowTimerDefinition struct {
	Type       WorkflowTimerType `protobuf:"varint,1,opt,name=type,proto3,enum=WorkflowTimerType" json:"type,omitempty"` // Type - whether the workflow timer is relative or absolute.
	Value      int64             `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`                      // Value - the time parameter.
	Repeat     int64             `protobuf:"varint,3,opt,name=repeat,proto3" json:"repeat,omitempty"`                    // Repeat - the repeat interval for the timer.
	DropEvents bool              `protobuf:"varint,4,opt,name=dropEvents,proto3" json:"dropEvents,omitempty"`            // DropEvents - unused.
	// contains filtered or unexported fields
}

WorkflowTimerDefinition defines a workflow timer that can be used to trigger an event.

func (*WorkflowTimerDefinition) Descriptor deprecated added in v0.1.181 

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

Deprecated: Use WorkflowTimerDefinition.ProtoReflect.Descriptor instead.

func (*WorkflowTimerDefinition) GetDropEvents added in v0.1.181 

func (x *WorkflowTimerDefinition) GetDropEvents() bool

func (*WorkflowTimerDefinition) GetRepeat added in v0.1.181 

func (x *WorkflowTimerDefinition) GetRepeat() int64

func (*WorkflowTimerDefinition) GetType added in v0.1.181 

func (x *WorkflowTimerDefinition) GetType() WorkflowTimerType

func (*WorkflowTimerDefinition) GetValue added in v0.1.181 

func (x *WorkflowTimerDefinition) GetValue() int64

func (*WorkflowTimerDefinition) ProtoMessage added in v0.1.181 

func (*WorkflowTimerDefinition) ProtoMessage()

func (*WorkflowTimerDefinition) ProtoReflect added in v0.1.181 

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

func (*WorkflowTimerDefinition) Reset added in v0.1.181 

func (x *WorkflowTimerDefinition) Reset()

func (*WorkflowTimerDefinition) String added in v0.1.181 

func (x *WorkflowTimerDefinition) String() string

type WorkflowTimerType added in v0.1.181 

type WorkflowTimerType int32

WorkflowTimerType describes whether a timer is relative or absolute 

const (
	WorkflowTimerType_duration WorkflowTimerType = 0 // Duration - a relative timer
	WorkflowTimerType_fixed    WorkflowTimerType = 1 // Fixed - an absolute timer
)

func (WorkflowTimerType) Descriptor added in v0.1.181 

func (WorkflowTimerType) Descriptor() protoreflect.EnumDescriptor

func (WorkflowTimerType) Enum added in v0.1.181 

func (x WorkflowTimerType) Enum() *WorkflowTimerType

func (WorkflowTimerType) EnumDescriptor deprecated added in v0.1.181 

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

Deprecated: Use WorkflowTimerType.Descriptor instead.

func (WorkflowTimerType) Number added in v0.1.181 

func (x WorkflowTimerType) Number() protoreflect.EnumNumber

func (WorkflowTimerType) String added in v0.1.181 

func (x WorkflowTimerType) String() string

func (WorkflowTimerType) Type added in v0.1.181 

func (WorkflowTimerType) Type() protoreflect.EnumType

type WorkflowVersion 

type WorkflowVersion struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`          // Id - the launchable ID for the workflow.
	Sha256 []byte `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`  // Sha256 - the hash of the workflow configuration.
	Number int32  `protobuf:"varint,3,opt,name=number,proto3" json:"number,omitempty"` // Number - the version number of the workflow
	// contains filtered or unexported fields
}

WorkflowVersion contains the metadata for a single workflow version

func (*WorkflowVersion) Descriptor deprecated 

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

Deprecated: Use WorkflowVersion.ProtoReflect.Descriptor instead.

func (*WorkflowVersion) GetId 

func (x *WorkflowVersion) GetId() string

func (*WorkflowVersion) GetNumber 

func (x *WorkflowVersion) GetNumber() int32

func (*WorkflowVersion) GetSha256 

func (x *WorkflowVersion) GetSha256() []byte

func (*WorkflowVersion) ProtoMessage 

func (*WorkflowVersion) ProtoMessage()

func (*WorkflowVersion) ProtoReflect 

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

func (*WorkflowVersion) Reset 

func (x *WorkflowVersion) Reset()

func (*WorkflowVersion) String 

func (x *WorkflowVersion) String() string

type WorkflowVersions 

type WorkflowVersions struct {
	Version []*WorkflowVersion `protobuf:"bytes,1,rep,name=version,proto3" json:"version,omitempty"` // WorkflowVersion - a single version of a workflow
	// contains filtered or unexported fields
}

WorkflowVersions describes the version history.

func (*WorkflowVersions) Descriptor deprecated 

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

Deprecated: Use WorkflowVersions.ProtoReflect.Descriptor instead.

func (*WorkflowVersions) GetVersion 

func (x *WorkflowVersions) GetVersion() []*WorkflowVersion

func (*WorkflowVersions) ProtoMessage 

func (*WorkflowVersions) ProtoMessage()

func (*WorkflowVersions) ProtoReflect 

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

func (*WorkflowVersions) Reset 

func (x *WorkflowVersions) Reset()

func (*WorkflowVersions) String 

func (x *WorkflowVersions) String() string

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.