persistence

package
v1.9.2 Latest Latest
Warning

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

 Go to latest Published: May 7, 2021 License: MIT Imports: 22 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthClusterMetadata        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowClusterMetadata          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupClusterMetadata = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthExecutions        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExecutions          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupExecutions = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthHistoryTree        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHistoryTree          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupHistoryTree = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthNamespaces        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNamespaces          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupNamespaces = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQueueMetadata        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQueueMetadata          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQueueMetadata = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTasks        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTasks          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTasks = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthWorkflowMutableState        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWorkflowMutableState          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWorkflowMutableState = 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        *v1.HistoryEvent `protobuf:"bytes,3,opt,name=scheduled_event,json=scheduledEvent,proto3" json:"scheduled_event,omitempty"`
	ScheduledTime         *time.Time       `protobuf:"bytes,4,opt,name=scheduled_time,json=scheduledTime,proto3,stdtime" json:"scheduled_time,omitempty"`
	StartedId             int64            `protobuf:"varint,5,opt,name=started_id,json=startedId,proto3" json:"started_id,omitempty"`
	StartedEvent          *v1.HistoryEvent `protobuf:"bytes,6,opt,name=started_event,json=startedEvent,proto3" json:"started_event,omitempty"`
	StartedTime           *time.Time       `protobuf:"bytes,7,opt,name=started_time,json=startedTime,proto3,stdtime" json:"started_time,omitempty"`
	ActivityId            string           `protobuf:"bytes,8,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	RequestId             string           `protobuf:"bytes,9,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. --)
	ScheduleToStartTimeout *time.Duration `` /* 144-byte string literal not displayed */
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToCloseTimeout *time.Duration `` /* 144-byte string literal not displayed */
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "to" is used to indicate interval. --)
	StartToCloseTimeout         *time.Duration `` /* 135-byte string literal not displayed */
	HeartbeatTimeout            *time.Duration `protobuf:"bytes,13,opt,name=heartbeat_timeout,json=heartbeatTimeout,proto3,stdduration" json:"heartbeat_timeout,omitempty"`
	CancelRequested             bool           `protobuf:"varint,14,opt,name=cancel_requested,json=cancelRequested,proto3" json:"cancel_requested,omitempty"`
	CancelRequestId             int64          `protobuf:"varint,15,opt,name=cancel_request_id,json=cancelRequestId,proto3" json:"cancel_request_id,omitempty"`
	TimerTaskStatus             int32          `protobuf:"varint,16,opt,name=timer_task_status,json=timerTaskStatus,proto3" json:"timer_task_status,omitempty"`
	Attempt                     int32          `protobuf:"varint,17,opt,name=attempt,proto3" json:"attempt,omitempty"`
	TaskQueue                   string         `protobuf:"bytes,18,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	StartedIdentity             string         `protobuf:"bytes,19,opt,name=started_identity,json=startedIdentity,proto3" json:"started_identity,omitempty"`
	HasRetryPolicy              bool           `protobuf:"varint,20,opt,name=has_retry_policy,json=hasRetryPolicy,proto3" json:"has_retry_policy,omitempty"`
	RetryInitialInterval        *time.Duration `` /* 136-byte string literal not displayed */
	RetryMaximumInterval        *time.Duration `` /* 136-byte string literal not displayed */
	RetryMaximumAttempts        int32          `protobuf:"varint,23,opt,name=retry_maximum_attempts,json=retryMaximumAttempts,proto3" json:"retry_maximum_attempts,omitempty"`
	RetryExpirationTime         *time.Time     `` /* 129-byte string literal not displayed */
	RetryBackoffCoefficient     float64        `` /* 135-byte string literal not displayed */
	RetryNonRetryableErrorTypes []string       `` /* 149-byte string literal not displayed */
	RetryLastFailure            *v16.Failure   `protobuf:"bytes,27,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,29,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	ScheduleId                  int64          `protobuf:"varint,30,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	LastHeartbeatDetails        *v12.Payloads  `protobuf:"bytes,31,opt,name=last_heartbeat_details,json=lastHeartbeatDetails,proto3" json:"last_heartbeat_details,omitempty"`
	LastHeartbeatUpdateTime     *time.Time     `` /* 143-byte string literal not displayed */
}

activity_map column

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) GetHeartbeatTimeout 

func (m *ActivityInfo) GetHeartbeatTimeout() *time.Duration

func (*ActivityInfo) GetLastHeartbeatDetails 

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

func (*ActivityInfo) GetLastHeartbeatUpdateTime 

func (m *ActivityInfo) GetLastHeartbeatUpdateTime() *time.Time

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) GetRetryExpirationTime 

func (m *ActivityInfo) GetRetryExpirationTime() *time.Time

func (*ActivityInfo) GetRetryInitialInterval 

func (m *ActivityInfo) GetRetryInitialInterval() *time.Duration

func (*ActivityInfo) GetRetryLastFailure 

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

func (*ActivityInfo) GetRetryLastWorkerIdentity 

func (m *ActivityInfo) GetRetryLastWorkerIdentity() string

func (*ActivityInfo) GetRetryMaximumAttempts 

func (m *ActivityInfo) GetRetryMaximumAttempts() int32

func (*ActivityInfo) GetRetryMaximumInterval 

func (m *ActivityInfo) GetRetryMaximumInterval() *time.Duration

