workflow

package
v0.26.0 Latest Latest
Warning

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

Go to latest
Published: Jun 26, 2020 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type PendingActivityInfo

type PendingActivityInfo struct {
	ActivityId             string                   `protobuf:"bytes,1,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	ActivityType           *v1.ActivityType         `protobuf:"bytes,2,opt,name=activity_type,json=activityType,proto3" json:"activity_type,omitempty"`
	State                  v11.PendingActivityState `protobuf:"varint,3,opt,name=state,proto3,enum=temporal.enums.v1.PendingActivityState" json:"state,omitempty"`
	HeartbeatDetails       *v1.Payloads             `protobuf:"bytes,4,opt,name=heartbeat_details,json=heartbeatDetails,proto3" json:"heartbeat_details,omitempty"`
	LastHeartbeatTimestamp int64                    `` /* 130-byte string literal not displayed */
	LastStartedTimestamp   int64                    `protobuf:"varint,6,opt,name=last_started_timestamp,json=lastStartedTimestamp,proto3" json:"last_started_timestamp,omitempty"`
	Attempt                int32                    `protobuf:"varint,7,opt,name=attempt,proto3" json:"attempt,omitempty"`
	MaximumAttempts        int32                    `protobuf:"varint,8,opt,name=maximum_attempts,json=maximumAttempts,proto3" json:"maximum_attempts,omitempty"`
	ScheduledTimestamp     int64                    `protobuf:"varint,9,opt,name=scheduled_timestamp,json=scheduledTimestamp,proto3" json:"scheduled_timestamp,omitempty"`
	ExpirationTimestamp    int64                    `protobuf:"varint,10,opt,name=expiration_timestamp,json=expirationTimestamp,proto3" json:"expiration_timestamp,omitempty"`
	LastFailure            *v13.Failure             `protobuf:"bytes,11,opt,name=last_failure,json=lastFailure,proto3" json:"last_failure,omitempty"`
	LastWorkerIdentity     string                   `protobuf:"bytes,12,opt,name=last_worker_identity,json=lastWorkerIdentity,proto3" json:"last_worker_identity,omitempty"`
}

func (*PendingActivityInfo) Descriptor

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

func (*PendingActivityInfo) Equal

func (this *PendingActivityInfo) Equal(that interface{}) bool

func (*PendingActivityInfo) GetActivityId

func (m *PendingActivityInfo) GetActivityId() string

func (*PendingActivityInfo) GetActivityType

func (m *PendingActivityInfo) GetActivityType() *v1.ActivityType

func (*PendingActivityInfo) GetAttempt

func (m *PendingActivityInfo) GetAttempt() int32

func (*PendingActivityInfo) GetExpirationTimestamp

func (m *PendingActivityInfo) GetExpirationTimestamp() int64

func (*PendingActivityInfo) GetHeartbeatDetails

func (m *PendingActivityInfo) GetHeartbeatDetails() *v1.Payloads

func (*PendingActivityInfo) GetLastFailure

func (m *PendingActivityInfo) GetLastFailure() *v13.Failure

func (*PendingActivityInfo) GetLastHeartbeatTimestamp

func (m *PendingActivityInfo) GetLastHeartbeatTimestamp() int64

func (*PendingActivityInfo) GetLastStartedTimestamp

func (m *PendingActivityInfo) GetLastStartedTimestamp() int64

func (*PendingActivityInfo) GetLastWorkerIdentity

func (m *PendingActivityInfo) GetLastWorkerIdentity() string

func (*PendingActivityInfo) GetMaximumAttempts

func (m *PendingActivityInfo) GetMaximumAttempts() int32

func (*PendingActivityInfo) GetScheduledTimestamp

func (m *PendingActivityInfo) GetScheduledTimestamp() int64

func (*PendingActivityInfo) GetState

func (*PendingActivityInfo) GoString

func (this *PendingActivityInfo) GoString() string

func (*PendingActivityInfo) Marshal

func (m *PendingActivityInfo) Marshal() (dAtA []byte, err error)

func (*PendingActivityInfo) MarshalTo

func (m *PendingActivityInfo) MarshalTo(dAtA []byte) (int, error)

func (*PendingActivityInfo) MarshalToSizedBuffer

func (m *PendingActivityInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PendingActivityInfo) ProtoMessage

func (*PendingActivityInfo) ProtoMessage()

func (*PendingActivityInfo) Reset

func (m *PendingActivityInfo) Reset()

func (*PendingActivityInfo) Size

func (m *PendingActivityInfo) Size() (n int)

func (*PendingActivityInfo) String

func (this *PendingActivityInfo) String() string

func (*PendingActivityInfo) Unmarshal

func (m *PendingActivityInfo) Unmarshal(dAtA []byte) error

func (*PendingActivityInfo) XXX_DiscardUnknown

func (m *PendingActivityInfo) XXX_DiscardUnknown()

func (*PendingActivityInfo) XXX_Marshal

func (m *PendingActivityInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PendingActivityInfo) XXX_Merge

func (m *PendingActivityInfo) XXX_Merge(src proto.Message)

func (*PendingActivityInfo) XXX_Size

func (m *PendingActivityInfo) XXX_Size() int

func (*PendingActivityInfo) XXX_Unmarshal

func (m *PendingActivityInfo) XXX_Unmarshal(b []byte) error

type PendingChildExecutionInfo

type PendingChildExecutionInfo struct {
	WorkflowId        string                `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId             string                `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	WorkflowTypeName  string                `protobuf:"bytes,3,opt,name=workflow_type_name,json=workflowTypeName,proto3" json:"workflow_type_name,omitempty"`
	InitiatedId       int64                 `protobuf:"varint,4,opt,name=initiated_id,json=initiatedId,proto3" json:"initiated_id,omitempty"`
	ParentClosePolicy v11.ParentClosePolicy `` /* 156-byte string literal not displayed */
}

func (*PendingChildExecutionInfo) Descriptor

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

func (*PendingChildExecutionInfo) Equal

func (this *PendingChildExecutionInfo) Equal(that interface{}) bool

func (*PendingChildExecutionInfo) GetInitiatedId

func (m *PendingChildExecutionInfo) GetInitiatedId() int64

func (*PendingChildExecutionInfo) GetParentClosePolicy

func (m *PendingChildExecutionInfo) GetParentClosePolicy() v11.ParentClosePolicy

func (*PendingChildExecutionInfo) GetRunId

func (m *PendingChildExecutionInfo) GetRunId() string

func (*PendingChildExecutionInfo) GetWorkflowId

func (m *PendingChildExecutionInfo) GetWorkflowId() string

func (*PendingChildExecutionInfo) GetWorkflowTypeName added in v0.24.4

func (m *PendingChildExecutionInfo) GetWorkflowTypeName() string

func (*PendingChildExecutionInfo) GoString

func (this *PendingChildExecutionInfo) GoString() string

func (*PendingChildExecutionInfo) Marshal

func (m *PendingChildExecutionInfo) Marshal() (dAtA []byte, err error)

func (*PendingChildExecutionInfo) MarshalTo

func (m *PendingChildExecutionInfo) MarshalTo(dAtA []byte) (int, error)

func (*PendingChildExecutionInfo) MarshalToSizedBuffer

func (m *PendingChildExecutionInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PendingChildExecutionInfo) ProtoMessage

func (*PendingChildExecutionInfo) ProtoMessage()

func (*PendingChildExecutionInfo) Reset

func (m *PendingChildExecutionInfo) Reset()

func (*PendingChildExecutionInfo) Size

func (m *PendingChildExecutionInfo) Size() (n int)

func (*PendingChildExecutionInfo) String

func (this *PendingChildExecutionInfo) String() string

func (*PendingChildExecutionInfo) Unmarshal

func (m *PendingChildExecutionInfo) Unmarshal(dAtA []byte) error

func (*PendingChildExecutionInfo) XXX_DiscardUnknown

func (m *PendingChildExecutionInfo) XXX_DiscardUnknown()

func (*PendingChildExecutionInfo) XXX_Marshal

func (m *PendingChildExecutionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PendingChildExecutionInfo) XXX_Merge

func (m *PendingChildExecutionInfo) XXX_Merge(src proto.Message)

func (*PendingChildExecutionInfo) XXX_Size

func (m *PendingChildExecutionInfo) XXX_Size() int

func (*PendingChildExecutionInfo) XXX_Unmarshal

func (m *PendingChildExecutionInfo) XXX_Unmarshal(b []byte) error

type ResetPointInfo

type ResetPointInfo struct {
	BinaryChecksum           string `protobuf:"bytes,1,opt,name=binary_checksum,json=binaryChecksum,proto3" json:"binary_checksum,omitempty"`
	RunId                    string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	FirstDecisionCompletedId int64  `` /* 138-byte string literal not displayed */
	CreateTimeNano           int64  `protobuf:"varint,4,opt,name=create_time_nano,json=createTimeNano,proto3" json:"create_time_nano,omitempty"`
	// The time that the run is deleted due to retention.
	ExpireTimeNano int64 `protobuf:"varint,5,opt,name=expire_time_nano,json=expireTimeNano,proto3" json:"expire_time_nano,omitempty"`
	// false if the reset point has pending childWFs/reqCancels/signalExternals.
	Resettable bool `protobuf:"varint,6,opt,name=resettable,proto3" json:"resettable,omitempty"`
}

func (*ResetPointInfo) Descriptor

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

func (*ResetPointInfo) Equal

func (this *ResetPointInfo) Equal(that interface{}) bool

func (*ResetPointInfo) GetBinaryChecksum

func (m *ResetPointInfo) GetBinaryChecksum() string

func (*ResetPointInfo) GetCreateTimeNano added in v0.24.4

func (m *ResetPointInfo) GetCreateTimeNano() int64

func (*ResetPointInfo) GetExpireTimeNano added in v0.24.4

func (m *ResetPointInfo) GetExpireTimeNano() int64

func (*ResetPointInfo) GetFirstDecisionCompletedId

func (m *ResetPointInfo) GetFirstDecisionCompletedId() int64

func (*ResetPointInfo) GetResettable

func (m *ResetPointInfo) GetResettable() bool

func (*ResetPointInfo) GetRunId

func (m *ResetPointInfo) GetRunId() string

func (*ResetPointInfo) GoString

func (this *ResetPointInfo) GoString() string

func (*ResetPointInfo) Marshal

func (m *ResetPointInfo) Marshal() (dAtA []byte, err error)

func (*ResetPointInfo) MarshalTo

func (m *ResetPointInfo) MarshalTo(dAtA []byte) (int, error)

func (*ResetPointInfo) MarshalToSizedBuffer

func (m *ResetPointInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResetPointInfo) ProtoMessage

func (*ResetPointInfo) ProtoMessage()

func (*ResetPointInfo) Reset

func (m *ResetPointInfo) Reset()

func (*ResetPointInfo) Size

func (m *ResetPointInfo) Size() (n int)

func (*ResetPointInfo) String

func (this *ResetPointInfo) String() string

func (*ResetPointInfo) Unmarshal

func (m *ResetPointInfo) Unmarshal(dAtA []byte) error

func (*ResetPointInfo) XXX_DiscardUnknown

func (m *ResetPointInfo) XXX_DiscardUnknown()

func (*ResetPointInfo) XXX_Marshal

func (m *ResetPointInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetPointInfo) XXX_Merge

func (m *ResetPointInfo) XXX_Merge(src proto.Message)

func (*ResetPointInfo) XXX_Size

func (m *ResetPointInfo) XXX_Size() int

func (*ResetPointInfo) XXX_Unmarshal

func (m *ResetPointInfo) XXX_Unmarshal(b []byte) error

type ResetPoints

type ResetPoints struct {
	Points []*ResetPointInfo `protobuf:"bytes,1,rep,name=points,proto3" json:"points,omitempty"`
}

func (*ResetPoints) Descriptor

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

func (*ResetPoints) Equal

func (this *ResetPoints) Equal(that interface{}) bool

func (*ResetPoints) GetPoints

func (m *ResetPoints) GetPoints() []*ResetPointInfo

func (*ResetPoints) GoString

func (this *ResetPoints) GoString() string

func (*ResetPoints) Marshal

func (m *ResetPoints) Marshal() (dAtA []byte, err error)

func (*ResetPoints) MarshalTo

func (m *ResetPoints) MarshalTo(dAtA []byte) (int, error)

func (*ResetPoints) MarshalToSizedBuffer

func (m *ResetPoints) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResetPoints) ProtoMessage

func (*ResetPoints) ProtoMessage()

func (*ResetPoints) Reset

func (m *ResetPoints) Reset()

func (*ResetPoints) Size

func (m *ResetPoints) Size() (n int)

func (*ResetPoints) String

func (this *ResetPoints) String() string

func (*ResetPoints) Unmarshal

func (m *ResetPoints) Unmarshal(dAtA []byte) error

func (*ResetPoints) XXX_DiscardUnknown

func (m *ResetPoints) XXX_DiscardUnknown()

func (*ResetPoints) XXX_Marshal

func (m *ResetPoints) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetPoints) XXX_Merge

func (m *ResetPoints) XXX_Merge(src proto.Message)

func (*ResetPoints) XXX_Size

func (m *ResetPoints) XXX_Size() int

func (*ResetPoints) XXX_Unmarshal

func (m *ResetPoints) XXX_Unmarshal(b []byte) error

type WorkflowExecutionConfig added in v0.24.4

type WorkflowExecutionConfig struct {
	TaskQueue                       *v12.TaskQueue `protobuf:"bytes,1,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	WorkflowExecutionTimeoutSeconds int32          `` /* 159-byte string literal not displayed */
	WorkflowRunTimeoutSeconds       int32          `` /* 141-byte string literal not displayed */
	WorkflowTaskTimeoutSeconds      int32          `` /* 144-byte string literal not displayed */
}

