persistenceblobs

package
v0.27.0 Latest Latest
Warning

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

Go to latest
Published: Jul 15, 2020 License: MIT Imports: 17 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 ActivityInfo

type ActivityInfo struct {
	Version                int64  `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	ScheduledEventBatchId  int64  `` /* 129-byte string literal not displayed */
	ScheduledEvent         []byte `protobuf:"bytes,3,opt,name=scheduled_event,json=scheduledEvent,proto3" json:"scheduled_event,omitempty"`
	ScheduledEventEncoding string `` /* 129-byte string literal not displayed */
	ScheduledTimeNanos     int64  `protobuf:"varint,5,opt,name=scheduled_time_nanos,json=scheduledTimeNanos,proto3" json:"scheduled_time_nanos,omitempty"`
	StartedId              int64  `protobuf:"varint,6,opt,name=started_id,json=startedId,proto3" json:"started_id,omitempty"`
	StartedEvent           []byte `protobuf:"bytes,7,opt,name=started_event,json=startedEvent,proto3" json:"started_event,omitempty"`
	StartedEventEncoding   string `protobuf:"bytes,8,opt,name=started_event_encoding,json=startedEventEncoding,proto3" json:"started_event_encoding,omitempty"`
	StartedTimeNanos       int64  `protobuf:"varint,9,opt,name=started_time_nanos,json=startedTimeNanos,proto3" json:"started_time_nanos,omitempty"`
	ActivityId             string `protobuf:"bytes,10,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	RequestId              string `protobuf:"bytes,11,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToStartTimeoutSeconds int32 `` /* 156-byte string literal not displayed */
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToCloseTimeoutSeconds int32 `` /* 156-byte string literal not displayed */
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "to" is used to indicate interval. --)
	StartToCloseTimeoutSeconds  int32            `` /* 147-byte string literal not displayed */
	HeartbeatTimeoutSeconds     int32            `` /* 134-byte string literal not displayed */
	CancelRequested             bool             `protobuf:"varint,16,opt,name=cancel_requested,json=cancelRequested,proto3" json:"cancel_requested,omitempty"`
	CancelRequestId             int64            `protobuf:"varint,17,opt,name=cancel_request_id,json=cancelRequestId,proto3" json:"cancel_request_id,omitempty"`
	TimerTaskStatus             int32            `protobuf:"varint,18,opt,name=timer_task_status,json=timerTaskStatus,proto3" json:"timer_task_status,omitempty"`
	Attempt                     int32            `protobuf:"varint,19,opt,name=attempt,proto3" json:"attempt,omitempty"`
	TaskQueue                   string           `protobuf:"bytes,20,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	StartedIdentity             string           `protobuf:"bytes,21,opt,name=started_identity,json=startedIdentity,proto3" json:"started_identity,omitempty"`
	HasRetryPolicy              bool             `protobuf:"varint,22,opt,name=has_retry_policy,json=hasRetryPolicy,proto3" json:"has_retry_policy,omitempty"`
	RetryInitialIntervalSeconds int32            `` /* 148-byte string literal not displayed */
	RetryMaximumIntervalSeconds int32            `` /* 148-byte string literal not displayed */
	RetryMaximumAttempts        int32            `protobuf:"varint,25,opt,name=retry_maximum_attempts,json=retryMaximumAttempts,proto3" json:"retry_maximum_attempts,omitempty"`
	RetryExpirationTimeNanos    int64            `` /* 139-byte string literal not displayed */
	RetryBackoffCoefficient     float64          `` /* 135-byte string literal not displayed */
	RetryNonRetryableErrorTypes []string         `` /* 149-byte string literal not displayed */
	RetryLastFailure            *v1.Failure      `protobuf:"bytes,29,opt,name=retry_last_failure,json=retryLastFailure,proto3" json:"retry_last_failure,omitempty"`
	RetryLastWorkerIdentity     string           `` /* 135-byte string literal not displayed */
	NamespaceId                 string           `protobuf:"bytes,31,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	ScheduleId                  int64            `protobuf:"varint,32,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	LastHeartbeatDetails        *v11.Payloads    `protobuf:"bytes,33,opt,name=last_heartbeat_details,json=lastHeartbeatDetails,proto3" json:"last_heartbeat_details,omitempty"`
	LastHeartbeatUpdateTime     *types.Timestamp `` /* 135-byte string literal not displayed */
}

func (*ActivityInfo) Descriptor

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

func (*ActivityInfo) Equal

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

func (*ActivityInfo) GetActivityId

func (m *ActivityInfo) GetActivityId() string

func (*ActivityInfo) GetAttempt

func (m *ActivityInfo) GetAttempt() int32

func (*ActivityInfo) GetCancelRequestId

func (m *ActivityInfo) GetCancelRequestId() int64

func (*ActivityInfo) GetCancelRequested

func (m *ActivityInfo) GetCancelRequested() bool

func (*ActivityInfo) GetHasRetryPolicy

func (m *ActivityInfo) GetHasRetryPolicy() bool

func (*ActivityInfo) GetHeartbeatTimeoutSeconds

func (m *ActivityInfo) GetHeartbeatTimeoutSeconds() int32

func (*ActivityInfo) GetLastHeartbeatDetails

func (m *ActivityInfo) GetLastHeartbeatDetails() *v11.Payloads

func (*ActivityInfo) GetLastHeartbeatUpdateTime

func (m *ActivityInfo) GetLastHeartbeatUpdateTime() *types.Timestamp

func (*ActivityInfo) GetNamespaceId

func (m *ActivityInfo) GetNamespaceId() string

func (*ActivityInfo) GetRequestId

func (m *ActivityInfo) GetRequestId() string

func (*ActivityInfo) GetRetryBackoffCoefficient

func (m *ActivityInfo) GetRetryBackoffCoefficient() float64

func (*ActivityInfo) GetRetryExpirationTimeNanos

func (m *ActivityInfo) GetRetryExpirationTimeNanos() int64

func (*ActivityInfo) GetRetryInitialIntervalSeconds

func (m *ActivityInfo) GetRetryInitialIntervalSeconds() int32

func (*ActivityInfo) GetRetryLastFailure

func (m *ActivityInfo) GetRetryLastFailure() *v1.Failure

func (*ActivityInfo) GetRetryLastWorkerIdentity

func (m *ActivityInfo) GetRetryLastWorkerIdentity() string

func (*ActivityInfo) GetRetryMaximumAttempts

func (m *ActivityInfo) GetRetryMaximumAttempts() int32

func (*ActivityInfo) GetRetryMaximumIntervalSeconds

func (m *ActivityInfo) GetRetryMaximumIntervalSeconds() int32

func (*ActivityInfo) GetRetryNonRetryableErrorTypes

func (m *ActivityInfo) GetRetryNonRetryableErrorTypes() []string

func (*ActivityInfo) GetScheduleId

func (m *ActivityInfo) GetScheduleId() int64

func (*ActivityInfo) GetScheduleToCloseTimeoutSeconds

func (m *ActivityInfo) GetScheduleToCloseTimeoutSeconds() int32

func (*ActivityInfo) GetScheduleToStartTimeoutSeconds

func (m *ActivityInfo) GetScheduleToStartTimeoutSeconds() int32

func (*ActivityInfo) GetScheduledEvent

func (m *ActivityInfo) GetScheduledEvent() []byte

func (*ActivityInfo) GetScheduledEventBatchId

func (m *ActivityInfo) GetScheduledEventBatchId() int64

func (*ActivityInfo) GetScheduledEventEncoding

func (m *ActivityInfo) GetScheduledEventEncoding() string

func (*ActivityInfo) GetScheduledTimeNanos

func (m *ActivityInfo) GetScheduledTimeNanos() int64

func (*ActivityInfo) GetStartToCloseTimeoutSeconds

func (m *ActivityInfo) GetStartToCloseTimeoutSeconds() int32

func (*ActivityInfo) GetStartedEvent

func (m *ActivityInfo) GetStartedEvent() []byte

func (*ActivityInfo) GetStartedEventEncoding

func (m *ActivityInfo) GetStartedEventEncoding() string

func (*ActivityInfo) GetStartedId

func (m *ActivityInfo) GetStartedId() int64

func (*ActivityInfo) GetStartedIdentity

func (m *ActivityInfo) GetStartedIdentity() string

func (*ActivityInfo) GetStartedTimeNanos

func (m *ActivityInfo) GetStartedTimeNanos() int64

func (*ActivityInfo) GetTaskQueue

func (m *ActivityInfo) GetTaskQueue() string

func (*ActivityInfo) GetTimerTaskStatus

func (m *ActivityInfo) GetTimerTaskStatus() int32

func (*ActivityInfo) GetVersion

func (m *ActivityInfo) GetVersion() int64

func (*ActivityInfo) GoString

func (this *ActivityInfo) GoString() string

func (*ActivityInfo) Marshal

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

func (*ActivityInfo) MarshalTo

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

func (*ActivityInfo) MarshalToSizedBuffer

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

func (*ActivityInfo) ProtoMessage

func (*ActivityInfo) ProtoMessage()

func (*ActivityInfo) Reset

func (m *ActivityInfo) Reset()

func (*ActivityInfo) Size

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

func (*ActivityInfo) String

func (this *ActivityInfo) String() string

func (*ActivityInfo) Unmarshal

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

func (*ActivityInfo) XXX_DiscardUnknown

func (m *ActivityInfo) XXX_DiscardUnknown()

func (*ActivityInfo) XXX_Marshal

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

func (*ActivityInfo) XXX_Merge

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

func (*ActivityInfo) XXX_Size

func (m *ActivityInfo) XXX_Size() int

func (*ActivityInfo) XXX_Unmarshal

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

type AllocatedTaskInfo

type AllocatedTaskInfo struct {
	Data   *TaskInfo `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	TaskId int64     `protobuf:"varint,8,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
}

func (*AllocatedTaskInfo) Descriptor

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

func (*AllocatedTaskInfo) Equal

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

func (*AllocatedTaskInfo) GetData

func (m *AllocatedTaskInfo) GetData() *TaskInfo

func (*AllocatedTaskInfo) GetTaskId

func (m *AllocatedTaskInfo) GetTaskId() int64

func (*AllocatedTaskInfo) GoString

func (this *AllocatedTaskInfo) GoString() string

func (*AllocatedTaskInfo) Marshal

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

func (*AllocatedTaskInfo) MarshalTo

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

func (*AllocatedTaskInfo) MarshalToSizedBuffer

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

func (*AllocatedTaskInfo) ProtoMessage

func (*AllocatedTaskInfo) ProtoMessage()

func (*AllocatedTaskInfo) Reset

func (m *AllocatedTaskInfo) Reset()

func (*AllocatedTaskInfo) Size

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