func (*ActivityInfo) GetRetryNonRetryableErrorTypes 

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

func (*ActivityInfo) GetScheduleId 

func (m *ActivityInfo) GetScheduleId() int64

func (*ActivityInfo) GetScheduleToCloseTimeout 

func (m *ActivityInfo) GetScheduleToCloseTimeout() *time.Duration

func (*ActivityInfo) GetScheduleToStartTimeout 

func (m *ActivityInfo) GetScheduleToStartTimeout() *time.Duration

func (*ActivityInfo) GetScheduledEvent 

func (m *ActivityInfo) GetScheduledEvent() *v1.HistoryEvent

func (*ActivityInfo) GetScheduledEventBatchId 

func (m *ActivityInfo) GetScheduledEventBatchId() int64

func (*ActivityInfo) GetScheduledTime 

func (m *ActivityInfo) GetScheduledTime() *time.Time

func (*ActivityInfo) GetStartToCloseTimeout 

func (m *ActivityInfo) GetStartToCloseTimeout() *time.Duration

func (*ActivityInfo) GetStartedEvent 

func (m *ActivityInfo) GetStartedEvent() *v1.HistoryEvent

func (*ActivityInfo) GetStartedId 

func (m *ActivityInfo) GetStartedId() int64

func (*ActivityInfo) GetStartedIdentity 

func (m *ActivityInfo) GetStartedIdentity() string

func (*ActivityInfo) GetStartedTime 

func (m *ActivityInfo) GetStartedTime() *time.Time

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,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
}

task column

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  v14.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"`
}

checksum column

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() v14.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        *v1.HistoryEvent      `protobuf:"bytes,4,opt,name=initiated_event,json=initiatedEvent,proto3" json:"initiated_event,omitempty"`
	StartedWorkflowId     string                `protobuf:"bytes,5,opt,name=started_workflow_id,json=startedWorkflowId,proto3" json:"started_workflow_id,omitempty"`
	StartedRunId          string                `protobuf:"bytes,6,opt,name=started_run_id,json=startedRunId,proto3" json:"started_run_id,omitempty"`
	StartedEvent          *v1.HistoryEvent      `protobuf:"bytes,7,opt,name=started_event,json=startedEvent,proto3" json:"started_event,omitempty"`
	CreateRequestId       string                `protobuf:"bytes,8,opt,name=create_request_id,json=createRequestId,proto3" json:"create_request_id,omitempty"`
	Namespace             string                `protobuf:"bytes,9,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowTypeName      string                `protobuf:"bytes,10,opt,name=workflow_type_name,json=workflowTypeName,proto3" json:"workflow_type_name,omitempty"`
	ParentClosePolicy     v15.ParentClosePolicy `` /* 161-byte string literal not displayed */
	InitiatedId           int64                 `protobuf:"varint,12,opt,name=initiated_id,json=initiatedId,proto3" json:"initiated_id,omitempty"`
}

child_executions_map column

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() *v1.HistoryEvent

func (*ChildExecutionInfo) GetInitiatedEventBatchId 

func (m *ChildExecutionInfo) GetInitiatedEventBatchId() int64

func (*ChildExecutionInfo) GetInitiatedId 

func (m *ChildExecutionInfo) GetInitiatedId() int64

func (*ChildExecutionInfo) GetNamespace 

func (m *ChildExecutionInfo) GetNamespace() string

func (*ChildExecutionInfo) GetParentClosePolicy 

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

func (*ChildExecutionInfo) GetStartedEvent 

func (m *ChildExecutionInfo) GetStartedEvent() *v1.HistoryEvent

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 ClusterMetadata 

type ClusterMetadata 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"`
	ClusterId         string          `protobuf:"bytes,3,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	VersionInfo       *v1.VersionInfo `protobuf:"bytes,4,opt,name=version_info,json=versionInfo,proto3" json:"version_info,omitempty"`
}

data column

func (*ClusterMetadata) Descriptor 

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

func (*ClusterMetadata) Equal 

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

func (*ClusterMetadata) GetClusterId 

func (m *ClusterMetadata) GetClusterId() string

func (*ClusterMetadata) GetClusterName 

func (m *ClusterMetadata) GetClusterName() string

func (*ClusterMetadata) GetHistoryShardCount 

func (m *ClusterMetadata) GetHistoryShardCount() int32

func (*ClusterMetadata) GetVersionInfo 

func (m *ClusterMetadata) GetVersionInfo() *v1.VersionInfo

func (*ClusterMetadata) GoString 

func (this *ClusterMetadata) GoString() string

func (*ClusterMetadata) Marshal 

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

func (*ClusterMetadata) MarshalTo 

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

func (*ClusterMetadata) MarshalToSizedBuffer 

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

func (*ClusterMetadata) ProtoMessage 

func (*ClusterMetadata) ProtoMessage()

func (*ClusterMetadata) Reset 

func (m *ClusterMetadata) Reset()

func (*ClusterMetadata) Size 

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

func (*ClusterMetadata) String 

func (this *ClusterMetadata) String() string

func (*ClusterMetadata) Unmarshal 

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

func (*ClusterMetadata) XXX_DiscardUnknown 

func (m *ClusterMetadata) XXX_DiscardUnknown()

func (*ClusterMetadata) XXX_Marshal 

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

func (*ClusterMetadata) XXX_Merge 

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

func (*ClusterMetadata) XXX_Size 

func (m *ClusterMetadata) XXX_Size() int

func (*ClusterMetadata) XXX_Unmarshal 

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

type ExecutionStats 

type ExecutionStats struct {
	HistorySize int64 `protobuf:"varint,1,opt,name=history_size,json=historySize,proto3" json:"history_size,omitempty"`
}

func (*ExecutionStats) Descriptor 

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

func (*ExecutionStats) Equal 

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

func (*ExecutionStats) GetHistorySize 

func (m *ExecutionStats) GetHistorySize() int64

func (*ExecutionStats) GoString 

func (this *ExecutionStats) GoString() string

func (*ExecutionStats) Marshal 

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

func (*ExecutionStats) MarshalTo 

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

func (*ExecutionStats) MarshalToSizedBuffer 

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

func (*ExecutionStats) ProtoMessage 

func (*ExecutionStats) ProtoMessage()

func (*ExecutionStats) Reset 

func (m *ExecutionStats) Reset()

func (*ExecutionStats) Size 

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

func (*ExecutionStats) String 

func (this *ExecutionStats) String() string

func (*ExecutionStats) Unmarshal 

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

func (*ExecutionStats) XXX_DiscardUnknown 

func (m *ExecutionStats) XXX_DiscardUnknown()

func (*ExecutionStats) XXX_Marshal 

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

func (*ExecutionStats) XXX_Merge 

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

func (*ExecutionStats) XXX_Size 

func (m *ExecutionStats) XXX_Size() int

func (*ExecutionStats) XXX_Unmarshal 

func (m *ExecutionStats) 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 *time.Time `protobuf:"bytes,2,opt,name=fork_time,json=forkTime,proto3,stdtime" 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"`
}