func (*WorkflowExecutionConfig) Descriptor added in v0.24.4

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

func (*WorkflowExecutionConfig) Equal added in v0.24.4

func (this *WorkflowExecutionConfig) Equal(that interface{}) bool

func (*WorkflowExecutionConfig) GetTaskQueue added in v0.26.0

func (m *WorkflowExecutionConfig) GetTaskQueue() *v12.TaskQueue

func (*WorkflowExecutionConfig) GetWorkflowExecutionTimeoutSeconds added in v0.24.4

func (m *WorkflowExecutionConfig) GetWorkflowExecutionTimeoutSeconds() int32

func (*WorkflowExecutionConfig) GetWorkflowRunTimeoutSeconds added in v0.24.4

func (m *WorkflowExecutionConfig) GetWorkflowRunTimeoutSeconds() int32

func (*WorkflowExecutionConfig) GetWorkflowTaskTimeoutSeconds added in v0.24.4

func (m *WorkflowExecutionConfig) GetWorkflowTaskTimeoutSeconds() int32

func (*WorkflowExecutionConfig) GoString added in v0.24.4

func (this *WorkflowExecutionConfig) GoString() string

func (*WorkflowExecutionConfig) Marshal added in v0.24.4

func (m *WorkflowExecutionConfig) Marshal() (dAtA []byte, err error)