func (*AllocatedTaskInfo) String

func (this *AllocatedTaskInfo) String() string

func (*AllocatedTaskInfo) Unmarshal

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

func (*AllocatedTaskInfo) XXX_DiscardUnknown

func (m *AllocatedTaskInfo) XXX_DiscardUnknown()

func (*AllocatedTaskInfo) XXX_Marshal

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

func (*AllocatedTaskInfo) XXX_Merge

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

func (*AllocatedTaskInfo) XXX_Size

func (m *AllocatedTaskInfo) XXX_Size() int

func (*AllocatedTaskInfo) XXX_Unmarshal

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

type Checksum

type Checksum struct {
	Version int32              `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Flavor  v12.ChecksumFlavor `protobuf:"varint,2,opt,name=flavor,proto3,enum=temporal.server.api.enums.v1.ChecksumFlavor" json:"flavor,omitempty"`
	Value   []byte             `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Checksum) Descriptor

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

func (*Checksum) Equal

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

func (*Checksum) GetFlavor

func (m *Checksum) GetFlavor() v12.ChecksumFlavor

func (*Checksum) GetValue

func (m *Checksum) GetValue() []byte

func (*Checksum) GetVersion

func (m *Checksum) GetVersion() int32

func (*Checksum) GoString

func (this *Checksum) GoString() string

func (*Checksum) Marshal

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

func (*Checksum) MarshalTo

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

func (*Checksum) MarshalToSizedBuffer

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

func (*Checksum) ProtoMessage

func (*Checksum) ProtoMessage()

func (*Checksum) Reset

func (m *Checksum) Reset()

func (*Checksum) Size

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

func (*Checksum) String

func (this *Checksum) String() string

func (*Checksum) Unmarshal

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

func (*Checksum) XXX_DiscardUnknown

func (m *Checksum) XXX_DiscardUnknown()

func (*Checksum) XXX_Marshal

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

func (*Checksum) XXX_Merge

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

func (*Checksum) XXX_Size

func (m *Checksum) XXX_Size() int

func (*Checksum) XXX_Unmarshal

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

type ChildExecutionInfo

type ChildExecutionInfo struct {
	Version                int64                 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	InitiatedEventBatchId  int64                 `` /* 129-byte string literal not displayed */
	StartedId              int64                 `protobuf:"varint,3,opt,name=started_id,json=startedId,proto3" json:"started_id,omitempty"`
	InitiatedEvent         []byte                `protobuf:"bytes,4,opt,name=initiated_event,json=initiatedEvent,proto3" json:"initiated_event,omitempty"`
	InitiatedEventEncoding string                `` /* 129-byte string literal not displayed */
	StartedWorkflowId      string                `protobuf:"bytes,6,opt,name=started_workflow_id,json=startedWorkflowId,proto3" json:"started_workflow_id,omitempty"`
	StartedRunId           string                `protobuf:"bytes,7,opt,name=started_run_id,json=startedRunId,proto3" json:"started_run_id,omitempty"`
	StartedEvent           []byte                `protobuf:"bytes,8,opt,name=started_event,json=startedEvent,proto3" json:"started_event,omitempty"`
	StartedEventEncoding   string                `protobuf:"bytes,9,opt,name=started_event_encoding,json=startedEventEncoding,proto3" json:"started_event_encoding,omitempty"`
	CreateRequestId        string                `protobuf:"bytes,10,opt,name=create_request_id,json=createRequestId,proto3" json:"create_request_id,omitempty"`
	Namespace              string                `protobuf:"bytes,11,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowTypeName       string                `protobuf:"bytes,12,opt,name=workflow_type_name,json=workflowTypeName,proto3" json:"workflow_type_name,omitempty"`
	ParentClosePolicy      v14.ParentClosePolicy `` /* 161-byte string literal not displayed */
	InitiatedId            int64                 `protobuf:"varint,14,opt,name=initiated_id,json=initiatedId,proto3" json:"initiated_id,omitempty"`
}

func (*ChildExecutionInfo) Descriptor

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

func (*ChildExecutionInfo) Equal

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

func (*ChildExecutionInfo) GetCreateRequestId

func (m *ChildExecutionInfo) GetCreateRequestId() string

func (*ChildExecutionInfo) GetInitiatedEvent

func (m *ChildExecutionInfo) GetInitiatedEvent() []byte

func (*ChildExecutionInfo) GetInitiatedEventBatchId

func (m *ChildExecutionInfo) GetInitiatedEventBatchId() int64

func (*ChildExecutionInfo) GetInitiatedEventEncoding

func (m *ChildExecutionInfo) GetInitiatedEventEncoding() string

func (*ChildExecutionInfo) GetInitiatedId

func (m *ChildExecutionInfo) GetInitiatedId() int64

func (*ChildExecutionInfo) GetNamespace

func (m *ChildExecutionInfo) GetNamespace() string

func (*ChildExecutionInfo) GetParentClosePolicy

func (m *ChildExecutionInfo) GetParentClosePolicy() v14.ParentClosePolicy

func (*ChildExecutionInfo) GetStartedEvent

func (m *ChildExecutionInfo) GetStartedEvent() []byte

func (*ChildExecutionInfo) GetStartedEventEncoding

func (m *ChildExecutionInfo) GetStartedEventEncoding() string

func (*ChildExecutionInfo) GetStartedId

func (m *ChildExecutionInfo) GetStartedId() int64

func (*ChildExecutionInfo) GetStartedRunId

func (m *ChildExecutionInfo) GetStartedRunId() string

func (*ChildExecutionInfo) GetStartedWorkflowId

func (m *ChildExecutionInfo) GetStartedWorkflowId() string

func (*ChildExecutionInfo) GetVersion

func (m *ChildExecutionInfo) GetVersion() int64

func (*ChildExecutionInfo) GetWorkflowTypeName

func (m *ChildExecutionInfo) GetWorkflowTypeName() string

func (*ChildExecutionInfo) GoString

func (this *ChildExecutionInfo) GoString() string

func (*ChildExecutionInfo) Marshal

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

func (*ChildExecutionInfo) MarshalTo

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

func (*ChildExecutionInfo) MarshalToSizedBuffer

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

func (*ChildExecutionInfo) ProtoMessage

func (*ChildExecutionInfo) ProtoMessage()

func (*ChildExecutionInfo) Reset

func (m *ChildExecutionInfo) Reset()

func (*ChildExecutionInfo) Size

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

func (*ChildExecutionInfo) String

func (this *ChildExecutionInfo) String() string

func (*ChildExecutionInfo) Unmarshal

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

func (*ChildExecutionInfo) XXX_DiscardUnknown

func (m *ChildExecutionInfo) XXX_DiscardUnknown()

func (*ChildExecutionInfo) XXX_Marshal

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

func (*ChildExecutionInfo) XXX_Merge

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

func (*ChildExecutionInfo) XXX_Size

func (m *ChildExecutionInfo) XXX_Size() int

func (*ChildExecutionInfo) XXX_Unmarshal

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

type HistoryBranch

type HistoryBranch struct {
	TreeId    string                `protobuf:"bytes,1,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	BranchId  string                `protobuf:"bytes,2,opt,name=branch_id,json=branchId,proto3" json:"branch_id,omitempty"`
	Ancestors []*HistoryBranchRange `protobuf:"bytes,3,rep,name=ancestors,proto3" json:"ancestors,omitempty"`
}

For history persistence to serialize/deserialize branch details.

func (*HistoryBranch) Descriptor

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

func (*HistoryBranch) Equal

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

func (*HistoryBranch) GetAncestors

func (m *HistoryBranch) GetAncestors() []*HistoryBranchRange

func (*HistoryBranch) GetBranchId

func (m *HistoryBranch) GetBranchId() string

func (*HistoryBranch) GetTreeId

func (m *HistoryBranch) GetTreeId() string

func (*HistoryBranch) GoString

func (this *HistoryBranch) GoString() string

func (*HistoryBranch) Marshal

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

func (*HistoryBranch) MarshalTo

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

func (*HistoryBranch) MarshalToSizedBuffer

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

func (*HistoryBranch) ProtoMessage

func (*HistoryBranch) ProtoMessage()

func (*HistoryBranch) Reset

func (m *HistoryBranch) Reset()

func (*HistoryBranch) Size

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

func (*HistoryBranch) String

func (this *HistoryBranch) String() string

func (*HistoryBranch) Unmarshal

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

func (*HistoryBranch) XXX_DiscardUnknown

func (m *HistoryBranch) XXX_DiscardUnknown()

func (*HistoryBranch) XXX_Marshal

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

func (*HistoryBranch) XXX_Merge

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

func (*HistoryBranch) XXX_Size

func (m *HistoryBranch) XXX_Size() int

func (*HistoryBranch) XXX_Unmarshal

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

type HistoryBranchRange

type HistoryBranchRange struct {
	// BranchId of original branch forked from.
	BranchId string `protobuf:"bytes,1,opt,name=branch_id,json=branchId,proto3" json:"branch_id,omitempty"`
	// Beginning node for the range, inclusive.
	BeginNodeId int64 `protobuf:"varint,2,opt,name=begin_node_id,json=beginNodeId,proto3" json:"begin_node_id,omitempty"`
	// Ending node for the range, exclusive.
	EndNodeId int64 `protobuf:"varint,3,opt,name=end_node_id,json=endNodeId,proto3" json:"end_node_id,omitempty"`
}

HistoryBranchRange represents a piece of range for a branch.

func (*HistoryBranchRange) Descriptor

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

func (*HistoryBranchRange) Equal

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

func (*HistoryBranchRange) GetBeginNodeId

func (m *HistoryBranchRange) GetBeginNodeId() int64

func (*HistoryBranchRange) GetBranchId

func (m *HistoryBranchRange) GetBranchId() string

func (*HistoryBranchRange) GetEndNodeId

func (m *HistoryBranchRange) GetEndNodeId() int64

func (*HistoryBranchRange) GoString

func (this *HistoryBranchRange) GoString() string

func (*HistoryBranchRange) Marshal

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

func (*HistoryBranchRange) MarshalTo

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

func (*HistoryBranchRange) MarshalToSizedBuffer

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

func (*HistoryBranchRange) ProtoMessage

func (*HistoryBranchRange) ProtoMessage()

func (*HistoryBranchRange) Reset

func (m *HistoryBranchRange) Reset()

func (*HistoryBranchRange) Size

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

func (*HistoryBranchRange) String

func (this *HistoryBranchRange) String() string

func (*HistoryBranchRange) Unmarshal

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

func (*HistoryBranchRange) XXX_DiscardUnknown

func (m *HistoryBranchRange) XXX_DiscardUnknown()

func (*HistoryBranchRange) XXX_Marshal

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

func (*HistoryBranchRange) XXX_Merge

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