branch column

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() *time.Time

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 NamespaceConfig 

type NamespaceConfig struct {
	Retention               *time.Duration   `protobuf:"bytes,1,opt,name=retention,proto3,stdduration" json:"retention,omitempty"`
	ArchivalBucket          string           `protobuf:"bytes,2,opt,name=archival_bucket,json=archivalBucket,proto3" json:"archival_bucket,omitempty"`
	BadBinaries             *v11.BadBinaries `protobuf:"bytes,3,opt,name=bad_binaries,json=badBinaries,proto3" json:"bad_binaries,omitempty"`
	HistoryArchivalState    v1.ArchivalState `` /* 165-byte string literal not displayed */
	HistoryArchivalUri      string           `protobuf:"bytes,5,opt,name=history_archival_uri,json=historyArchivalUri,proto3" json:"history_archival_uri,omitempty"`
	VisibilityArchivalState v1.ArchivalState `` /* 174-byte string literal not displayed */
	VisibilityArchivalUri   string           `` /* 126-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() *v11.BadBinaries

func (*NamespaceConfig) GetHistoryArchivalState 

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

func (*NamespaceConfig) GetHistoryArchivalUri 

func (m *NamespaceConfig) GetHistoryArchivalUri() string

func (*NamespaceConfig) GetRetention 

func (m *NamespaceConfig) GetRetention() *time.Duration

func (*NamespaceConfig) GetVisibilityArchivalState 

func (m *NamespaceConfig) GetVisibilityArchivalState() v1.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,4,opt,name=config_version,json=configVersion,proto3" json:"config_version,omitempty"`
	FailoverNotificationVersion int64                       `` /* 145-byte string literal not displayed */
	FailoverVersion             int64                       `protobuf:"varint,6,opt,name=failover_version,json=failoverVersion,proto3" json:"failover_version,omitempty"`
	FailoverEndTime             *time.Time                  `protobuf:"bytes,7,opt,name=failover_end_time,json=failoverEndTime,proto3,stdtime" json:"failover_end_time,omitempty"`
}

detail column

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() *time.Time

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       v1.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() v1.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 QueueMetadata added in v1.4.0 

type QueueMetadata struct {
	ClusterAckLevels map[string]int64 `` /* 200-byte string literal not displayed */
}

data column

func (*QueueMetadata) Descriptor added in v1.4.0 

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

func (*QueueMetadata) Equal added in v1.4.0 

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

func (*QueueMetadata) GetClusterAckLevels added in v1.4.0 

func (m *QueueMetadata) GetClusterAckLevels() map[string]int64

func (*QueueMetadata) GoString added in v1.4.0 

func (this *QueueMetadata) GoString() string

func (*QueueMetadata) Marshal added in v1.4.0 

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

func (*QueueMetadata) MarshalTo added in v1.4.0 

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

func (*QueueMetadata) MarshalToSizedBuffer added in v1.4.0 

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

func (*QueueMetadata) ProtoMessage added in v1.4.0 

func (*QueueMetadata) ProtoMessage()

func (*QueueMetadata) Reset added in v1.4.0 

func (m *QueueMetadata) Reset()

func (*QueueMetadata) Size added in v1.4.0 

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

func (*QueueMetadata) String added in v1.4.0 

func (this *QueueMetadata) String() string

func (*QueueMetadata) Unmarshal added in v1.4.0 

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

func (*QueueMetadata) XXX_DiscardUnknown added in v1.4.0 

func (m *QueueMetadata) XXX_DiscardUnknown()

func (*QueueMetadata) XXX_Marshal added in v1.4.0 

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

func (*QueueMetadata) XXX_Merge added in v1.4.0 

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

func (*QueueMetadata) XXX_Size added in v1.4.0 

