model

package
v1.1.1503 Latest Latest
Warning

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

 Go to latest Published: Nov 18, 2024 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ThreadingType_name = map[int32]string{
		0: "Sequential",
		2: "Parallel",
	}
	ThreadingType_value = map[string]int32{
		"Sequential": 0,
		"Parallel":   2,
	}
)

Enum value maps for ThreadingType.

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 (
	ProcessHistoryType_name = map[int32]string{
		0:  "processExecute",
		1:  "activityExecute",
		2:  "activityComplete",
		3:  "processSpawnSync",
		4:  "processComplete",
		5:  "processAbort",
		6:  "activityAbort",
		7:  "jobAbort",
		8:  "jobExecute",
		9:  "jobComplete",
		10: "compensationCheckpoint",
	}
	ProcessHistoryType_value = map[string]int32{
		"processExecute":         0,
		"activityExecute":        1,
		"activityComplete":       2,
		"processSpawnSync":       3,
		"processComplete":        4,
		"processAbort":           5,
		"activityAbort":          6,
		"jobAbort":               7,
		"jobExecute":             8,
		"jobComplete":            9,
		"compensationCheckpoint": 10,
	}
)

Enum value maps for ProcessHistoryType.

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 (
	RecipientType_name = map[int32]string{
		0: "job",
	}
	RecipientType_value = map[string]int32{
		"job": 0,
	}
)

Enum value maps for RecipientType.

View Source 
var (
	CancellationState_name = map[int32]string{
		0: "executing",
		1: "completed",
		2: "terminated",
		3: "errored",
		4: "obsolete",
		5: "compensating",
	}
	CancellationState_value = map[string]int32{
		"executing":    0,
		"completed":    1,
		"terminated":   2,
		"errored":      3,
		"obsolete":     4,
		"compensating": 5,
	}
)

Enum value maps for CancellationState.

View Source 
var (
	LogSource_name = map[int32]string{
		0: "logSourceEngine",
		2: "logSourceWorkflow",
		3: "logSourceClient",
		4: "logSourceJob",
		5: "logSourceTelemetry",
	}
	LogSource_value = map[string]int32{
		"logSourceEngine":    0,
		"logSourceWorkflow":  2,
		"logSourceClient":    3,
		"logSourceJob":       4,
		"logSourceTelemetry": 5,
	}
)

Enum value maps for LogSource.

View Source 
var (
	RetryStrategy_name = map[int32]string{
		0: "Linear",
		1: "Exponential",
	}
	RetryStrategy_value = map[string]int32{
		"Linear":      0,
		"Exponential": 1,
	}
)

Enum value maps for RetryStrategy.

View Source 
var (
	RetryErrorAction_name = map[int32]string{
		0: "PauseWorkflow",
		1: "ThrowWorkflowError",
		2: "SetVariableValue",
		3: "FailWorkflow",
	}
	RetryErrorAction_value = map[string]int32{
		"PauseWorkflow":      0,
		"ThrowWorkflowError": 1,
		"SetVariableValue":   2,
		"FailWorkflow":       3,
	}
)

Enum value maps for RetryErrorAction.

View Source 
var (
	HandlingStrategy_name = map[int32]string{
		0: "Pause",
		1: "TearDown",
	}
	HandlingStrategy_value = map[string]int32{
		"Pause":    0,
		"TearDown": 1,
	}
)

Enum value maps for HandlingStrategy.

View Source 
var ErrVarNotFound = errors.New("variable not found")

ErrVarNotFound is returned when a variable is not found in the provided Vars map.

View Source 
var File_shar_workflow_models_proto protoreflect.FileDescriptor

Functions

func GetStruct added in v1.1.1409 

func GetStruct[T any](vars *ClientVars, key string) (*T, error)

GetStruct unmarshals a SHAR variable into a struct.

func SetStruct added in v1.1.1409 

func SetStruct[T any](v *ClientVars, key string, t *T) error

SetStruct marshals a struct into a SHAR variable.

Types

type AbandonUserTaskRequest added in v1.1.1492 

type AbandonUserTaskRequest struct {
	// contains filtered or unexported fields
}

func (*AbandonUserTaskRequest) Descriptor deprecated added in v1.1.1492 

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

Deprecated: Use AbandonUserTaskRequest.ProtoReflect.Descriptor instead.

func (*AbandonUserTaskRequest) ProtoMessage added in v1.1.1492 

func (*AbandonUserTaskRequest) ProtoMessage()

func (*AbandonUserTaskRequest) ProtoReflect added in v1.1.1492 

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

func (*AbandonUserTaskRequest) Reset added in v1.1.1492 

func (x *AbandonUserTaskRequest) Reset()

func (*AbandonUserTaskRequest) String added in v1.1.1492 

func (x *AbandonUserTaskRequest) String() string

type AbandonUserTaskResponse added in v1.1.1492 

type AbandonUserTaskResponse struct {
	// contains filtered or unexported fields
}

func (*AbandonUserTaskResponse) Descriptor deprecated added in v1.1.1492 

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

Deprecated: Use AbandonUserTaskResponse.ProtoReflect.Descriptor instead.

func (*AbandonUserTaskResponse) ProtoMessage added in v1.1.1492 

func (*AbandonUserTaskResponse) ProtoMessage()

func (*AbandonUserTaskResponse) ProtoReflect added in v1.1.1492 

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

func (*AbandonUserTaskResponse) Reset added in v1.1.1492 

func (x *AbandonUserTaskResponse) Reset()

func (*AbandonUserTaskResponse) String added in v1.1.1492 

func (x *AbandonUserTaskResponse) String() string

type ApiAuthenticationRequest added in v1.0.362 

type ApiAuthenticationRequest struct {
	Headers map[string]string `` /* 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 CancelProcessInstanceRequest added in v1.0.645 

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

func (*CancelProcessInstanceRequest) Descriptor deprecated added in v1.0.645 

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

Deprecated: Use CancelProcessInstanceRequest.ProtoReflect.Descriptor instead.

func (*CancelProcessInstanceRequest) GetError added in v1.0.645 

func (x *CancelProcessInstanceRequest) GetError() *Error

func (*CancelProcessInstanceRequest) GetId added in v1.0.645 

func (x *CancelProcessInstanceRequest) GetId() string

func (*CancelProcessInstanceRequest) GetState added in v1.0.645 

func (x *CancelProcessInstanceRequest) GetState() CancellationState

func (*CancelProcessInstanceRequest) ProtoMessage added in v1.0.645 

func (*CancelProcessInstanceRequest) ProtoMessage()

func (*CancelProcessInstanceRequest) ProtoReflect added in v1.0.645 

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

func (*CancelProcessInstanceRequest) Reset added in v1.0.645 

func (x *CancelProcessInstanceRequest) Reset()

func (*CancelProcessInstanceRequest) String added in v1.0.645 

func (x *CancelProcessInstanceRequest) String() string

type CancelProcessInstanceResponse added in v1.1.725 

type CancelProcessInstanceResponse struct {
	// contains filtered or unexported fields
}

func (*CancelProcessInstanceResponse) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use CancelProcessInstanceResponse.ProtoReflect.Descriptor instead.

func (*CancelProcessInstanceResponse) ProtoMessage added in v1.1.725 

func (*CancelProcessInstanceResponse) ProtoMessage()

func (*CancelProcessInstanceResponse) ProtoReflect added in v1.1.725 

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

func (*CancelProcessInstanceResponse) Reset added in v1.1.725 

func (x *CancelProcessInstanceResponse) Reset()

func (*CancelProcessInstanceResponse) String added in v1.1.725 

func (x *CancelProcessInstanceResponse) String() string

type CancellationState added in v0.1.134 

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

func (CancellationState) Descriptor added in v0.1.134 

func (CancellationState) Descriptor() protoreflect.EnumDescriptor

func (CancellationState) Enum added in v0.1.134 

func (x CancellationState) Enum() *CancellationState

func (CancellationState) EnumDescriptor deprecated added in v0.1.134 

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

Deprecated: Use CancellationState.Descriptor instead.

func (CancellationState) Number added in v0.1.134 

func (x CancellationState) Number() protoreflect.EnumNumber

func (CancellationState) String added in v0.1.134 

func (x CancellationState) String() string

func (CancellationState) Type added in v0.1.134 

func (CancellationState) Type() protoreflect.EnumType

type CatchError added in v0.1.134 

type CatchError struct {
	Id              string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`           // Id - the unique id.
	ErrorId         string            `protobuf:"bytes,2,opt,name=errorId,proto3" json:"errorId,omitempty"` // Id - the id of the error.
	Target          string            `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`   // Target ID for the transition.
	OutputTransform map[string]string ``                                                                    // OutputTransform - The transformation to apply to variables during the transition.
	/* 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 ClientVars added in v1.1.1409 

type ClientVars struct {
	// contains filtered or unexported fields
}

ClientVars holds a map of client-defined variables with string keys and values of workflow variables.

func NewVars added in v1.1.1409 

func NewVars() *ClientVars

NewVars creates and returns a new instance of ClientVars.

func NewVarsFromMap added in v1.1.1442 

func NewVarsFromMap(vars map[string]any) (*ClientVars, error)

NewVarsFromMap creates and returns a new instance of ClientVars populated with the given map of vars.

func (*ClientVars) Decode added in v1.1.1409 

func (vars *ClientVars) Decode(ctx context.Context, b []byte) error

Decode decodes a go binary object containing workflow variables.

func (*ClientVars) Encode added in v1.1.1409 

func (vars *ClientVars) Encode(ctx context.Context) ([]byte, error)

Encode encodes the map of workflow variables into a go binary to be sent across the wire.

func (*ClientVars) GetBool added in v1.1.1409 

func (vars *ClientVars) GetBool(key string) (bool, error)

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

func (*ClientVars) GetFloat64 added in v1.1.1409 

func (vars *ClientVars) GetFloat64(key string) (float64, error)

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

func (*ClientVars) GetInt64 added in v1.1.1409 

func (vars *ClientVars) GetInt64(key string) (int64, error)

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

func (*ClientVars) GetString added in v1.1.1409 

func (vars *ClientVars) GetString(key string) (string, error)

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

func (*ClientVars) Keys added in v1.1.1409 

func (vars *ClientVars) Keys() iter.Seq[string]

Keys returns an iterator sequence of all the keys in the ClientVars map.

func (*ClientVars) Len added in v1.1.1409 

func (vars *ClientVars) Len() int

Len returns the number of key-value pairs in ClientVars.

func (*ClientVars) SetBool added in v1.1.1409 

func (vars *ClientVars) SetBool(key string, value bool)

SetBool sets a boolean value for the specified key in the Vars map.

func (*ClientVars) SetFloat64 added in v1.1.1409 

func (vars *ClientVars) SetFloat64(key string, value float64)

SetFloat64 sets a float64 value for the specified key in the Vars map.

func (*ClientVars) SetInt64 added in v1.1.1409 

func (vars *ClientVars) SetInt64(key string, value int64)

SetInt64 sets an int64 value for the specified key in the Vars map.

func (*ClientVars) SetString added in v1.1.1409 

func (vars *ClientVars) SetString(key string, value string)

SetString sets a string value for the specified key in the Vars map.

type Collaboration added in v1.0.645 

type Collaboration struct {
	Participant []*Participant `protobuf:"bytes,1,rep,name=participant,proto3" json:"participant,omitempty"` // Participant in a collaboration.
	MessageFlow []*MessageFlow `protobuf:"bytes,2,rep,name=messageFlow,proto3" json:"messageFlow,omitempty"` // MessageFlow describes the collaboration message participants.
	// contains filtered or unexported fields
}

func (*Collaboration) Descriptor deprecated added in v1.0.645 

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

Deprecated: Use Collaboration.ProtoReflect.Descriptor instead.

func (*Collaboration) GetMessageFlow added in v1.0.645 

func (x *Collaboration) GetMessageFlow() []*MessageFlow

func (*Collaboration) GetParticipant added in v1.0.645 

func (x *Collaboration) GetParticipant() []*Participant

func (*Collaboration) ProtoMessage added in v1.0.645 

func (*Collaboration) ProtoMessage()

func (*Collaboration) ProtoReflect added in v1.0.645 

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

func (*Collaboration) Reset added in v1.0.645 

func (x *Collaboration) Reset()

func (*Collaboration) String added in v1.0.645 

func (x *Collaboration) String() string

type Compensation added in v1.1.1099 

type Compensation struct {
	Step          int64  `protobuf:"varint,1,opt,name=step,proto3" json:"step,omitempty"`                  // Step is the currently executing step in a compensation plan
	TotalSteps    int64  `protobuf:"varint,2,opt,name=totalSteps,proto3" json:"totalSteps,omitempty"`      // TotalSteps is the total number of steps in the compensation plan.
	ForTrackingId string `protobuf:"bytes,3,opt,name=forTrackingId,proto3" json:"forTrackingId,omitempty"` // ForTrackingId is the trackingID of the job being compensated.
	// contains filtered or unexported fields
}

func (*Compensation) Descriptor deprecated added in v1.1.1099 

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

Deprecated: Use Compensation.ProtoReflect.Descriptor instead.

func (*Compensation) GetForTrackingId added in v1.1.1099 

func (x *Compensation) GetForTrackingId() string

func (*Compensation) GetStep added in v1.1.1099 

func (x *Compensation) GetStep() int64

func (*Compensation) GetTotalSteps added in v1.1.1099 

func (x *Compensation) GetTotalSteps() int64

func (*Compensation) ProtoMessage added in v1.1.1099 

func (*Compensation) ProtoMessage()

func (*Compensation) ProtoReflect added in v1.1.1099 

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

func (*Compensation) Reset added in v1.1.1099 

func (x *Compensation) Reset()

func (*Compensation) String added in v1.1.1099 

func (x *Compensation) String() string

type CompleteManualTaskRequest added in v0.1.86 

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

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

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

Deprecated: Use CompleteManualTaskRequest.ProtoReflect.Descriptor instead.

func (*CompleteManualTaskRequest) GetTrackingId added in v0.1.86 

func (x *CompleteManualTaskRequest) GetTrackingId() string

func (*CompleteManualTaskRequest) GetVars added in v0.1.86 

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

func (*CompleteManualTaskRequest) ProtoMessage added in v0.1.86 

func (*CompleteManualTaskRequest) ProtoMessage()

func (*CompleteManualTaskRequest) ProtoReflect added in v0.1.86 

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

func (*CompleteManualTaskRequest) Reset added in v0.1.86 

func (x *CompleteManualTaskRequest) Reset()

func (*CompleteManualTaskRequest) String added in v0.1.86 

func (x *CompleteManualTaskRequest) String() string

type CompleteManualTaskResponse added in v1.1.725 

type CompleteManualTaskResponse struct {
	// contains filtered or unexported fields
}

func (*CompleteManualTaskResponse) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use CompleteManualTaskResponse.ProtoReflect.Descriptor instead.

func (*CompleteManualTaskResponse) ProtoMessage added in v1.1.725 

func (*CompleteManualTaskResponse) ProtoMessage()

func (*CompleteManualTaskResponse) ProtoReflect added in v1.1.725 

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

func (*CompleteManualTaskResponse) Reset added in v1.1.725 

func (x *CompleteManualTaskResponse) Reset()

func (*CompleteManualTaskResponse) String added in v1.1.725 

func (x *CompleteManualTaskResponse) String() string

type CompleteSendMessageRequest added in v0.1.185 

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

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

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

Deprecated: Use CompleteSendMessageRequest.ProtoReflect.Descriptor instead.

func (*CompleteSendMessageRequest) GetTrackingId added in v0.1.185 

func (x *CompleteSendMessageRequest) GetTrackingId() string

func (*CompleteSendMessageRequest) GetVars added in v0.1.185 

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

func (*CompleteSendMessageRequest) ProtoMessage added in v0.1.185 

func (*CompleteSendMessageRequest) ProtoMessage()

func (*CompleteSendMessageRequest) ProtoReflect added in v0.1.185 

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

func (*CompleteSendMessageRequest) Reset added in v0.1.185 

func (x *CompleteSendMessageRequest) Reset()

func (*CompleteSendMessageRequest) String added in v0.1.185 

func (x *CompleteSendMessageRequest) String() string

type CompleteSendMessageResponse added in v1.1.725 

type CompleteSendMessageResponse struct {
	// contains filtered or unexported fields
}

func (*CompleteSendMessageResponse) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use CompleteSendMessageResponse.ProtoReflect.Descriptor instead.

func (*CompleteSendMessageResponse) ProtoMessage added in v1.1.725 

func (*CompleteSendMessageResponse) ProtoMessage()

func (*CompleteSendMessageResponse) ProtoReflect added in v1.1.725 

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

func (*CompleteSendMessageResponse) Reset added in v1.1.725 

func (x *CompleteSendMessageResponse) Reset()

func (*CompleteSendMessageResponse) String added in v1.1.725 

func (x *CompleteSendMessageResponse) String() string

type CompleteServiceTaskRequest added in v0.1.86 

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

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

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

Deprecated: Use CompleteServiceTaskRequest.ProtoReflect.Descriptor instead.

func (*CompleteServiceTaskRequest) GetCompensating added in v1.1.1099 

func (x *CompleteServiceTaskRequest) GetCompensating() bool

func (*CompleteServiceTaskRequest) GetTrackingId added in v0.1.86 

func (x *CompleteServiceTaskRequest) GetTrackingId() string

func (*CompleteServiceTaskRequest) GetVars added in v0.1.86 

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

func (*CompleteServiceTaskRequest) ProtoMessage added in v0.1.86 

func (*CompleteServiceTaskRequest) ProtoMessage()

func (*CompleteServiceTaskRequest) ProtoReflect added in v0.1.86 

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

func (*CompleteServiceTaskRequest) Reset added in v0.1.86 

func (x *CompleteServiceTaskRequest) Reset()

func (*CompleteServiceTaskRequest) String added in v0.1.86 

func (x *CompleteServiceTaskRequest) String() string

type CompleteServiceTaskResponse added in v1.1.725 

type CompleteServiceTaskResponse struct {
	// contains filtered or unexported fields
}

func (*CompleteServiceTaskResponse) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use CompleteServiceTaskResponse.ProtoReflect.Descriptor instead.

func (*CompleteServiceTaskResponse) ProtoMessage added in v1.1.725 

func (*CompleteServiceTaskResponse) ProtoMessage()

func (*CompleteServiceTaskResponse) ProtoReflect added in v1.1.725 

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

func (*CompleteServiceTaskResponse) Reset added in v1.1.725 

func (x *CompleteServiceTaskResponse) Reset()

func (*CompleteServiceTaskResponse) String added in v1.1.725 

func (x *CompleteServiceTaskResponse) String() string

type CompleteUserTaskRequest added in v0.1.86 

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

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

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

Deprecated: Use CompleteUserTaskRequest.ProtoReflect.Descriptor instead.

func (*CompleteUserTaskRequest) GetId added in v1.1.1492 

func (x *CompleteUserTaskRequest) GetId() string

func (*CompleteUserTaskRequest) ProtoMessage added in v0.1.86 

func (*CompleteUserTaskRequest) ProtoMessage()

func (*CompleteUserTaskRequest) ProtoReflect added in v0.1.86 

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

func (*CompleteUserTaskRequest) Reset added in v0.1.86 

func (x *CompleteUserTaskRequest) Reset()

func (*CompleteUserTaskRequest) String added in v0.1.86 

func (x *CompleteUserTaskRequest) String() string

type CompleteUserTaskResponse added in v1.1.725 

type CompleteUserTaskResponse struct {
	// contains filtered or unexported fields
}

func (*CompleteUserTaskResponse) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use CompleteUserTaskResponse.ProtoReflect.Descriptor instead.

func (*CompleteUserTaskResponse) ProtoMessage added in v1.1.725 

func (*CompleteUserTaskResponse) ProtoMessage()

func (*CompleteUserTaskResponse) ProtoReflect added in v1.1.725 

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

func (*CompleteUserTaskResponse) Reset added in v1.1.725 

func (x *CompleteUserTaskResponse) Reset()

func (*CompleteUserTaskResponse) String added in v1.1.725 

func (x *CompleteUserTaskResponse) String() string

type DefaultRetryExceededBehaviour added in v1.0.623 

type DefaultRetryExceededBehaviour struct {
	Action        RetryErrorAction `protobuf:"varint,1,opt,name=action,proto3,enum=RetryErrorAction" json:"action,omitempty"` // Action to take when retries are exceeded.
	Variable      string           `protobuf:"bytes,2,opt,name=variable,proto3" json:"variable,omitempty"`                    // Variable - name of variable to set for the SetVariableValue action. valid-value: shar-variable
	VariableType  string           `protobuf:"bytes,3,opt,name=variableType,proto3" json:"variableType,omitempty"`            // VariableType - type of the variable for the SetVariableValue action. valid-value: "string", "int", "float", "bool"
	VariableValue string           `protobuf:"bytes,4,opt,name=variableValue,proto3" json:"variableValue,omitempty"`          // Variable value to set for the SetVariableValue action. valid-value: arbitrary string representation of a valid value for variableType
	ErrorCode     string           `protobuf:"bytes,5,opt,name=errorCode,proto3" json:"errorCode,omitempty"`                  // ErrorCode for the ThrowWorkflowError action. valid-value: a valid workflow error code for the task.
	// contains filtered or unexported fields
}

func (*DefaultRetryExceededBehaviour) Descriptor deprecated added in v1.0.623 

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

Deprecated: Use DefaultRetryExceededBehaviour.ProtoReflect.Descriptor instead.

func (*DefaultRetryExceededBehaviour) GetAction added in v1.0.623 

func (x *DefaultRetryExceededBehaviour) GetAction() RetryErrorAction

func (*DefaultRetryExceededBehaviour) GetErrorCode added in v1.0.623 

func (x *DefaultRetryExceededBehaviour) GetErrorCode() string

func (*DefaultRetryExceededBehaviour) GetVariable added in v1.0.623 

func (x *DefaultRetryExceededBehaviour) GetVariable() string

func (*DefaultRetryExceededBehaviour) GetVariableType added in v1.0.623 

func (x *DefaultRetryExceededBehaviour) GetVariableType() string

func (*DefaultRetryExceededBehaviour) GetVariableValue added in v1.0.623 

func (x *DefaultRetryExceededBehaviour) GetVariableValue() string

func (*DefaultRetryExceededBehaviour) ProtoMessage added in v1.0.623 

func (*DefaultRetryExceededBehaviour) ProtoMessage()

func (*DefaultRetryExceededBehaviour) ProtoReflect added in v1.0.623 

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

func (*DefaultRetryExceededBehaviour) Reset added in v1.0.623 

func (x *DefaultRetryExceededBehaviour) Reset()

func (*DefaultRetryExceededBehaviour) String added in v1.0.623 

func (x *DefaultRetryExceededBehaviour) String() string

type DefaultTaskRetry added in v1.0.623 

type DefaultTaskRetry struct {
	Number          uint32                         `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`                        // Retry - the recommended number of retries for the task. valid-value: arbitrary positive integer
	Strategy        RetryStrategy                  `protobuf:"varint,2,opt,name=strategy,proto3,enum=RetryStrategy" json:"strategy,omitempty"` // Strategy for retrying the task.
	InitMilli       int64                          `protobuf:"varint,3,opt,name=initMilli,proto3" json:"initMilli,omitempty"`                  // InitMilli - initial backoff delay for Static, Linear, Incremental. valid-value: positive int
	IntervalMilli   int64                          `protobuf:"varint,4,opt,name=intervalMilli,proto3" json:"intervalMilli,omitempty"`          // IntervalMilli - delay interval (Linear) amount to add each attempt (Incremental). valid-value: positive int
	MaxMilli        int64                          `protobuf:"varint,5,opt,name=maxMilli,proto3" json:"maxMilli,omitempty"`                    // MaxMilli - delay ceiling (Static, Linear, Incremental). valid-value: positive int
	DefaultExceeded *DefaultRetryExceededBehaviour `protobuf:"bytes,6,opt,name=defaultExceeded,proto3" json:"defaultExceeded,omitempty"`       // DefaultExceeded - specifies what to do by default when the attempts have been exhausted.  This only specifies the strategy, and doesn't contain runtime parameters.
	// contains filtered or unexported fields
}

func (*DefaultTaskRetry) Descriptor deprecated added in v1.0.623 

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

Deprecated: Use DefaultTaskRetry.ProtoReflect.Descriptor instead.

func (*DefaultTaskRetry) GetDefaultExceeded added in v1.0.623 

func (x *DefaultTaskRetry) GetDefaultExceeded() *DefaultRetryExceededBehaviour

func (*DefaultTaskRetry) GetInitMilli added in v1.0.623 

func (x *DefaultTaskRetry) GetInitMilli() int64

func (*DefaultTaskRetry) GetIntervalMilli added in v1.0.623 

func (x *DefaultTaskRetry) GetIntervalMilli() int64

func (*DefaultTaskRetry) GetMaxMilli added in v1.0.623 

func (x *DefaultTaskRetry) GetMaxMilli() int64

func (*DefaultTaskRetry) GetNumber added in v1.0.623 

func (x *DefaultTaskRetry) GetNumber() uint32

func (*DefaultTaskRetry) GetStrategy added in v1.0.623 

func (x *DefaultTaskRetry) GetStrategy() RetryStrategy

func (*DefaultTaskRetry) ProtoMessage added in v1.0.623 

func (*DefaultTaskRetry) ProtoMessage()

func (*DefaultTaskRetry) ProtoReflect added in v1.0.623 

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

func (*DefaultTaskRetry) Reset added in v1.0.623 

func (x *DefaultTaskRetry) Reset()

func (*DefaultTaskRetry) String added in v1.0.623 

func (x *DefaultTaskRetry) String() string

type DeprecateServiceTaskRequest added in v1.1.670 

type DeprecateServiceTaskRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Name of the task specification.
	// contains filtered or unexported fields
}

DeleteServiceTaskRequest contains the UID of a registered task.

func (*DeprecateServiceTaskRequest) Descriptor deprecated added in v1.1.670 

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

Deprecated: Use DeprecateServiceTaskRequest.ProtoReflect.Descriptor instead.

func (*DeprecateServiceTaskRequest) GetName added in v1.1.670 

func (x *DeprecateServiceTaskRequest) GetName() string

func (*DeprecateServiceTaskRequest) ProtoMessage added in v1.1.670 

func (*DeprecateServiceTaskRequest) ProtoMessage()

func (*DeprecateServiceTaskRequest) ProtoReflect added in v1.1.670 

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

func (*DeprecateServiceTaskRequest) Reset added in v1.1.670 

func (x *DeprecateServiceTaskRequest) Reset()

func (*DeprecateServiceTaskRequest) String added in v1.1.670 

func (x *DeprecateServiceTaskRequest) String() string

type DeprecateServiceTaskResponse added in v1.1.670 

type DeprecateServiceTaskResponse struct {
	Usage   *TaskSpecUsageReport `protobuf:"bytes,1,opt,name=usage,proto3,oneof" json:"usage,omitempty"`
	Success bool                 `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

DeleteServiceTaskResponse is the result of unregistering a task.

func (*DeprecateServiceTaskResponse) Descriptor deprecated added in v1.1.670 

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

Deprecated: Use DeprecateServiceTaskResponse.ProtoReflect.Descriptor instead.

func (*DeprecateServiceTaskResponse) GetSuccess added in v1.1.670 

func (x *DeprecateServiceTaskResponse) GetSuccess() bool

func (*DeprecateServiceTaskResponse) GetUsage added in v1.1.670 

func (x *DeprecateServiceTaskResponse) GetUsage() *TaskSpecUsageReport

func (*DeprecateServiceTaskResponse) ProtoMessage added in v1.1.670 

func (*DeprecateServiceTaskResponse) ProtoMessage()

func (*DeprecateServiceTaskResponse) ProtoReflect added in v1.1.670 

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

func (*DeprecateServiceTaskResponse) Reset added in v1.1.670 

func (x *DeprecateServiceTaskResponse) Reset()

func (*DeprecateServiceTaskResponse) String added in v1.1.670 

func (x *DeprecateServiceTaskResponse) String() string

type DisableWorkflowLaunch added in v1.1.1484 

type DisableWorkflowLaunch struct {
	Timestamp    int64  `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	WorkflowName string `protobuf:"bytes,2,opt,name=workflowName,proto3" json:"workflowName,omitempty"`
	// contains filtered or unexported fields
}

func (*DisableWorkflowLaunch) Descriptor deprecated added in v1.1.1484 

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

Deprecated: Use DisableWorkflowLaunch.ProtoReflect.Descriptor instead.

func (*DisableWorkflowLaunch) GetTimestamp added in v1.1.1484 

func (x *DisableWorkflowLaunch) GetTimestamp() int64

func (*DisableWorkflowLaunch) GetWorkflowName added in v1.1.1484 

func (x *DisableWorkflowLaunch) GetWorkflowName() string

func (*DisableWorkflowLaunch) ProtoMessage added in v1.1.1484 

func (*DisableWorkflowLaunch) ProtoMessage()

func (*DisableWorkflowLaunch) ProtoReflect added in v1.1.1484 

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

func (*DisableWorkflowLaunch) Reset added in v1.1.1484 

func (x *DisableWorkflowLaunch) Reset()

func (*DisableWorkflowLaunch) String added in v1.1.1484 

func (x *DisableWorkflowLaunch) String() string

type DisableWorkflowRequest added in v1.1.1460 

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

func (*DisableWorkflowRequest) Descriptor deprecated added in v1.1.1460 

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

Deprecated: Use DisableWorkflowRequest.ProtoReflect.Descriptor instead.

func (*DisableWorkflowRequest) GetWorkflowName added in v1.1.1460 

func (x *DisableWorkflowRequest) GetWorkflowName() string

func (*DisableWorkflowRequest) ProtoMessage added in v1.1.1460 

func (*DisableWorkflowRequest) ProtoMessage()

func (*DisableWorkflowRequest) ProtoReflect added in v1.1.1460 

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

func (*DisableWorkflowRequest) Reset added in v1.1.1460 

func (x *DisableWorkflowRequest) Reset()

func (*DisableWorkflowRequest) String added in v1.1.1460 

func (x *DisableWorkflowRequest) String() string

type DisableWorkflowResponse added in v1.1.1460 

type DisableWorkflowResponse struct {
	// contains filtered or unexported fields
}

func (*DisableWorkflowResponse) Descriptor deprecated added in v1.1.1460 

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

Deprecated: Use DisableWorkflowResponse.ProtoReflect.Descriptor instead.

func (*DisableWorkflowResponse) ProtoMessage added in v1.1.1460 

func (*DisableWorkflowResponse) ProtoMessage()

func (*DisableWorkflowResponse) ProtoReflect added in v1.1.1460 

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

func (*DisableWorkflowResponse) Reset added in v1.1.1460 

func (x *DisableWorkflowResponse) Reset()

func (*DisableWorkflowResponse) String added in v1.1.1460 

func (x *DisableWorkflowResponse) String() string

type Element 

type Element struct {
	Id              string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                // Id - the unique identifier for the workflow state machine element.
	Name            string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                            // Name - the name of the state machine element.
	Type            string            `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`                            // Type - the type of state machine element
	Documentation   string            `protobuf:"bytes,4,opt,name=documentation,proto3" json:"documentation,omitempty"`          // Documentation - any documentation describing the state machine element.
	Execute         string            `protobuf:"bytes,5,opt,name=execute,proto3" json:"execute,omitempty"`                      // Execute - describes the execution parameter,  This is used for different purposes depending on the type.
	Outbound        *Targets          `protobuf:"bytes,6,opt,name=outbound,proto3" json:"outbound,omitempty"`                    // Outbound - a number of possible transitions to other state machine state elements.s
	CompensateWith  *string           `protobuf:"bytes,22,opt,name=compensateWith,proto3,oneof" json:"compensateWith,omitempty"` // CompensateWith defines the element used for compensation.
	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
	Candidates      string            `protobuf:"bytes,10,opt,name=candidates,proto3" json:"candidates,omitempty"`               // Candidates - used for user related state machine types to define users that may complete the task.
	CandidateGroups string            `protobuf:"bytes,11,opt,name=candidateGroups,proto3" json:"candidateGroups,omitempty"`     // CandidateGroups - used for user related state machine types to define groups that may complete a task.
	Errors          []*CatchError     `protobuf:"bytes,12,rep,name=errors,proto3" json:"errors,omitempty"`                       // Errors - a number of catchable errors for this state machine element.
	Error           *Error            `protobuf:"bytes,13,opt,name=error,proto3" json:"error,omitempty"`                         // Error - an error that may be thrown.
	InputTransform  map[string]string ``                                                                                         // InputTransform - a transformation to perform between variable names when calling a state machine task.
	/* 170-byte string literal not displayed */
	OutputTransform map[string]string `` // OutputTransform - a transformation to perform 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.
	Iteration         *Iteration               `protobuf:"bytes,19,opt,name=iteration,proto3,oneof" json:"iteration,omitempty"`            // Iteration - gives any instructions for multi instance execution.
	Version           *string                  `protobuf:"bytes,20,opt,name=version,proto3,oneof" json:"version,omitempty"`                // Version - provides version information about a resource such as a task.
	RetryBehaviour    *DefaultTaskRetry        `protobuf:"bytes,21,opt,name=retryBehaviour,proto3,oneof" json:"retryBehaviour,omitempty"`  // RetryBehaviour - the style and type of retry associated with a service task.
	IsForCompensation bool                     `protobuf:"varint,23,opt,name=isForCompensation,proto3" json:"isForCompensation,omitempty"` // IsForCompensation - this element is used for compensation activities.
	// 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) GetCompensateWith added in v1.1.1099 

func (x *Element) GetCompensateWith() 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) GetIsForCompensation added in v1.1.1099 