func (*HistoryBranchRange) XXX_Size

func (m *HistoryBranchRange) XXX_Size() int

func (*HistoryBranchRange) XXX_Unmarshal

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

type HistoryTreeInfo

type HistoryTreeInfo struct {
	BranchInfo *HistoryBranch `protobuf:"bytes,1,opt,name=branch_info,json=branchInfo,proto3" json:"branch_info,omitempty"`
	// For fork operation to prevent race condition of leaking event data when forking branches fail. Also can be used for clean up leaked data.
	ForkTime *types.Timestamp `protobuf:"bytes,2,opt,name=fork_time,json=forkTime,proto3" json:"fork_time,omitempty"`
	// For lookup back to workflow during debugging, also background cleanup when fork operation cannot finish self cleanup due to crash.
	Info string `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
}

func (*HistoryTreeInfo) Descriptor

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

func (*HistoryTreeInfo) Equal

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

func (*HistoryTreeInfo) GetBranchInfo

func (m *HistoryTreeInfo) GetBranchInfo() *HistoryBranch

func (*HistoryTreeInfo) GetForkTime

func (m *HistoryTreeInfo) GetForkTime() *types.Timestamp

func (*HistoryTreeInfo) GetInfo

func (m *HistoryTreeInfo) GetInfo() string

func (*HistoryTreeInfo) GoString

func (this *HistoryTreeInfo) GoString() string

func (*HistoryTreeInfo) Marshal

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

func (*HistoryTreeInfo) MarshalTo

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

func (*HistoryTreeInfo) MarshalToSizedBuffer

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

func (*HistoryTreeInfo) ProtoMessage

func (*HistoryTreeInfo) ProtoMessage()

func (*HistoryTreeInfo) Reset

func (m *HistoryTreeInfo) Reset()

func (*HistoryTreeInfo) Size

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

func (*HistoryTreeInfo) String

func (this *HistoryTreeInfo) String() string

func (*HistoryTreeInfo) Unmarshal

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

func (*HistoryTreeInfo) XXX_DiscardUnknown

func (m *HistoryTreeInfo) XXX_DiscardUnknown()

func (*HistoryTreeInfo) XXX_Marshal

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

func (*HistoryTreeInfo) XXX_Merge

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

func (*HistoryTreeInfo) XXX_Size

func (m *HistoryTreeInfo) XXX_Size() int

func (*HistoryTreeInfo) XXX_Unmarshal

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

type ImmutableClusterMetadata

type ImmutableClusterMetadata struct {
	ClusterName       string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	HistoryShardCount int32  `protobuf:"varint,2,opt,name=history_shard_count,json=historyShardCount,proto3" json:"history_shard_count,omitempty"`
}

ImmutableClusterMetadata contains initialization configuration and metadata for the cluster.

func (*ImmutableClusterMetadata) Descriptor

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

func (*ImmutableClusterMetadata) Equal

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

func (*ImmutableClusterMetadata) GetClusterName

func (m *ImmutableClusterMetadata) GetClusterName() string

func (*ImmutableClusterMetadata) GetHistoryShardCount

func (m *ImmutableClusterMetadata) GetHistoryShardCount() int32

func (*ImmutableClusterMetadata) GoString

func (this *ImmutableClusterMetadata) GoString() string

func (*ImmutableClusterMetadata) Marshal

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

func (*ImmutableClusterMetadata) MarshalTo

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

func (*ImmutableClusterMetadata) MarshalToSizedBuffer

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

func (*ImmutableClusterMetadata) ProtoMessage

func (*ImmutableClusterMetadata) ProtoMessage()

func (*ImmutableClusterMetadata) Reset

func (m *ImmutableClusterMetadata) Reset()

func (*ImmutableClusterMetadata) Size

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

func (*ImmutableClusterMetadata) String

func (this *ImmutableClusterMetadata) String() string

func (*ImmutableClusterMetadata) Unmarshal

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

func (*ImmutableClusterMetadata) XXX_DiscardUnknown

func (m *ImmutableClusterMetadata) XXX_DiscardUnknown()

func (*ImmutableClusterMetadata) XXX_Marshal

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

func (*ImmutableClusterMetadata) XXX_Merge

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

func (*ImmutableClusterMetadata) XXX_Size

func (m *ImmutableClusterMetadata) XXX_Size() int

func (*ImmutableClusterMetadata) XXX_Unmarshal

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

type NamespaceConfig

type NamespaceConfig struct {
	RetentionDays           int32             `protobuf:"varint,1,opt,name=retention_days,json=retentionDays,proto3" json:"retention_days,omitempty"`
	EmitMetric              bool              `protobuf:"varint,2,opt,name=emit_metric,json=emitMetric,proto3" json:"emit_metric,omitempty"`
	ArchivalBucket          string            `protobuf:"bytes,3,opt,name=archival_bucket,json=archivalBucket,proto3" json:"archival_bucket,omitempty"`
	BadBinaries             *v15.BadBinaries  `protobuf:"bytes,16,opt,name=bad_binaries,json=badBinaries,proto3" json:"bad_binaries,omitempty"`
	HistoryArchivalState    v14.ArchivalState `` /* 166-byte string literal not displayed */
	HistoryArchivalUri      string            `protobuf:"bytes,19,opt,name=history_archival_uri,json=historyArchivalUri,proto3" json:"history_archival_uri,omitempty"`
	VisibilityArchivalState v14.ArchivalState `` /* 175-byte string literal not displayed */
	VisibilityArchivalUri   string            `` /* 127-byte string literal not displayed */
}

func (*NamespaceConfig) Descriptor

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

func (*NamespaceConfig) Equal

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

func (*NamespaceConfig) GetArchivalBucket

func (m *NamespaceConfig) GetArchivalBucket() string

func (*NamespaceConfig) GetBadBinaries

func (m *NamespaceConfig) GetBadBinaries() *v15.BadBinaries

func (*NamespaceConfig) GetEmitMetric

func (m *NamespaceConfig) GetEmitMetric() bool

func (*NamespaceConfig) GetHistoryArchivalState

func (m *NamespaceConfig) GetHistoryArchivalState() v14.ArchivalState

func (*NamespaceConfig) GetHistoryArchivalUri

func (m *NamespaceConfig) GetHistoryArchivalUri() string

func (*NamespaceConfig) GetRetentionDays

func (m *NamespaceConfig) GetRetentionDays() int32

func (*NamespaceConfig) GetVisibilityArchivalState

func (m *NamespaceConfig) GetVisibilityArchivalState() v14.ArchivalState

func (*NamespaceConfig) GetVisibilityArchivalUri

func (m *NamespaceConfig) GetVisibilityArchivalUri() string

func (*NamespaceConfig) GoString

func (this *NamespaceConfig) GoString() string

func (*NamespaceConfig) Marshal

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

func (*NamespaceConfig) MarshalTo

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

func (*NamespaceConfig) MarshalToSizedBuffer

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

func (*NamespaceConfig) ProtoMessage

func (*NamespaceConfig) ProtoMessage()

func (*NamespaceConfig) Reset

func (m *NamespaceConfig) Reset()

func (*NamespaceConfig) Size

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

func (*NamespaceConfig) String

func (this *NamespaceConfig) String() string

func (*NamespaceConfig) Unmarshal

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

func (*NamespaceConfig) XXX_DiscardUnknown

func (m *NamespaceConfig) XXX_DiscardUnknown()

func (*NamespaceConfig) XXX_Marshal

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

func (*NamespaceConfig) XXX_Merge

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

func (*NamespaceConfig) XXX_Size

func (m *NamespaceConfig) XXX_Size() int

func (*NamespaceConfig) XXX_Unmarshal

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

type NamespaceDetail

type NamespaceDetail struct {
	Info                        *NamespaceInfo              `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	Config                      *NamespaceConfig            `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	ReplicationConfig           *NamespaceReplicationConfig `protobuf:"bytes,3,opt,name=replication_config,json=replicationConfig,proto3" json:"replication_config,omitempty"`
	ConfigVersion               int64                       `protobuf:"varint,9,opt,name=config_version,json=configVersion,proto3" json:"config_version,omitempty"`
	FailoverNotificationVersion int64                       `` /* 146-byte string literal not displayed */
	FailoverVersion             int64                       `protobuf:"varint,12,opt,name=failover_version,json=failoverVersion,proto3" json:"failover_version,omitempty"`
	FailoverEndTime             int64                       `protobuf:"varint,13,opt,name=failover_end_time,json=failoverEndTime,proto3" json:"failover_end_time,omitempty"`
}

func (*NamespaceDetail) Descriptor

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

func (*NamespaceDetail) Equal

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

func (*NamespaceDetail) GetConfig

func (m *NamespaceDetail) GetConfig() *NamespaceConfig

func (*NamespaceDetail) GetConfigVersion

func (m *NamespaceDetail) GetConfigVersion() int64

func (*NamespaceDetail) GetFailoverEndTime

func (m *NamespaceDetail) GetFailoverEndTime() int64

func (*NamespaceDetail) GetFailoverNotificationVersion

func (m *NamespaceDetail) GetFailoverNotificationVersion() int64

func (*NamespaceDetail) GetFailoverVersion

func (m *NamespaceDetail) GetFailoverVersion() int64

func (*NamespaceDetail) GetInfo

func (m *NamespaceDetail) GetInfo() *NamespaceInfo

func (*NamespaceDetail) GetReplicationConfig

func (m *NamespaceDetail) GetReplicationConfig() *NamespaceReplicationConfig

func (*NamespaceDetail) GoString

func (this *NamespaceDetail) GoString() string

func (*NamespaceDetail) Marshal

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

func (*NamespaceDetail) MarshalTo

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

func (*NamespaceDetail) MarshalToSizedBuffer

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

func (*NamespaceDetail) ProtoMessage

func (*NamespaceDetail) ProtoMessage()

func (*NamespaceDetail) Reset

func (m *NamespaceDetail) Reset()

func (*NamespaceDetail) Size

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

func (*NamespaceDetail) String

func (this *NamespaceDetail) String() string

func (*NamespaceDetail) Unmarshal

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

func (*NamespaceDetail) XXX_DiscardUnknown

func (m *NamespaceDetail) XXX_DiscardUnknown()

func (*NamespaceDetail) XXX_Marshal

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

func (*NamespaceDetail) XXX_Merge

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

func (*NamespaceDetail) XXX_Size

func (m *NamespaceDetail) XXX_Size() int

func (*NamespaceDetail) XXX_Unmarshal

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

type NamespaceInfo

type NamespaceInfo struct {
	Id          string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State       v14.NamespaceState `protobuf:"varint,2,opt,name=state,proto3,enum=temporal.api.enums.v1.NamespaceState" json:"state,omitempty"`
	Name        string             `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Description string             `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Owner       string             `protobuf:"bytes,5,opt,name=owner,proto3" json:"owner,omitempty"`
	Data        map[string]string  `` /* 149-byte string literal not displayed */
}

func (*NamespaceInfo) Descriptor

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

func (*NamespaceInfo) Equal

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

func (*NamespaceInfo) GetData

func (m *NamespaceInfo) GetData() map[string]string

func (*NamespaceInfo) GetDescription

func (m *NamespaceInfo) GetDescription() string

func (*NamespaceInfo) GetId

func (m *NamespaceInfo) GetId() string

func (*NamespaceInfo) GetName

func (m *NamespaceInfo) GetName() string

func (*NamespaceInfo) GetOwner

func (m *NamespaceInfo) GetOwner() string

func (*NamespaceInfo) GetState

func (m *NamespaceInfo) GetState() v14.NamespaceState

func (*NamespaceInfo) GoString

func (this *NamespaceInfo) GoString() string

func (*NamespaceInfo) Marshal

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

func (*NamespaceInfo) MarshalTo

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

func (*NamespaceInfo) MarshalToSizedBuffer

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

func (*NamespaceInfo) ProtoMessage

func (*NamespaceInfo) ProtoMessage()

func (*NamespaceInfo) Reset

func (m *NamespaceInfo) Reset()

func (*NamespaceInfo) Size

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

func (*NamespaceInfo) String

func (this *NamespaceInfo) String() string

func (*NamespaceInfo) Unmarshal

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

func (*NamespaceInfo) XXX_DiscardUnknown

func (m *NamespaceInfo) XXX_DiscardUnknown()

func (*NamespaceInfo) XXX_Marshal

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

func (*NamespaceInfo) XXX_Merge

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

func (*NamespaceInfo) XXX_Size

func (m *NamespaceInfo) XXX_Size() int

func (*NamespaceInfo) XXX_Unmarshal

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

type NamespaceReplicationConfig

type NamespaceReplicationConfig struct {
	ActiveClusterName string   `protobuf:"bytes,1,opt,name=active_cluster_name,json=activeClusterName,proto3" json:"active_cluster_name,omitempty"`
	Clusters          []string `protobuf:"bytes,2,rep,name=clusters,proto3" json:"clusters,omitempty"`
}

func (*NamespaceReplicationConfig) Descriptor

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

func (*NamespaceReplicationConfig) Equal

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

func (*NamespaceReplicationConfig) GetActiveClusterName

func (m *NamespaceReplicationConfig) GetActiveClusterName() string

func (*NamespaceReplicationConfig) GetClusters

func (m *NamespaceReplicationConfig) GetClusters() []string

func (*NamespaceReplicationConfig) GoString

func (this *NamespaceReplicationConfig) GoString() string

func (*NamespaceReplicationConfig) Marshal

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

func (*NamespaceReplicationConfig) MarshalTo

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

func (*NamespaceReplicationConfig) MarshalToSizedBuffer

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

func (*NamespaceReplicationConfig) ProtoMessage

func (*NamespaceReplicationConfig) ProtoMessage()

func (*NamespaceReplicationConfig) Reset

func (m *NamespaceReplicationConfig) Reset()

func (*NamespaceReplicationConfig) Size

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

func (*NamespaceReplicationConfig) String

func (this *NamespaceReplicationConfig) String() string

func (*NamespaceReplicationConfig) Unmarshal

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

func (*NamespaceReplicationConfig) XXX_DiscardUnknown

func (m *NamespaceReplicationConfig) XXX_DiscardUnknown()

func (*NamespaceReplicationConfig) XXX_Marshal

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

func (*NamespaceReplicationConfig) XXX_Merge

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

func (*NamespaceReplicationConfig) XXX_Size

func (m *NamespaceReplicationConfig) XXX_Size() int

func (*NamespaceReplicationConfig) XXX_Unmarshal

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

type ReplicationData

type ReplicationData struct {
	LastWriteEventId    int64                           `protobuf:"varint,1,opt,name=last_write_event_id,json=lastWriteEventId,proto3" json:"last_write_event_id,omitempty"`
	LastReplicationInfo map[string]*v13.ReplicationInfo `` /* 208-byte string literal not displayed */
}

ReplicationData represents mutable state information for global namespaces. This information is used by replication protocol when applying events from remote clusters only used in cassandra

func (*ReplicationData) Descriptor

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

func (*ReplicationData) Equal

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

func (*ReplicationData) GetLastReplicationInfo

func (m *ReplicationData) GetLastReplicationInfo() map[string]*v13.ReplicationInfo

func (*ReplicationData) GetLastWriteEventId

func (m *ReplicationData) GetLastWriteEventId() int64

func (*ReplicationData) GoString

func (this *ReplicationData) GoString() string

func (*ReplicationData) Marshal

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

func (*ReplicationData) MarshalTo

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

func (*ReplicationData) MarshalToSizedBuffer

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

func (*ReplicationData) ProtoMessage

func (*ReplicationData) ProtoMessage()

func (*ReplicationData) Reset

func (m *ReplicationData) Reset()

func (*ReplicationData) Size

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

func (*ReplicationData) String

func (this *ReplicationData) String() string

func (*ReplicationData) Unmarshal

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

func (*ReplicationData) XXX_DiscardUnknown

func (m *ReplicationData) XXX_DiscardUnknown()

func (*ReplicationData) XXX_Marshal

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

func (*ReplicationData) XXX_Merge

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

func (*ReplicationData) XXX_Size

func (m *ReplicationData) XXX_Size() int

func (*ReplicationData) XXX_Unmarshal

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

type ReplicationTaskInfo

type ReplicationTaskInfo struct {
	NamespaceId             string                          `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId              string                          `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId                   string                          `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	TaskType                v12.TaskType                    `` /* 129-byte string literal not displayed */
	Version                 int64                           `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	FirstEventId            int64                           `protobuf:"varint,6,opt,name=first_event_id,json=firstEventId,proto3" json:"first_event_id,omitempty"`
	NextEventId             int64                           `protobuf:"varint,7,opt,name=next_event_id,json=nextEventId,proto3" json:"next_event_id,omitempty"`
	ScheduledId             int64                           `protobuf:"varint,8,opt,name=scheduled_id,json=scheduledId,proto3" json:"scheduled_id,omitempty"`
	EventStoreVersion       int32                           `protobuf:"varint,9,opt,name=event_store_version,json=eventStoreVersion,proto3" json:"event_store_version,omitempty"`
	NewRunEventStoreVersion int32                           `` /* 138-byte string literal not displayed */
	BranchToken             []byte                          `protobuf:"bytes,11,opt,name=branch_token,json=branchToken,proto3" json:"branch_token,omitempty"`
	LastReplicationInfo     map[string]*v13.ReplicationInfo `` /* 209-byte string literal not displayed */
	NewRunBranchToken       []byte                          `protobuf:"bytes,13,opt,name=new_run_branch_token,json=newRunBranchToken,proto3" json:"new_run_branch_token,omitempty"`
	ResetWorkflow           bool                            `protobuf:"varint,14,opt,name=reset_workflow,json=resetWorkflow,proto3" json:"reset_workflow,omitempty"`
	TaskId                  int64                           `protobuf:"varint,15,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
}