func (m *QueueMetadata) XXX_Size() int

func (*QueueMetadata) XXX_Unmarshal added in v1.4.0 

func (m *QueueMetadata) 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          v14.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"`
	BranchToken       []byte       `protobuf:"bytes,11,opt,name=branch_token,json=branchToken,proto3" json:"branch_token,omitempty"`
	NewRunBranchToken []byte       `protobuf:"bytes,13,opt,name=new_run_branch_token,json=newRunBranchToken,proto3" json:"new_run_branch_token,omitempty"`
	TaskId            int64        `protobuf:"varint,15,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
}

replication column

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) GetFirstEventId 

func (m *ReplicationTaskInfo) GetFirstEventId() int64

func (*ReplicationTaskInfo) GetNamespaceId 

func (m *ReplicationTaskInfo) GetNamespaceId() string

func (*ReplicationTaskInfo) GetNewRunBranchToken 

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

func (*ReplicationTaskInfo) GetNextEventId 

func (m *ReplicationTaskInfo) GetNextEventId() int64

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() v14.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 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"`
}

request_cancel_map column

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                   *time.Time            `protobuf:"bytes,7,opt,name=update_time,json=updateTime,proto3,stdtime" json:"update_time,omitempty"`
	TimerAckLevelTime            *time.Time            `protobuf:"bytes,8,opt,name=timer_ack_level_time,json=timerAckLevelTime,proto3,stdtime" 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]*time.Time `` /* 222-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 */
	VisibilityAckLevel           int64                 `protobuf:"varint,14,opt,name=visibility_ack_level,json=visibilityAckLevel,proto3" json:"visibility_ack_level,omitempty"`
}

shard column

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]*time.Time

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() *time.Time

func (*ShardInfo) GetTransferAckLevel 

func (m *ShardInfo) GetTransferAckLevel() int64

func (*ShardInfo) GetUpdateTime 

func (m *ShardInfo) GetUpdateTime() *time.Time

func (*ShardInfo) GetVisibilityAckLevel added in v1.5.0 

func (m *ShardInfo) GetVisibilityAckLevel() int64

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                 *v12.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"`
}

signal_map column

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() *v12.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  *time.Time `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3,stdtime" json:"create_time,omitempty"`
	ExpiryTime  *time.Time `protobuf:"bytes,6,opt,name=expiry_time,json=expiryTime,proto3,stdtime" 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() *time.Time

func (*TaskInfo) GetExpiryTime 

func (m *TaskInfo) GetExpiryTime() *time.Time

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       v1.TaskQueueType `` /* 127-byte string literal not displayed */
	Kind           v1.TaskQueueKind `protobuf:"varint,4,opt,name=kind,proto3,enum=temporal.api.enums.v1.TaskQueueKind" json:"kind,omitempty"`
	AckLevel       int64            `protobuf:"varint,5,opt,name=ack_level,json=ackLevel,proto3" json:"ack_level,omitempty"`
	ExpiryTime     *time.Time       `protobuf:"bytes,6,opt,name=expiry_time,json=expiryTime,proto3,stdtime" json:"expiry_time,omitempty"`
	LastUpdateTime *time.Time       `protobuf:"bytes,7,opt,name=last_update_time,json=lastUpdateTime,proto3,stdtime" json:"last_update_time,omitempty"`
}

task_queue column

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() *time.Time

func (*TaskQueueInfo) GetKind 

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

func (*TaskQueueInfo) GetLastUpdateTime 

func (m *TaskQueueInfo) GetLastUpdateTime() *time.Time

func (*TaskQueueInfo) GetName 

func (m *TaskQueueInfo) GetName() string

func (*TaskQueueInfo) GetNamespaceId 

func (m *TaskQueueInfo) GetNamespaceId() string

func (*TaskQueueInfo) GetTaskType 

func (m *TaskQueueInfo) GetTaskType() v1.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 *time.Time `protobuf:"bytes,3,opt,name=expiry_time,json=expiryTime,proto3,stdtime" 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"`
}