func (x *Element) GetIsForCompensation() bool

func (*Element) GetIteration added in v1.0.485 

func (x *Element) GetIteration() *Iteration

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) GetRetryBehaviour added in v1.0.623 

func (x *Element) GetRetryBehaviour() *DefaultTaskRetry

func (*Element) GetTimer added in v0.1.181 

func (x *Element) GetTimer() *WorkflowTimerDefinition

func (*Element) GetType 

func (x *Element) GetType() string

func (*Element) GetVersion added in v1.0.623 

func (x *Element) GetVersion() 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 EnableWorkflowLaunch added in v1.1.1484 

type EnableWorkflowLaunch struct {
	Timestamp    int64  `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	WorkflowName string `protobuf:"bytes,2,opt,name=workflowName,proto3" json:"workflowName,omitempty"`
	// contains filtered or unexported fields
}

func (*EnableWorkflowLaunch) Descriptor deprecated added in v1.1.1484 

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

Deprecated: Use EnableWorkflowLaunch.ProtoReflect.Descriptor instead.

func (*EnableWorkflowLaunch) GetTimestamp added in v1.1.1484 

func (x *EnableWorkflowLaunch) GetTimestamp() int64

func (*EnableWorkflowLaunch) GetWorkflowName added in v1.1.1484 

func (x *EnableWorkflowLaunch) GetWorkflowName() string

func (*EnableWorkflowLaunch) ProtoMessage added in v1.1.1484 

func (*EnableWorkflowLaunch) ProtoMessage()

func (*EnableWorkflowLaunch) ProtoReflect added in v1.1.1484 

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

func (*EnableWorkflowLaunch) Reset added in v1.1.1484 

func (x *EnableWorkflowLaunch) Reset()

func (*EnableWorkflowLaunch) String added in v1.1.1484 

func (x *EnableWorkflowLaunch) String() string

type EnableWorkflowRequest added in v1.1.1460 

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

func (*EnableWorkflowRequest) Descriptor deprecated added in v1.1.1460 

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

Deprecated: Use EnableWorkflowRequest.ProtoReflect.Descriptor instead.

func (*EnableWorkflowRequest) GetWorkflowName added in v1.1.1460 

func (x *EnableWorkflowRequest) GetWorkflowName() string

func (*EnableWorkflowRequest) ProtoMessage added in v1.1.1460 

func (*EnableWorkflowRequest) ProtoMessage()

func (*EnableWorkflowRequest) ProtoReflect added in v1.1.1460 

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

func (*EnableWorkflowRequest) Reset added in v1.1.1460 

func (x *EnableWorkflowRequest) Reset()

func (*EnableWorkflowRequest) String added in v1.1.1460 

func (x *EnableWorkflowRequest) String() string

type EnableWorkflowResponse added in v1.1.1460 

type EnableWorkflowResponse struct {
	// contains filtered or unexported fields
}

func (*EnableWorkflowResponse) Descriptor deprecated added in v1.1.1460 

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

Deprecated: Use EnableWorkflowResponse.ProtoReflect.Descriptor instead.

func (*EnableWorkflowResponse) ProtoMessage added in v1.1.1460 

func (*EnableWorkflowResponse) ProtoMessage()

func (*EnableWorkflowResponse) ProtoReflect added in v1.1.1460 

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

func (*EnableWorkflowResponse) Reset added in v1.1.1460 

func (x *EnableWorkflowResponse) Reset()

func (*EnableWorkflowResponse) String added in v1.1.1460 

func (x *EnableWorkflowResponse) String() string

type Error added in v0.1.134 

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

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

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

func (*Error) 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 Exchange added in v1.1.725 

type Exchange struct {
	Sender    *Sender              `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` // Sender - the sender side of the exchange
	Receivers map[string]*Receiver ``                                                                  // Receivers - the receiver sides of the exchange
	/* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Exchange) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use Exchange.ProtoReflect.Descriptor instead.

func (*Exchange) GetReceivers added in v1.1.725 

func (x *Exchange) GetReceivers() map[string]*Receiver

func (*Exchange) GetSender added in v1.1.725 

func (x *Exchange) GetSender() *Sender

func (*Exchange) ProtoMessage added in v1.1.725 

func (*Exchange) ProtoMessage()

func (*Exchange) ProtoReflect added in v1.1.725 

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

func (*Exchange) Reset added in v1.1.725 

func (x *Exchange) Reset()

func (*Exchange) String added in v1.1.725 

func (x *Exchange) String() string

type ExecutableStartParameter added in v1.1.1032 

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

func (*ExecutableStartParameter) Descriptor deprecated added in v1.1.1032 

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

Deprecated: Use ExecutableStartParameter.ProtoReflect.Descriptor instead.

func (*ExecutableStartParameter) GetName added in v1.1.1032 

func (x *ExecutableStartParameter) GetName() string

func (*ExecutableStartParameter) ProtoMessage added in v1.1.1032 

func (*ExecutableStartParameter) ProtoMessage()

func (*ExecutableStartParameter) ProtoReflect added in v1.1.1032 

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

func (*ExecutableStartParameter) Reset added in v1.1.1032 

func (x *ExecutableStartParameter) Reset()

func (*ExecutableStartParameter) String added in v1.1.1032 

func (x *ExecutableStartParameter) String() string

type Execution added in v1.0.645 

type Execution struct {
	ExecutionId       string   `protobuf:"bytes,1,opt,name=executionId,proto3" json:"executionId,omitempty"`             // executionId - The id of this particular BPMExecution
	WorkflowId        string   `protobuf:"bytes,2,opt,name=workflowId,proto3" json:"workflowId,omitempty"`               // WorkflowId - the workflow version ID that this instance is executing.
	WorkflowName      string   `protobuf:"bytes,5,opt,name=workflowName,proto3" json:"workflowName,omitempty"`           // WorkflowName - name of this workflow to avoid lookups.
	ProcessInstanceId []string `protobuf:"bytes,6,rep,name=processInstanceId,proto3" json:"processInstanceId,omitempty"` // ProcessInstance - process instances berlonging to this execution.
	// contains filtered or unexported fields
}

Execution contains all of the metadata for a currently running workflow.

func (*Execution) Descriptor deprecated added in v1.0.645 

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

Deprecated: Use Execution.ProtoReflect.Descriptor instead.

func (*Execution) GetExecutionId added in v1.0.645 

func (x *Execution) GetExecutionId() string

func (*Execution) GetProcessInstanceId added in v1.0.645 

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

func (*Execution) GetWorkflowId added in v1.0.645 

func (x *Execution) GetWorkflowId() string

func (*Execution) GetWorkflowName added in v1.0.645 

func (x *Execution) GetWorkflowName() string

func (*Execution) ProtoMessage added in v1.0.645 

func (*Execution) ProtoMessage()

func (*Execution) ProtoReflect added in v1.0.645 

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

func (*Execution) Reset added in v1.0.645 

func (x *Execution) Reset()

func (*Execution) String added in v1.0.645 

func (x *Execution) String() string

type FatalError added in v1.1.1102 

type FatalError struct {
	HandlingStrategy HandlingStrategy `protobuf:"varint,1,opt,name=handlingStrategy,proto3,enum=HandlingStrategy" json:"handlingStrategy,omitempty"`
	WorkflowState    *WorkflowState   `protobuf:"bytes,2,opt,name=workflowState,proto3" json:"workflowState,omitempty"`
	// contains filtered or unexported fields
}

func (*FatalError) Descriptor deprecated added in v1.1.1102 

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

Deprecated: Use FatalError.ProtoReflect.Descriptor instead.

func (*FatalError) GetHandlingStrategy added in v1.1.1102 

func (x *FatalError) GetHandlingStrategy() HandlingStrategy

func (*FatalError) GetWorkflowState added in v1.1.1102 

func (x *FatalError) GetWorkflowState() *WorkflowState

func (*FatalError) ProtoMessage added in v1.1.1102 

func (*FatalError) ProtoMessage()

func (*FatalError) ProtoReflect added in v1.1.1102 

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

func (*FatalError) Reset added in v1.1.1102 

func (x *FatalError) Reset()

func (*FatalError) String added in v1.1.1102 

func (x *FatalError) String() string

type Gateway added in v1.0.446 

type Gateway struct {
	MetExpectations map[string]string `` // MetExpectations - a list of expectations that were met for the gateway.
	/* 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 GetCompensationInputVariablesRequest added in v1.1.1099 

type GetCompensationInputVariablesRequest struct {
	ProcessInstanceId string `protobuf:"bytes,1,opt,name=processInstanceId,proto3" json:"processInstanceId,omitempty"`
	TrackingId        string `protobuf:"bytes,2,opt,name=trackingId,proto3" json:"trackingId,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCompensationInputVariablesRequest) Descriptor deprecated added in v1.1.1099 

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

Deprecated: Use GetCompensationInputVariablesRequest.ProtoReflect.Descriptor instead.

func (*GetCompensationInputVariablesRequest) GetProcessInstanceId added in v1.1.1099 

func (x *GetCompensationInputVariablesRequest) GetProcessInstanceId() string

func (*GetCompensationInputVariablesRequest) GetTrackingId added in v1.1.1099 

func (x *GetCompensationInputVariablesRequest) GetTrackingId() string

func (*GetCompensationInputVariablesRequest) ProtoMessage added in v1.1.1099 

func (*GetCompensationInputVariablesRequest) ProtoMessage()

func (*GetCompensationInputVariablesRequest) ProtoReflect added in v1.1.1099 

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

func (*GetCompensationInputVariablesRequest) Reset added in v1.1.1099 

func (x *GetCompensationInputVariablesRequest) Reset()

func (*GetCompensationInputVariablesRequest) String added in v1.1.1099 

func (x *GetCompensationInputVariablesRequest) String() string

type GetCompensationInputVariablesResponse added in v1.1.1099 

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

func (*GetCompensationInputVariablesResponse) Descriptor deprecated added in v1.1.1099 

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

Deprecated: Use GetCompensationInputVariablesResponse.ProtoReflect.Descriptor instead.

func (*GetCompensationInputVariablesResponse) GetVars added in v1.1.1099 

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

func (*GetCompensationInputVariablesResponse) ProtoMessage added in v1.1.1099 

func (*GetCompensationInputVariablesResponse) ProtoMessage()

func (*GetCompensationInputVariablesResponse) ProtoReflect added in v1.1.1099 

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

func (*GetCompensationInputVariablesResponse) Reset added in v1.1.1099 

func (x *GetCompensationInputVariablesResponse) Reset()

func (*GetCompensationInputVariablesResponse) String added in v1.1.1099 

func (x *GetCompensationInputVariablesResponse) String() string

type GetCompensationOutputVariablesRequest added in v1.1.1099 

type GetCompensationOutputVariablesRequest struct {
	ProcessInstanceId string `protobuf:"bytes,1,opt,name=processInstanceId,proto3" json:"processInstanceId,omitempty"`
	TrackingId        string `protobuf:"bytes,2,opt,name=trackingId,proto3" json:"trackingId,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCompensationOutputVariablesRequest) Descriptor deprecated added in v1.1.1099 

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

Deprecated: Use GetCompensationOutputVariablesRequest.ProtoReflect.Descriptor instead.

func (*GetCompensationOutputVariablesRequest) GetProcessInstanceId added in v1.1.1099 

func (x *GetCompensationOutputVariablesRequest) GetProcessInstanceId() string

func (*GetCompensationOutputVariablesRequest) GetTrackingId added in v1.1.1099 

func (x *GetCompensationOutputVariablesRequest) GetTrackingId() string

func (*GetCompensationOutputVariablesRequest) ProtoMessage added in v1.1.1099 

func (*GetCompensationOutputVariablesRequest) ProtoMessage()

func (*GetCompensationOutputVariablesRequest) ProtoReflect added in v1.1.1099 

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

func (*GetCompensationOutputVariablesRequest) Reset added in v1.1.1099 

func (x *GetCompensationOutputVariablesRequest) Reset()

func (*GetCompensationOutputVariablesRequest) String added in v1.1.1099 

func (x *GetCompensationOutputVariablesRequest) String() string

type GetCompensationOutputVariablesResponse added in v1.1.1099 

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

func (*GetCompensationOutputVariablesResponse) Descriptor deprecated added in v1.1.1099 

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

Deprecated: Use GetCompensationOutputVariablesResponse.ProtoReflect.Descriptor instead.

func (*GetCompensationOutputVariablesResponse) GetVars added in v1.1.1099 

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

func (*GetCompensationOutputVariablesResponse) ProtoMessage added in v1.1.1099 

func (*GetCompensationOutputVariablesResponse) ProtoMessage()

func (*GetCompensationOutputVariablesResponse) ProtoReflect added in v1.1.1099 

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

func (*GetCompensationOutputVariablesResponse) Reset added in v1.1.1099 

func (x *GetCompensationOutputVariablesResponse) Reset()

func (*GetCompensationOutputVariablesResponse) String added in v1.1.1099 

func (x *GetCompensationOutputVariablesResponse) String() string

type GetFatalErrorRequest added in v1.1.1377 

type GetFatalErrorRequest struct {
	WfName            string `protobuf:"bytes,1,opt,name=wfName,proto3" json:"wfName,omitempty"`
	WfId              string `protobuf:"bytes,2,opt,name=wfId,proto3" json:"wfId,omitempty"`
	ExecutionId       string `protobuf:"bytes,3,opt,name=executionId,proto3" json:"executionId,omitempty"`
	ProcessInstanceId string `protobuf:"bytes,4,opt,name=processInstanceId,proto3" json:"processInstanceId,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFatalErrorRequest) Descriptor deprecated added in v1.1.1377 

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

Deprecated: Use GetFatalErrorRequest.ProtoReflect.Descriptor instead.

func (*GetFatalErrorRequest) GetExecutionId added in v1.1.1377 

func (x *GetFatalErrorRequest) GetExecutionId() string

func (*GetFatalErrorRequest) GetProcessInstanceId added in v1.1.1377 

func (x *GetFatalErrorRequest) GetProcessInstanceId() string

func (*GetFatalErrorRequest) GetWfId added in v1.1.1377 

func (x *GetFatalErrorRequest) GetWfId() string

func (*GetFatalErrorRequest) GetWfName added in v1.1.1377 

func (x *GetFatalErrorRequest) GetWfName() string

func (*GetFatalErrorRequest) ProtoMessage added in v1.1.1377 

func (*GetFatalErrorRequest) ProtoMessage()

func (*GetFatalErrorRequest) ProtoReflect added in v1.1.1377 

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

func (*GetFatalErrorRequest) Reset added in v1.1.1377 

func (x *GetFatalErrorRequest) Reset()

func (*GetFatalErrorRequest) String added in v1.1.1377 

func (x *GetFatalErrorRequest) String() string

type GetJobRequest added in v1.1.797 

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

func (*GetJobRequest) Descriptor deprecated added in v1.1.797 

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetJobId added in v1.1.797 

func (x *GetJobRequest) GetJobId() string

func (*GetJobRequest) ProtoMessage added in v1.1.797 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect added in v1.1.797 

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

func (*GetJobRequest) Reset added in v1.1.797 

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String added in v1.1.797 

func (x *GetJobRequest) String() string

type GetJobResponse added in v1.1.797 

type GetJobResponse struct {
	Job *WorkflowState `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobResponse) Descriptor deprecated added in v1.1.797 

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

Deprecated: Use GetJobResponse.ProtoReflect.Descriptor instead.

func (*GetJobResponse) GetJob added in v1.1.797 

func (x *GetJobResponse) GetJob() *WorkflowState

func (*GetJobResponse) ProtoMessage added in v1.1.797 

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) ProtoReflect added in v1.1.797 

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

func (*GetJobResponse) Reset added in v1.1.797 

func (x *GetJobResponse) Reset()

func (*GetJobResponse) String added in v1.1.797 

func (x *GetJobResponse) String() string

type GetProcessHeadersRequest added in v1.1.1323 

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

func (*GetProcessHeadersRequest) Descriptor deprecated added in v1.1.1323 

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

Deprecated: Use GetProcessHeadersRequest.ProtoReflect.Descriptor instead.

func (*GetProcessHeadersRequest) GetProcessInstanceID added in v1.1.1323 

func (x *GetProcessHeadersRequest) GetProcessInstanceID() string

func (*GetProcessHeadersRequest) ProtoMessage added in v1.1.1323 

func (*GetProcessHeadersRequest) ProtoMessage()

func (*GetProcessHeadersRequest) ProtoReflect added in v1.1.1323 

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

func (*GetProcessHeadersRequest) Reset added in v1.1.1323 

func (x *GetProcessHeadersRequest) Reset()

func (*GetProcessHeadersRequest) String added in v1.1.1323 

func (x *GetProcessHeadersRequest) String() string

type GetProcessHeadersResponse added in v1.1.1323 

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

func (*GetProcessHeadersResponse) Descriptor deprecated added in v1.1.1323 

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

Deprecated: Use GetProcessHeadersResponse.ProtoReflect.Descriptor instead.

func (*GetProcessHeadersResponse) GetHeaders added in v1.1.1323 

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

func (*GetProcessHeadersResponse) ProtoMessage added in v1.1.1323 

func (*GetProcessHeadersResponse) ProtoMessage()

func (*GetProcessHeadersResponse) ProtoReflect added in v1.1.1323 

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

func (*GetProcessHeadersResponse) Reset added in v1.1.1323 

func (x *GetProcessHeadersResponse) Reset()

func (*GetProcessHeadersResponse) String added in v1.1.1323 

func (x *GetProcessHeadersResponse) String() string

type GetProcessHistoryRequest added in v1.0.477 

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

func (*GetProcessHistoryRequest) Descriptor deprecated added in v1.0.477 

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

Deprecated: Use GetProcessHistoryRequest.ProtoReflect.Descriptor instead.

func (*GetProcessHistoryRequest) GetId added in v1.0.477 

func (x *GetProcessHistoryRequest) GetId() string

func (*GetProcessHistoryRequest) ProtoMessage added in v1.0.477 

func (*GetProcessHistoryRequest) ProtoMessage()

func (*GetProcessHistoryRequest) ProtoReflect added in v1.0.477 

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

func (*GetProcessHistoryRequest) Reset added in v1.0.477 

func (x *GetProcessHistoryRequest) Reset()

func (*GetProcessHistoryRequest) String added in v1.0.477 

func (x *GetProcessHistoryRequest) String() string

type GetProcessHistoryResponse added in v1.0.477 

type GetProcessHistoryResponse struct {
	Entry []*ProcessHistoryEntry `protobuf:"bytes,1,rep,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

func (*GetProcessHistoryResponse) Descriptor deprecated added in v1.0.477 

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

Deprecated: Use GetProcessHistoryResponse.ProtoReflect.Descriptor instead.

func (*GetProcessHistoryResponse) GetEntry added in v1.0.477 

func (x *GetProcessHistoryResponse) GetEntry() []*ProcessHistoryEntry

func (*GetProcessHistoryResponse) ProtoMessage added in v1.0.477 

func (*GetProcessHistoryResponse) ProtoMessage()

func (*GetProcessHistoryResponse) ProtoReflect added in v1.0.477 

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

func (*GetProcessHistoryResponse) Reset added in v1.0.477 

func (x *GetProcessHistoryResponse) Reset()

func (*GetProcessHistoryResponse) String added in v1.0.477 

func (x *GetProcessHistoryResponse) String() string

type GetProcessInstanceStatusRequest added in v1.0.427 

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

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

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

Deprecated: Use GetProcessInstanceStatusRequest.ProtoReflect.Descriptor instead.

func (*GetProcessInstanceStatusRequest) GetId added in v1.0.427 

func (x *GetProcessInstanceStatusRequest) GetId() string

func (*GetProcessInstanceStatusRequest) ProtoMessage added in v1.0.427 

func (*GetProcessInstanceStatusRequest) ProtoMessage()

func (*GetProcessInstanceStatusRequest) ProtoReflect added in v1.0.427 

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

func (*GetProcessInstanceStatusRequest) Reset added in v1.0.427 

func (x *GetProcessInstanceStatusRequest) Reset()

func (*GetProcessInstanceStatusRequest) String added in v1.0.427 

func (x *GetProcessInstanceStatusRequest) String() string

type GetProcessInstanceStatusResponse added in v1.1.725 

type GetProcessInstanceStatusResponse struct {
	// contains filtered or unexported fields
}

func (*GetProcessInstanceStatusResponse) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use GetProcessInstanceStatusResponse.ProtoReflect.Descriptor instead.

func (*GetProcessInstanceStatusResponse) ProtoMessage added in v1.1.725 

func (*GetProcessInstanceStatusResponse) ProtoMessage()

func (*GetProcessInstanceStatusResponse) ProtoReflect added in v1.1.725 

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

func (*GetProcessInstanceStatusResponse) Reset added in v1.1.725 

func (x *GetProcessInstanceStatusResponse) Reset()

func (*GetProcessInstanceStatusResponse) String added in v1.1.725 

func (x *GetProcessInstanceStatusResponse) String() string

type GetProcessInstanceStatusResult added in v1.0.427 

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

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

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

Deprecated: Use GetProcessInstanceStatusResult.ProtoReflect.Descriptor instead.

func (*GetProcessInstanceStatusResult) GetProcessState added in v1.0.427 

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

func (*GetProcessInstanceStatusResult) ProtoMessage added in v1.0.427 

func (*GetProcessInstanceStatusResult) ProtoMessage()

func (*GetProcessInstanceStatusResult) ProtoReflect added in v1.0.427 

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

func (*GetProcessInstanceStatusResult) Reset added in v1.0.427 

func (x *GetProcessInstanceStatusResult) Reset()

func (*GetProcessInstanceStatusResult) String added in v1.0.427 

func (x *GetProcessInstanceStatusResult) String() string

type GetServiceTaskRoutingIDRequest added in v1.0.514 

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

func (*GetServiceTaskRoutingIDRequest) Descriptor deprecated added in v1.0.514 

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

Deprecated: Use GetServiceTaskRoutingIDRequest.ProtoReflect.Descriptor instead.

func (*GetServiceTaskRoutingIDRequest) GetName added in v1.0.514 

func (x *GetServiceTaskRoutingIDRequest) GetName() string

func (*GetServiceTaskRoutingIDRequest) GetRequestedId added in v1.0.514 

func (x *GetServiceTaskRoutingIDRequest) GetRequestedId() string

func (*GetServiceTaskRoutingIDRequest) ProtoMessage added in v1.0.514 

func (*GetServiceTaskRoutingIDRequest) ProtoMessage()

func (*GetServiceTaskRoutingIDRequest) ProtoReflect added in v1.0.514 

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

func (*GetServiceTaskRoutingIDRequest) Reset added in v1.0.514 

func (x *GetServiceTaskRoutingIDRequest) Reset()

func (*GetServiceTaskRoutingIDRequest) String added in v1.0.514 

func (x *GetServiceTaskRoutingIDRequest) String() string

type GetServiceTaskRoutingIDResponse added in v1.0.514 

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

func (*GetServiceTaskRoutingIDResponse) Descriptor deprecated added in v1.0.514 

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

Deprecated: Use GetServiceTaskRoutingIDResponse.ProtoReflect.Descriptor instead.

func (*GetServiceTaskRoutingIDResponse) GetId added in v1.0.514 

func (x *GetServiceTaskRoutingIDResponse) GetId() string

func (*GetServiceTaskRoutingIDResponse) ProtoMessage added in v1.0.514 

func (*GetServiceTaskRoutingIDResponse) ProtoMessage()

func (*GetServiceTaskRoutingIDResponse) ProtoReflect added in v1.0.514 

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

func (*GetServiceTaskRoutingIDResponse) Reset added in v1.0.514 

func (x *GetServiceTaskRoutingIDResponse) Reset()

func (*GetServiceTaskRoutingIDResponse) String added in v1.0.514 

func (x *GetServiceTaskRoutingIDResponse) String() string

type GetTaskSpecRequest added in v1.0.623 

type GetTaskSpecRequest struct {
	Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"` // Uid of the registered task.
	// contains filtered or unexported fields
}

GetTaskSpecRequest contains the UID of a registered task.

func (*GetTaskSpecRequest) Descriptor deprecated added in v1.0.623 

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

Deprecated: Use GetTaskSpecRequest.ProtoReflect.Descriptor instead.

func (*GetTaskSpecRequest) GetUid added in v1.0.623 

func (x *GetTaskSpecRequest) GetUid() string

func (*GetTaskSpecRequest) ProtoMessage added in v1.0.623 

func (*GetTaskSpecRequest) ProtoMessage()

func (*GetTaskSpecRequest) ProtoReflect added in v1.0.623 

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

func (*GetTaskSpecRequest) Reset added in v1.0.623 

func (x *GetTaskSpecRequest) Reset()

func (*GetTaskSpecRequest) String added in v1.0.623 

func (x *GetTaskSpecRequest) String() string

type GetTaskSpecResponse added in v1.0.623 

type GetTaskSpecResponse struct {
	Spec *TaskSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` // Spec - the task specification.
	// contains filtered or unexported fields
}

GetTaskSpecResponse returns a task spec.

func (*GetTaskSpecResponse) Descriptor deprecated added in v1.0.623 

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

Deprecated: Use GetTaskSpecResponse.ProtoReflect.Descriptor instead.

func (*GetTaskSpecResponse) GetSpec added in v1.0.623 

func (x *GetTaskSpecResponse) GetSpec() *TaskSpec

func (*GetTaskSpecResponse) ProtoMessage added in v1.0.623 

func (*GetTaskSpecResponse) ProtoMessage()

func (*GetTaskSpecResponse) ProtoReflect added in v1.0.623 

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

func (*GetTaskSpecResponse) Reset added in v1.0.623 

func (x *GetTaskSpecResponse) Reset()

func (*GetTaskSpecResponse) String added in v1.0.623 

func (x *GetTaskSpecResponse) String() string

type GetTaskSpecUsageRequest added in v1.1.670 

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

func (*GetTaskSpecUsageRequest) Descriptor deprecated added in v1.1.670 

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

Deprecated: Use GetTaskSpecUsageRequest.ProtoReflect.Descriptor instead.

func (*GetTaskSpecUsageRequest) GetId added in v1.1.670 

func (x *GetTaskSpecUsageRequest) GetId() string

func (*GetTaskSpecUsageRequest) ProtoMessage added in v1.1.670 

func (*GetTaskSpecUsageRequest) ProtoMessage()

func (*GetTaskSpecUsageRequest) ProtoReflect added in v1.1.670 

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

func (*GetTaskSpecUsageRequest) Reset added in v1.1.670 

func (x *GetTaskSpecUsageRequest) Reset()

func (*GetTaskSpecUsageRequest) String added in v1.1.670 

func (x *GetTaskSpecUsageRequest) String() string

type GetTaskSpecUsageResponse added in v1.1.725 

type GetTaskSpecUsageResponse struct {
	// contains filtered or unexported fields
}

func (*GetTaskSpecUsageResponse) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use GetTaskSpecUsageResponse.ProtoReflect.Descriptor instead.

func (*GetTaskSpecUsageResponse) ProtoMessage added in v1.1.725 

func (*GetTaskSpecUsageResponse) ProtoMessage()

func (*GetTaskSpecUsageResponse) ProtoReflect added in v1.1.725 

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

func (*GetTaskSpecUsageResponse) Reset added in v1.1.725 

func (x *GetTaskSpecUsageResponse) Reset()

func (*GetTaskSpecUsageResponse) String added in v1.1.725 

func (x *GetTaskSpecUsageResponse) String() string

type GetTaskSpecVersionsRequest added in v1.1.670 

type GetTaskSpecVersionsRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Name of the task specification.
	// contains filtered or unexported fields
}

func (*GetTaskSpecVersionsRequest) Descriptor deprecated added in v1.1.670 

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

Deprecated: Use GetTaskSpecVersionsRequest.ProtoReflect.Descriptor instead.

func (*GetTaskSpecVersionsRequest) GetName added in v1.1.670 

func (x *GetTaskSpecVersionsRequest) GetName() string

func (*GetTaskSpecVersionsRequest) ProtoMessage added in v1.1.670 

func (*GetTaskSpecVersionsRequest) ProtoMessage()

func (*GetTaskSpecVersionsRequest) ProtoReflect added in v1.1.670 

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

func (*GetTaskSpecVersionsRequest) Reset added in v1.1.670 

func (x *GetTaskSpecVersionsRequest) Reset()

func (*GetTaskSpecVersionsRequest) String added in v1.1.670 

func (x *GetTaskSpecVersionsRequest) String() string

type GetTaskSpecVersionsResponse added in v1.1.725 

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

func (*GetTaskSpecVersionsResponse) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use GetTaskSpecVersionsResponse.ProtoReflect.Descriptor instead.

func (*GetTaskSpecVersionsResponse) GetVersions added in v1.1.725 

func (x *GetTaskSpecVersionsResponse) GetVersions() *TaskSpecVersions

func (*GetTaskSpecVersionsResponse) ProtoMessage added in v1.1.725 

func (*GetTaskSpecVersionsResponse) ProtoMessage()

func (*GetTaskSpecVersionsResponse) ProtoReflect added in v1.1.725 

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

func (*GetTaskSpecVersionsResponse) Reset added in v1.1.725 

func (x *GetTaskSpecVersionsResponse) Reset()

func (*GetTaskSpecVersionsResponse) String added in v1.1.725 

func (x *GetTaskSpecVersionsResponse) String() string

type GetUserTaskRequest added in v0.1.88 

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

func (*GetUserTaskRequest) Descriptor deprecated added in v0.1.88 

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

Deprecated: Use GetUserTaskRequest.ProtoReflect.Descriptor instead.

func (*GetUserTaskRequest) GetOwner added in v0.1.88 

func (x *GetUserTaskRequest) GetOwner() string

func (*GetUserTaskRequest) GetTrackingId added in v0.1.88 

func (x *GetUserTaskRequest) GetTrackingId() string

func (*GetUserTaskRequest) ProtoMessage added in v0.1.88 

func (*GetUserTaskRequest) ProtoMessage()

func (*GetUserTaskRequest) ProtoReflect added in v0.1.88 

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

func (*GetUserTaskRequest) Reset added in v0.1.88 

func (x *GetUserTaskRequest) Reset()

func (*GetUserTaskRequest) String added in v0.1.88 

func (x *GetUserTaskRequest) String() string

type GetUserTaskResponse added in v0.1.134 

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

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

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

Deprecated: Use GetUserTaskResponse.ProtoReflect.Descriptor instead.

func (*GetUserTaskResponse) GetDescription added in v0.1.134 

func (x *GetUserTaskResponse) GetDescription() string

func (*GetUserTaskResponse) GetName added in v0.1.134 

func (x *GetUserTaskResponse) GetName() string

func (*GetUserTaskResponse) GetOwner added in v0.1.134 

func (x *GetUserTaskResponse) GetOwner() string

func (*GetUserTaskResponse) GetTrackingId added in v0.1.134 

func (x *GetUserTaskResponse) GetTrackingId() string

func (*GetUserTaskResponse) GetVars added in v0.1.134 

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

func (*GetUserTaskResponse) ProtoMessage added in v0.1.134 

func (*GetUserTaskResponse) ProtoMessage()

func (*GetUserTaskResponse) ProtoReflect added in v0.1.134 

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

func (*GetUserTaskResponse) Reset added in v0.1.134 

func (x *GetUserTaskResponse) Reset()

func (*GetUserTaskResponse) String added in v0.1.134 

func (x *GetUserTaskResponse) String() string

type GetVersionInfoRequest added in v1.0.514 

type GetVersionInfoRequest struct {
	ClientVersion     string `protobuf:"bytes,1,opt,name=clientVersion,proto3" json:"clientVersion,omitempty"`
	CompatibleVersion string `protobuf:"bytes,2,opt,name=compatibleVersion,proto3" json:"compatibleVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVersionInfoRequest) Descriptor deprecated added in v1.0.514 

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

Deprecated: Use GetVersionInfoRequest.ProtoReflect.Descriptor instead.

func (*GetVersionInfoRequest) GetClientVersion added in v1.0.514 

func (x *GetVersionInfoRequest) GetClientVersion() string

func (*GetVersionInfoRequest) GetCompatibleVersion added in v1.1.677 

func (x *GetVersionInfoRequest) GetCompatibleVersion() string

func (*GetVersionInfoRequest) ProtoMessage added in v1.0.514 

func (*GetVersionInfoRequest) ProtoMessage()

func (*GetVersionInfoRequest) ProtoReflect added in v1.0.514 

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

func (*GetVersionInfoRequest) Reset added in v1.0.514 

func (x *GetVersionInfoRequest) Reset()

func (*GetVersionInfoRequest) String added in v1.0.514 

func (x *GetVersionInfoRequest) String() string

type GetVersionInfoResponse added in v1.0.514 

type GetVersionInfoResponse struct {
	ServerVersion        string `protobuf:"bytes,1,opt,name=serverVersion,proto3" json:"serverVersion,omitempty"`
	MinCompatibleVersion string `protobuf:"bytes,2,opt,name=minCompatibleVersion,proto3" json:"minCompatibleVersion,omitempty"`
	Connect              bool   `protobuf:"varint,3,opt,name=connect,proto3" json:"connect,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVersionInfoResponse) Descriptor deprecated added in v1.0.514 

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

Deprecated: Use GetVersionInfoResponse.ProtoReflect.Descriptor instead.

func (*GetVersionInfoResponse) GetConnect added in v1.0.514 

func (x *GetVersionInfoResponse) GetConnect() bool

func (*GetVersionInfoResponse) GetMinCompatibleVersion added in v1.0.514 

func (x *GetVersionInfoResponse) GetMinCompatibleVersion() string

func (*GetVersionInfoResponse) GetServerVersion added in v1.0.514 

func (x *GetVersionInfoResponse) GetServerVersion() string

func (*GetVersionInfoResponse) ProtoMessage added in v1.0.514 

func (*GetVersionInfoResponse) ProtoMessage()

func (*GetVersionInfoResponse) ProtoReflect added in v1.0.514 

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

func (*GetVersionInfoResponse) Reset added in v1.0.514 

func (x *GetVersionInfoResponse) Reset()

func (*GetVersionInfoResponse) String added in v1.0.514 

func (x *GetVersionInfoResponse) String() string

type GetWorkflowRequest added in v1.0.366 

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

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

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

Deprecated: Use GetWorkflowRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowRequest) GetId added in v1.0.366 

func (x *GetWorkflowRequest) GetId() string

func (*GetWorkflowRequest) ProtoMessage added in v1.0.366 

func (*GetWorkflowRequest) ProtoMessage()

func (*GetWorkflowRequest) ProtoReflect added in v1.0.366 

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

func (*GetWorkflowRequest) Reset added in v1.0.366 

func (x *GetWorkflowRequest) Reset()

func (*GetWorkflowRequest) String added in v1.0.366 

func (x *GetWorkflowRequest) String() string

type GetWorkflowResponse added in v1.0.366 

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

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

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

Deprecated: Use GetWorkflowResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowResponse) GetDefinition added in v1.0.366 

func (x *GetWorkflowResponse) GetDefinition() *Workflow

func (*GetWorkflowResponse) ProtoMessage added in v1.0.366 

func (*GetWorkflowResponse) ProtoMessage()

func (*GetWorkflowResponse) ProtoReflect added in v1.0.366 

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

func (*GetWorkflowResponse) Reset added in v1.0.366 

func (x *GetWorkflowResponse) Reset()

func (*GetWorkflowResponse) String added in v1.0.366 

func (x *GetWorkflowResponse) String() string

type GetWorkflowVersionsRequest added in v1.0.366 

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

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

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

Deprecated: Use GetWorkflowVersionsRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowVersionsRequest) GetName added in v1.0.366 

func (x *GetWorkflowVersionsRequest) GetName() string

func (*GetWorkflowVersionsRequest) ProtoMessage added in v1.0.366 

func (*GetWorkflowVersionsRequest) ProtoMessage()

func (*GetWorkflowVersionsRequest) ProtoReflect added in v1.0.366 

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

func (*GetWorkflowVersionsRequest) Reset added in v1.0.366 

func (x *GetWorkflowVersionsRequest) Reset()

func (*GetWorkflowVersionsRequest) String added in v1.0.366 

func (x *GetWorkflowVersionsRequest) String() string

type GetWorkflowVersionsResponse added in v1.0.366 

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

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

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

Deprecated: Use GetWorkflowVersionsResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowVersionsResponse) GetVersions added in v1.0.366 

func (x *GetWorkflowVersionsResponse) GetVersions() *WorkflowVersions

func (*GetWorkflowVersionsResponse) ProtoMessage added in v1.0.366 

func (*GetWorkflowVersionsResponse) ProtoMessage()

func (*GetWorkflowVersionsResponse) ProtoReflect added in v1.0.366 

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

func (*GetWorkflowVersionsResponse) Reset added in v1.0.366 

func (x *GetWorkflowVersionsResponse) Reset()

func (*GetWorkflowVersionsResponse) String added in v1.0.366 

func (x *GetWorkflowVersionsResponse) String() string

type HandleWorkflowErrorRequest added in v0.1.134 

type HandleWorkflowErrorRequest struct {
	TrackingId string `protobuf:"bytes,1,opt,name=trackingId,proto3" json:"trackingId,omitempty"`
	ErrorCode  string `protobuf:"bytes,2,opt,name=errorCode,proto3" json:"errorCode,omitempty"`
	Message    string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Vars       []byte `protobuf:"bytes,4,opt,name=vars,proto3" json:"vars,omitempty"`
	// 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 HandleWorkflowFatalErrorRequest added in v1.1.1102 

type HandleWorkflowFatalErrorRequest struct {
	WorkflowState    *WorkflowState   `protobuf:"bytes,1,opt,name=workflowState,proto3" json:"workflowState,omitempty"`
	Message          string           `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	HandlingStrategy HandlingStrategy `protobuf:"varint,3,opt,name=handlingStrategy,proto3,enum=HandlingStrategy" json:"handlingStrategy,omitempty"`
	// contains filtered or unexported fields
}

func (*HandleWorkflowFatalErrorRequest) Descriptor deprecated added in v1.1.1102 

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

Deprecated: Use HandleWorkflowFatalErrorRequest.ProtoReflect.Descriptor instead.

func (*HandleWorkflowFatalErrorRequest) GetHandlingStrategy added in v1.1.1377 

func (x *HandleWorkflowFatalErrorRequest) GetHandlingStrategy() HandlingStrategy

func (*HandleWorkflowFatalErrorRequest) GetMessage added in v1.1.1102 

func (x *HandleWorkflowFatalErrorRequest) GetMessage() string

func (*HandleWorkflowFatalErrorRequest) GetWorkflowState added in v1.1.1102 

func (x *HandleWorkflowFatalErrorRequest) GetWorkflowState() *WorkflowState

func (*HandleWorkflowFatalErrorRequest) ProtoMessage added in v1.1.1102 

func (*HandleWorkflowFatalErrorRequest) ProtoMessage()

func (*HandleWorkflowFatalErrorRequest) ProtoReflect added in v1.1.1102 

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

func (*HandleWorkflowFatalErrorRequest) Reset added in v1.1.1102 

func (x *HandleWorkflowFatalErrorRequest) Reset()

func (*HandleWorkflowFatalErrorRequest) String added in v1.1.1102 

func (x *HandleWorkflowFatalErrorRequest) String() string

type HandleWorkflowFatalErrorResponse added in v1.1.1102 

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

func (*HandleWorkflowFatalErrorResponse) Descriptor deprecated added in v1.1.1102 

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

Deprecated: Use HandleWorkflowFatalErrorResponse.ProtoReflect.Descriptor instead.

func (*HandleWorkflowFatalErrorResponse) GetHandled added in v1.1.1102 

func (x *HandleWorkflowFatalErrorResponse) GetHandled() bool

func (*HandleWorkflowFatalErrorResponse) ProtoMessage added in v1.1.1102 

func (*HandleWorkflowFatalErrorResponse) ProtoMessage()

func (*HandleWorkflowFatalErrorResponse) ProtoReflect added in v1.1.1102 

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

func (*HandleWorkflowFatalErrorResponse) Reset added in v1.1.1102 

func (x *HandleWorkflowFatalErrorResponse) Reset()

func (*HandleWorkflowFatalErrorResponse) String added in v1.1.1102 

func (x *HandleWorkflowFatalErrorResponse) String() string

type HandlingStrategy added in v1.1.1102 

type HandlingStrategy int32
const (
	HandlingStrategy_Pause    HandlingStrategy = 0
	HandlingStrategy_TearDown HandlingStrategy = 1
)

func (HandlingStrategy) Descriptor added in v1.1.1102 

func (HandlingStrategy) Descriptor() protoreflect.EnumDescriptor

func (HandlingStrategy) Enum added in v1.1.1102 

func (x HandlingStrategy) Enum() *HandlingStrategy

func (HandlingStrategy) EnumDescriptor deprecated added in v1.1.1102 

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

Deprecated: Use HandlingStrategy.Descriptor instead.

func (HandlingStrategy) Number added in v1.1.1102 

func (x HandlingStrategy) Number() protoreflect.EnumNumber

func (HandlingStrategy) String added in v1.1.1102 

func (x HandlingStrategy) String() string

func (HandlingStrategy) Type added in v1.1.1102 

func (HandlingStrategy) Type() protoreflect.EnumType

type HeartbeatRequest added in v1.1.731 

type HeartbeatRequest struct {
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Id   string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Time int64  `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatRequest) Descriptor deprecated added in v1.1.731 

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

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetHost added in v1.1.731 

func (x *HeartbeatRequest) GetHost() string

func (*HeartbeatRequest) GetId added in v1.1.731 

func (x *HeartbeatRequest) GetId() string

func (*HeartbeatRequest) GetTime added in v1.1.731 

func (x *HeartbeatRequest) GetTime() int64

func (*HeartbeatRequest) ProtoMessage added in v1.1.731 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoReflect added in v1.1.731 

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

func (*HeartbeatRequest) Reset added in v1.1.731 

func (x *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String added in v1.1.731 

func (x *HeartbeatRequest) String() string

type HeartbeatResponse added in v1.1.731 

type HeartbeatResponse struct {
	// contains filtered or unexported fields
}

func (*HeartbeatResponse) Descriptor deprecated added in v1.1.731 

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

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) ProtoMessage added in v1.1.731 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) ProtoReflect added in v1.1.731 

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

func (*HeartbeatResponse) Reset added in v1.1.731 

func (x *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String added in v1.1.731 

func (x *HeartbeatResponse) String() string

type Iteration added in v1.0.485 

type Iteration struct {
	Collection  string        `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	Iterator    string        `protobuf:"bytes,2,opt,name=iterator,proto3" json:"iterator,omitempty"`
	CollateAs   string        `protobuf:"bytes,3,opt,name=collateAs,proto3" json:"collateAs,omitempty"`
	CollateFrom string        `protobuf:"bytes,4,opt,name=collateFrom,proto3" json:"collateFrom,omitempty"`
	Until       *string       `protobuf:"bytes,5,opt,name=until,proto3,oneof" json:"until,omitempty"`
	Execute     ThreadingType `protobuf:"varint,6,opt,name=execute,proto3,enum=ThreadingType" json:"execute,omitempty"`
	// contains filtered or unexported fields
}

func (*Iteration) Descriptor deprecated added in v1.0.485 

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

Deprecated: Use Iteration.ProtoReflect.Descriptor instead.

func (*Iteration) GetCollateAs added in v1.0.485 

func (x *Iteration) GetCollateAs() string

func (*Iteration) GetCollateFrom added in v1.0.485 

func (x *Iteration) GetCollateFrom() string

func (*Iteration) GetCollection added in v1.0.485 

func (x *Iteration) GetCollection() string

func (*Iteration) GetExecute added in v1.0.485 

func (x *Iteration) GetExecute() ThreadingType

func (*Iteration) GetIterator added in v1.0.485 

func (x *Iteration) GetIterator() string

func (*Iteration) GetUntil added in v1.0.485 

func (x *Iteration) GetUntil() string

func (*Iteration) ProtoMessage added in v1.0.485 

func (*Iteration) ProtoMessage()

func (*Iteration) ProtoReflect added in v1.0.485 

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

func (*Iteration) Reset added in v1.0.485 

func (x *Iteration) Reset()

func (*Iteration) String added in v1.0.485 

func (x *Iteration) String() string

type Iterator added in v1.0.498 

type Iterator struct {
	Id       string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Value    [][]byte `protobuf:"bytes,2,rep,name=value,proto3" json:"value,omitempty"`
	Collated [][]byte `protobuf:"bytes,3,rep,name=collated,proto3" json:"collated,omitempty"`
	// contains filtered or unexported fields
}

func (*Iterator) Descriptor deprecated added in v1.0.498 

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

Deprecated: Use Iterator.ProtoReflect.Descriptor instead.

func (*Iterator) GetCollated added in v1.0.498 

func (x *Iterator) GetCollated() [][]byte

func (*Iterator) GetId added in v1.0.498 

func (x *Iterator) GetId() string

func (*Iterator) GetValue added in v1.0.498 

func (x *Iterator) GetValue() [][]byte

func (*Iterator) ProtoMessage added in v1.0.498 

func (*Iterator) ProtoMessage()

func (*Iterator) ProtoReflect added in v1.0.498 

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

func (*Iterator) Reset added in v1.0.498 

func (x *Iterator) Reset()

func (*Iterator) String added in v1.0.498 

func (x *Iterator) String() string

type LaunchWorkflowRequest 

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

func (*LaunchWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use LaunchWorkflowRequest.ProtoReflect.Descriptor instead.

func (*LaunchWorkflowRequest) GetHeaders added in v1.1.1323 

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

func (*LaunchWorkflowRequest) GetProcessId added in v1.1.991 

func (x *LaunchWorkflowRequest) GetProcessId() string

func (*LaunchWorkflowRequest) GetVars 

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

func (*LaunchWorkflowRequest) ProtoMessage 

func (*LaunchWorkflowRequest) ProtoMessage()

func (*LaunchWorkflowRequest) ProtoReflect 

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

func (*LaunchWorkflowRequest) Reset 

func (x *LaunchWorkflowRequest) Reset()

func (*LaunchWorkflowRequest) String 

func (x *LaunchWorkflowRequest) String() string

type LaunchWorkflowResponse added in v1.0.366 

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

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

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

Deprecated: Use LaunchWorkflowResponse.ProtoReflect.Descriptor instead.

func (*LaunchWorkflowResponse) GetExecutionId added in v1.1.991 

func (x *LaunchWorkflowResponse) GetExecutionId() string

func (*LaunchWorkflowResponse) GetWorkflowId added in v1.0.366 

func (x *LaunchWorkflowResponse) GetWorkflowId() string

func (*LaunchWorkflowResponse) ProtoMessage added in v1.0.366 

func (*LaunchWorkflowResponse) ProtoMessage()

func (*LaunchWorkflowResponse) ProtoReflect added in v1.0.366 

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

func (*LaunchWorkflowResponse) Reset added in v1.0.366 

func (x *LaunchWorkflowResponse) Reset()

func (*LaunchWorkflowResponse) String added in v1.0.366 

func (x *LaunchWorkflowResponse) String() string

type ListExecutableProcessesItem added in v1.1.1032 

type ListExecutableProcessesItem struct {
	ProcessId    string                      `protobuf:"bytes,1,opt,name=processId,proto3" json:"processId,omitempty"`
	WorkflowName string                      `protobuf:"bytes,2,opt,name=workflowName,proto3" json:"workflowName,omitempty"`
	Parameter    []*ExecutableStartParameter `protobuf:"bytes,3,rep,name=parameter,proto3" json:"parameter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListExecutableProcessesItem) Descriptor deprecated added in v1.1.1032 

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

Deprecated: Use ListExecutableProcessesItem.ProtoReflect.Descriptor instead.

func (*ListExecutableProcessesItem) GetParameter added in v1.1.1032 

func (x *ListExecutableProcessesItem) GetParameter() []*ExecutableStartParameter

func (*ListExecutableProcessesItem) GetProcessId added in v1.1.1212 

func (x *ListExecutableProcessesItem) GetProcessId() string

func (*ListExecutableProcessesItem) GetWorkflowName added in v1.1.1032 

func (x *ListExecutableProcessesItem) GetWorkflowName() string

func (*ListExecutableProcessesItem) ProtoMessage added in v1.1.1032 

func (*ListExecutableProcessesItem) ProtoMessage()

func (*ListExecutableProcessesItem) ProtoReflect added in v1.1.1032 

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

func (*ListExecutableProcessesItem) Reset added in v1.1.1032 

func (x *ListExecutableProcessesItem) Reset()

func (*ListExecutableProcessesItem) String added in v1.1.1032 

func (x *ListExecutableProcessesItem) String() string

type ListExecutableProcessesRequest added in v1.1.1032 

type ListExecutableProcessesRequest struct {
	// contains filtered or unexported fields
}

func (*ListExecutableProcessesRequest) Descriptor deprecated added in v1.1.1032 

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

Deprecated: Use ListExecutableProcessesRequest.ProtoReflect.Descriptor instead.

func (*ListExecutableProcessesRequest) ProtoMessage added in v1.1.1032 

func (*ListExecutableProcessesRequest) ProtoMessage()

func (*ListExecutableProcessesRequest) ProtoReflect added in v1.1.1032 

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

func (*ListExecutableProcessesRequest) Reset added in v1.1.1032 

func (x *ListExecutableProcessesRequest) Reset()

func (*ListExecutableProcessesRequest) String added in v1.1.1032 

func (x *ListExecutableProcessesRequest) String() string

type ListExecutionItem added in v1.1.725 

type ListExecutionItem struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Version int32  `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ListExecutionItem) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use ListExecutionItem.ProtoReflect.Descriptor instead.

func (*ListExecutionItem) GetId added in v1.1.725 

func (x *ListExecutionItem) GetId() string

func (*ListExecutionItem) GetVersion added in v1.1.725 

func (x *ListExecutionItem) GetVersion() int32

func (*ListExecutionItem) ProtoMessage added in v1.1.725 

func (*ListExecutionItem) ProtoMessage()

func (*ListExecutionItem) ProtoReflect added in v1.1.725 

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

func (*ListExecutionItem) Reset added in v1.1.725 

func (x *ListExecutionItem) Reset()

func (*ListExecutionItem) String added in v1.1.725 

func (x *ListExecutionItem) String() string

type ListExecutionProcessesRequest added in v1.0.645 

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

func (*ListExecutionProcessesRequest) Descriptor deprecated added in v1.0.645 

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

Deprecated: Use ListExecutionProcessesRequest.ProtoReflect.Descriptor instead.

func (*ListExecutionProcessesRequest) GetId added in v1.0.645 

func (x *ListExecutionProcessesRequest) GetId() string

func (*ListExecutionProcessesRequest) ProtoMessage added in v1.0.645 

func (*ListExecutionProcessesRequest) ProtoMessage()

func (*ListExecutionProcessesRequest) ProtoReflect added in v1.0.645 

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

func (*ListExecutionProcessesRequest) Reset added in v1.0.645 

func (x *ListExecutionProcessesRequest) Reset()

func (*ListExecutionProcessesRequest) String added in v1.0.645 

func (x *ListExecutionProcessesRequest) String() string

type ListExecutionProcessesResponse added in v1.1.725 

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

func (*ListExecutionProcessesResponse) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use ListExecutionProcessesResponse.ProtoReflect.Descriptor instead.

func (*ListExecutionProcessesResponse) GetProcessInstanceId added in v1.1.725 

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

func (*ListExecutionProcessesResponse) ProtoMessage added in v1.1.725 

func (*ListExecutionProcessesResponse) ProtoMessage()

func (*ListExecutionProcessesResponse) ProtoReflect added in v1.1.725 

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

func (*ListExecutionProcessesResponse) Reset added in v1.1.725 

func (x *ListExecutionProcessesResponse) Reset()

func (*ListExecutionProcessesResponse) String added in v1.1.725 

func (x *ListExecutionProcessesResponse) String() string

type ListExecutionRequest added in v1.0.645 

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

func (*ListExecutionRequest) Descriptor deprecated added in v1.0.645 

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

Deprecated: Use ListExecutionRequest.ProtoReflect.Descriptor instead.

func (*ListExecutionRequest) GetWorkflowName added in v1.0.645 

func (x *ListExecutionRequest) GetWorkflowName() string

func (*ListExecutionRequest) ProtoMessage added in v1.0.645 

func (*ListExecutionRequest) ProtoMessage()

func (*ListExecutionRequest) ProtoReflect added in v1.0.645 

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

func (*ListExecutionRequest) Reset added in v1.0.645 

func (x *ListExecutionRequest) Reset()

func (*ListExecutionRequest) String added in v1.0.645 

func (x *ListExecutionRequest) String() string

type ListExecutionResponse added in v1.0.645 

type ListExecutionResponse struct {
	Result []*ListExecutionItem `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ListExecutionResponse) Descriptor deprecated added in v1.0.645 

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

Deprecated: Use ListExecutionResponse.ProtoReflect.Descriptor instead.

func (*ListExecutionResponse) GetResult added in v1.0.645 

func (x *ListExecutionResponse) GetResult() []*ListExecutionItem

func (*ListExecutionResponse) ProtoMessage added in v1.0.645 

func (*ListExecutionResponse) ProtoMessage()

func (*ListExecutionResponse) ProtoReflect added in v1.0.645 

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

func (*ListExecutionResponse) Reset added in v1.0.645 

func (x *ListExecutionResponse) Reset()

func (*ListExecutionResponse) String added in v1.0.645 

func (x *ListExecutionResponse) String() string

type ListTaskSpecUIDsRequest added in v1.1.725 

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

func (*ListTaskSpecUIDsRequest) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use ListTaskSpecUIDsRequest.ProtoReflect.Descriptor instead.

func (*ListTaskSpecUIDsRequest) GetIncludeDeprecated added in v1.1.725 

func (x *ListTaskSpecUIDsRequest) GetIncludeDeprecated() bool

func (*ListTaskSpecUIDsRequest) ProtoMessage added in v1.1.725 

func (*ListTaskSpecUIDsRequest) ProtoMessage()

func (*ListTaskSpecUIDsRequest) ProtoReflect added in v1.1.725 

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

func (*ListTaskSpecUIDsRequest) Reset added in v1.1.725 

func (x *ListTaskSpecUIDsRequest) Reset()

func (*ListTaskSpecUIDsRequest) String added in v1.1.725 

func (x *ListTaskSpecUIDsRequest) String() string

type ListTaskSpecUIDsResponse added in v1.1.725 

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

func (*ListTaskSpecUIDsResponse) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use ListTaskSpecUIDsResponse.ProtoReflect.Descriptor instead.

func (*ListTaskSpecUIDsResponse) GetUid added in v1.1.725 

func (x *ListTaskSpecUIDsResponse) GetUid() []string

func (*ListTaskSpecUIDsResponse) ProtoMessage added in v1.1.725 

func (*ListTaskSpecUIDsResponse) ProtoMessage()

func (*ListTaskSpecUIDsResponse) ProtoReflect added in v1.1.725 

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

func (*ListTaskSpecUIDsResponse) Reset added in v1.1.725 

func (x *ListTaskSpecUIDsResponse) Reset()

func (*ListTaskSpecUIDsResponse) String added in v1.1.725 

func (x *ListTaskSpecUIDsResponse) String() string

type ListUserTasksRequest added in v0.1.86 

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

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

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

Deprecated: Use ListUserTasksRequest.ProtoReflect.Descriptor instead.

func (*ListUserTasksRequest) GetGroup added in v1.1.1492 

func (x *ListUserTasksRequest) GetGroup() string

func (*ListUserTasksRequest) GetOwner added in v0.1.86 

func (x *ListUserTasksRequest) GetOwner() string

func (*ListUserTasksRequest) ProtoMessage added in v0.1.86 

func (*ListUserTasksRequest) ProtoMessage()

func (*ListUserTasksRequest) ProtoReflect added in v0.1.86 

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

func (*ListUserTasksRequest) Reset added in v0.1.86 

func (x *ListUserTasksRequest) Reset()

func (*ListUserTasksRequest) String added in v0.1.86 

func (x *ListUserTasksRequest) String() string

type ListUserTasksResponse added in v1.1.725 

type ListUserTasksResponse struct {
	Id       string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	SpecUid  string `protobuf:"bytes,2,opt,name=specUid,proto3" json:"specUid,omitempty"`
	State    []byte `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	LockedBy string `protobuf:"bytes,4,opt,name=lockedBy,proto3" json:"lockedBy,omitempty"`
	// contains filtered or unexported fields
}

func (*ListUserTasksResponse) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use ListUserTasksResponse.ProtoReflect.Descriptor instead.

func (*ListUserTasksResponse) GetId added in v1.1.1492 

func (x *ListUserTasksResponse) GetId() string

func (*ListUserTasksResponse) GetLockedBy added in v1.1.1492 

func (x *ListUserTasksResponse) GetLockedBy() string

func (*ListUserTasksResponse) GetSpecUid added in v1.1.1492 

func (x *ListUserTasksResponse) GetSpecUid() string

func (*ListUserTasksResponse) GetState added in v1.1.1492 

func (x *ListUserTasksResponse) GetState() []byte

func (*ListUserTasksResponse) ProtoMessage added in v1.1.725 

func (*ListUserTasksResponse) ProtoMessage()

func (*ListUserTasksResponse) ProtoReflect added in v1.1.725 

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

func (*ListUserTasksResponse) Reset added in v1.1.725 

func (x *ListUserTasksResponse) Reset()

func (*ListUserTasksResponse) String added in v1.1.725 

func (x *ListUserTasksResponse) String() string

type ListWorkflowResponse added in v1.1.725 

type ListWorkflowResponse struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version int32  `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ListWorkflowResponse) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use ListWorkflowResponse.ProtoReflect.Descriptor instead.

func (*ListWorkflowResponse) GetName added in v1.1.725 

func (x *ListWorkflowResponse) GetName() string

func (*ListWorkflowResponse) GetVersion added in v1.1.725 

func (x *ListWorkflowResponse) GetVersion() int32

func (*ListWorkflowResponse) ProtoMessage added in v1.1.725 

func (*ListWorkflowResponse) ProtoMessage()

func (*ListWorkflowResponse) ProtoReflect added in v1.1.725 

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

func (*ListWorkflowResponse) Reset added in v1.1.725 

func (x *ListWorkflowResponse) Reset()

func (*ListWorkflowResponse) String added in v1.1.725 

func (x *ListWorkflowResponse) String() string

type ListWorkflowsRequest added in v1.1.725 

type ListWorkflowsRequest struct {
	// contains filtered or unexported fields
}

func (*ListWorkflowsRequest) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use ListWorkflowsRequest.ProtoReflect.Descriptor instead.

func (*ListWorkflowsRequest) ProtoMessage added in v1.1.725 

func (*ListWorkflowsRequest) ProtoMessage()

func (*ListWorkflowsRequest) ProtoReflect added in v1.1.725 

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

func (*ListWorkflowsRequest) Reset added in v1.1.725 

func (x *ListWorkflowsRequest) Reset()

func (*ListWorkflowsRequest) String added in v1.1.725 

func (x *ListWorkflowsRequest) String() string

type ListWorkflowsResponse 

type ListWorkflowsResponse struct {
	Result []*ListWorkflowResponse `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ListWorkflowsResponse) Descriptor deprecated 

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

Deprecated: Use ListWorkflowsResponse.ProtoReflect.Descriptor instead.

func (*ListWorkflowsResponse) GetResult 

func (x *ListWorkflowsResponse) GetResult() []*ListWorkflowResponse

func (*ListWorkflowsResponse) ProtoMessage 

func (*ListWorkflowsResponse) ProtoMessage()

func (*ListWorkflowsResponse) ProtoReflect 

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

func (*ListWorkflowsResponse) Reset 

func (x *ListWorkflowsResponse) Reset()

func (*ListWorkflowsResponse) String 

func (x *ListWorkflowsResponse) String() string

type LogRequest added in v1.1.754 

type LogRequest struct {
	Hostname   string            `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	ClientId   string            `protobuf:"bytes,2,opt,name=clientId,proto3" json:"clientId,omitempty"`
	TrackingId []byte            `protobuf:"bytes,3,opt,name=trackingId,proto3" json:"trackingId,omitempty"`
	Level      int64             `protobuf:"varint,4,opt,name=level,proto3" json:"level,omitempty"`
	Time       int64             `protobuf:"varint,5,opt,name=time,proto3" json:"time,omitempty"`
	Source     LogSource         `protobuf:"varint,6,opt,name=source,proto3,enum=LogSource" json:"source,omitempty"`
	Message    string            `protobuf:"bytes,7,opt,name=message,proto3" json:"message,omitempty"`
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LogRequest) Descriptor deprecated added in v1.1.754 

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

Deprecated: Use LogRequest.ProtoReflect.Descriptor instead.

func (*LogRequest) GetAttributes added in v1.1.754 

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

func (*LogRequest) GetClientId added in v1.1.754 

func (x *LogRequest) GetClientId() string

func (*LogRequest) GetHostname added in v1.1.754 

func (x *LogRequest) GetHostname() string

func (*LogRequest) GetLevel added in v1.1.754 

func (x *LogRequest) GetLevel() int64

func (*LogRequest) GetMessage added in v1.1.754 

func (x *LogRequest) GetMessage() string

func (*LogRequest) GetSource added in v1.1.754 

func (x *LogRequest) GetSource() LogSource

func (*LogRequest) GetTime added in v1.1.754 

func (x *LogRequest) GetTime() int64

func (*LogRequest) GetTrackingId added in v1.1.754 

func (x *LogRequest) GetTrackingId() []byte

func (*LogRequest) ProtoMessage added in v1.1.754 

func (*LogRequest) ProtoMessage()

func (*LogRequest) ProtoReflect added in v1.1.754 

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

func (*LogRequest) Reset added in v1.1.754 

func (x *LogRequest) Reset()

func (*LogRequest) String added in v1.1.754 

func (x *LogRequest) String() string

type LogResponse added in v1.1.754 

type LogResponse struct {
	// contains filtered or unexported fields
}

func (*LogResponse) Descriptor deprecated added in v1.1.754 

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

Deprecated: Use LogResponse.ProtoReflect.Descriptor instead.

func (*LogResponse) ProtoMessage added in v1.1.754 

func (*LogResponse) ProtoMessage()

func (*LogResponse) ProtoReflect added in v1.1.754 

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

func (*LogResponse) Reset added in v1.1.754 

func (x *LogResponse) Reset()

func (*LogResponse) String added in v1.1.754 

func (x *LogResponse) String() string

type LogSource added in v1.0.271 

type LogSource int32
const (
	LogSource_logSourceEngine    LogSource = 0
	LogSource_logSourceWorkflow  LogSource = 2
	LogSource_logSourceClient    LogSource = 3
	LogSource_logSourceJob       LogSource = 4
	LogSource_logSourceTelemetry LogSource = 5
)

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 Message added in v1.0.514 

type Message struct {
	Name           string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                     // Name - Message name for a workflow message. valid-value: arbitrary string
	CorrelationKey string `protobuf:"bytes,2,opt,name=correlationKey,proto3" json:"correlationKey,omitempty"` // CorrelationKey - the workflow message correlation key. valid-value: NATS-safe identifier
	Short          string `protobuf:"bytes,3,opt,name=short,proto3" json:"short,omitempty"`                   // Short description of the parameter. valid-value: arbitrary string
	Description    string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`       // Description - a long description of the parameter. valid-value: arbitrary string
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated added in v1.0.514 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetCorrelationKey added in v1.0.514 

func (x *Message) GetCorrelationKey() string

func (*Message) GetDescription added in v1.0.623 

func (x *Message) GetDescription() string

func (*Message) GetName added in v1.0.514 

func (x *Message) GetName() string

func (*Message) GetShort added in v1.0.623 

func (x *Message) GetShort() string

func (*Message) ProtoMessage added in v1.0.514 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect added in v1.0.514 

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

func (*Message) Reset added in v1.0.514 

func (x *Message) Reset()

func (*Message) String added in v1.0.514 

func (x *Message) String() string

type MessageFlow added in v1.0.645 

type MessageFlow struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`               // Id for the message flow.
	Sender    string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`       // Source of the message.
	Recipient string `protobuf:"bytes,3,opt,name=recipient,proto3" json:"recipient,omitempty"` // Recipient of the message.
	// contains filtered or unexported fields
}

func (*MessageFlow) Descriptor deprecated added in v1.0.645 

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

Deprecated: Use MessageFlow.ProtoReflect.Descriptor instead.

func (*MessageFlow) GetId added in v1.0.645 

func (x *MessageFlow) GetId() string

func (*MessageFlow) GetRecipient added in v1.0.645 

func (x *MessageFlow) GetRecipient() string

func (*MessageFlow) GetSender added in v1.0.645 

func (x *MessageFlow) GetSender() string

func (*MessageFlow) ProtoMessage added in v1.0.645 

func (*MessageFlow) ProtoMessage()

func (*MessageFlow) ProtoReflect added in v1.0.645 

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

func (*MessageFlow) Reset added in v1.0.645 

func (x *MessageFlow) Reset()

func (*MessageFlow) String added in v1.0.645 

func (x *MessageFlow) String() string

type MessageInstance 

type MessageInstance struct {
	Name           string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                     // MessageId - the unique messageId for the message.
	CorrelationKey string `protobuf:"bytes,2,opt,name=correlationKey,proto3" json:"correlationKey,omitempty"` // CorrelationKey - a receiving key to correlate this message to.
	Vars           []byte `protobuf:"bytes,3,opt,name=vars,proto3" json:"vars,omitempty"`                     // Vars - A go binary encoded map[string]interface{} of variables.
	// contains filtered or unexported fields
}

MessageInstance represents a workflow message.

func (*MessageInstance) Descriptor deprecated 

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

Deprecated: Use MessageInstance.ProtoReflect.Descriptor instead.

func (*MessageInstance) GetCorrelationKey 

func (x *MessageInstance) GetCorrelationKey() string

func (*MessageInstance) GetName added in v1.0.477 

func (x *MessageInstance) GetName() string

func (*MessageInstance) GetVars added in v0.1.70 

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

func (*MessageInstance) ProtoMessage 

func (*MessageInstance) ProtoMessage()

func (*MessageInstance) ProtoReflect 

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

func (*MessageInstance) Reset 

func (x *MessageInstance) Reset()

func (*MessageInstance) String 

func (x *MessageInstance) String() string

type MessageReceiver added in v1.1.725 

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

func (*MessageReceiver) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use MessageReceiver.ProtoReflect.Descriptor instead.

func (*MessageReceiver) GetId added in v1.1.725 

func (x *MessageReceiver) GetId() string

func (*MessageReceiver) GetProcessIdToStart added in v1.1.725 

func (x *MessageReceiver) GetProcessIdToStart() string

func (*MessageReceiver) ProtoMessage added in v1.1.725 

func (*MessageReceiver) ProtoMessage()

func (*MessageReceiver) ProtoReflect added in v1.1.725 

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

func (*MessageReceiver) Reset added in v1.1.725 

func (x *MessageReceiver) Reset()

func (*MessageReceiver) String added in v1.1.725 

func (x *MessageReceiver) String() string

type MessageReceivers added in v1.1.725 

type MessageReceivers struct {
	MessageReceiver        []*MessageReceiver `protobuf:"bytes,1,rep,name=messageReceiver,proto3" json:"messageReceiver,omitempty"` //MessageReceiver s are the elements receiving/referencing a message. They could be start events or intermediate catch events.
	AssociatedWorkflowName string             `protobuf:"bytes,2,opt,name=associatedWorkflowName,proto3" json:"associatedWorkflowName,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageReceivers) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use MessageReceivers.ProtoReflect.Descriptor instead.

func (*MessageReceivers) GetAssociatedWorkflowName added in v1.1.725 

func (x *MessageReceivers) GetAssociatedWorkflowName() string

func (*MessageReceivers) GetMessageReceiver added in v1.1.725 

func (x *MessageReceivers) GetMessageReceiver() []*MessageReceiver

func (*MessageReceivers) ProtoMessage added in v1.1.725 

func (*MessageReceivers) ProtoMessage()

func (*MessageReceivers) ProtoReflect added in v1.1.725 

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

func (*MessageReceivers) Reset added in v1.1.725 

func (x *MessageReceivers) Reset()

func (*MessageReceivers) String added in v1.1.725 

func (x *MessageReceivers) String() string

type MessageRecipient added in v1.0.477 

type MessageRecipient struct {
	Type           RecipientType `protobuf:"varint,1,opt,name=type,proto3,enum=RecipientType" json:"type,omitempty"`
	Id             string        `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	CorrelationKey string        `protobuf:"bytes,3,opt,name=CorrelationKey,proto3" json:"CorrelationKey,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageRecipient) Descriptor deprecated added in v1.0.477 

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

Deprecated: Use MessageRecipient.ProtoReflect.Descriptor instead.

func (*MessageRecipient) GetCorrelationKey added in v1.0.477 

func (x *MessageRecipient) GetCorrelationKey() string

func (*MessageRecipient) GetId added in v1.0.477 

func (x *MessageRecipient) GetId() string

func (*MessageRecipient) GetType added in v1.0.477 

func (x *MessageRecipient) GetType() RecipientType

func (*MessageRecipient) ProtoMessage added in v1.0.477 

func (*MessageRecipient) ProtoMessage()

func (*MessageRecipient) ProtoReflect added in v1.0.477 

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

func (*MessageRecipient) Reset added in v1.0.477 

func (x *MessageRecipient) Reset()

func (*MessageRecipient) String added in v1.0.477 

func (x *MessageRecipient) String() string

type Metadata added in v1.0.427 

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

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

func (*Metadata) 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 OpenUserTaskRequest added in v1.1.1492 

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

func (*OpenUserTaskRequest) Descriptor deprecated added in v1.1.1492 

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

Deprecated: Use OpenUserTaskRequest.ProtoReflect.Descriptor instead.

func (*OpenUserTaskRequest) GetId added in v1.1.1492 

func (x *OpenUserTaskRequest) GetId() string

func (*OpenUserTaskRequest) ProtoMessage added in v1.1.1492 

func (*OpenUserTaskRequest) ProtoMessage()

func (*OpenUserTaskRequest) ProtoReflect added in v1.1.1492 

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

func (*OpenUserTaskRequest) Reset added in v1.1.1492 

func (x *OpenUserTaskRequest) Reset()

func (*OpenUserTaskRequest) String added in v1.1.1492 

func (x *OpenUserTaskRequest) String() string

type OpenUserTaskResponse added in v1.1.1492 

type OpenUserTaskResponse struct {
	State []byte `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*OpenUserTaskResponse) Descriptor deprecated added in v1.1.1492 

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

Deprecated: Use OpenUserTaskResponse.ProtoReflect.Descriptor instead.

func (*OpenUserTaskResponse) GetState added in v1.1.1492 

func (x *OpenUserTaskResponse) GetState() []byte

func (*OpenUserTaskResponse) ProtoMessage added in v1.1.1492 

func (*OpenUserTaskResponse) ProtoMessage()

func (*OpenUserTaskResponse) ProtoReflect added in v1.1.1492 

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

func (*OpenUserTaskResponse) Reset added in v1.1.1492 

func (x *OpenUserTaskResponse) Reset()

func (*OpenUserTaskResponse) String added in v1.1.1492 

func (x *OpenUserTaskResponse) String() string

type Parameter added in v1.0.514 

type Parameter struct {
	Name                string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                     // Name of the parameter. valid-value: arbitrary string
	Short               string            `protobuf:"bytes,2,opt,name=short,proto3" json:"short,omitempty"`                                   // Short description of the parameter. valid-value: arbitrary string
	Description         string            `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`                       // Description - a long description of the parameter. valid-value: arbitrary string
	Type                string            `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`                                     // Type of the parameter. valid-value: "string", "int", "float", "bool"
	CustomTypeExtension *string           `protobuf:"bytes,5,opt,name=customTypeExtension,proto3,oneof" json:"customTypeExtension,omitempty"` // Subtype describing the use of the type.  valid-value: eg. "IPAddress"
	Collection          bool              `protobuf:"varint,6,opt,name=collection,proto3" json:"collection,omitempty"`                        // Collection specifies the parameter is an array. valid-value: bool
	Group               *string           `protobuf:"bytes,7,opt,name=group,proto3,oneof" json:"group,omitempty"`                             // Group declares this parameter as part of a named parameter group. valid-value: parameter group name.
	ExtensionData       map[string]string ``                                                                                                  // ExtensionData - a map of values that can be used by third party tools. valid-value: arbitrary map of string/string
	/* 167-byte string literal not displayed */
	Mandatory    bool   `protobuf:"varint,9,opt,name=mandatory,proto3" json:"mandatory,omitempty"`       // Mandatory specifies that this parameter is required. valid-value: bool
	ValidateExpr string `protobuf:"bytes,10,opt,name=validateExpr,proto3" json:"validateExpr,omitempty"` // ValidateExpr - an EXPR that is used to validate the field value. valid-value: a valid EXPR expression prefixed by'='
	Example      string `protobuf:"bytes,11,opt,name=example,proto3" json:"example,omitempty"`           // Example - an example EXPR that is used to provide a hint to a user on the nature of a task.  It is also used when the task is being used as a mock before implementation. valid-value: a valid EXPR expression prefixed by'='
	// contains filtered or unexported fields
}

func (*Parameter) Descriptor deprecated added in v1.0.514 

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

Deprecated: Use Parameter.ProtoReflect.Descriptor instead.

func (*Parameter) GetCollection added in v1.0.623 

func (x *Parameter) GetCollection() bool

func (*Parameter) GetCustomTypeExtension added in v1.0.623 

func (x *Parameter) GetCustomTypeExtension() string

func (*Parameter) GetDescription added in v1.0.514 

func (x *Parameter) GetDescription() string

func (*Parameter) GetExample added in v1.0.623 

func (x *Parameter) GetExample() string

func (*Parameter) GetExtensionData added in v1.0.514 

func (x *Parameter) GetExtensionData() map[string]string

func (*Parameter) GetGroup added in v1.0.514 

func (x *Parameter) GetGroup() string

func (*Parameter) GetMandatory added in v1.0.548 

func (x *Parameter) GetMandatory() bool

func (*Parameter) GetName added in v1.0.514 

func (x *Parameter) GetName() string

func (*Parameter) GetShort added in v1.0.514 

func (x *Parameter) GetShort() string

func (*Parameter) GetType added in v1.0.514 

func (x *Parameter) GetType() string

func (*Parameter) GetValidateExpr added in v1.0.623 

func (x *Parameter) GetValidateExpr() string

func (*Parameter) ProtoMessage added in v1.0.514 

func (*Parameter) ProtoMessage()

func (*Parameter) ProtoReflect added in v1.0.514 

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

func (*Parameter) Reset added in v1.0.514 

func (x *Parameter) Reset()

func (*Parameter) String added in v1.0.514 

func (x *Parameter) String() string

type ParameterGroup added in v1.0.514 

type ParameterGroup struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`               // Name of the parameter group. valid-value: arbitrary string
	Short       string `protobuf:"bytes,2,opt,name=short,proto3" json:"short,omitempty"`             // Short description of the parameter group. valid-value: arbitrary string
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` // Description - a long description of the parameter group. valid-value: arbitrary string
	// contains filtered or unexported fields
}

func (*ParameterGroup) Descriptor deprecated added in v1.0.514 

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

Deprecated: Use ParameterGroup.ProtoReflect.Descriptor instead.

func (*ParameterGroup) GetDescription added in v1.0.514 

func (x *ParameterGroup) GetDescription() string

func (*ParameterGroup) GetName added in v1.0.514 

func (x *ParameterGroup) GetName() string

func (*ParameterGroup) GetShort added in v1.0.514 

func (x *ParameterGroup) GetShort() string

func (*ParameterGroup) ProtoMessage added in v1.0.514 

func (*ParameterGroup) ProtoMessage()

func (*ParameterGroup) ProtoReflect added in v1.0.514 

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

func (*ParameterGroup) Reset added in v1.0.514 

func (x *ParameterGroup) Reset()

func (*ParameterGroup) String added in v1.0.514 

func (x *ParameterGroup) String() string

type Participant added in v1.0.645 

type Participant struct {
	Id        string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`               // Id - participation ID.
	ProcessId string `protobuf:"bytes,1,opt,name=processId,proto3" json:"processId,omitempty"` // ProcessId of the participating process.
	// contains filtered or unexported fields
}

func (*Participant) Descriptor deprecated added in v1.0.645 

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

Deprecated: Use Participant.ProtoReflect.Descriptor instead.

func (*Participant) GetId added in v1.0.645 

func (x *Participant) GetId() string

func (*Participant) GetProcessId added in v1.0.645 

func (x *Participant) GetProcessId() string

func (*Participant) ProtoMessage added in v1.0.645 

func (*Participant) ProtoMessage()

func (*Participant) ProtoReflect added in v1.0.645 

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

func (*Participant) Reset added in v1.0.645 

func (x *Participant) Reset()

func (*Participant) String added in v1.0.645 

func (x *Participant) String() string

type Process 

type Process struct {
	Elements []*Element `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`       // Elements describes each state in the state machine.
	Id       string     `protobuf:"bytes,2,opt,name=Id,proto3" json:"Id,omitempty"`                   // Id - the id of the process .
	Metadata *Metadata  `protobuf:"bytes,6,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"` // Metadata created by SHAR to describe process behavior.
	// 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) GetId added in v1.1.1212 

func (x *Process) GetId() string

func (*Process) GetMetadata added in v1.0.427 

func (x *Process) GetMetadata() *Metadata

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 ProcessHistory added in v1.0.477 

type ProcessHistory struct {
	Item []*ProcessHistoryEntry `protobuf:"bytes,1,rep,name=item,proto3" json:"item,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessHistory) Descriptor deprecated added in v1.0.477 

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

Deprecated: Use ProcessHistory.ProtoReflect.Descriptor instead.

func (*ProcessHistory) GetItem added in v1.0.477 

func (x *ProcessHistory) GetItem() []*ProcessHistoryEntry

func (*ProcessHistory) ProtoMessage added in v1.0.477 

func (*ProcessHistory) ProtoMessage()

func (*ProcessHistory) ProtoReflect added in v1.0.477 

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

func (*ProcessHistory) Reset added in v1.0.477 

func (x *ProcessHistory) Reset()

func (*ProcessHistory) String added in v1.0.477 

func (x *ProcessHistory) String() string

type ProcessHistoryEntry added in v1.0.477 

type ProcessHistoryEntry struct {
	ItemType                    ProcessHistoryType           `protobuf:"varint,1,opt,name=itemType,proto3,enum=ProcessHistoryType" json:"itemType,omitempty"`
	WorkflowId                  *string                      `protobuf:"bytes,2,opt,name=workflowId,proto3,oneof" json:"workflowId,omitempty"`
	ExecutionId                 *string                      `protobuf:"bytes,3,opt,name=executionId,proto3,oneof" json:"executionId,omitempty"`
	ElementId                   *string                      `protobuf:"bytes,4,opt,name=elementId,proto3,oneof" json:"elementId,omitempty"`
	ElementName                 *string                      `protobuf:"bytes,15,opt,name=elementName,proto3,oneof" json:"elementName,omitempty"`
	ProcessInstanceId           *string                      `protobuf:"bytes,5,opt,name=processInstanceId,proto3,oneof" json:"processInstanceId,omitempty"`
	CancellationState           *CancellationState           `protobuf:"varint,6,opt,name=cancellationState,proto3,enum=CancellationState,oneof" json:"cancellationState,omitempty"`
	Vars                        []byte                       `protobuf:"bytes,7,opt,name=vars,proto3" json:"vars,omitempty"`
	Timer                       *WorkflowTimer               `protobuf:"bytes,8,opt,name=timer,proto3,oneof" json:"timer,omitempty"`
	Error                       *Error                       `protobuf:"bytes,9,opt,name=error,proto3,oneof" json:"error,omitempty"`
	UnixTimeNano                int64                        `protobuf:"varint,10,opt,name=unixTimeNano,proto3" json:"unixTimeNano,omitempty"`
	Execute                     *string                      `protobuf:"bytes,11,opt,name=execute,proto3,oneof" json:"execute,omitempty"`
	Id                          []string                     `protobuf:"bytes,12,rep,name=id,proto3" json:"id,omitempty"`
	Compensating                bool                         `protobuf:"varint,14,opt,name=compensating,proto3" json:"compensating,omitempty"`
	ProcessId                   string                       `protobuf:"bytes,16,opt,name=processId,proto3" json:"processId,omitempty"`
	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 */
	WorkflowName     string `protobuf:"bytes,19,opt,name=workflowName,proto3" json:"workflowName,omitempty"`
	PreviousActivity string `protobuf:"bytes,20,opt,name=previousActivity,proto3" json:"previousActivity,omitempty"` // PreviousActivity - the ID of the last activity
	PreviousElement  string `protobuf:"bytes,21,opt,name=previousElement,proto3" json:"previousElement,omitempty"`   // PreviousElement - the ID of the last element.
	// contains filtered or unexported fields
}

func (*ProcessHistoryEntry) Descriptor deprecated added in v1.0.477 

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

Deprecated: Use ProcessHistoryEntry.ProtoReflect.Descriptor instead.

func (*ProcessHistoryEntry) GetCancellationState added in v1.0.477 

func (x *ProcessHistoryEntry) GetCancellationState() CancellationState

func (*ProcessHistoryEntry) GetCompensating added in v1.1.1099 

func (x *ProcessHistoryEntry) GetCompensating() bool

func (*ProcessHistoryEntry) GetElementId added in v1.0.477 

func (x *ProcessHistoryEntry) GetElementId() string

func (*ProcessHistoryEntry) GetElementName added in v1.1.1171 

func (x *ProcessHistoryEntry) GetElementName() string

func (*ProcessHistoryEntry) GetError added in v1.0.477 

func (x *ProcessHistoryEntry) GetError() *Error

func (*ProcessHistoryEntry) GetExecute added in v1.0.477 

func (x *ProcessHistoryEntry) GetExecute() string

func (*ProcessHistoryEntry) GetExecutionId added in v1.0.645 

func (x *ProcessHistoryEntry) GetExecutionId() string

func (*ProcessHistoryEntry) GetGatewayExpectations added in v1.1.1209 

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

func (*ProcessHistoryEntry) GetId added in v1.1.1099 

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

func (*ProcessHistoryEntry) GetItemType added in v1.0.477 

func (x *ProcessHistoryEntry) GetItemType() ProcessHistoryType

func (*ProcessHistoryEntry) GetPreviousActivity added in v1.1.1268 

func (x *ProcessHistoryEntry) GetPreviousActivity() string

func (*ProcessHistoryEntry) GetPreviousElement added in v1.1.1268 

func (x *ProcessHistoryEntry) GetPreviousElement() string

func (*ProcessHistoryEntry) GetProcessId added in v1.1.1212 

func (x *ProcessHistoryEntry) GetProcessId() string

func (*ProcessHistoryEntry) GetProcessInstanceId added in v1.0.477 

func (x *ProcessHistoryEntry) GetProcessInstanceId() string

func (*ProcessHistoryEntry) GetSatisfiesGatewayExpectation added in v1.1.1209 

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

func (*ProcessHistoryEntry) GetTimer added in v1.0.477 

func (x *ProcessHistoryEntry) GetTimer() *WorkflowTimer

func (*ProcessHistoryEntry) GetUnixTimeNano added in v1.0.477 

func (x *ProcessHistoryEntry) GetUnixTimeNano() int64

func (*ProcessHistoryEntry) GetVars added in v1.0.477 

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

func (*ProcessHistoryEntry) GetWorkflowId added in v1.0.477 

func (x *ProcessHistoryEntry) GetWorkflowId() string

func (*ProcessHistoryEntry) GetWorkflowName added in v1.1.1209 

func (x *ProcessHistoryEntry) GetWorkflowName() string

func (*ProcessHistoryEntry) ProtoMessage added in v1.0.477 

func (*ProcessHistoryEntry) ProtoMessage()

func (*ProcessHistoryEntry) ProtoReflect added in v1.0.477 

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

func (*ProcessHistoryEntry) Reset added in v1.0.477 

func (x *ProcessHistoryEntry) Reset()

func (*ProcessHistoryEntry) String added in v1.0.477 

func (x *ProcessHistoryEntry) String() string

type ProcessHistoryType added in v1.0.477 

type ProcessHistoryType int32
const (
	ProcessHistoryType_processExecute         ProcessHistoryType = 0
	ProcessHistoryType_activityExecute        ProcessHistoryType = 1
	ProcessHistoryType_activityComplete       ProcessHistoryType = 2
	ProcessHistoryType_processSpawnSync       ProcessHistoryType = 3
	ProcessHistoryType_processComplete        ProcessHistoryType = 4
	ProcessHistoryType_processAbort           ProcessHistoryType = 5
	ProcessHistoryType_activityAbort          ProcessHistoryType = 6
	ProcessHistoryType_jobAbort               ProcessHistoryType = 7
	ProcessHistoryType_jobExecute             ProcessHistoryType = 8
	ProcessHistoryType_jobComplete            ProcessHistoryType = 9
	ProcessHistoryType_compensationCheckpoint ProcessHistoryType = 10
)

func (ProcessHistoryType) Descriptor added in v1.0.477 

func (ProcessHistoryType) Descriptor() protoreflect.EnumDescriptor

func (ProcessHistoryType) Enum added in v1.0.477 

func (x ProcessHistoryType) Enum() *ProcessHistoryType

func (ProcessHistoryType) EnumDescriptor deprecated added in v1.0.477 

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

Deprecated: Use ProcessHistoryType.Descriptor instead.

func (ProcessHistoryType) Number added in v1.0.477 

func (x ProcessHistoryType) Number() protoreflect.EnumNumber

func (ProcessHistoryType) String added in v1.0.477 

func (x ProcessHistoryType) String() string

func (ProcessHistoryType) Type added in v1.0.477 

func (ProcessHistoryType) Type() protoreflect.EnumType

type ProcessInstance added in v1.0.427 

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

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

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

Deprecated: Use ProcessInstance.ProtoReflect.Descriptor instead.

func (*ProcessInstance) GetExecutionId added in v1.0.645 

func (x *ProcessInstance) GetExecutionId() string

func (*ProcessInstance) GetGatewayComplete added in v1.0.446 

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

func (*ProcessInstance) GetHeaders added in v1.1.1323 

func (x *ProcessInstance) GetHeaders() []byte

func (*ProcessInstance) GetParentElementId added in v1.0.427 

func (x *ProcessInstance) GetParentElementId() string

func (*ProcessInstance) GetParentProcessId added in v1.0.427 

func (x *ProcessInstance) GetParentProcessId() string

func (*ProcessInstance) GetProcessId added in v1.1.1212 

func (x *ProcessInstance) GetProcessId() string

func (*ProcessInstance) GetProcessInstanceId added in v1.0.427 

func (x *ProcessInstance) GetProcessInstanceId() string

func (*ProcessInstance) GetWorkflowId added in v1.0.427 

func (x *ProcessInstance) GetWorkflowId() string

func (*ProcessInstance) GetWorkflowName added in v1.0.427 

func (x *ProcessInstance) GetWorkflowName() string

func (*ProcessInstance) ProtoMessage added in v1.0.427 

func (*ProcessInstance) ProtoMessage()

func (*ProcessInstance) ProtoReflect added in v1.0.427 

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

func (*ProcessInstance) Reset added in v1.0.427 

func (x *ProcessInstance) Reset()

func (*ProcessInstance) String added in v1.0.427 

func (x *ProcessInstance) String() string

type Receiver added in v1.1.725 

type Receiver struct {
	Id             string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                         // Id - a uuid identifying the job associated with the receiver
	CorrelationKey string `protobuf:"bytes,2,opt,name=correlationKey,proto3" json:"correlationKey,omitempty"` // CorrelationKey - the workflow message correlation key.
	// contains filtered or unexported fields
}

Receiver is the receiver side of a BPMN message. It contains a reference to the job which receivers the vars from the sender

func (*Receiver) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use Receiver.ProtoReflect.Descriptor instead.

func (*Receiver) GetCorrelationKey added in v1.1.725 

func (x *Receiver) GetCorrelationKey() string

func (*Receiver) GetId added in v1.1.725 

func (x *Receiver) GetId() string

func (*Receiver) ProtoMessage added in v1.1.725 

func (*Receiver) ProtoMessage()

func (*Receiver) ProtoReflect added in v1.1.725 

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

func (*Receiver) Reset added in v1.1.725 

func (x *Receiver) Reset()

func (*Receiver) String added in v1.1.725 

func (x *Receiver) String() string

type RecipientType added in v1.0.477 

type RecipientType int32
const (
	RecipientType_job RecipientType = 0
)

func (RecipientType) Descriptor added in v1.0.477 

func (RecipientType) Descriptor() protoreflect.EnumDescriptor

func (RecipientType) Enum added in v1.0.477 

func (x RecipientType) Enum() *RecipientType

func (RecipientType) EnumDescriptor deprecated added in v1.0.477 

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

Deprecated: Use RecipientType.Descriptor instead.

func (RecipientType) Number added in v1.0.477 

func (x RecipientType) Number() protoreflect.EnumNumber

func (RecipientType) String added in v1.0.477 

func (x RecipientType) String() string

func (RecipientType) Type added in v1.0.477 

func (RecipientType) Type() protoreflect.EnumType

type RegisterTaskRequest added in v1.0.623 

type RegisterTaskRequest struct {
	Spec *TaskSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` // Spec - the task specification.
	// contains filtered or unexported fields
}

RegisterTaskRequest registers a task in SHAR.

func (*RegisterTaskRequest) Descriptor deprecated added in v1.0.623 

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

Deprecated: Use RegisterTaskRequest.ProtoReflect.Descriptor instead.

func (*RegisterTaskRequest) GetSpec added in v1.0.623 

func (x *RegisterTaskRequest) GetSpec() *TaskSpec

func (*RegisterTaskRequest) ProtoMessage added in v1.0.623 

func (*RegisterTaskRequest) ProtoMessage()

func (*RegisterTaskRequest) ProtoReflect added in v1.0.623 

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

func (*RegisterTaskRequest) Reset added in v1.0.623 

func (x *RegisterTaskRequest) Reset()

func (*RegisterTaskRequest) String added in v1.0.623 

func (x *RegisterTaskRequest) String() string

type RegisterTaskResponse added in v1.0.623 

type RegisterTaskResponse struct {
	Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"` // Uid of the registered task.
	// contains filtered or unexported fields
}

RegisterTaskResponse contains the UID of a registered task.

func (*RegisterTaskResponse) Descriptor deprecated added in v1.0.623 

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

Deprecated: Use RegisterTaskResponse.ProtoReflect.Descriptor instead.

func (*RegisterTaskResponse) GetUid added in v1.0.623 

func (x *RegisterTaskResponse) GetUid() string

func (*RegisterTaskResponse) ProtoMessage added in v1.0.623 

func (*RegisterTaskResponse) ProtoMessage()

func (*RegisterTaskResponse) ProtoReflect added in v1.0.623 

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

func (*RegisterTaskResponse) Reset added in v1.0.623 

func (x *RegisterTaskResponse) Reset()

func (*RegisterTaskResponse) String added in v1.0.623 

func (x *RegisterTaskResponse) String() string

type ResolveWorkflowRequest added in v1.1.927 

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

func (*ResolveWorkflowRequest) Descriptor deprecated added in v1.1.927 

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

Deprecated: Use ResolveWorkflowRequest.ProtoReflect.Descriptor instead.

func (*ResolveWorkflowRequest) GetWorkflow added in v1.1.927 

func (x *ResolveWorkflowRequest) GetWorkflow() *Workflow

func (*ResolveWorkflowRequest) ProtoMessage added in v1.1.927 

func (*ResolveWorkflowRequest) ProtoMessage()

func (*ResolveWorkflowRequest) ProtoReflect added in v1.1.927 

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

func (*ResolveWorkflowRequest) Reset added in v1.1.927 

func (x *ResolveWorkflowRequest) Reset()

func (*ResolveWorkflowRequest) String added in v1.1.927 

func (x *ResolveWorkflowRequest) String() string

type ResolveWorkflowResponse added in v1.1.927 

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

func (*ResolveWorkflowResponse) Descriptor deprecated added in v1.1.927 

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

Deprecated: Use ResolveWorkflowResponse.ProtoReflect.Descriptor instead.

func (*ResolveWorkflowResponse) GetWorkflow added in v1.1.927 

func (x *ResolveWorkflowResponse) GetWorkflow() *Workflow

func (*ResolveWorkflowResponse) ProtoMessage added in v1.1.927 

func (*ResolveWorkflowResponse) ProtoMessage()

func (*ResolveWorkflowResponse) ProtoReflect added in v1.1.927 

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

func (*ResolveWorkflowResponse) Reset added in v1.1.927 

func (x *ResolveWorkflowResponse) Reset()

func (*ResolveWorkflowResponse) String added in v1.1.927 

func (x *ResolveWorkflowResponse) String() string

type RetryActivityRequest added in v1.1.1377 

type RetryActivityRequest struct {
	WorkflowState *WorkflowState `protobuf:"bytes,1,opt,name=workflowState,proto3" json:"workflowState,omitempty"`
	// contains filtered or unexported fields
}

func (*RetryActivityRequest) Descriptor deprecated added in v1.1.1377 

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

Deprecated: Use RetryActivityRequest.ProtoReflect.Descriptor instead.

func (*RetryActivityRequest) GetWorkflowState added in v1.1.1377 

func (x *RetryActivityRequest) GetWorkflowState() *WorkflowState

func (*RetryActivityRequest) ProtoMessage added in v1.1.1377 

func (*RetryActivityRequest) ProtoMessage()

func (*RetryActivityRequest) ProtoReflect added in v1.1.1377 

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

func (*RetryActivityRequest) Reset added in v1.1.1377 

func (x *RetryActivityRequest) Reset()

func (*RetryActivityRequest) String added in v1.1.1377 

func (x *RetryActivityRequest) String() string

type RetryActivityResponse added in v1.1.1377 

type RetryActivityResponse struct {
	// contains filtered or unexported fields
}

func (*RetryActivityResponse) Descriptor deprecated added in v1.1.1377 

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

Deprecated: Use RetryActivityResponse.ProtoReflect.Descriptor instead.

func (*RetryActivityResponse) ProtoMessage added in v1.1.1377 

func (*RetryActivityResponse) ProtoMessage()

func (*RetryActivityResponse) ProtoReflect added in v1.1.1377 

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

func (*RetryActivityResponse) Reset added in v1.1.1377 

func (x *RetryActivityResponse) Reset()

func (*RetryActivityResponse) String added in v1.1.1377 

func (x *RetryActivityResponse) String() string

type RetryErrorAction added in v1.0.623 

type RetryErrorAction int32
const (
	RetryErrorAction_PauseWorkflow      RetryErrorAction = 0 // PauseWorkflow - exhausting retries will pause the workflow and send a shar operational message.
	RetryErrorAction_ThrowWorkflowError RetryErrorAction = 1 // ThrowWorkflowError - throw a workflow error.
	RetryErrorAction_SetVariableValue   RetryErrorAction = 2 // SetVariableValue - set a workflow variable value.
	RetryErrorAction_FailWorkflow       RetryErrorAction = 3 // FailWorkflow - exhausting retries will fail the workflow.
)

func (RetryErrorAction) Descriptor added in v1.0.623 

func (RetryErrorAction) Descriptor() protoreflect.EnumDescriptor

func (RetryErrorAction) Enum added in v1.0.623 

func (x RetryErrorAction) Enum() *RetryErrorAction

func (RetryErrorAction) EnumDescriptor deprecated added in v1.0.623 

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

Deprecated: Use RetryErrorAction.Descriptor instead.

func (RetryErrorAction) Number added in v1.0.623 

func (x RetryErrorAction) Number() protoreflect.EnumNumber

func (RetryErrorAction) String added in v1.0.623 

func (x RetryErrorAction) String() string

func (RetryErrorAction) Type added in v1.0.623 

func (RetryErrorAction) Type() protoreflect.EnumType

type RetryStrategy added in v1.0.623 

type RetryStrategy int32
const (
	RetryStrategy_Linear      RetryStrategy = 0 // Retry at regular intervals.
	RetryStrategy_Exponential RetryStrategy = 1 // Retry at increasingly large intervals.
)

func (RetryStrategy) Descriptor added in v1.0.623 

func (RetryStrategy) Descriptor() protoreflect.EnumDescriptor

func (RetryStrategy) Enum added in v1.0.623 

func (x RetryStrategy) Enum() *RetryStrategy

func (RetryStrategy) EnumDescriptor deprecated added in v1.0.623 

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

Deprecated: Use RetryStrategy.Descriptor instead.

func (RetryStrategy) Number added in v1.0.623 

func (x RetryStrategy) Number() protoreflect.EnumNumber

func (RetryStrategy) String added in v1.0.623 

func (x RetryStrategy) String() string

func (RetryStrategy) Type added in v1.0.623 

func (RetryStrategy) Type() protoreflect.EnumType

type 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 SaveUserTaskRequest added in v1.1.1492 

type SaveUserTaskRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Vars      []byte `protobuf:"bytes,2,opt,name=vars,proto3" json:"vars,omitempty"`
	Overwrite bool   `protobuf:"varint,3,opt,name=overwrite,proto3" json:"overwrite,omitempty"`
	// contains filtered or unexported fields
}

func (*SaveUserTaskRequest) Descriptor deprecated added in v1.1.1492 

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

Deprecated: Use SaveUserTaskRequest.ProtoReflect.Descriptor instead.

func (*SaveUserTaskRequest) GetId added in v1.1.1492 

func (x *SaveUserTaskRequest) GetId() string

func (*SaveUserTaskRequest) GetOverwrite added in v1.1.1492 

func (x *SaveUserTaskRequest) GetOverwrite() bool

func (*SaveUserTaskRequest) GetVars added in v1.1.1492 

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

func (*SaveUserTaskRequest) ProtoMessage added in v1.1.1492 

func (*SaveUserTaskRequest) ProtoMessage()

func (*SaveUserTaskRequest) ProtoReflect added in v1.1.1492 

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

func (*SaveUserTaskRequest) Reset added in v1.1.1492 

func (x *SaveUserTaskRequest) Reset()

func (*SaveUserTaskRequest) String added in v1.1.1492 

func (x *SaveUserTaskRequest) String() string

type SaveUserTaskResponse added in v1.1.1492 

type SaveUserTaskResponse struct {
	// contains filtered or unexported fields
}

func (*SaveUserTaskResponse) Descriptor deprecated added in v1.1.1492 

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

Deprecated: Use SaveUserTaskResponse.ProtoReflect.Descriptor instead.

func (*SaveUserTaskResponse) ProtoMessage added in v1.1.1492 

func (*SaveUserTaskResponse) ProtoMessage()

func (*SaveUserTaskResponse) ProtoReflect added in v1.1.1492 

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

func (*SaveUserTaskResponse) Reset added in v1.1.1492 

func (x *SaveUserTaskResponse) Reset()

func (*SaveUserTaskResponse) String added in v1.1.1492 

func (x *SaveUserTaskResponse) String() string

type SendMessageRequest 

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

func (*SendMessageRequest) Descriptor deprecated 

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

Deprecated: Use SendMessageRequest.ProtoReflect.Descriptor instead.

func (*SendMessageRequest) GetCorrelationKey added in v1.0.477 

func (x *SendMessageRequest) GetCorrelationKey() string

func (*SendMessageRequest) GetName 

func (x *SendMessageRequest) GetName() string

func (*SendMessageRequest) GetVars added in v0.1.70 

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

func (*SendMessageRequest) ProtoMessage 

func (*SendMessageRequest) ProtoMessage()

func (*SendMessageRequest) ProtoReflect 

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

func (*SendMessageRequest) Reset 

func (x *SendMessageRequest) Reset()

func (*SendMessageRequest) String 

func (x *SendMessageRequest) String() string

type SendMessageResponse added in v1.1.725 

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

func (*SendMessageResponse) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use SendMessageResponse.ProtoReflect.Descriptor instead.

func (*SendMessageResponse) GetExecutionId added in v1.1.725 

func (x *SendMessageResponse) GetExecutionId() string

func (*SendMessageResponse) GetWorkflowId added in v1.1.725 

func (x *SendMessageResponse) GetWorkflowId() string

func (*SendMessageResponse) ProtoMessage added in v1.1.725 

func (*SendMessageResponse) ProtoMessage()

func (*SendMessageResponse) ProtoReflect added in v1.1.725 

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

func (*SendMessageResponse) Reset added in v1.1.725 

func (x *SendMessageResponse) Reset()

func (*SendMessageResponse) String added in v1.1.725 

func (x *SendMessageResponse) String() string

type Sender added in v1.1.725 

type Sender struct {
	Vars           []byte `protobuf:"bytes,1,opt,name=vars,proto3" json:"vars,omitempty"`                     // Vars - A go binary encoded map[string]interface{} of variables.
	CorrelationKey string `protobuf:"bytes,2,opt,name=correlationKey,proto3" json:"correlationKey,omitempty"` // CorrelationKey - the workflow message correlation key.
	// contains filtered or unexported fields
}

Sender is the sender side of a BPMN message. It contains a byte array of vars destined for the receiver

func (*Sender) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use Sender.ProtoReflect.Descriptor instead.

func (*Sender) GetCorrelationKey added in v1.1.725 

func (x *Sender) GetCorrelationKey() string

func (*Sender) GetVars added in v1.1.725 

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

func (*Sender) ProtoMessage added in v1.1.725 

func (*Sender) ProtoMessage()

func (*Sender) ProtoReflect added in v1.1.725 

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

func (*Sender) Reset added in v1.1.725 

func (x *Sender) Reset()

func (*Sender) String added in v1.1.725 

func (x *Sender) String() string

type StoreWorkflowRequest added in v1.1.725 

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

func (*StoreWorkflowRequest) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use StoreWorkflowRequest.ProtoReflect.Descriptor instead.

func (*StoreWorkflowRequest) GetWorkflow added in v1.1.725 

func (x *StoreWorkflowRequest) GetWorkflow() *Workflow

func (*StoreWorkflowRequest) ProtoMessage added in v1.1.725 

func (*StoreWorkflowRequest) ProtoMessage()

func (*StoreWorkflowRequest) ProtoReflect added in v1.1.725 

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

func (*StoreWorkflowRequest) Reset added in v1.1.725 

func (x *StoreWorkflowRequest) Reset()

func (*StoreWorkflowRequest) String added in v1.1.725 

func (x *StoreWorkflowRequest) String() string

type StoreWorkflowResponse added in v1.1.725 

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

func (*StoreWorkflowResponse) Descriptor deprecated added in v1.1.725 

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

Deprecated: Use StoreWorkflowResponse.ProtoReflect.Descriptor instead.

func (*StoreWorkflowResponse) GetWorkflowId added in v1.1.731 

func (x *StoreWorkflowResponse) GetWorkflowId() string

func (*StoreWorkflowResponse) ProtoMessage added in v1.1.725 

func (*StoreWorkflowResponse) ProtoMessage()

func (*StoreWorkflowResponse) ProtoReflect added in v1.1.725 

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

func (*StoreWorkflowResponse) Reset added in v1.1.725 

func (x *StoreWorkflowResponse) Reset()

func (*StoreWorkflowResponse) String added in v1.1.725 

func (x *StoreWorkflowResponse) String() string

type Target 

type Target struct {
	Id         string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                 // Id for the transition.
	Conditions []string `protobuf:"bytes,2,rep,name=conditions,proto3" json:"conditions,omitempty"` // Conditions -to apply to the transition specified as Expr.
	Target     string   `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`         // Target ID for the transition.
	// contains filtered or unexported fields
}

Target specifies the target for a state transition.

func (*Target) Descriptor deprecated 

func (*Target) 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.
	DefaultTarget int64     `protobuf:"varint,2,opt,name=defaultTarget,proto3" json:"defaultTarget,omitempty"` // DefaultTarget - the ordinal for a default target.
	// contains filtered or unexported fields
}

Targets defines a set of targets for transition and as to whether only the first match should be executed.

func (*Targets) Descriptor deprecated 

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

Deprecated: Use Targets.ProtoReflect.Descriptor instead.

func (*Targets) GetDefaultTarget added in v1.1.697 

func (x *Targets) GetDefaultTarget() int64

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 TaskBehaviour added in v1.0.514 

type TaskBehaviour struct {
	DefaultRetry         *DefaultTaskRetry   `protobuf:"bytes,1,opt,name=defaultRetry,proto3" json:"defaultRetry,omitempty"`                  // Retry - the recommended retry behavior for the task, this could be overriden by a workflow.
	EstimatedMaxDuration uint64              `protobuf:"varint,7,opt,name=estimatedMaxDuration,proto3" json:"estimatedMaxDuration,omitempty"` // EstimatedMaxDuration documents how long the task is expected to run for. valid-value: a unix millisecond duration
	Unsafe               bool                `protobuf:"varint,2,opt,name=unsafe,proto3" json:"unsafe,omitempty"`                             // Unsafe labels the task as non-idempotent.  Non-idempotent tasks are highly unrecommended. valid-value: boolean
	Mock                 bool                `protobuf:"varint,3,opt,name=mock,proto3" json:"mock,omitempty"`                                 // Mock this task as it has no concrete implementation. valid-value: boolean
	Deprecated           bool                `protobuf:"varint,4,opt,name=deprecated,proto3" json:"deprecated,omitempty"`                     // Deprecated task.  Workflows can not be executed that include this task. valid-value: boolean
	MockBehaviour        *TaskMockBehaviours `protobuf:"bytes,5,opt,name=mockBehaviour,proto3" json:"mockBehaviour,omitempty"`                // MockBehaviour lists behaviours exhibited by the task when mocked.
	// contains filtered or unexported fields
}

func (*TaskBehaviour) Descriptor deprecated added in v1.0.514 

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

Deprecated: Use TaskBehaviour.ProtoReflect.Descriptor instead.

func (*TaskBehaviour) GetDefaultRetry added in v1.0.623 

func (x *TaskBehaviour) GetDefaultRetry() *DefaultTaskRetry

func (*TaskBehaviour) GetDeprecated added in v1.1.670 

func (x *TaskBehaviour) GetDeprecated() bool

func (*TaskBehaviour) GetEstimatedMaxDuration added in v1.1.763 

func (x *TaskBehaviour) GetEstimatedMaxDuration() uint64

func (*TaskBehaviour) GetMock added in v1.0.623 

func (x *TaskBehaviour) GetMock() bool

func (*TaskBehaviour) GetMockBehaviour added in v1.1.1124 

func (x *TaskBehaviour) GetMockBehaviour() *TaskMockBehaviours

func (*TaskBehaviour) GetUnsafe added in v1.0.514 

func (x *TaskBehaviour) GetUnsafe() bool

func (*TaskBehaviour) ProtoMessage added in v1.0.514 

func (*TaskBehaviour) ProtoMessage()

func (*TaskBehaviour) ProtoReflect added in v1.0.514 

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

func (*TaskBehaviour) Reset added in v1.0.514 

func (x *TaskBehaviour) Reset()

func (*TaskBehaviour) String added in v1.0.514 

func (x *TaskBehaviour) String() string

type TaskError added in v1.0.514 

type TaskError struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`               // Name of the error. valid-value: arbitrary string
	Code        string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`               // Code a unique code for the error. valid-value: NATS-safe identifier
	Short       string `protobuf:"bytes,3,opt,name=short,proto3" json:"short,omitempty"`             // Short description of the error. valid-value: arbitrary string
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` // Description - a long description of the error. valid-value: arbitrary string
	// contains filtered or unexported fields
}

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

func (*TaskError) Descriptor deprecated added in v1.0.514 

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

Deprecated: Use TaskError.ProtoReflect.Descriptor instead.

func (*TaskError) GetCode added in v1.0.514 

func (x *TaskError) GetCode() string

func (*TaskError) GetDescription added in v1.0.623 

func (x *TaskError) GetDescription() string

func (*TaskError) GetName added in v1.0.514 

func (x *TaskError) GetName() string

func (*TaskError) GetShort added in v1.0.623 

func (x *TaskError) GetShort() string

func (*TaskError) ProtoMessage added in v1.0.514 

func (*TaskError) ProtoMessage()

func (*TaskError) ProtoReflect added in v1.0.514 

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

func (*TaskError) Reset added in v1.0.514 

func (x *TaskError) Reset()

func (*TaskError) String added in v1.0.514 

func (x *TaskError) String() string

type TaskEvents added in v1.0.514 

type TaskEvents struct {
	Error   []*TaskError `protobuf:"bytes,1,rep,name=error,proto3" json:"error,omitempty"`     // Error workflow events that can be returned from the task.
	Message []*Message   `protobuf:"bytes,2,rep,name=message,proto3" json:"message,omitempty"` // Message workflow events that can be returned from the task.
	// contains filtered or unexported fields
}

func (*TaskEvents) Descriptor deprecated added in v1.0.514 

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

Deprecated: Use TaskEvents.ProtoReflect.Descriptor instead.

func (*TaskEvents) GetError added in v1.0.514 

func (x *TaskEvents) GetError() []*TaskError

func (*TaskEvents) GetMessage added in v1.0.514 

func (x *TaskEvents) GetMessage() []*Message

func (*TaskEvents) ProtoMessage added in v1.0.514 

func (*TaskEvents) ProtoMessage()

func (*TaskEvents) ProtoReflect added in v1.0.514 

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

func (*TaskEvents) Reset added in v1.0.514 

func (x *TaskEvents) Reset()

func (*TaskEvents) String added in v1.0.514 

func (x *TaskEvents) String() string

type TaskMetadata added in v1.0.514 

type TaskMetadata struct {
	Uid           string            `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`                 // Uid of the task. valid-value: a ksuid
	Type          string            `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`               // Type - the name for the task when referred to by process. valid-value: arbitrary string
	Version       string            `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`         // Version - the task version number.  This is useful to describe that the task has internally changed without modifying the input/outout parameters. valid-value: semantic version number
	Short         string            `protobuf:"bytes,4,opt,name=short,proto3" json:"short,omitempty"`             // Short description of the task. valid-value: arbitrary string
	Description   string            `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"` // Description - a long description of the task. valid-value: arbitrary string
	Labels        []string          `protobuf:"bytes,6,rep,name=labels,proto3" json:"labels,omitempty"`           // Labels - a list of searchable tags for the task. valid-value: arbitrary string
	ExtensionData map[string]string ``                                                                            // ExtensionData - a map of values that can be used by third party tools. valid-value: arbitrary string
	/* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TaskMetadata) Descriptor deprecated added in v1.0.514 

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

Deprecated: Use TaskMetadata.ProtoReflect.Descriptor instead.

func (*TaskMetadata) GetDescription added in v1.0.514 

func (x *TaskMetadata) GetDescription() string

func (*TaskMetadata) GetExtensionData added in v1.0.623 

func (x *TaskMetadata) GetExtensionData() map[string]string

func (*TaskMetadata) GetLabels added in v1.0.514 

func (x *TaskMetadata) GetLabels() []string

func (*TaskMetadata) GetShort added in v1.0.514 

func (x *TaskMetadata) GetShort() string

func (*TaskMetadata) GetType added in v1.0.514 

func (x *TaskMetadata) GetType() string

func (*TaskMetadata) GetUid added in v1.0.514 

func (x *TaskMetadata) GetUid() string

func (*TaskMetadata) GetVersion added in v1.0.514 

func (x *TaskMetadata) GetVersion() string

func (*TaskMetadata) ProtoMessage added in v1.0.514 

func (*TaskMetadata) ProtoMessage()

func (*TaskMetadata) ProtoReflect added in v1.0.514 

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

func (*TaskMetadata) Reset added in v1.0.514 

func (x *TaskMetadata) Reset()

func (*TaskMetadata) String added in v1.0.514 

func (x *TaskMetadata) String() string

type TaskMockBehaviours added in v1.1.1124 

type TaskMockBehaviours struct {
	ErrorCodeExpr  string `protobuf:"bytes,1,opt,name=errorCodeExpr,proto3" json:"errorCodeExpr,omitempty"`   // errorCodeExpr generates a workflow error with the code specified by this expression.  If this is, or returns an empty string, no error is returned.
	FatalErrorExpr string `protobuf:"bytes,2,opt,name=fatalErrorExpr,proto3" json:"fatalErrorExpr,omitempty"` // fatalErrorExpr is a boolean expression that if true, will throw a workflow fatal error.
	// contains filtered or unexported fields
}

func (*TaskMockBehaviours) Descriptor deprecated added in v1.1.1124 

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

Deprecated: Use TaskMockBehaviours.ProtoReflect.Descriptor instead.

func (*TaskMockBehaviours) GetErrorCodeExpr added in v1.1.1124 

func (x *TaskMockBehaviours) GetErrorCodeExpr() string

func (*TaskMockBehaviours) GetFatalErrorExpr added in v1.1.1124 

func (x *TaskMockBehaviours) GetFatalErrorExpr() string

func (*TaskMockBehaviours) ProtoMessage added in v1.1.1124 

func (*TaskMockBehaviours) ProtoMessage()

func (*TaskMockBehaviours) ProtoReflect added in v1.1.1124 

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

func (*TaskMockBehaviours) Reset added in v1.1.1124 

func (x *TaskMockBehaviours) Reset()

func (*TaskMockBehaviours) String added in v1.1.1124 

func (x *TaskMockBehaviours) String() string

type TaskParameters added in v1.0.514 

type TaskParameters struct {
	ParameterGroup []*ParameterGroup `protobuf:"bytes,1,rep,name=parameterGroup,proto3" json:"parameterGroup,omitempty"` // ParameterGroup is a list of parameters with their categorization.  This is useful for display. valid-value: arbitrary string
	Input          []*Parameter      `protobuf:"bytes,2,rep,name=input,proto3" json:"input,omitempty"`                   // Input documents input parameters to the task.
	Output         []*Parameter      `protobuf:"bytes,3,rep,name=output,proto3" json:"output,omitempty"`                 // Output documents output parameters for the task.
	// contains filtered or unexported fields
}

func (*TaskParameters) Descriptor deprecated added in v1.0.514 

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

Deprecated: Use TaskParameters.ProtoReflect.Descriptor instead.

func (*TaskParameters) GetInput added in v1.0.514 

func (x *TaskParameters) GetInput() []*Parameter

func (*TaskParameters) GetOutput added in v1.0.514 

func (x *TaskParameters) GetOutput() []*Parameter

func (*TaskParameters) GetParameterGroup added in v1.0.514 

func (x *TaskParameters) GetParameterGroup() []*ParameterGroup

func (*TaskParameters) ProtoMessage added in v1.0.514 

func (*TaskParameters) ProtoMessage()

func (*TaskParameters) ProtoReflect added in v1.0.514 

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

func (*TaskParameters) Reset added in v1.0.514 

func (x *TaskParameters) Reset()

func (*TaskParameters) String added in v1.0.514 

func (x *TaskParameters) String() string

type TaskSpec added in v1.0.514 

type TaskSpec struct {
	Version    string          `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`       // Version of task specification. valid-value: "1.0"
	Kind       string          `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`             // Kind of task specification. valid-value: "ServiceTask" or "UserTask".
	Metadata   *TaskMetadata   `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`     // Metadata document any non functional information regarding the TaskSpec.
	Behaviour  *TaskBehaviour  `protobuf:"bytes,4,opt,name=behaviour,proto3" json:"behaviour,omitempty"`   // Behaviour documents instance behaviour.
	Parameters *TaskParameters `protobuf:"bytes,5,opt,name=parameters,proto3" json:"parameters,omitempty"` // Parameters document input and output parameters for the task.
	Events     *TaskEvents     `protobuf:"bytes,6,opt,name=events,proto3" json:"events,omitempty"`         // Events document errors and messages that can be emitted from the task.
	// contains filtered or unexported fields
}

Task specification

func (*TaskSpec) Descriptor deprecated added in v1.0.514 

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

Deprecated: Use TaskSpec.ProtoReflect.Descriptor instead.

func (*TaskSpec) GetBehaviour added in v1.0.514 

func (x *TaskSpec) GetBehaviour() *TaskBehaviour

func (*TaskSpec) GetEvents added in v1.0.514 

func (x *TaskSpec) GetEvents() *TaskEvents

func (*TaskSpec) GetKind added in v1.0.514 

func (x *TaskSpec) GetKind() string

func (*TaskSpec) GetMetadata added in v1.0.514 

func (x *TaskSpec) GetMetadata() *TaskMetadata

func (*TaskSpec) GetParameters added in v1.0.514 

func (x *TaskSpec) GetParameters() *TaskParameters

func (*TaskSpec) GetVersion added in v1.0.514 

func (x *TaskSpec) GetVersion() string

func (*TaskSpec) ProtoMessage added in v1.0.514 

func (*TaskSpec) ProtoMessage()

func (*TaskSpec) ProtoReflect added in v1.0.514 

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

func (*TaskSpec) Reset added in v1.0.514 

func (x *TaskSpec) Reset()

func (*TaskSpec) String added in v1.0.514 

func (x *TaskSpec) String() string

type TaskSpecUsageReport added in v1.1.670 

type TaskSpecUsageReport struct {
	Workflow                 []string `protobuf:"bytes,1,rep,name=workflow,proto3" json:"workflow,omitempty"`
	Process                  []string `protobuf:"bytes,2,rep,name=process,proto3" json:"process,omitempty"`
	ExecutingWorkflow        []string `protobuf:"bytes,3,rep,name=executingWorkflow,proto3" json:"executingWorkflow,omitempty"`
	ExecutingProcessInstance []string `protobuf:"bytes,4,rep,name=executingProcessInstance,proto3" json:"executingProcessInstance,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskSpecUsageReport) Descriptor deprecated added in v1.1.670 

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

Deprecated: Use TaskSpecUsageReport.ProtoReflect.Descriptor instead.

func (*TaskSpecUsageReport) GetExecutingProcessInstance added in v1.1.670 

func (x *TaskSpecUsageReport) GetExecutingProcessInstance() []string

func (*TaskSpecUsageReport) GetExecutingWorkflow added in v1.1.670 

func (x *TaskSpecUsageReport) GetExecutingWorkflow() []string

func (*TaskSpecUsageReport) GetProcess added in v1.1.670 

func (x *TaskSpecUsageReport) GetProcess() []string

func (*TaskSpecUsageReport) GetWorkflow added in v1.1.670 

func (x *TaskSpecUsageReport) GetWorkflow() []string

func (*TaskSpecUsageReport) ProtoMessage added in v1.1.670 

func (*TaskSpecUsageReport) ProtoMessage()

func (*TaskSpecUsageReport) ProtoReflect added in v1.1.670 

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

func (*TaskSpecUsageReport) Reset added in v1.1.670 

func (x *TaskSpecUsageReport) Reset()

func (*TaskSpecUsageReport) String added in v1.1.670 

func (x *TaskSpecUsageReport) String() string

type TaskSpecVersions added in v1.0.623 

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

func (*TaskSpecVersions) Descriptor deprecated added in v1.0.623 

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

Deprecated: Use TaskSpecVersions.ProtoReflect.Descriptor instead.

func (*TaskSpecVersions) GetId added in v1.0.623 

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

func (*TaskSpecVersions) ProtoMessage added in v1.0.623 

func (*TaskSpecVersions) ProtoMessage()

func (*TaskSpecVersions) ProtoReflect added in v1.0.623 

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

func (*TaskSpecVersions) Reset added in v1.0.623 

func (x *TaskSpecVersions) Reset()

func (*TaskSpecVersions) String added in v1.0.623 

func (x *TaskSpecVersions) String() string

type TaskState added in v1.1.1492 

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

func (*TaskState) Descriptor deprecated added in v1.1.1492 

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

Deprecated: Use TaskState.ProtoReflect.Descriptor instead.

func (*TaskState) GetId added in v1.1.1492 

func (x *TaskState) GetId() string

func (*TaskState) GetOwner added in v1.1.1492 

func (x *TaskState) GetOwner() string

func (*TaskState) GetVars added in v1.1.1492 

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

func (*TaskState) ProtoMessage added in v1.1.1492 

func (*TaskState) ProtoMessage()

func (*TaskState) ProtoReflect added in v1.1.1492 

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

func (*TaskState) Reset added in v1.1.1492 

func (x *TaskState) Reset()

func (*TaskState) String added in v1.1.1492 

func (x *TaskState) String() string

type TelemetryClients added in v1.1.732 

type TelemetryClients struct {
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*TelemetryClients) Descriptor deprecated added in v1.1.732 

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

Deprecated: Use TelemetryClients.ProtoReflect.Descriptor instead.

func (*TelemetryClients) GetCount added in v1.1.732 

func (x *TelemetryClients) GetCount() int32

func (*TelemetryClients) ProtoMessage added in v1.1.732 

func (*TelemetryClients) ProtoMessage()

func (*TelemetryClients) ProtoReflect added in v1.1.732 

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

func (*TelemetryClients) Reset added in v1.1.732 

func (x *TelemetryClients) Reset()

func (*TelemetryClients) String added in v1.1.732 

func (x *TelemetryClients) String() string

type TelemetryLogEntry added in v1.0.240 

type TelemetryLogEntry struct {
	TrackingID string            `protobuf:"bytes,1,opt,name=trackingID,proto3" json:"trackingID,omitempty"`
	Source     LogSource         `protobuf:"varint,2,opt,name=source,proto3,enum=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 ThreadingType added in v1.0.485 

type ThreadingType int32
const (
	ThreadingType_Sequential ThreadingType = 0
	ThreadingType_Parallel   ThreadingType = 2
)

func (ThreadingType) Descriptor added in v1.0.485 

func (ThreadingType) Descriptor() protoreflect.EnumDescriptor

func (ThreadingType) Enum added in v1.0.485 

func (x ThreadingType) Enum() *ThreadingType

func (ThreadingType) EnumDescriptor deprecated added in v1.0.485 

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

Deprecated: Use ThreadingType.Descriptor instead.

func (ThreadingType) Number added in v1.0.485 

func (x ThreadingType) Number() protoreflect.EnumNumber

func (ThreadingType) String added in v1.0.485 

func (x ThreadingType) String() string

func (ThreadingType) Type added in v1.0.485 

func (ThreadingType) Type() protoreflect.EnumType

type Timer added in v1.0.235 

type Timer struct {
	Id              string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`             // Id - the unique identifier for the timer.
	Duration        string            `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"` // Duration - the duration of the timer.
	Target          string            `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`     // Target - state machine element ID to transition to.
	OutputTransform map[string]string ``                                                                      // OutputTransform - The transformation to apply to variables during the transition.
	/* 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 interface {
	GetString(key string) (string, error)
	GetInt64(key string) (int64, error)
	GetBool(key string) (bool, error)
	GetFloat64(key string) (float64, error)
	SetString(key string, value string)
	SetInt64(key string, value int64)
	SetFloat64(key string, value float64)
	SetBool(key string, value bool)
	Decode(ctx context.Context, vars []byte) error
	Encode(ctx context.Context) ([]byte, error)
	Keys() iter.Seq[string]
	Len() int
}

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

type Workflow 

type Workflow struct {
	Name    string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Name defines the common name that describes the workflow.
	Process map[string]*Process ``                                                              // Process is a map of process names to workflow state machines.
	/* 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.
	Collaboration    *Collaboration               `protobuf:"bytes,6,opt,name=collaboration,proto3" json:"collaboration,omitempty"` // Collaboration between processes.
	MessageReceivers map[string]*MessageReceivers ``                                                                                //MessageReceivers are the activity ids that receive a given message.
	/* 173-byte string literal not displayed */
	AutoLaunchHeaders []byte `protobuf:"bytes,8,opt,name=autoLaunchHeaders,proto3" json:"autoLaunchHeaders,omitempty"` // AutoLaunchHeaders contains any headers added to processes that are launched non-interactively.
	// contains filtered or unexported fields
}

Workflow describes a number of processes that interact together. It also contains all messages and errors used by the processes.

func (*Workflow) Descriptor deprecated 

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

Deprecated: Use Workflow.ProtoReflect.Descriptor instead.

func (*Workflow) GetAutoLaunchHeaders added in v1.1.1323 

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

func (*Workflow) GetCollaboration added in v1.0.645 

func (x *Workflow) GetCollaboration() *Collaboration

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) GetMessageReceivers added in v1.1.725 