func (*ReplicationTaskInfo) Descriptor

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

func (*ReplicationTaskInfo) Equal

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

func (*ReplicationTaskInfo) GetBranchToken

func (m *ReplicationTaskInfo) GetBranchToken() []byte

func (*ReplicationTaskInfo) GetEventStoreVersion

func (m *ReplicationTaskInfo) GetEventStoreVersion() int32

func (*ReplicationTaskInfo) GetFirstEventId

func (m *ReplicationTaskInfo) GetFirstEventId() int64

func (*ReplicationTaskInfo) GetLastReplicationInfo

func (m *ReplicationTaskInfo) GetLastReplicationInfo() map[string]*v13.ReplicationInfo

func (*ReplicationTaskInfo) GetNamespaceId

func (m *ReplicationTaskInfo) GetNamespaceId() string

func (*ReplicationTaskInfo) GetNewRunBranchToken

func (m *ReplicationTaskInfo) GetNewRunBranchToken() []byte

func (*ReplicationTaskInfo) GetNewRunEventStoreVersion

func (m *ReplicationTaskInfo) GetNewRunEventStoreVersion() int32

func (*ReplicationTaskInfo) GetNextEventId

func (m *ReplicationTaskInfo) GetNextEventId() int64

func (*ReplicationTaskInfo) GetResetWorkflow

func (m *ReplicationTaskInfo) GetResetWorkflow() bool

func (*ReplicationTaskInfo) GetRunId

func (m *ReplicationTaskInfo) GetRunId() string

func (*ReplicationTaskInfo) GetScheduledId

func (m *ReplicationTaskInfo) GetScheduledId() int64

func (*ReplicationTaskInfo) GetTaskId

func (m *ReplicationTaskInfo) GetTaskId() int64

func (*ReplicationTaskInfo) GetTaskType

func (m *ReplicationTaskInfo) GetTaskType() v12.TaskType

func (*ReplicationTaskInfo) GetVersion

func (m *ReplicationTaskInfo) GetVersion() int64

func (*ReplicationTaskInfo) GetWorkflowId

func (m *ReplicationTaskInfo) GetWorkflowId() string

func (*ReplicationTaskInfo) GoString

func (this *ReplicationTaskInfo) GoString() string

func (*ReplicationTaskInfo) Marshal

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

func (*ReplicationTaskInfo) MarshalTo

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

func (*ReplicationTaskInfo) MarshalToSizedBuffer

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

func (*ReplicationTaskInfo) ProtoMessage

func (*ReplicationTaskInfo) ProtoMessage()

func (*ReplicationTaskInfo) Reset

func (m *ReplicationTaskInfo) Reset()

func (*ReplicationTaskInfo) Size

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

func (*ReplicationTaskInfo) String

func (this *ReplicationTaskInfo) String() string

func (*ReplicationTaskInfo) Unmarshal

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

func (*ReplicationTaskInfo) XXX_DiscardUnknown

func (m *ReplicationTaskInfo) XXX_DiscardUnknown()

func (*ReplicationTaskInfo) XXX_Marshal

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

func (*ReplicationTaskInfo) XXX_Merge

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

func (*ReplicationTaskInfo) XXX_Size

func (m *ReplicationTaskInfo) XXX_Size() int

func (*ReplicationTaskInfo) XXX_Unmarshal

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

type ReplicationVersions