timer_map column

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() *time.Time

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            v14.TaskType            `` /* 129-byte string literal not displayed */
	TimeoutType         v15.TimeoutType         `` /* 134-byte string literal not displayed */
	WorkflowBackoffType v14.WorkflowBackoffType `` /* 175-byte string literal not displayed */
	Version             int64                   `protobuf:"varint,7,opt,name=version,proto3" json:"version,omitempty"`
	ScheduleAttempt     int32                   `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      *time.Time              `protobuf:"bytes,11,opt,name=visibility_time,json=visibilityTime,proto3,stdtime" json:"visibility_time,omitempty"`
}

timer column

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() int32

func (*TimerTaskInfo) GetTaskId 

func (m *TimerTaskInfo) GetTaskId() int64

func (*TimerTaskInfo) GetTaskType 

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

func (*TimerTaskInfo) GetTimeoutType 

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

func (*TimerTaskInfo) GetVersion 

func (m *TimerTaskInfo) GetVersion() int64

func (*TimerTaskInfo) GetVisibilityTime 

func (m *TimerTaskInfo) GetVisibilityTime() *time.Time

func (*TimerTaskInfo) GetWorkflowBackoffType 

func (m *TimerTaskInfo) GetWorkflowBackoffType() v14.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                v14.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          *time.Time   `protobuf:"bytes,13,opt,name=visibility_time,json=visibilityTime,proto3,stdtime" json:"visibility_time,omitempty"`
}

transfer column

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) 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() v14.TaskType

func (*TransferTaskInfo) GetVersion 

func (m *TransferTaskInfo) GetVersion() int64

func (*TransferTaskInfo) GetVisibilityTime 

func (m *TransferTaskInfo) GetVisibilityTime() *time.Time

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 VisibilityTaskInfo added in v1.5.0 

type VisibilityTaskInfo 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       v14.TaskType `` /* 129-byte string literal not displayed */
	Version        int64        `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	TaskId         int64        `protobuf:"varint,6,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	VisibilityTime *time.Time   `protobuf:"bytes,7,opt,name=visibility_time,json=visibilityTime,proto3,stdtime" json:"visibility_time,omitempty"`
}

visibility_task_data column

func (*VisibilityTaskInfo) Descriptor added in v1.5.0 

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

func (*VisibilityTaskInfo) Equal added in v1.5.0 

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

func (*VisibilityTaskInfo) GetNamespaceId added in v1.5.0 

func (m *VisibilityTaskInfo) GetNamespaceId() string

func (*VisibilityTaskInfo) GetRunId added in v1.5.0 

func (m *VisibilityTaskInfo) GetRunId() string

func (*VisibilityTaskInfo) GetTaskId added in v1.5.0 

func (m *VisibilityTaskInfo) GetTaskId() int64

func (*VisibilityTaskInfo) GetTaskType added in v1.5.0 

func (m *VisibilityTaskInfo) GetTaskType() v14.TaskType

func (*VisibilityTaskInfo) GetVersion added in v1.5.0 

func (m *VisibilityTaskInfo) GetVersion() int64

func (*VisibilityTaskInfo) GetVisibilityTime added in v1.5.0 

func (m *VisibilityTaskInfo) GetVisibilityTime() *time.Time

func (*VisibilityTaskInfo) GetWorkflowId added in v1.5.0 

func (m *VisibilityTaskInfo) GetWorkflowId() string

func (*VisibilityTaskInfo) GoString added in v1.5.0 

func (this *VisibilityTaskInfo) GoString() string

func (*VisibilityTaskInfo) Marshal added in v1.5.0 

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

func (*VisibilityTaskInfo) MarshalTo added in v1.5.0 

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

func (*VisibilityTaskInfo) MarshalToSizedBuffer added in v1.5.0 

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

func (*VisibilityTaskInfo) ProtoMessage added in v1.5.0 

func (*VisibilityTaskInfo) ProtoMessage()

func (*VisibilityTaskInfo) Reset added in v1.5.0 

func (m *VisibilityTaskInfo) Reset()

func (*VisibilityTaskInfo) Size added in v1.5.0 

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

func (*VisibilityTaskInfo) String added in v1.5.0 

func (this *VisibilityTaskInfo) String() string

func (*VisibilityTaskInfo) Unmarshal added in v1.5.0 

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

func (*VisibilityTaskInfo) XXX_DiscardUnknown added in v1.5.0 

func (m *VisibilityTaskInfo) XXX_DiscardUnknown()

func (*VisibilityTaskInfo) XXX_Marshal added in v1.5.0 

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

func (*VisibilityTaskInfo) XXX_Merge added in v1.5.0 

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

func (*VisibilityTaskInfo) XXX_Size added in v1.5.0 

func (m *VisibilityTaskInfo) XXX_Size() int

func (*VisibilityTaskInfo) XXX_Unmarshal added in v1.5.0 

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

type WorkflowExecutionInfo 

type WorkflowExecutionInfo 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"`
	ParentNamespaceId                 string           `protobuf:"bytes,3,opt,name=parent_namespace_id,json=parentNamespaceId,proto3" json:"parent_namespace_id,omitempty"`
	ParentWorkflowId                  string           `protobuf:"bytes,4,opt,name=parent_workflow_id,json=parentWorkflowId,proto3" json:"parent_workflow_id,omitempty"`
	ParentRunId                       string           `protobuf:"bytes,5,opt,name=parent_run_id,json=parentRunId,proto3" json:"parent_run_id,omitempty"`
	InitiatedId                       int64            `protobuf:"varint,6,opt,name=initiated_id,json=initiatedId,proto3" json:"initiated_id,omitempty"`
	CompletionEventBatchId            int64            `` /* 132-byte string literal not displayed */
	CompletionEvent                   *v1.HistoryEvent `protobuf:"bytes,8,opt,name=completion_event,json=completionEvent,proto3" json:"completion_event,omitempty"`
	TaskQueue                         string           `protobuf:"bytes,9,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	WorkflowTypeName                  string           `protobuf:"bytes,10,opt,name=workflow_type_name,json=workflowTypeName,proto3" json:"workflow_type_name,omitempty"`
	WorkflowExecutionTimeout          *time.Duration   `` /* 148-byte string literal not displayed */
	WorkflowRunTimeout                *time.Duration   `` /* 130-byte string literal not displayed */
	DefaultWorkflowTaskTimeout        *time.Duration   `` /* 156-byte string literal not displayed */
	StartVersion                      int64            `protobuf:"varint,14,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
	LastEventTaskId                   int64            `protobuf:"varint,17,opt,name=last_event_task_id,json=lastEventTaskId,proto3" json:"last_event_task_id,omitempty"`
	LastFirstEventId                  int64            `protobuf:"varint,18,opt,name=last_first_event_id,json=lastFirstEventId,proto3" json:"last_first_event_id,omitempty"`
	LastProcessedEvent                int64            `protobuf:"varint,19,opt,name=last_processed_event,json=lastProcessedEvent,proto3" json:"last_processed_event,omitempty"`
	StartTime                         *time.Time       `protobuf:"bytes,20,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time,omitempty"`
	LastUpdateTime                    *time.Time       `protobuf:"bytes,21,opt,name=last_update_time,json=lastUpdateTime,proto3,stdtime" json:"last_update_time,omitempty"`
	WorkflowTaskVersion               int64            `protobuf:"varint,22,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 */
	WorkflowTaskTimeout               *time.Duration   `` /* 133-byte string literal not displayed */
	WorkflowTaskAttempt               int32            `protobuf:"varint,26,opt,name=workflow_task_attempt,json=workflowTaskAttempt,proto3" json:"workflow_task_attempt,omitempty"`
	WorkflowTaskStartedTime           *time.Time       `` /* 143-byte string literal not displayed */
	WorkflowTaskScheduledTime         *time.Time       `` /* 149-byte string literal not displayed */
	CancelRequested                   bool             `protobuf:"varint,29,opt,name=cancel_requested,json=cancelRequested,proto3" json:"cancel_requested,omitempty"`
	WorkflowTaskOriginalScheduledTime *time.Time       `` /* 175-byte string literal not displayed */
	WorkflowTaskRequestId             string           `` /* 129-byte string literal not displayed */
	CancelRequestId                   string           `protobuf:"bytes,32,opt,name=cancel_request_id,json=cancelRequestId,proto3" json:"cancel_request_id,omitempty"`
	StickyTaskQueue                   string           `protobuf:"bytes,33,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    *time.Duration          `` /* 164-byte string literal not displayed */
	Attempt                         int32                   `protobuf:"varint,35,opt,name=attempt,proto3" json:"attempt,omitempty"`
	RetryInitialInterval            *time.Duration          `` /* 136-byte string literal not displayed */
	RetryMaximumInterval            *time.Duration          `` /* 136-byte string literal not displayed */
	RetryMaximumAttempts            int32                   `protobuf:"varint,38,opt,name=retry_maximum_attempts,json=retryMaximumAttempts,proto3" json:"retry_maximum_attempts,omitempty"`
	RetryBackoffCoefficient         float64                 `` /* 135-byte string literal not displayed */
	WorkflowExecutionExpirationTime *time.Time              `` /* 167-byte string literal not displayed */
	RetryNonRetryableErrorTypes     []string                `` /* 149-byte string literal not displayed */
	HasRetryPolicy                  bool                    `protobuf:"varint,42,opt,name=has_retry_policy,json=hasRetryPolicy,proto3" json:"has_retry_policy,omitempty"`
	CronSchedule                    string                  `protobuf:"bytes,43,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"`
	SignalCount                     int64                   `protobuf:"varint,46,opt,name=signal_count,json=signalCount,proto3" json:"signal_count,omitempty"`
	HistorySize                     int64                   `protobuf:"varint,47,opt,name=history_size,json=historySize,proto3" json:"history_size,omitempty"` // Deprecated: Do not use.
	AutoResetPoints                 *v11.ResetPoints        `protobuf:"bytes,51,opt,name=auto_reset_points,json=autoResetPoints,proto3" json:"auto_reset_points,omitempty"`
	SearchAttributes                map[string]*v12.Payload `` /* 198-byte string literal not displayed */
	Memo                            map[string]*v12.Payload `` /* 150-byte string literal not displayed */
	VersionHistories                *v13.VersionHistories   `protobuf:"bytes,54,opt,name=version_histories,json=versionHistories,proto3" json:"version_histories,omitempty"`
	FirstExecutionRunId             string                  `protobuf:"bytes,55,opt,name=first_execution_run_id,json=firstExecutionRunId,proto3" json:"first_execution_run_id,omitempty"`
	ExecutionStats                  *ExecutionStats         `protobuf:"bytes,56,opt,name=execution_stats,json=executionStats,proto3" json:"execution_stats,omitempty"`
	WorkflowRunExpirationTime       *time.Time              `` /* 149-byte string literal not displayed */
	// Transaction Id of the first event in the last batch of events.
	LastFirstEventTxnId int64 `` /* 126-byte string literal not displayed */
}