func (x *Workflow) GetMessageReceivers() map[string]*MessageReceivers

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 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 WorkflowState 

type WorkflowState struct {
	WorkflowId                  string                       `protobuf:"bytes,1,opt,name=workflowId,proto3" json:"workflowId,omitempty"`                // WorkflowId - the ID of the workflow version that provides the template for execution.
	ExecutionId                 string                       `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"`              // executionId - The id of the Execution this workflow state is for
	ElementId                   string                       `protobuf:"bytes,3,opt,name=elementId,proto3" json:"elementId,omitempty"`                  // ElementId - the currently executing element withing the workflow state machine.
	ElementType                 string                       `protobuf:"bytes,4,opt,name=elementType,proto3" json:"elementType,omitempty"`              // ElementType - the currently executing element type, cached here to reduce lookups.
	Id                          []string                     `protobuf:"bytes,5,rep,name=id,proto3" json:"id,omitempty"`                                // Id - a stack of IDs that descibe the state and its parents up to the original execution ID.
	ExecuteVersion              string                       `protobuf:"bytes,22,opt,name=executeVersion,proto3" json:"executeVersion,omitempty"`       // ExecuteVersion specifies a particular version to execute.
	Execute                     *string                      `protobuf:"bytes,7,opt,name=execute,proto3,oneof" json:"execute,omitempty"`                // Execute - additional information required to execute depending on the element type.
	State                       CancellationState            `protobuf:"varint,8,opt,name=state,proto3,enum=CancellationState" json:"state,omitempty"`  // State - the current execution state of the state machine.
	Condition                   *string                      `protobuf:"bytes,9,opt,name=condition,proto3,oneof" json:"condition,omitempty"`            // Condition - a message condition that needs to be fulfilled before proceeding.
	UnixTimeNano                int64                        `protobuf:"varint,10,opt,name=unixTimeNano,proto3" json:"unixTimeNano,omitempty"`          // UnixTimeNano - the time this state was observed.
	Vars                        []byte                       `protobuf:"bytes,11,opt,name=vars,proto3" json:"vars,omitempty"`                           // Vars - A go binary encoded map[string]interface{} of variables.
	Owners                      []string                     `protobuf:"bytes,12,rep,name=owners,proto3" json:"owners,omitempty"`                       // Owners - a list of user owners for this state that may be responsible for completing tasks
	Groups                      []string                     `protobuf:"bytes,13,rep,name=groups,proto3" json:"groups,omitempty"`                       // Groups - a list of user groups for this state that may be responsible for completing tasks
	Error                       *Error                       `protobuf:"bytes,14,opt,name=error,proto3" json:"error,omitempty"`                         // Error - an error being carried by the state if it has faulted.
	Timer                       *WorkflowTimer               `protobuf:"bytes,16,opt,name=timer,proto3" json:"timer,omitempty"`                         // Timer - a time needed to transition to the next state.
	WorkflowName                string                       `protobuf:"bytes,17,opt,name=workflowName,proto3" json:"workflowName,omitempty"`           // WorkflowName - name of this workflow to avoid lookups.
	ProcessId                   string                       `protobuf:"bytes,18,opt,name=processId,proto3" json:"processId,omitempty"`                 // ProcessId - id of this process to avoid lookups.
	ProcessInstanceId           string                       `protobuf:"bytes,19,opt,name=processInstanceId,proto3" json:"processInstanceId,omitempty"` // ProcessInstanceId - the unique ID for the process instance.
	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 */
	TraceParent      string        `protobuf:"bytes,23,opt,name=traceParent,proto3" json:"traceParent,omitempty"`           // TraceContext holds an OTEL trace context.
	Compensation     *Compensation `protobuf:"bytes,24,opt,name=compensation,proto3" json:"compensation,omitempty"`         // Compensation holds compensation state parameters.
	ElementName      string        `protobuf:"bytes,25,opt,name=elementName,proto3" json:"elementName,omitempty"`           // ElementName - the human readable name of this element
	PreviousActivity string        `protobuf:"bytes,26,opt,name=previousActivity,proto3" json:"previousActivity,omitempty"` // PreviousActivity - the ID of the last activity
	PreviousElement  string        `protobuf:"bytes,27,opt,name=previousElement,proto3" json:"previousElement,omitempty"`   // PreviousElement - the ID of the last element.
	// contains filtered or unexported fields
}

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