func (*WorkflowExecutionConfig) MarshalTo added in v0.24.4

func (m *WorkflowExecutionConfig) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowExecutionConfig) MarshalToSizedBuffer added in v0.24.4

func (m *WorkflowExecutionConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowExecutionConfig) ProtoMessage added in v0.24.4

func (*WorkflowExecutionConfig) ProtoMessage()

func (*WorkflowExecutionConfig) Reset added in v0.24.4

func (m *WorkflowExecutionConfig) Reset()

func (*WorkflowExecutionConfig) Size added in v0.24.4

func (m *WorkflowExecutionConfig) Size() (n int)

func (*WorkflowExecutionConfig) String added in v0.24.4

func (this *WorkflowExecutionConfig) String() string

func (*WorkflowExecutionConfig) Unmarshal added in v0.24.4

func (m *WorkflowExecutionConfig) Unmarshal(dAtA []byte) error

func (*WorkflowExecutionConfig) XXX_DiscardUnknown added in v0.24.4

func (m *WorkflowExecutionConfig) XXX_DiscardUnknown()

func (*WorkflowExecutionConfig) XXX_Marshal added in v0.24.4

func (m *WorkflowExecutionConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowExecutionConfig) XXX_Merge added in v0.24.4

func (m *WorkflowExecutionConfig) XXX_Merge(src proto.Message)