execution column

func (*WorkflowExecutionInfo) Descriptor 

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

func (*WorkflowExecutionInfo) Equal 

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

func (*WorkflowExecutionInfo) GetAttempt 

func (m *WorkflowExecutionInfo) GetAttempt() int32

func (*WorkflowExecutionInfo) GetAutoResetPoints 

func (m *WorkflowExecutionInfo) GetAutoResetPoints() *v11.ResetPoints

func (*WorkflowExecutionInfo) GetCancelRequestId 

func (m *WorkflowExecutionInfo) GetCancelRequestId() string

func (*WorkflowExecutionInfo) GetCancelRequested 

func (m *WorkflowExecutionInfo) GetCancelRequested() bool

func (*WorkflowExecutionInfo) GetCompletionEvent 

func (m *WorkflowExecutionInfo) GetCompletionEvent() *v1.HistoryEvent

func (*WorkflowExecutionInfo) GetCompletionEventBatchId 

func (m *WorkflowExecutionInfo) GetCompletionEventBatchId() int64

func (*WorkflowExecutionInfo) GetCronSchedule 

func (m *WorkflowExecutionInfo) GetCronSchedule() string

func (*WorkflowExecutionInfo) GetDefaultWorkflowTaskTimeout 

func (m *WorkflowExecutionInfo) GetDefaultWorkflowTaskTimeout() *time.Duration