func (*WorkflowState) Descriptor deprecated 

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

Deprecated: Use WorkflowState.ProtoReflect.Descriptor instead.

func (*WorkflowState) GetCompensation added in v1.1.1099 

func (x *WorkflowState) GetCompensation() *Compensation

func (*WorkflowState) GetCondition 

func (x *WorkflowState) GetCondition() string

func (*WorkflowState) GetElementId 

func (x *WorkflowState) GetElementId() string

func (*WorkflowState) GetElementName added in v1.1.1171 

func (x *WorkflowState) GetElementName() string

func (*WorkflowState) GetElementType 

func (x *WorkflowState) GetElementType() string

func (*WorkflowState) GetError added in v0.1.134 

func (x *WorkflowState) GetError() *Error

func (*WorkflowState) GetExecute 

func (x *WorkflowState) GetExecute() string

func (*WorkflowState) GetExecuteVersion added in v1.0.623 

func (x *WorkflowState) GetExecuteVersion() string

func (*WorkflowState) GetExecutionId added in v1.0.645 

func (x *WorkflowState) GetExecutionId() string

func (*WorkflowState) 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) GetPreviousActivity added in v1.1.1268 

func (x *WorkflowState) GetPreviousActivity() string

func (*WorkflowState) GetPreviousElement added in v1.1.1268 