type ReplicationVersions struct {
	StartVersion     *types.Int64Value `protobuf:"bytes,15,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
	LastWriteVersion *types.Int64Value `protobuf:"bytes,16,opt,name=last_write_version,json=lastWriteVersion,proto3" json:"last_write_version,omitempty"`
}

func (*ReplicationVersions) Descriptor

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

func (*ReplicationVersions) Equal

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

func (*ReplicationVersions) GetLastWriteVersion

func (m *ReplicationVersions) GetLastWriteVersion() *types.Int64Value

func (*ReplicationVersions) GetStartVersion

func (m *ReplicationVersions) GetStartVersion() *types.Int64Value

func (*ReplicationVersions) GoString

func (this *ReplicationVersions) GoString() string

func (*ReplicationVersions) Marshal

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

func (*ReplicationVersions) MarshalTo

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

func (*ReplicationVersions) MarshalToSizedBuffer

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

func (*ReplicationVersions) ProtoMessage

func (*ReplicationVersions) ProtoMessage()

func (*ReplicationVersions) Reset

func (m *ReplicationVersions) Reset()

func (*ReplicationVersions) Size

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

func (*ReplicationVersions) String

func (this *ReplicationVersions) String() string

func (*ReplicationVersions) Unmarshal

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

func (*ReplicationVersions) XXX_DiscardUnknown

func (m *ReplicationVersions) XXX_DiscardUnknown()

func (*ReplicationVersions) XXX_Marshal

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

func (*ReplicationVersions) XXX_Merge

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

func (*ReplicationVersions) XXX_Size

func (m *ReplicationVersions) XXX_Size() int

func (*ReplicationVersions) XXX_Unmarshal

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

type RequestCancelInfo

type RequestCancelInfo struct {
	Version               int64  `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	InitiatedEventBatchId int64  `` /* 129-byte string literal not displayed */
	CancelRequestId       string `protobuf:"bytes,3,opt,name=cancel_request_id,json=cancelRequestId,proto3" json:"cancel_request_id,omitempty"`
	InitiatedId           int64  `protobuf:"varint,4,opt,name=initiated_id,json=initiatedId,proto3" json:"initiated_id,omitempty"`
}

func (*RequestCancelInfo) Descriptor

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

func (*RequestCancelInfo) Equal

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

func (*RequestCancelInfo) GetCancelRequestId

func (m *RequestCancelInfo) GetCancelRequestId() string

func (*RequestCancelInfo) GetInitiatedEventBatchId

func (m *RequestCancelInfo) GetInitiatedEventBatchId() int64

func (*RequestCancelInfo) GetInitiatedId

func (m *RequestCancelInfo) GetInitiatedId() int64

func (*RequestCancelInfo) GetVersion

func (m *RequestCancelInfo) GetVersion() int64

func (*RequestCancelInfo) GoString

func (this *RequestCancelInfo) GoString() string

func (*RequestCancelInfo) Marshal

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

func (*RequestCancelInfo) MarshalTo

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

func (*RequestCancelInfo) MarshalToSizedBuffer

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

func (*RequestCancelInfo) ProtoMessage

func (*RequestCancelInfo) ProtoMessage()

func (*RequestCancelInfo) Reset

func (m *RequestCancelInfo) Reset()

func (*RequestCancelInfo) Size

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

func (*RequestCancelInfo) String

func (this *RequestCancelInfo) String() string

func (*RequestCancelInfo) Unmarshal

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

func (*RequestCancelInfo) XXX_DiscardUnknown

func (m *RequestCancelInfo) XXX_DiscardUnknown()

func (*RequestCancelInfo) XXX_Marshal

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

func (*RequestCancelInfo) XXX_Merge

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

func (*RequestCancelInfo) XXX_Size

func (m *RequestCancelInfo) XXX_Size() int

func (*RequestCancelInfo) XXX_Unmarshal

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

type ShardInfo

type ShardInfo struct {
	ShardId             int32  `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	RangeId             int64  `protobuf:"varint,2,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	Owner               string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	ReplicationAckLevel int64  `protobuf:"varint,4,opt,name=replication_ack_level,json=replicationAckLevel,proto3" json:"replication_ack_level,omitempty"`
	TransferAckLevel    int64  `protobuf:"varint,5,opt,name=transfer_ack_level,json=transferAckLevel,proto3" json:"transfer_ack_level,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "since" is needed here. --)
	StolenSinceRenew             int32                       `protobuf:"varint,6,opt,name=stolen_since_renew,json=stolenSinceRenew,proto3" json:"stolen_since_renew,omitempty"`
	UpdateTime                   *types.Timestamp            `protobuf:"bytes,7,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	TimerAckLevelTime            *types.Timestamp            `protobuf:"bytes,8,opt,name=timer_ack_level_time,json=timerAckLevelTime,proto3" json:"timer_ack_level_time,omitempty"`
	NamespaceNotificationVersion int64                       `` /* 148-byte string literal not displayed */
	ClusterTransferAckLevel      map[string]int64            `` /* 224-byte string literal not displayed */
	ClusterTimerAckLevel         map[string]*types.Timestamp `` /* 214-byte string literal not displayed */
	ClusterReplicationLevel      map[string]int64            `` /* 222-byte string literal not displayed */
	ReplicationDlqAckLevel       map[string]int64            `` /* 221-byte string literal not displayed */
}

func (*ShardInfo) Descriptor

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

func (*ShardInfo) Equal

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

func (*ShardInfo) GetClusterReplicationLevel

func (m *ShardInfo) GetClusterReplicationLevel() map[string]int64

func (*ShardInfo) GetClusterTimerAckLevel

func (m *ShardInfo) GetClusterTimerAckLevel() map[string]*types.Timestamp

func (*ShardInfo) GetClusterTransferAckLevel

func (m *ShardInfo) GetClusterTransferAckLevel() map[string]int64

func (*ShardInfo) GetNamespaceNotificationVersion

func (m *ShardInfo) GetNamespaceNotificationVersion() int64

func (*ShardInfo) GetOwner

func (m *ShardInfo) GetOwner() string

func (*ShardInfo) GetRangeId

func (m *ShardInfo) GetRangeId() int64

func (*ShardInfo) GetReplicationAckLevel

func (m *ShardInfo) GetReplicationAckLevel() int64

func (*ShardInfo) GetReplicationDlqAckLevel

func (m *ShardInfo) GetReplicationDlqAckLevel() map[string]int64

func (*ShardInfo) GetShardId

func (m *ShardInfo) GetShardId() int32

func (*ShardInfo) GetStolenSinceRenew

func (m *ShardInfo) GetStolenSinceRenew() int32

func (*ShardInfo) GetTimerAckLevelTime

func (m *ShardInfo) GetTimerAckLevelTime() *types.Timestamp

func (*ShardInfo) GetTransferAckLevel

func (m *ShardInfo) GetTransferAckLevel() int64

func (*ShardInfo) GetUpdateTime

func (m *ShardInfo) GetUpdateTime() *types.Timestamp

func (*ShardInfo) GoString

func (this *ShardInfo) GoString() string

func (*ShardInfo) Marshal

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

func (*ShardInfo) MarshalTo

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

func (*ShardInfo) MarshalToSizedBuffer

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

func (*ShardInfo) ProtoMessage

func (*ShardInfo) ProtoMessage()

func (*ShardInfo) Reset

func (m *ShardInfo) Reset()

func (*ShardInfo) Size

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

func (*ShardInfo) String

func (this *ShardInfo) String() string

func (*ShardInfo) Unmarshal

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

func (*ShardInfo) XXX_DiscardUnknown

func (m *ShardInfo) XXX_DiscardUnknown()

func (*ShardInfo) XXX_Marshal

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

func (*ShardInfo) XXX_Merge

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

func (*ShardInfo) XXX_Size

func (m *ShardInfo) XXX_Size() int

func (*ShardInfo) XXX_Unmarshal

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

type SignalInfo

type SignalInfo struct {
	Version               int64         `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	InitiatedEventBatchId int64         `` /* 129-byte string literal not displayed */
	RequestId             string        `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Name                  string        `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Input                 *v11.Payloads `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"`
	Control               string        `protobuf:"bytes,6,opt,name=control,proto3" json:"control,omitempty"`
	InitiatedId           int64         `protobuf:"varint,7,opt,name=initiated_id,json=initiatedId,proto3" json:"initiated_id,omitempty"`
}

func (*SignalInfo) Descriptor

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

func (*SignalInfo) Equal

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

func (*SignalInfo) GetControl

func (m *SignalInfo) GetControl() string

func (*SignalInfo) GetInitiatedEventBatchId

func (m *SignalInfo) GetInitiatedEventBatchId() int64

func (*SignalInfo) GetInitiatedId

func (m *SignalInfo) GetInitiatedId() int64

func (*SignalInfo) GetInput

func (m *SignalInfo) GetInput() *v11.Payloads

func (*SignalInfo) GetName

func (m *SignalInfo) GetName() string

func (*SignalInfo) GetRequestId

func (m *SignalInfo) GetRequestId() string

func (*SignalInfo) GetVersion

func (m *SignalInfo) GetVersion() int64

func (*SignalInfo) GoString

func (this *SignalInfo) GoString() string

func (*SignalInfo) Marshal

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

func (*SignalInfo) MarshalTo

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

func (*SignalInfo) MarshalToSizedBuffer

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

func (*SignalInfo) ProtoMessage

func (*SignalInfo) ProtoMessage()

func (*SignalInfo) Reset

func (m *SignalInfo) Reset()

func (*SignalInfo) Size

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

func (*SignalInfo) String

func (this *SignalInfo) String() string

func (*SignalInfo) Unmarshal

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

func (*SignalInfo) XXX_DiscardUnknown

func (m *SignalInfo) XXX_DiscardUnknown()

func (*SignalInfo) XXX_Marshal

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

func (*SignalInfo) XXX_Merge

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

func (*SignalInfo) XXX_Size

func (m *SignalInfo) XXX_Size() int

func (*SignalInfo) XXX_Unmarshal

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

type TaskInfo

type TaskInfo struct {
	NamespaceId string           `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId  string           `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId       string           `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	ScheduleId  int64            `protobuf:"varint,4,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	CreateTime  *types.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	ExpiryTime  *types.Timestamp `protobuf:"bytes,6,opt,name=expiry_time,json=expiryTime,proto3" json:"expiry_time,omitempty"`
}

func (*TaskInfo) Descriptor

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

func (*TaskInfo) Equal

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

func (*TaskInfo) GetCreateTime

func (m *TaskInfo) GetCreateTime() *types.Timestamp

func (*TaskInfo) GetExpiryTime

func (m *TaskInfo) GetExpiryTime() *types.Timestamp

func (*TaskInfo) GetNamespaceId

func (m *TaskInfo) GetNamespaceId() string

func (*TaskInfo) GetRunId

func (m *TaskInfo) GetRunId() string

func (*TaskInfo) GetScheduleId

func (m *TaskInfo) GetScheduleId() int64