func (*WorkflowExecutionConfig) XXX_Size added in v0.24.4

func (m *WorkflowExecutionConfig) XXX_Size() int

func (*WorkflowExecutionConfig) XXX_Unmarshal added in v0.24.4

func (m *WorkflowExecutionConfig) XXX_Unmarshal(b []byte) error

type WorkflowExecutionInfo

type WorkflowExecutionInfo struct {
	Execution         *v1.WorkflowExecution       `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
	Type              *v1.WorkflowType            `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	StartTime         *types.Int64Value           `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	CloseTime         *types.Int64Value           `protobuf:"bytes,4,opt,name=close_time,json=closeTime,proto3" json:"close_time,omitempty"`
	Status            v11.WorkflowExecutionStatus `protobuf:"varint,5,opt,name=status,proto3,enum=temporal.enums.v1.WorkflowExecutionStatus" json:"status,omitempty"`
	HistoryLength     int64                       `protobuf:"varint,6,opt,name=history_length,json=historyLength,proto3" json:"history_length,omitempty"`
	ParentNamespaceId string                      `protobuf:"bytes,7,opt,name=parent_namespace_id,json=parentNamespaceId,proto3" json:"parent_namespace_id,omitempty"`
	ParentExecution   *v1.WorkflowExecution       `protobuf:"bytes,8,opt,name=parent_execution,json=parentExecution,proto3" json:"parent_execution,omitempty"`
	ExecutionTime     int64                       `protobuf:"varint,9,opt,name=execution_time,json=executionTime,proto3" json:"execution_time,omitempty"`
	Memo              *v1.Memo                    `protobuf:"bytes,10,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes  *v1.SearchAttributes        `protobuf:"bytes,11,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	AutoResetPoints   *ResetPoints                `protobuf:"bytes,12,opt,name=auto_reset_points,json=autoResetPoints,proto3" json:"auto_reset_points,omitempty"`
	TaskQueue         string                      `protobuf:"bytes,13,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
}

func (*WorkflowExecutionInfo) Descriptor

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

func (*WorkflowExecutionInfo) Equal

func (this *WorkflowExecutionInfo) Equal(that interface{}) bool

func (*WorkflowExecutionInfo) GetAutoResetPoints

func (m *WorkflowExecutionInfo) GetAutoResetPoints() *ResetPoints

func (*WorkflowExecutionInfo) GetCloseTime

func (m *WorkflowExecutionInfo) GetCloseTime() *types.Int64Value

func (*WorkflowExecutionInfo) GetExecution

func (m *WorkflowExecutionInfo) GetExecution() *v1.WorkflowExecution

func (*WorkflowExecutionInfo) GetExecutionTime

func (m *WorkflowExecutionInfo) GetExecutionTime() int64

func (*WorkflowExecutionInfo) GetHistoryLength

func (m *WorkflowExecutionInfo) GetHistoryLength() int64

func (*WorkflowExecutionInfo) GetMemo

func (m *WorkflowExecutionInfo) GetMemo() *v1.Memo

func (*WorkflowExecutionInfo) GetParentExecution

func (m *WorkflowExecutionInfo) GetParentExecution() *v1.WorkflowExecution

func (*WorkflowExecutionInfo) GetParentNamespaceId

func (m *WorkflowExecutionInfo) GetParentNamespaceId() string

func (*WorkflowExecutionInfo) GetSearchAttributes

func (m *WorkflowExecutionInfo) GetSearchAttributes() *v1.SearchAttributes

func (*WorkflowExecutionInfo) GetStartTime

func (m *WorkflowExecutionInfo) GetStartTime() *types.Int64Value

func (*WorkflowExecutionInfo) GetStatus

func (*WorkflowExecutionInfo) GetTaskQueue added in v0.26.0

func (m *WorkflowExecutionInfo) GetTaskQueue() string

func (*WorkflowExecutionInfo) GetType

func (m *WorkflowExecutionInfo) GetType() *v1.WorkflowType

func (*WorkflowExecutionInfo) GoString

func (this *WorkflowExecutionInfo) GoString() string

func (*WorkflowExecutionInfo) Marshal

func (m *WorkflowExecutionInfo) Marshal() (dAtA []byte, err error)

func (*WorkflowExecutionInfo) MarshalTo

func (m *WorkflowExecutionInfo) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowExecutionInfo) MarshalToSizedBuffer

func (m *WorkflowExecutionInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowExecutionInfo) ProtoMessage

func (*WorkflowExecutionInfo) ProtoMessage()

func (*WorkflowExecutionInfo) Reset

func (m *WorkflowExecutionInfo) Reset()

func (*WorkflowExecutionInfo) Size

func (m *WorkflowExecutionInfo) Size() (n int)

func (*WorkflowExecutionInfo) String

func (this *WorkflowExecutionInfo) String() string

func (*WorkflowExecutionInfo) Unmarshal

func (m *WorkflowExecutionInfo) Unmarshal(dAtA []byte) error

func (*WorkflowExecutionInfo) XXX_DiscardUnknown

func (m *WorkflowExecutionInfo) XXX_DiscardUnknown()

func (*WorkflowExecutionInfo) XXX_Marshal

func (m *WorkflowExecutionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowExecutionInfo) XXX_Merge

func (m *WorkflowExecutionInfo) XXX_Merge(src proto.Message)

func (*WorkflowExecutionInfo) XXX_Size

func (m *WorkflowExecutionInfo) XXX_Size() int

func (*WorkflowExecutionInfo) XXX_Unmarshal

func (m *WorkflowExecutionInfo) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

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