func (*WorkflowExecutionInfo) GetExecutionStats 

func (m *WorkflowExecutionInfo) GetExecutionStats() *ExecutionStats

func (*WorkflowExecutionInfo) GetFirstExecutionRunId 

func (m *WorkflowExecutionInfo) GetFirstExecutionRunId() string

func (*WorkflowExecutionInfo) GetHasRetryPolicy 

func (m *WorkflowExecutionInfo) GetHasRetryPolicy() bool

func (*WorkflowExecutionInfo) GetHistorySize deprecated 

func (m *WorkflowExecutionInfo) GetHistorySize() int64

Deprecated: Do not use.

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) GetLastFirstEventTxnId added in v1.9.0 

func (m *WorkflowExecutionInfo) GetLastFirstEventTxnId() int64

func (*WorkflowExecutionInfo) GetLastProcessedEvent 

func (m *WorkflowExecutionInfo) GetLastProcessedEvent() int64

func (*WorkflowExecutionInfo) GetLastUpdateTime 

func (m *WorkflowExecutionInfo) GetLastUpdateTime() *time.Time

func (*WorkflowExecutionInfo) GetMemo 

func (m *WorkflowExecutionInfo) GetMemo() map[string]*v12.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) GetRetryBackoffCoefficient 

func (m *WorkflowExecutionInfo) GetRetryBackoffCoefficient() float64

func (*WorkflowExecutionInfo) GetRetryInitialInterval 

func (m *WorkflowExecutionInfo) GetRetryInitialInterval() *time.Duration

func (*WorkflowExecutionInfo) GetRetryMaximumAttempts 

func (m *WorkflowExecutionInfo) GetRetryMaximumAttempts() int32

func (*WorkflowExecutionInfo) GetRetryMaximumInterval 

func (m *WorkflowExecutionInfo) GetRetryMaximumInterval() *time.Duration

func (*WorkflowExecutionInfo) GetRetryNonRetryableErrorTypes 

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

func (*WorkflowExecutionInfo) GetSearchAttributes 

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

func (*WorkflowExecutionInfo) GetSignalCount 

func (m *WorkflowExecutionInfo) GetSignalCount() int64

func (*WorkflowExecutionInfo) GetStartTime 

func (m *WorkflowExecutionInfo) GetStartTime() *time.Time

func (*WorkflowExecutionInfo) GetStartVersion 

func (m *WorkflowExecutionInfo) GetStartVersion() int64

func (*WorkflowExecutionInfo) GetStickyScheduleToStartTimeout 

func (m *WorkflowExecutionInfo) GetStickyScheduleToStartTimeout() *time.Duration

func (*WorkflowExecutionInfo) GetStickyTaskQueue 

func (m *WorkflowExecutionInfo) GetStickyTaskQueue() string

func (*WorkflowExecutionInfo) GetTaskQueue 

func (m *WorkflowExecutionInfo) GetTaskQueue() string

func (*WorkflowExecutionInfo) GetVersionHistories 

func (m *WorkflowExecutionInfo) GetVersionHistories() *v13.VersionHistories

func (*WorkflowExecutionInfo) GetWorkflowExecutionExpirationTime added in v1.4.0 

func (m *WorkflowExecutionInfo) GetWorkflowExecutionExpirationTime() *time.Time

func (*WorkflowExecutionInfo) GetWorkflowExecutionTimeout 

func (m *WorkflowExecutionInfo) GetWorkflowExecutionTimeout() *time.Duration

func (*WorkflowExecutionInfo) GetWorkflowId 

func (m *WorkflowExecutionInfo) GetWorkflowId() string

func (*WorkflowExecutionInfo) GetWorkflowRunExpirationTime added in v1.4.0 

func (m *WorkflowExecutionInfo) GetWorkflowRunExpirationTime() *time.Time

func (*WorkflowExecutionInfo) GetWorkflowRunTimeout 

func (m *WorkflowExecutionInfo) GetWorkflowRunTimeout() *time.Duration

func (*WorkflowExecutionInfo) GetWorkflowTaskAttempt 

func (m *WorkflowExecutionInfo) GetWorkflowTaskAttempt() int32

func (*WorkflowExecutionInfo) GetWorkflowTaskOriginalScheduledTime 

func (m *WorkflowExecutionInfo) GetWorkflowTaskOriginalScheduledTime() *time.Time

func (*WorkflowExecutionInfo) GetWorkflowTaskRequestId 

func (m *WorkflowExecutionInfo) GetWorkflowTaskRequestId() string

func (*WorkflowExecutionInfo) GetWorkflowTaskScheduleId 

func (m *WorkflowExecutionInfo) GetWorkflowTaskScheduleId() int64

func (*WorkflowExecutionInfo) GetWorkflowTaskScheduledTime 

func (m *WorkflowExecutionInfo) GetWorkflowTaskScheduledTime() *time.Time

func (*WorkflowExecutionInfo) GetWorkflowTaskStartedId 

func (m *WorkflowExecutionInfo) GetWorkflowTaskStartedId() int64