func (*TaskInfo) GetWorkflowId

func (m *TaskInfo) GetWorkflowId() string

func (*TaskInfo) GoString

func (this *TaskInfo) GoString() string

func (*TaskInfo) Marshal

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

func (*TaskInfo) MarshalTo

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

func (*TaskInfo) MarshalToSizedBuffer

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

func (*TaskInfo) ProtoMessage

func (*TaskInfo) ProtoMessage()

func (*TaskInfo) Reset

func (m *TaskInfo) Reset()

func (*TaskInfo) Size

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

func (*TaskInfo) String

func (this *TaskInfo) String() string

func (*TaskInfo) Unmarshal

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

func (*TaskInfo) XXX_DiscardUnknown

func (m *TaskInfo) XXX_DiscardUnknown()

func (*TaskInfo) XXX_Marshal

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

func (*TaskInfo) XXX_Merge

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

func (*TaskInfo) XXX_Size

func (m *TaskInfo) XXX_Size() int

func (*TaskInfo) XXX_Unmarshal

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

type TaskQueueInfo

type TaskQueueInfo struct {
	NamespaceId    string            `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Name           string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	TaskType       v14.TaskQueueType `` /* 127-byte string literal not displayed */
	Kind           v14.TaskQueueKind `protobuf:"varint,5,opt,name=kind,proto3,enum=temporal.api.enums.v1.TaskQueueKind" json:"kind,omitempty"`
	AckLevel       int64             `protobuf:"varint,6,opt,name=ack_level,json=ackLevel,proto3" json:"ack_level,omitempty"`
	ExpiryTime     *types.Timestamp  `protobuf:"bytes,7,opt,name=expiry_time,json=expiryTime,proto3" json:"expiry_time,omitempty"`
	LastUpdateTime *types.Timestamp  `protobuf:"bytes,8,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
}

func (*TaskQueueInfo) Descriptor

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

func (*TaskQueueInfo) Equal

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

func (*TaskQueueInfo) GetAckLevel

func (m *TaskQueueInfo) GetAckLevel() int64

func (*TaskQueueInfo) GetExpiryTime

func (m *TaskQueueInfo) GetExpiryTime() *types.Timestamp

func (*TaskQueueInfo) GetKind

func (m *TaskQueueInfo) GetKind() v14.TaskQueueKind

func (*TaskQueueInfo) GetLastUpdateTime

func (m *TaskQueueInfo) GetLastUpdateTime() *types.Timestamp

func (*TaskQueueInfo) GetName

func (m *TaskQueueInfo) GetName() string

func (*TaskQueueInfo) GetNamespaceId

func (m *TaskQueueInfo) GetNamespaceId() string

func (*TaskQueueInfo) GetTaskType

func (m *TaskQueueInfo) GetTaskType() v14.TaskQueueType

func (*TaskQueueInfo) GoString

func (this *TaskQueueInfo) GoString() string

func (*TaskQueueInfo) Marshal

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

func (*TaskQueueInfo) MarshalTo

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

func (*TaskQueueInfo) MarshalToSizedBuffer

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

func (*TaskQueueInfo) ProtoMessage

func (*TaskQueueInfo) ProtoMessage()

func (*TaskQueueInfo) Reset

func (m *TaskQueueInfo) Reset()

func (*TaskQueueInfo) Size

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

func (*TaskQueueInfo) String

func (this *TaskQueueInfo) String() string

func (*TaskQueueInfo) Unmarshal

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

func (*TaskQueueInfo) XXX_DiscardUnknown

func (m *TaskQueueInfo) XXX_DiscardUnknown()

func (*TaskQueueInfo) XXX_Marshal

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

func (*TaskQueueInfo) XXX_Merge

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

func (*TaskQueueInfo) XXX_Size

func (m *TaskQueueInfo) XXX_Size() int

func (*TaskQueueInfo) XXX_Unmarshal

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

type TimerInfo

type TimerInfo struct {
	Version    int64            `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	StartedId  int64            `protobuf:"varint,2,opt,name=started_id,json=startedId,proto3" json:"started_id,omitempty"`
	ExpiryTime *types.Timestamp `protobuf:"bytes,3,opt,name=expiry_time,json=expiryTime,proto3" json:"expiry_time,omitempty"`
	TaskStatus int64            `protobuf:"varint,4,opt,name=task_status,json=taskStatus,proto3" json:"task_status,omitempty"`
	// timerId serves the purpose of indicating whether a timer task is generated for this timer info.
	TimerId string `protobuf:"bytes,5,opt,name=timer_id,json=timerId,proto3" json:"timer_id,omitempty"`
}

func (*TimerInfo) Descriptor

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

func (*TimerInfo) Equal

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

func (*TimerInfo) GetExpiryTime

func (m *TimerInfo) GetExpiryTime() *types.Timestamp

func (*TimerInfo) GetStartedId

func (m *TimerInfo) GetStartedId() int64

func (*TimerInfo) GetTaskStatus

func (m *TimerInfo) GetTaskStatus() int64

func (*TimerInfo) GetTimerId

func (m *TimerInfo) GetTimerId() string

func (*TimerInfo) GetVersion

func (m *TimerInfo) GetVersion() int64

func (*TimerInfo) GoString

func (this *TimerInfo) GoString() string

func (*TimerInfo) Marshal

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

func (*TimerInfo) MarshalTo

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

func (*TimerInfo) MarshalToSizedBuffer

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

func (*TimerInfo) ProtoMessage

func (*TimerInfo) ProtoMessage()

func (*TimerInfo) Reset

func (m *TimerInfo) Reset()

func (*TimerInfo) Size

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

func (*TimerInfo) String

func (this *TimerInfo) String() string

func (*TimerInfo) Unmarshal

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

func (*TimerInfo) XXX_DiscardUnknown

func (m *TimerInfo) XXX_DiscardUnknown()

func (*TimerInfo) XXX_Marshal

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

func (*TimerInfo) XXX_Merge

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

func (*TimerInfo) XXX_Size

func (m *TimerInfo) XXX_Size() int

func (*TimerInfo) XXX_Unmarshal

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

type TimerTaskInfo

type TimerTaskInfo struct {
	NamespaceId         string                  `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId          string                  `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId               string                  `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	TaskType            v12.TaskType            `` /* 129-byte string literal not displayed */
	TimeoutType         v14.TimeoutType         `` /* 134-byte string literal not displayed */
	WorkflowBackoffType v12.WorkflowBackoffType `` /* 175-byte string literal not displayed */
	Version             int64                   `protobuf:"varint,7,opt,name=version,proto3" json:"version,omitempty"`
	ScheduleAttempt     int64                   `protobuf:"varint,8,opt,name=schedule_attempt,json=scheduleAttempt,proto3" json:"schedule_attempt,omitempty"`
	EventId             int64                   `protobuf:"varint,9,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	TaskId              int64                   `protobuf:"varint,10,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	VisibilityTime      *types.Timestamp        `protobuf:"bytes,11,opt,name=visibility_time,json=visibilityTime,proto3" json:"visibility_time,omitempty"`
}

func (*TimerTaskInfo) Descriptor

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

func (*TimerTaskInfo) Equal

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

func (*TimerTaskInfo) GetEventId

func (m *TimerTaskInfo) GetEventId() int64

func (*TimerTaskInfo) GetNamespaceId

func (m *TimerTaskInfo) GetNamespaceId() string

func (*TimerTaskInfo) GetRunId

func (m *TimerTaskInfo) GetRunId() string

func (*TimerTaskInfo) GetScheduleAttempt

func (m *TimerTaskInfo) GetScheduleAttempt() int64

func (*TimerTaskInfo) GetTaskId

func (m *TimerTaskInfo) GetTaskId() int64

func (*TimerTaskInfo) GetTaskType

func (m *TimerTaskInfo) GetTaskType() v12.TaskType

func (*TimerTaskInfo) GetTimeoutType

func (m *TimerTaskInfo) GetTimeoutType() v14.TimeoutType

func (*TimerTaskInfo) GetVersion

func (m *TimerTaskInfo) GetVersion() int64

func (*TimerTaskInfo) GetVisibilityTime

func (m *TimerTaskInfo) GetVisibilityTime() *types.Timestamp

func (*TimerTaskInfo) GetWorkflowBackoffType

func (m *TimerTaskInfo) GetWorkflowBackoffType() v12.WorkflowBackoffType

func (*TimerTaskInfo) GetWorkflowId

func (m *TimerTaskInfo) GetWorkflowId() string

func (*TimerTaskInfo) GoString

func (this *TimerTaskInfo) GoString() string

func (*TimerTaskInfo) Marshal

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

func (*TimerTaskInfo) MarshalTo

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

func (*TimerTaskInfo) MarshalToSizedBuffer

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

func (*TimerTaskInfo) ProtoMessage

func (*TimerTaskInfo) ProtoMessage()

func (*TimerTaskInfo) Reset

func (m *TimerTaskInfo) Reset()

func (*TimerTaskInfo) Size

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

func (*TimerTaskInfo) String

func (this *TimerTaskInfo) String() string

func (*TimerTaskInfo) Unmarshal

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

func (*TimerTaskInfo) XXX_DiscardUnknown

func (m *TimerTaskInfo) XXX_DiscardUnknown()

func (*TimerTaskInfo) XXX_Marshal

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

func (*TimerTaskInfo) XXX_Merge

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

func (*TimerTaskInfo) XXX_Size

func (m *TimerTaskInfo) XXX_Size() int

func (*TimerTaskInfo) XXX_Unmarshal

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

type TransferTaskInfo

type TransferTaskInfo struct {
	NamespaceId             string           `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId              string           `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId                   string           `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	TaskType                v12.TaskType     `` /* 129-byte string literal not displayed */
	TargetNamespaceId       string           `protobuf:"bytes,5,opt,name=target_namespace_id,json=targetNamespaceId,proto3" json:"target_namespace_id,omitempty"`
	TargetWorkflowId        string           `protobuf:"bytes,6,opt,name=target_workflow_id,json=targetWorkflowId,proto3" json:"target_workflow_id,omitempty"`
	TargetRunId             string           `protobuf:"bytes,7,opt,name=target_run_id,json=targetRunId,proto3" json:"target_run_id,omitempty"`
	TaskQueue               string           `protobuf:"bytes,8,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	TargetChildWorkflowOnly bool             `` /* 135-byte string literal not displayed */
	ScheduleId              int64            `protobuf:"varint,10,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	Version                 int64            `protobuf:"varint,11,opt,name=version,proto3" json:"version,omitempty"`
	TaskId                  int64            `protobuf:"varint,12,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	VisibilityTime          *types.Timestamp `protobuf:"bytes,13,opt,name=visibility_time,json=visibilityTime,proto3" json:"visibility_time,omitempty"`
	RecordVisibility        bool             `protobuf:"varint,14,opt,name=record_visibility,json=recordVisibility,proto3" json:"record_visibility,omitempty"`
}