func (x *WorkflowState) GetPreviousElement() string

func (*WorkflowState) GetProcessId added in v1.1.1212 

func (x *WorkflowState) GetProcessId() string

func (*WorkflowState) GetProcessInstanceId added in v1.0.427 

func (x *WorkflowState) GetProcessInstanceId() string

func (*WorkflowState) 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) GetTraceParent added in v1.1.848 

func (x *WorkflowState) GetTraceParent() string

func (*WorkflowState) GetUnixTimeNano 

func (x *WorkflowState) GetUnixTimeNano() int64

func (*WorkflowState) GetVars 

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

func (*WorkflowState) GetWorkflowId 

func (x *WorkflowState) GetWorkflowId() string

func (*WorkflowState) GetWorkflowName added in v1.0.362 

func (x *WorkflowState) GetWorkflowName() string

func (*WorkflowState) ProtoMessage 

func (*WorkflowState) ProtoMessage()

func (*WorkflowState) ProtoReflect 

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

func (*WorkflowState) Reset 

func (x *WorkflowState) Reset()

func (*WorkflowState) String 

func (x *WorkflowState) String() string

type WorkflowStateSummary added in v1.0.512 

type WorkflowStateSummary struct {
	WorkflowId        string            `protobuf:"bytes,1,opt,name=workflowId,proto3" json:"workflowId,omitempty"`                // WorkflowId - the ID of the workflow version that provides the template for execution.
	ExecutionId       string            `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"`              // ExecutionId - the execution that this state belongs to.
	ElementId         string            `protobuf:"bytes,3,opt,name=elementId,proto3" json:"elementId,omitempty"`                  // ElementId - the currently executing element withing the workflow state machine.
	ElementType       string            `protobuf:"bytes,4,opt,name=elementType,proto3" json:"elementType,omitempty"`              // ElementType - the currently executing element type, cached here to reduce lookups.
	Id                []string          `protobuf:"bytes,5,rep,name=id,proto3" json:"id,omitempty"`                                // Id - a stack of IDs that describe the state and its parents up to the original execution ID.
	Execute           *string           `protobuf:"bytes,7,opt,name=execute,proto3,oneof" json:"execute,omitempty"`                // Execute - additional information required to execute depending on the element type.
	State             CancellationState `protobuf:"varint,8,opt,name=state,proto3,enum=CancellationState" json:"state,omitempty"`  // State - the current execution state of the state machine.
	Condition         *string           `protobuf:"bytes,9,opt,name=condition,proto3,oneof" json:"condition,omitempty"`            // Condition - a message condition that needs to be fulfilled before proceeding.
	UnixTimeNano      int64             `protobuf:"varint,10,opt,name=unixTimeNano,proto3" json:"unixTimeNano,omitempty"`          // UnixTimeNano - the time this state was observed.
	Vars              []byte            `protobuf:"bytes,11,opt,name=vars,proto3" json:"vars,omitempty"`                           // Vars - A go binary encoded map[string]interface{} of variables.
	Error             *Error            `protobuf:"bytes,14,opt,name=error,proto3" json:"error,omitempty"`                         // Error - an error being carried by the state if it has faulted.
	Timer             *WorkflowTimer    `protobuf:"bytes,16,opt,name=timer,proto3" json:"timer,omitempty"`                         // Timer - a time needed to transition to the next state.
	ProcessInstanceId string            `protobuf:"bytes,19,opt,name=processInstanceId,proto3" json:"processInstanceId,omitempty"` // ProcessInstanceId - the unique ID for the process instance.
	// contains filtered or unexported fields
}