func (*WorkflowExecutionInfo) GetWorkflowTaskStartedTime 

func (m *WorkflowExecutionInfo) GetWorkflowTaskStartedTime() *time.Time

func (*WorkflowExecutionInfo) GetWorkflowTaskTimeout 

func (m *WorkflowExecutionInfo) GetWorkflowTaskTimeout() *time.Duration

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           v14.WorkflowExecutionState  `protobuf:"varint,3,opt,name=state,proto3,enum=temporal.server.api.enums.v1.WorkflowExecutionState" json:"state,omitempty"`
	Status          v15.WorkflowExecutionStatus `protobuf:"varint,4,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkflowExecutionStatus" json:"status,omitempty"`
}

execution_state column

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 (m *WorkflowExecutionState) GetState() v14.WorkflowExecutionState

func (*WorkflowExecutionState) GetStatus 

func (m *WorkflowExecutionState) GetStatus() v15.WorkflowExecutionStatus

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

type WorkflowMutableState 

type WorkflowMutableState struct {
	ActivityInfos       map[int64]*ActivityInfo       `` /* 189-byte string literal not displayed */
	TimerInfos          map[string]*TimerInfo         `` /* 179-byte string literal not displayed */
	ChildExecutionInfos map[int64]*ChildExecutionInfo `` /* 209-byte string literal not displayed */
	RequestCancelInfos  map[int64]*RequestCancelInfo  `` /* 206-byte string literal not displayed */
	SignalInfos         map[int64]*SignalInfo         `` /* 183-byte string literal not displayed */
	SignalRequestedIds  []string                      `protobuf:"bytes,6,rep,name=signal_requested_ids,json=signalRequestedIds,proto3" json:"signal_requested_ids,omitempty"`
	ExecutionInfo       *WorkflowExecutionInfo        `protobuf:"bytes,7,opt,name=execution_info,json=executionInfo,proto3" json:"execution_info,omitempty"`
	ExecutionState      *WorkflowExecutionState       `protobuf:"bytes,8,opt,name=execution_state,json=executionState,proto3" json:"execution_state,omitempty"`
	NextEventId         int64                         `protobuf:"varint,9,opt,name=next_event_id,json=nextEventId,proto3" json:"next_event_id,omitempty"`
	BufferedEvents      []*v1.HistoryEvent            `protobuf:"bytes,10,rep,name=buffered_events,json=bufferedEvents,proto3" json:"buffered_events,omitempty"`
	Checksum            *Checksum                     `protobuf:"bytes,11,opt,name=checksum,proto3" json:"checksum,omitempty"`
}

func (*WorkflowMutableState) Descriptor 

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

func (*WorkflowMutableState) Equal 

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

func (*WorkflowMutableState) GetActivityInfos 

func (m *WorkflowMutableState) GetActivityInfos() map[int64]*ActivityInfo

func (*WorkflowMutableState) GetBufferedEvents 

func (m *WorkflowMutableState) GetBufferedEvents() []*v1.HistoryEvent

func (*WorkflowMutableState) GetChecksum 

func (m *WorkflowMutableState) GetChecksum() *Checksum

func (*WorkflowMutableState) GetChildExecutionInfos 

func (m *WorkflowMutableState) GetChildExecutionInfos() map[int64]*ChildExecutionInfo

func (*WorkflowMutableState) GetExecutionInfo 

func (m *WorkflowMutableState) GetExecutionInfo() *WorkflowExecutionInfo

func (*WorkflowMutableState) GetExecutionState 

func (m *WorkflowMutableState) GetExecutionState() *WorkflowExecutionState

func (*WorkflowMutableState) GetNextEventId 

func (m *WorkflowMutableState) GetNextEventId() int64

func (*WorkflowMutableState) GetRequestCancelInfos 

func (m *WorkflowMutableState) GetRequestCancelInfos() map[int64]*RequestCancelInfo

func (*WorkflowMutableState) GetSignalInfos 

func (m *WorkflowMutableState) GetSignalInfos() map[int64]*SignalInfo

func (*WorkflowMutableState) GetSignalRequestedIds 

func (m *WorkflowMutableState) GetSignalRequestedIds() []string

func (*WorkflowMutableState) GetTimerInfos 

func (m *WorkflowMutableState) GetTimerInfos() map[string]*TimerInfo

func (*WorkflowMutableState) GoString 

func (this *WorkflowMutableState) GoString() string

func (*WorkflowMutableState) Marshal 

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

func (*WorkflowMutableState) MarshalTo 

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

func (*WorkflowMutableState) MarshalToSizedBuffer 

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

func (*WorkflowMutableState) ProtoMessage 

func (*WorkflowMutableState) ProtoMessage()

func (*WorkflowMutableState) Reset 

func (m *WorkflowMutableState) Reset()

func (*WorkflowMutableState) Size 

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

func (*WorkflowMutableState) String 

func (this *WorkflowMutableState) String() string

func (*WorkflowMutableState) Unmarshal 

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

func (*WorkflowMutableState) XXX_DiscardUnknown 

func (m *WorkflowMutableState) XXX_DiscardUnknown()

func (*WorkflowMutableState) XXX_Marshal 

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

func (*WorkflowMutableState) XXX_Merge 

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

func (*WorkflowMutableState) XXX_Size 

func (m *WorkflowMutableState) XXX_Size() int

func (*WorkflowMutableState) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.