func (*TransferTaskInfo) Descriptor

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

func (*TransferTaskInfo) Equal

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

func (*TransferTaskInfo) GetNamespaceId

func (m *TransferTaskInfo) GetNamespaceId() string

func (*TransferTaskInfo) GetRecordVisibility

func (m *TransferTaskInfo) GetRecordVisibility() bool

func (*TransferTaskInfo) GetRunId

func (m *TransferTaskInfo) GetRunId() string

func (*TransferTaskInfo) GetScheduleId

func (m *TransferTaskInfo) GetScheduleId() int64

func (*TransferTaskInfo) GetTargetChildWorkflowOnly

func (m *TransferTaskInfo) GetTargetChildWorkflowOnly() bool

func (*TransferTaskInfo) GetTargetNamespaceId

func (m *TransferTaskInfo) GetTargetNamespaceId() string

func (*TransferTaskInfo) GetTargetRunId

func (m *TransferTaskInfo) GetTargetRunId() string

func (*TransferTaskInfo) GetTargetWorkflowId

func (m *TransferTaskInfo) GetTargetWorkflowId() string

func (*TransferTaskInfo) GetTaskId

func (m *TransferTaskInfo) GetTaskId() int64

func (*TransferTaskInfo) GetTaskQueue

func (m *TransferTaskInfo) GetTaskQueue() string

func (*TransferTaskInfo) GetTaskType

func (m *TransferTaskInfo) GetTaskType() v12.TaskType

func (*TransferTaskInfo) GetVersion

func (m *TransferTaskInfo) GetVersion() int64

func (*TransferTaskInfo) GetVisibilityTime

func (m *TransferTaskInfo) GetVisibilityTime() *types.Timestamp

func (*TransferTaskInfo) GetWorkflowId

func (m *TransferTaskInfo) GetWorkflowId() string

func (*TransferTaskInfo) GoString

func (this *TransferTaskInfo) GoString() string

func (*TransferTaskInfo) Marshal

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

func (*TransferTaskInfo) MarshalTo

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

func (*TransferTaskInfo) MarshalToSizedBuffer

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

func (*TransferTaskInfo) ProtoMessage

func (*TransferTaskInfo) ProtoMessage()

func (*TransferTaskInfo) Reset

func (m *TransferTaskInfo) Reset()

func (*TransferTaskInfo) Size

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

func (*TransferTaskInfo) String

func (this *TransferTaskInfo) String() string

func (*TransferTaskInfo) Unmarshal

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

func (*TransferTaskInfo) XXX_DiscardUnknown

func (m *TransferTaskInfo) XXX_DiscardUnknown()

func (*TransferTaskInfo) XXX_Marshal

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

func (*TransferTaskInfo) XXX_Merge

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

func (*TransferTaskInfo) XXX_Size

func (m *TransferTaskInfo) XXX_Size() int

func (*TransferTaskInfo) XXX_Unmarshal

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

type WorkflowExecutionInfo