func (*WorkflowStateSummary) Descriptor deprecated added in v1.0.512 

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

Deprecated: Use WorkflowStateSummary.ProtoReflect.Descriptor instead.

func (*WorkflowStateSummary) GetCondition added in v1.0.512 

func (x *WorkflowStateSummary) GetCondition() string

func (*WorkflowStateSummary) GetElementId added in v1.0.512 

func (x *WorkflowStateSummary) GetElementId() string

func (*WorkflowStateSummary) GetElementType added in v1.0.512 

func (x *WorkflowStateSummary) GetElementType() string

func (*WorkflowStateSummary) GetError added in v1.0.512 

func (x *WorkflowStateSummary) GetError() *Error

func (*WorkflowStateSummary) GetExecute added in v1.0.512 

func (x *WorkflowStateSummary) GetExecute() string

func (*WorkflowStateSummary) GetExecutionId added in v1.0.645 

func (x *WorkflowStateSummary) GetExecutionId() string

func (*WorkflowStateSummary) GetId added in v1.0.512 

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

func (*WorkflowStateSummary) GetProcessInstanceId added in v1.0.512 

func (x *WorkflowStateSummary) GetProcessInstanceId() string

func (*WorkflowStateSummary) GetState added in v1.0.512 

func (x *WorkflowStateSummary) GetState() CancellationState