type WorkflowExecutionInfo struct {
	NamespaceId                                 string           `protobuf:"bytes,61,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId                                  string           `protobuf:"bytes,62,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	ParentNamespaceId                           string           `protobuf:"bytes,1,opt,name=parent_namespace_id,json=parentNamespaceId,proto3" json:"parent_namespace_id,omitempty"`
	ParentWorkflowId                            string           `protobuf:"bytes,2,opt,name=parent_workflow_id,json=parentWorkflowId,proto3" json:"parent_workflow_id,omitempty"`
	ParentRunId                                 string           `protobuf:"bytes,3,opt,name=parent_run_id,json=parentRunId,proto3" json:"parent_run_id,omitempty"`
	InitiatedId                                 int64            `protobuf:"varint,4,opt,name=initiated_id,json=initiatedId,proto3" json:"initiated_id,omitempty"`
	CompletionEventBatchId                      int64            `` /* 132-byte string literal not displayed */
	CompletionEvent                             []byte           `protobuf:"bytes,6,opt,name=completion_event,json=completionEvent,proto3" json:"completion_event,omitempty"`
	CompletionEventEncoding                     string           `` /* 132-byte string literal not displayed */
	TaskQueue                                   string           `protobuf:"bytes,8,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	WorkflowTypeName                            string           `protobuf:"bytes,9,opt,name=workflow_type_name,json=workflowTypeName,proto3" json:"workflow_type_name,omitempty"`
	WorkflowExecutionTimeoutSeconds             int32            `` /* 160-byte string literal not displayed */
	WorkflowRunTimeoutSeconds                   int32            `` /* 142-byte string literal not displayed */
	WorkflowTaskTimeoutSeconds                  int32            `` /* 145-byte string literal not displayed */
	StartVersion                                int64            `protobuf:"varint,15,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
	CurrentVersion                              int64            `protobuf:"varint,16,opt,name=current_version,json=currentVersion,proto3" json:"current_version,omitempty"`
	ReplicationData                             *ReplicationData `protobuf:"bytes,17,opt,name=replication_data,json=replicationData,proto3" json:"replication_data,omitempty"`
	LastEventTaskId                             int64            `protobuf:"varint,19,opt,name=last_event_task_id,json=lastEventTaskId,proto3" json:"last_event_task_id,omitempty"`
	LastFirstEventId                            int64            `protobuf:"varint,20,opt,name=last_first_event_id,json=lastFirstEventId,proto3" json:"last_first_event_id,omitempty"`
	LastProcessedEvent                          int64            `protobuf:"varint,21,opt,name=last_processed_event,json=lastProcessedEvent,proto3" json:"last_processed_event,omitempty"`
	StartTimeNanos                              int64            `protobuf:"varint,22,opt,name=start_time_nanos,json=startTimeNanos,proto3" json:"start_time_nanos,omitempty"`
	LastUpdateTimeNanos                         int64            `protobuf:"varint,23,opt,name=last_update_time_nanos,json=lastUpdateTimeNanos,proto3" json:"last_update_time_nanos,omitempty"`
	WorkflowTaskVersion                         int64            `protobuf:"varint,24,opt,name=workflow_task_version,json=workflowTaskVersion,proto3" json:"workflow_task_version,omitempty"`
	WorkflowTaskScheduleId                      int64            `` /* 133-byte string literal not displayed */
	WorkflowTaskStartedId                       int64            `` /* 130-byte string literal not displayed */
	CurrentWorkflowTaskTimeout                  int32            `` /* 145-byte string literal not displayed */
	WorkflowTaskAttempt                         int64            `protobuf:"varint,28,opt,name=workflow_task_attempt,json=workflowTaskAttempt,proto3" json:"workflow_task_attempt,omitempty"`
	WorkflowTaskStartedTimestampNanos           int64            `` /* 168-byte string literal not displayed */
	WorkflowTaskScheduledTimestampNanos         int64            `` /* 174-byte string literal not displayed */
	CancelRequested                             bool             `protobuf:"varint,31,opt,name=cancel_requested,json=cancelRequested,proto3" json:"cancel_requested,omitempty"`
	WorkflowTaskOriginalScheduledTimestampNanos int64            `` /* 200-byte string literal not displayed */
	WorkflowTaskRequestId                       string           `` /* 129-byte string literal not displayed */
	CancelRequestId                             string           `protobuf:"bytes,35,opt,name=cancel_request_id,json=cancelRequestId,proto3" json:"cancel_request_id,omitempty"`
	StickyTaskQueue                             string           `protobuf:"bytes,36,opt,name=sticky_task_queue,json=stickyTaskQueue,proto3" json:"sticky_task_queue,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "to" is used to indicate interval. --)
	StickyScheduleToStartTimeout int64                   `` /* 153-byte string literal not displayed */
	RetryAttempt                 int64                   `protobuf:"varint,38,opt,name=retry_attempt,json=retryAttempt,proto3" json:"retry_attempt,omitempty"`
	RetryInitialIntervalSeconds  int32                   `` /* 148-byte string literal not displayed */
	RetryMaximumIntervalSeconds  int32                   `` /* 148-byte string literal not displayed */
	RetryMaximumAttempts         int32                   `protobuf:"varint,41,opt,name=retry_maximum_attempts,json=retryMaximumAttempts,proto3" json:"retry_maximum_attempts,omitempty"`
	RetryBackoffCoefficient      float64                 `` /* 135-byte string literal not displayed */
	RetryExpirationTimeNanos     int64                   `` /* 139-byte string literal not displayed */
	RetryNonRetryableErrorTypes  []string                `` /* 149-byte string literal not displayed */
	HasRetryPolicy               bool                    `protobuf:"varint,45,opt,name=has_retry_policy,json=hasRetryPolicy,proto3" json:"has_retry_policy,omitempty"`
	CronSchedule                 string                  `protobuf:"bytes,46,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"`
	EventStoreVersion            int32                   `protobuf:"varint,47,opt,name=event_store_version,json=eventStoreVersion,proto3" json:"event_store_version,omitempty"`
	EventBranchToken             []byte                  `protobuf:"bytes,48,opt,name=event_branch_token,json=eventBranchToken,proto3" json:"event_branch_token,omitempty"`
	SignalCount                  int64                   `protobuf:"varint,49,opt,name=signal_count,json=signalCount,proto3" json:"signal_count,omitempty"`
	HistorySize                  int64                   `protobuf:"varint,50,opt,name=history_size,json=historySize,proto3" json:"history_size,omitempty"`
	ClientLibraryVersion         string                  `protobuf:"bytes,51,opt,name=client_library_version,json=clientLibraryVersion,proto3" json:"client_library_version,omitempty"`
	ClientFeatureVersion         string                  `protobuf:"bytes,52,opt,name=client_feature_version,json=clientFeatureVersion,proto3" json:"client_feature_version,omitempty"`
	ClientImpl                   string                  `protobuf:"bytes,53,opt,name=client_impl,json=clientImpl,proto3" json:"client_impl,omitempty"`
	AutoResetPoints              []byte                  `protobuf:"bytes,54,opt,name=auto_reset_points,json=autoResetPoints,proto3" json:"auto_reset_points,omitempty"`
	AutoResetPointsEncoding      string                  `` /* 135-byte string literal not displayed */
	SearchAttributes             map[string]*v11.Payload `` /* 198-byte string literal not displayed */
	Memo                         map[string]*v11.Payload `` /* 150-byte string literal not displayed */
	VersionHistories             []byte                  `protobuf:"bytes,58,opt,name=version_histories,json=versionHistories,proto3" json:"version_histories,omitempty"`
	VersionHistoriesEncoding     string                  `` /* 136-byte string literal not displayed */
}

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

func (*WorkflowExecutionInfo) GetAutoResetPointsEncoding

func (m *WorkflowExecutionInfo) GetAutoResetPointsEncoding() string

func (*WorkflowExecutionInfo) GetCancelRequestId

func (m *WorkflowExecutionInfo) GetCancelRequestId() string

func (*WorkflowExecutionInfo) GetCancelRequested

func (m *WorkflowExecutionInfo) GetCancelRequested() bool

func (*WorkflowExecutionInfo) GetClientFeatureVersion

func (m *WorkflowExecutionInfo) GetClientFeatureVersion() string

func (*WorkflowExecutionInfo) GetClientImpl

func (m *WorkflowExecutionInfo) GetClientImpl() string

func (*WorkflowExecutionInfo) GetClientLibraryVersion

func (m *WorkflowExecutionInfo) GetClientLibraryVersion() string

func (*WorkflowExecutionInfo) GetCompletionEvent

func (m *WorkflowExecutionInfo) GetCompletionEvent() []byte

func (*WorkflowExecutionInfo) GetCompletionEventBatchId

func (m *WorkflowExecutionInfo) GetCompletionEventBatchId() int64

func (*WorkflowExecutionInfo) GetCompletionEventEncoding

func (m *WorkflowExecutionInfo) GetCompletionEventEncoding() string

func (*WorkflowExecutionInfo) GetCronSchedule

func (m *WorkflowExecutionInfo) GetCronSchedule() string

func (*WorkflowExecutionInfo) GetCurrentVersion

func (m *WorkflowExecutionInfo) GetCurrentVersion() int64

func (*WorkflowExecutionInfo) GetCurrentWorkflowTaskTimeout

func (m *WorkflowExecutionInfo) GetCurrentWorkflowTaskTimeout() int32

func (*WorkflowExecutionInfo) GetEventBranchToken

func (m *WorkflowExecutionInfo) GetEventBranchToken() []byte

func (*WorkflowExecutionInfo) GetEventStoreVersion

func (m *WorkflowExecutionInfo) GetEventStoreVersion() int32

func (*WorkflowExecutionInfo) GetHasRetryPolicy

func (m *WorkflowExecutionInfo) GetHasRetryPolicy() bool

func (*WorkflowExecutionInfo) GetHistorySize

func (m *WorkflowExecutionInfo) GetHistorySize() int64

func (*WorkflowExecutionInfo) GetInitiatedId

func (m *WorkflowExecutionInfo) GetInitiatedId() int64

func (*WorkflowExecutionInfo) GetLastEventTaskId

func (m *WorkflowExecutionInfo) GetLastEventTaskId() int64

func (*WorkflowExecutionInfo) GetLastFirstEventId

func (m *WorkflowExecutionInfo) GetLastFirstEventId() int64

func (*WorkflowExecutionInfo) GetLastProcessedEvent

func (m *WorkflowExecutionInfo) GetLastProcessedEvent() int64

func (*WorkflowExecutionInfo) GetLastUpdateTimeNanos

func (m *WorkflowExecutionInfo) GetLastUpdateTimeNanos() int64

func (*WorkflowExecutionInfo) GetMemo

func (m *WorkflowExecutionInfo) GetMemo() map[string]*v11.Payload

func (*WorkflowExecutionInfo) GetNamespaceId

func (m *WorkflowExecutionInfo) GetNamespaceId() string

func (*WorkflowExecutionInfo) GetParentNamespaceId

func (m *WorkflowExecutionInfo) GetParentNamespaceId() string

func (*WorkflowExecutionInfo) GetParentRunId

func (m *WorkflowExecutionInfo) GetParentRunId() string

func (*WorkflowExecutionInfo) GetParentWorkflowId

func (m *WorkflowExecutionInfo) GetParentWorkflowId() string

func (*WorkflowExecutionInfo) GetReplicationData

func (m *WorkflowExecutionInfo) GetReplicationData() *ReplicationData

func (*WorkflowExecutionInfo) GetRetryAttempt

func (m *WorkflowExecutionInfo) GetRetryAttempt() int64

func (*WorkflowExecutionInfo) GetRetryBackoffCoefficient

func (m *WorkflowExecutionInfo) GetRetryBackoffCoefficient() float64

func (*WorkflowExecutionInfo) GetRetryExpirationTimeNanos

func (m *WorkflowExecutionInfo) GetRetryExpirationTimeNanos() int64

func (*WorkflowExecutionInfo) GetRetryInitialIntervalSeconds

func (m *WorkflowExecutionInfo) GetRetryInitialIntervalSeconds() int32

func (*WorkflowExecutionInfo) GetRetryMaximumAttempts

func (m *WorkflowExecutionInfo) GetRetryMaximumAttempts() int32

func (*WorkflowExecutionInfo) GetRetryMaximumIntervalSeconds

func (m *WorkflowExecutionInfo) GetRetryMaximumIntervalSeconds() int32

func (*WorkflowExecutionInfo) GetRetryNonRetryableErrorTypes

func (m *WorkflowExecutionInfo) GetRetryNonRetryableErrorTypes() []string

func (*WorkflowExecutionInfo) GetSearchAttributes

func (m *WorkflowExecutionInfo) GetSearchAttributes() map[string]*v11.Payload

func (*WorkflowExecutionInfo) GetSignalCount

func (m *WorkflowExecutionInfo) GetSignalCount() int64

func (*WorkflowExecutionInfo) GetStartTimeNanos

func (m *WorkflowExecutionInfo) GetStartTimeNanos() int64

func (*WorkflowExecutionInfo) GetStartVersion

func (m *WorkflowExecutionInfo) GetStartVersion() int64

func (*WorkflowExecutionInfo) GetStickyScheduleToStartTimeout

func (m *WorkflowExecutionInfo) GetStickyScheduleToStartTimeout() int64

func (*WorkflowExecutionInfo) GetStickyTaskQueue

func (m *WorkflowExecutionInfo) GetStickyTaskQueue() string

func (*WorkflowExecutionInfo) GetTaskQueue

func (m *WorkflowExecutionInfo) GetTaskQueue() string

func (*WorkflowExecutionInfo) GetVersionHistories

func (m *WorkflowExecutionInfo) GetVersionHistories() []byte

func (*WorkflowExecutionInfo) GetVersionHistoriesEncoding

func (m *WorkflowExecutionInfo) GetVersionHistoriesEncoding() string

func (*WorkflowExecutionInfo) GetWorkflowExecutionTimeoutSeconds

func (m *WorkflowExecutionInfo) GetWorkflowExecutionTimeoutSeconds() int32

func (*WorkflowExecutionInfo) GetWorkflowId

func (m *WorkflowExecutionInfo) GetWorkflowId() string

func (*WorkflowExecutionInfo) GetWorkflowRunTimeoutSeconds

func (m *WorkflowExecutionInfo) GetWorkflowRunTimeoutSeconds() int32

func (*WorkflowExecutionInfo) GetWorkflowTaskAttempt

func (m *WorkflowExecutionInfo) GetWorkflowTaskAttempt() int64

func (*WorkflowExecutionInfo) GetWorkflowTaskOriginalScheduledTimestampNanos

func (m *WorkflowExecutionInfo) GetWorkflowTaskOriginalScheduledTimestampNanos() int64

func (*WorkflowExecutionInfo) GetWorkflowTaskRequestId

func (m *WorkflowExecutionInfo) GetWorkflowTaskRequestId() string

func (*WorkflowExecutionInfo) GetWorkflowTaskScheduleId

func (m *WorkflowExecutionInfo) GetWorkflowTaskScheduleId() int64

func (*WorkflowExecutionInfo) GetWorkflowTaskScheduledTimestampNanos

func (m *WorkflowExecutionInfo) GetWorkflowTaskScheduledTimestampNanos() int64

func (*WorkflowExecutionInfo) GetWorkflowTaskStartedId

func (m *WorkflowExecutionInfo) GetWorkflowTaskStartedId() int64

func (*WorkflowExecutionInfo) GetWorkflowTaskStartedTimestampNanos

func (m *WorkflowExecutionInfo) GetWorkflowTaskStartedTimestampNanos() int64

func (*WorkflowExecutionInfo) GetWorkflowTaskTimeoutSeconds

func (m *WorkflowExecutionInfo) GetWorkflowTaskTimeoutSeconds() int32

func (*WorkflowExecutionInfo) GetWorkflowTaskVersion

func (m *WorkflowExecutionInfo) GetWorkflowTaskVersion() int64

func (*WorkflowExecutionInfo) GetWorkflowTypeName

func (m *WorkflowExecutionInfo) GetWorkflowTypeName() string

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

type WorkflowExecutionState

type WorkflowExecutionState struct {
	CreateRequestId string                      `protobuf:"bytes,1,opt,name=create_request_id,json=createRequestId,proto3" json:"create_request_id,omitempty"`
	RunId           string                      `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	State           v12.WorkflowExecutionState  `protobuf:"varint,3,opt,name=state,proto3,enum=temporal.server.api.enums.v1.WorkflowExecutionState" json:"state,omitempty"`
	Status          v14.WorkflowExecutionStatus `protobuf:"varint,4,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkflowExecutionStatus" json:"status,omitempty"`
}

func (*WorkflowExecutionState) Descriptor

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

func (*WorkflowExecutionState) Equal

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

func (*WorkflowExecutionState) GetCreateRequestId

func (m *WorkflowExecutionState) GetCreateRequestId() string

func (*WorkflowExecutionState) GetRunId

func (m *WorkflowExecutionState) GetRunId() string

func (*WorkflowExecutionState) GetState

func (*WorkflowExecutionState) GetStatus

func (*WorkflowExecutionState) GoString

func (this *WorkflowExecutionState) GoString() string

func (*WorkflowExecutionState) Marshal

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

func (*WorkflowExecutionState) MarshalTo

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

func (*WorkflowExecutionState) MarshalToSizedBuffer

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

func (*WorkflowExecutionState) ProtoMessage

func (*WorkflowExecutionState) ProtoMessage()

func (*WorkflowExecutionState) Reset

func (m *WorkflowExecutionState) Reset()

func (*WorkflowExecutionState) Size

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

func (*WorkflowExecutionState) String

func (this *WorkflowExecutionState) String() string

func (*WorkflowExecutionState) Unmarshal

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

func (*WorkflowExecutionState) XXX_DiscardUnknown

func (m *WorkflowExecutionState) XXX_DiscardUnknown()

func (*WorkflowExecutionState) XXX_Marshal

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

func (*WorkflowExecutionState) XXX_Merge

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

func (*WorkflowExecutionState) XXX_Size

func (m *WorkflowExecutionState) XXX_Size() int

func (*WorkflowExecutionState) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
JackTT - Gopher 🇻🇳