func (*WorkflowStateSummary) GetTimer added in v1.0.512 

func (x *WorkflowStateSummary) GetTimer() *WorkflowTimer

func (*WorkflowStateSummary) GetUnixTimeNano added in v1.0.512 

func (x *WorkflowStateSummary) GetUnixTimeNano() int64

func (*WorkflowStateSummary) GetVars added in v1.0.512 

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

func (*WorkflowStateSummary) GetWorkflowId added in v1.0.512 

func (x *WorkflowStateSummary) GetWorkflowId() string

func (*WorkflowStateSummary) ProtoMessage added in v1.0.512 

func (*WorkflowStateSummary) ProtoMessage()

func (*WorkflowStateSummary) ProtoReflect added in v1.0.512 

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

func (*WorkflowStateSummary) Reset added in v1.0.512 

func (x *WorkflowStateSummary) Reset()

func (*WorkflowStateSummary) String added in v1.0.512 

func (x *WorkflowStateSummary) String() string

type WorkflowStats added in v0.1.134 

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

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

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

Deprecated: Use WorkflowStats.ProtoReflect.Descriptor instead.

func (*WorkflowStats) GetInstancesComplete added in v0.1.134 

func (x *WorkflowStats) GetInstancesComplete() int64

func (*WorkflowStats) GetInstancesStarted added in v0.1.134 

func (x *WorkflowStats) GetInstancesStarted() int64

func (*WorkflowStats) GetWorkflows added in v0.1.134 

func (x *WorkflowStats) GetWorkflows() int64

func (*WorkflowStats) ProtoMessage added in v0.1.134 

func (*WorkflowStats) ProtoMessage()

func (*WorkflowStats) ProtoReflect added in v0.1.134 

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

func (*WorkflowStats) Reset added in v0.1.134 

func (x *WorkflowStats) Reset()

func (*WorkflowStats) String added in v0.1.134 

func (x *WorkflowStats) String() string

type WorkflowTimer added in v0.1.181 

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

WorkflowTimer holds the last execution state of a timer.

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

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

Deprecated: Use WorkflowTimer.ProtoReflect.Descriptor instead.

func (*WorkflowTimer) GetCount added in v0.1.181 

func (x *WorkflowTimer) GetCount() int64

func (*WorkflowTimer) GetLastFired added in v0.1.181 

func (x *WorkflowTimer) GetLastFired() int64

func (*WorkflowTimer) ProtoMessage added in v0.1.181 

func (*WorkflowTimer) ProtoMessage()

func (*WorkflowTimer) ProtoReflect added in v0.1.181 

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

func (*WorkflowTimer) Reset added in v0.1.181 

func (x *WorkflowTimer) Reset()

func (*WorkflowTimer) String added in v0.1.181 

func (x *WorkflowTimer) String() string

type WorkflowTimerDefinition added in v0.1.181 

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

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

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

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

Deprecated: Use WorkflowTimerDefinition.ProtoReflect.Descriptor instead.

func (*WorkflowTimerDefinition) GetDropEvents added in v0.1.181 

func (x *WorkflowTimerDefinition) GetDropEvents() bool

func (*WorkflowTimerDefinition) GetRepeat added in v0.1.181 

func (x *WorkflowTimerDefinition) GetRepeat() int64

func (*WorkflowTimerDefinition) GetType added in v0.1.181 

func (x *WorkflowTimerDefinition) GetType() WorkflowTimerType

func (*WorkflowTimerDefinition) GetValue added in v0.1.181 

func (x *WorkflowTimerDefinition) GetValue() int64

func (*WorkflowTimerDefinition) ProtoMessage added in v0.1.181 

func (*WorkflowTimerDefinition) ProtoMessage()

func (*WorkflowTimerDefinition) ProtoReflect added in v0.1.181 

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

func (*WorkflowTimerDefinition) Reset added in v0.1.181 

func (x *WorkflowTimerDefinition) Reset()

func (*WorkflowTimerDefinition) String added in v0.1.181 

func (x *WorkflowTimerDefinition) String() string

type WorkflowTimerType added in v0.1.181 

type WorkflowTimerType int32

WorkflowTimerType describes whether a timer is relative or absolute 

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

func (WorkflowTimerType) Descriptor added in v0.1.181 

func (WorkflowTimerType) Descriptor() protoreflect.EnumDescriptor

func (WorkflowTimerType) Enum added in v0.1.181 

func (x WorkflowTimerType) Enum() *WorkflowTimerType

func (WorkflowTimerType) EnumDescriptor deprecated added in v0.1.181 

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

Deprecated: Use WorkflowTimerType.Descriptor instead.

func (WorkflowTimerType) Number added in v0.1.181 

func (x WorkflowTimerType) Number() protoreflect.EnumNumber

func (WorkflowTimerType) String added in v0.1.181 

func (x WorkflowTimerType) String() string

func (WorkflowTimerType) Type added in v0.1.181 

func (WorkflowTimerType) Type() protoreflect.EnumType

type WorkflowVersion 

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

WorkflowVersion contains the metadata for a single workflow version

func (*WorkflowVersion) Descriptor deprecated 

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

Deprecated: Use WorkflowVersion.ProtoReflect.Descriptor instead.

func (*WorkflowVersion) GetId 

func (x *WorkflowVersion) GetId() string

func (*WorkflowVersion) GetNumber 

func (x *WorkflowVersion) GetNumber() int32

func (*WorkflowVersion) GetSha256 

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

func (*WorkflowVersion) ProtoMessage 

func (*WorkflowVersion) ProtoMessage()

func (*WorkflowVersion) ProtoReflect 

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

func (*WorkflowVersion) Reset 

func (x *WorkflowVersion) Reset()

func (*WorkflowVersion) String 

func (x *WorkflowVersion) String() string

type WorkflowVersions 

type WorkflowVersions struct {
	Version             []*WorkflowVersion `protobuf:"bytes,1,rep,name=version,proto3" json:"version,omitempty"`                          // WorkflowVersion - a single version of a workflow
	IsExecutionDisabled bool               `protobuf:"varint,2,opt,name=isExecutionDisabled,proto3" json:"isExecutionDisabled,omitempty"` // isExecutionDisabled - whether this workflow is allowed to be executed
	// contains filtered or unexported fields
}

WorkflowVersions describes the version history.

func (*WorkflowVersions) Descriptor deprecated 

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

Deprecated: Use WorkflowVersions.ProtoReflect.Descriptor instead.

func (*WorkflowVersions) GetIsExecutionDisabled added in v1.1.1460 

func (x *WorkflowVersions) GetIsExecutionDisabled() bool

func (*WorkflowVersions) GetVersion 

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

func (*WorkflowVersions) ProtoMessage 

func (*WorkflowVersions) ProtoMessage()

func (*WorkflowVersions) ProtoReflect 

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

func (*WorkflowVersions) Reset 

func (x *WorkflowVersions) Reset()

func (*WorkflowVersions) String 

func (x *WorkflowVersions) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.