persistence

package
v1.17.3 Latest Latest
Warning

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

 Go to latest Published: Aug 17, 2022 License: MIT Imports: 24 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 (
	ErrInvalidLengthPredicates        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPredicates          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPredicates = 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 (
	ErrInvalidLengthQueues        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQueues          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQueues = 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 */
	ScheduledTime         *time.Time `protobuf:"bytes,4,opt,name=scheduled_time,json=scheduledTime,proto3,stdtime" json:"scheduled_time,omitempty"`
	StartedEventId        int64      `protobuf:"varint,5,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,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 */
	// TODO: remove this after 1.17 release.
	NamespaceId             string        `protobuf:"bytes,29,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	ScheduledEventId        int64         `protobuf:"varint,30,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
	LastHeartbeatDetails    *v11.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() *v11.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) GetScheduleToCloseTimeout 

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

func (*ActivityInfo) GetScheduleToStartTimeout 

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

func (*ActivityInfo) GetScheduledEventBatchId 

func (m *ActivityInfo) GetScheduledEventBatchId() int64

func (*ActivityInfo) GetScheduledEventId added in v1.17.0 

func (m *ActivityInfo) GetScheduledEventId() int64

func (*ActivityInfo) GetScheduledTime 

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

func (*ActivityInfo) GetStartToCloseTimeout 

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

func (*ActivityInfo) GetStartedEventId added in v1.17.0 

func (m *ActivityInfo) GetStartedEventId() 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 AndPredicateAttributes added in v1.17.3 

type AndPredicateAttributes struct {
	Predicates []*Predicate `protobuf:"bytes,1,rep,name=predicates,proto3" json:"predicates,omitempty"`
}

func (*AndPredicateAttributes) Descriptor added in v1.17.3 

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

func (*AndPredicateAttributes) Equal added in v1.17.3 

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

func (*AndPredicateAttributes) GetPredicates added in v1.17.3 

func (m *AndPredicateAttributes) GetPredicates() []*Predicate

func (*AndPredicateAttributes) GoString added in v1.17.3 

func (this *AndPredicateAttributes) GoString() string

func (*AndPredicateAttributes) Marshal added in v1.17.3 

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

func (*AndPredicateAttributes) MarshalTo added in v1.17.3 

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

func (*AndPredicateAttributes) MarshalToSizedBuffer added in v1.17.3 

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

func (*AndPredicateAttributes) ProtoMessage added in v1.17.3 

func (*AndPredicateAttributes) ProtoMessage()

func (*AndPredicateAttributes) Reset added in v1.17.3 

func (m *AndPredicateAttributes) Reset()

func (*AndPredicateAttributes) Size added in v1.17.3 

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

func (*AndPredicateAttributes) String added in v1.17.3 

func (this *AndPredicateAttributes) String() string

func (*AndPredicateAttributes) Unmarshal added in v1.17.3 

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

func (*AndPredicateAttributes) XXX_DiscardUnknown added in v1.17.3 

func (m *AndPredicateAttributes) XXX_DiscardUnknown()

func (*AndPredicateAttributes) XXX_Marshal added in v1.17.3 

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

func (*AndPredicateAttributes) XXX_Merge added in v1.17.3 

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

func (*AndPredicateAttributes) XXX_Size added in v1.17.3 

func (m *AndPredicateAttributes) XXX_Size() int

func (*AndPredicateAttributes) XXX_Unmarshal added in v1.17.3 

func (m *AndPredicateAttributes) 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 */
	StartedEventId        int64                 `protobuf:"varint,3,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,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"`
	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 */
	InitiatedEventId      int64                 `protobuf:"varint,12,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"`
	Clock                 *v13.VectorClock      `protobuf:"bytes,13,opt,name=clock,proto3" json:"clock,omitempty"`
	NamespaceId           string                `protobuf:"bytes,14,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_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) GetClock added in v1.17.0 

func (m *ChildExecutionInfo) GetClock() *v13.VectorClock

func (*ChildExecutionInfo) GetCreateRequestId 

func (m *ChildExecutionInfo) GetCreateRequestId() string

func (*ChildExecutionInfo) GetInitiatedEventBatchId 

func (m *ChildExecutionInfo) GetInitiatedEventBatchId() int64

func (*ChildExecutionInfo) GetInitiatedEventId added in v1.17.0 

func (m *ChildExecutionInfo) GetInitiatedEventId() int64

func (*ChildExecutionInfo) GetNamespace 

func (m *ChildExecutionInfo) GetNamespace() string

func (*ChildExecutionInfo) GetNamespaceId added in v1.17.0 

func (m *ChildExecutionInfo) GetNamespaceId() string

func (*ChildExecutionInfo) GetParentClosePolicy 

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

func (*ChildExecutionInfo) GetStartedEventId added in v1.17.0 

func (m *ChildExecutionInfo) GetStartedEventId() 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"`
	IndexSearchAttributes    map[string]*IndexSearchAttributes `` /* 214-byte string literal not displayed */
	ClusterAddress           string                            `protobuf:"bytes,6,opt,name=cluster_address,json=clusterAddress,proto3" json:"cluster_address,omitempty"`
	FailoverVersionIncrement int64                             `` /* 136-byte string literal not displayed */
	InitialFailoverVersion   int64                             `` /* 130-byte string literal not displayed */
	IsGlobalNamespaceEnabled bool                              `` /* 138-byte string literal not displayed */
	IsConnectionEnabled      bool                              `protobuf:"varint,10,opt,name=is_connection_enabled,json=isConnectionEnabled,proto3" json:"is_connection_enabled,omitempty"`
}

data column

func (*ClusterMetadata) Descriptor 

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

func (*ClusterMetadata) Equal 

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

func (*ClusterMetadata) GetClusterAddress added in v1.14.0 

func (m *ClusterMetadata) GetClusterAddress() string

func (*ClusterMetadata) GetClusterId 

func (m *ClusterMetadata) GetClusterId() string

func (*ClusterMetadata) GetClusterName 

func (m *ClusterMetadata) GetClusterName() string

func (*ClusterMetadata) GetFailoverVersionIncrement added in v1.14.0 

func (m *ClusterMetadata) GetFailoverVersionIncrement() int64

func (*ClusterMetadata) GetHistoryShardCount 

func (m *ClusterMetadata) GetHistoryShardCount() int32

func (*ClusterMetadata) GetIndexSearchAttributes added in v1.10.0 

func (m *ClusterMetadata) GetIndexSearchAttributes() map[string]*IndexSearchAttributes

func (*ClusterMetadata) GetInitialFailoverVersion added in v1.14.0 

func (m *ClusterMetadata) GetInitialFailoverVersion() int64

func (*ClusterMetadata) GetIsConnectionEnabled added in v1.14.0 

func (m *ClusterMetadata) GetIsConnectionEnabled() bool

func (*ClusterMetadata) GetIsGlobalNamespaceEnabled added in v1.14.0 

func (m *ClusterMetadata) GetIsGlobalNamespaceEnabled() bool

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 EmptyPredicateAttributes added in v1.17.3 

type EmptyPredicateAttributes struct {
}

func (*EmptyPredicateAttributes) Descriptor added in v1.17.3 

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

func (*EmptyPredicateAttributes) Equal added in v1.17.3 

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

func (*EmptyPredicateAttributes) GoString added in v1.17.3 

func (this *EmptyPredicateAttributes) GoString() string

func (*EmptyPredicateAttributes) Marshal added in v1.17.3 

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

func (*EmptyPredicateAttributes) MarshalTo added in v1.17.3 

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

func (*EmptyPredicateAttributes) MarshalToSizedBuffer added in v1.17.3 

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

func (*EmptyPredicateAttributes) ProtoMessage added in v1.17.3 

func (*EmptyPredicateAttributes) ProtoMessage()

func (*EmptyPredicateAttributes) Reset added in v1.17.3 

func (m *EmptyPredicateAttributes) Reset()

func (*EmptyPredicateAttributes) Size added in v1.17.3 

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

func (*EmptyPredicateAttributes) String added in v1.17.3 

func (this *EmptyPredicateAttributes) String() string

func (*EmptyPredicateAttributes) Unmarshal added in v1.17.3 

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

func (*EmptyPredicateAttributes) XXX_DiscardUnknown added in v1.17.3 

func (m *EmptyPredicateAttributes) XXX_DiscardUnknown()

func (*EmptyPredicateAttributes) XXX_Marshal added in v1.17.3 

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

func (*EmptyPredicateAttributes) XXX_Merge added in v1.17.3 

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

func (*EmptyPredicateAttributes) XXX_Size added in v1.17.3 

func (m *EmptyPredicateAttributes) XXX_Size() int

func (*EmptyPredicateAttributes) XXX_Unmarshal added in v1.17.3 

func (m *EmptyPredicateAttributes) 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 FailoverStatus added in v1.17.3 

type FailoverStatus struct {
	FailoverTime    *time.Time `protobuf:"bytes,1,opt,name=failover_time,json=failoverTime,proto3,stdtime" json:"failover_time,omitempty"`
	FailoverVersion int64      `protobuf:"varint,2,opt,name=failover_version,json=failoverVersion,proto3" json:"failover_version,omitempty"`
}

Represents a historical replication status of a Namespace

func (*FailoverStatus) Descriptor added in v1.17.3 

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

func (*FailoverStatus) Equal added in v1.17.3 

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

func (*FailoverStatus) GetFailoverTime added in v1.17.3 

func (m *FailoverStatus) GetFailoverTime() *time.Time

func (*FailoverStatus) GetFailoverVersion added in v1.17.3 

func (m *FailoverStatus) GetFailoverVersion() int64

func (*FailoverStatus) GoString added in v1.17.3 

func (this *FailoverStatus) GoString() string

func (*FailoverStatus) Marshal added in v1.17.3 

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

func (*FailoverStatus) MarshalTo added in v1.17.3 

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

func (*FailoverStatus) MarshalToSizedBuffer added in v1.17.3 

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

func (*FailoverStatus) ProtoMessage added in v1.17.3 

func (*FailoverStatus) ProtoMessage()

func (*FailoverStatus) Reset added in v1.17.3 

func (m *FailoverStatus) Reset()

func (*FailoverStatus) Size added in v1.17.3 

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

func (*FailoverStatus) String added in v1.17.3 

func (this *FailoverStatus) String() string

func (*FailoverStatus) Unmarshal added in v1.17.3 

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

func (*FailoverStatus) XXX_DiscardUnknown added in v1.17.3 

func (m *FailoverStatus) XXX_DiscardUnknown()

func (*FailoverStatus) XXX_Marshal added in v1.17.3 

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

func (*FailoverStatus) XXX_Merge added in v1.17.3 

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

func (*FailoverStatus) XXX_Size added in v1.17.3 

func (m *FailoverStatus) XXX_Size() int

func (*FailoverStatus) XXX_Unmarshal added in v1.17.3 

func (m *FailoverStatus) 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 IndexSearchAttributes added in v1.10.0 

type IndexSearchAttributes struct {
	CustomSearchAttributes map[string]v11.IndexedValueType `` /* 262-byte string literal not displayed */
}

func (*IndexSearchAttributes) Descriptor added in v1.10.0 

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

func (*IndexSearchAttributes) Equal added in v1.10.0 

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

func (*IndexSearchAttributes) GetCustomSearchAttributes added in v1.10.0 

func (m *IndexSearchAttributes) GetCustomSearchAttributes() map[string]v11.IndexedValueType

func (*IndexSearchAttributes) GoString added in v1.10.0 

func (this *IndexSearchAttributes) GoString() string

func (*IndexSearchAttributes) Marshal added in v1.10.0 

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

func (*IndexSearchAttributes) MarshalTo added in v1.10.0 

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

func (*IndexSearchAttributes) MarshalToSizedBuffer added in v1.10.0 

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

func (*IndexSearchAttributes) ProtoMessage added in v1.10.0 

func (*IndexSearchAttributes) ProtoMessage()

func (*IndexSearchAttributes) Reset added in v1.10.0 

func (m *IndexSearchAttributes) Reset()

func (*IndexSearchAttributes) Size added in v1.10.0 

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

func (*IndexSearchAttributes) String added in v1.10.0 

func (this *IndexSearchAttributes) String() string

func (*IndexSearchAttributes) Unmarshal added in v1.10.0 

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

func (*IndexSearchAttributes) XXX_DiscardUnknown added in v1.10.0 

func (m *IndexSearchAttributes) XXX_DiscardUnknown()

func (*IndexSearchAttributes) XXX_Marshal added in v1.10.0 

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

func (*IndexSearchAttributes) XXX_Merge added in v1.10.0 

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

func (*IndexSearchAttributes) XXX_Size added in v1.10.0 

func (m *IndexSearchAttributes) XXX_Size() int

func (*IndexSearchAttributes) XXX_Unmarshal added in v1.10.0 

func (m *IndexSearchAttributes) 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 NamespaceIdPredicateAttributes added in v1.17.3 

type NamespaceIdPredicateAttributes struct {
	NamespaceIds []string `protobuf:"bytes,1,rep,name=namespace_ids,json=namespaceIds,proto3" json:"namespace_ids,omitempty"`
}

func (*NamespaceIdPredicateAttributes) Descriptor added in v1.17.3 

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

func (*NamespaceIdPredicateAttributes) Equal added in v1.17.3 

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

func (*NamespaceIdPredicateAttributes) GetNamespaceIds added in v1.17.3 

func (m *NamespaceIdPredicateAttributes) GetNamespaceIds() []string

func (*NamespaceIdPredicateAttributes) GoString added in v1.17.3 

func (this *NamespaceIdPredicateAttributes) GoString() string

func (*NamespaceIdPredicateAttributes) Marshal added in v1.17.3 

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

func (*NamespaceIdPredicateAttributes) MarshalTo added in v1.17.3 

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

func (*NamespaceIdPredicateAttributes) MarshalToSizedBuffer added in v1.17.3 

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

func (*NamespaceIdPredicateAttributes) ProtoMessage added in v1.17.3 

func (*NamespaceIdPredicateAttributes) ProtoMessage()

func (*NamespaceIdPredicateAttributes) Reset added in v1.17.3 

func (m *NamespaceIdPredicateAttributes) Reset()

func (*NamespaceIdPredicateAttributes) Size added in v1.17.3 

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

func (*NamespaceIdPredicateAttributes) String added in v1.17.3 

func (this *NamespaceIdPredicateAttributes) String() string

func (*NamespaceIdPredicateAttributes) Unmarshal added in v1.17.3 

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

func (*NamespaceIdPredicateAttributes) XXX_DiscardUnknown added in v1.17.3 

func (m *NamespaceIdPredicateAttributes) XXX_DiscardUnknown()

func (*NamespaceIdPredicateAttributes) XXX_Marshal added in v1.17.3 

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

func (*NamespaceIdPredicateAttributes) XXX_Merge added in v1.17.3 

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

func (*NamespaceIdPredicateAttributes) XXX_Size added in v1.17.3 

func (m *NamespaceIdPredicateAttributes) XXX_Size() int

func (*NamespaceIdPredicateAttributes) XXX_Unmarshal added in v1.17.3 

func (m *NamespaceIdPredicateAttributes) 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"`
	State             v1.ReplicationState `protobuf:"varint,3,opt,name=state,proto3,enum=temporal.api.enums.v1.ReplicationState" json:"state,omitempty"`
	FailoverHistory   []*FailoverStatus   `protobuf:"bytes,8,rep,name=failover_history,json=failoverHistory,proto3" json:"failover_history,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) GetFailoverHistory added in v1.17.3 

func (m *NamespaceReplicationConfig) GetFailoverHistory() []*FailoverStatus

func (*NamespaceReplicationConfig) GetState added in v1.14.0 

func (m *NamespaceReplicationConfig) GetState() v1.ReplicationState

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 NotPredicateAttributes added in v1.17.3 

type NotPredicateAttributes struct {
	Predicate *Predicate `protobuf:"bytes,1,opt,name=predicate,proto3" json:"predicate,omitempty"`
}

func (*NotPredicateAttributes) Descriptor added in v1.17.3 

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

func (*NotPredicateAttributes) Equal added in v1.17.3 

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

func (*NotPredicateAttributes) GetPredicate added in v1.17.3 

func (m *NotPredicateAttributes) GetPredicate() *Predicate

func (*NotPredicateAttributes) GoString added in v1.17.3 

func (this *NotPredicateAttributes) GoString() string

func (*NotPredicateAttributes) Marshal added in v1.17.3 

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

func (*NotPredicateAttributes) MarshalTo added in v1.17.3 

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

func (*NotPredicateAttributes) MarshalToSizedBuffer added in v1.17.3 

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

func (*NotPredicateAttributes) ProtoMessage added in v1.17.3 

func (*NotPredicateAttributes) ProtoMessage()

func (*NotPredicateAttributes) Reset added in v1.17.3 

func (m *NotPredicateAttributes) Reset()

func (*NotPredicateAttributes) Size added in v1.17.3 

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

func (*NotPredicateAttributes) String added in v1.17.3 

func (this *NotPredicateAttributes) String() string

func (*NotPredicateAttributes) Unmarshal added in v1.17.3 

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

func (*NotPredicateAttributes) XXX_DiscardUnknown added in v1.17.3 

func (m *NotPredicateAttributes) XXX_DiscardUnknown()

func (*NotPredicateAttributes) XXX_Marshal added in v1.17.3 

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

func (*NotPredicateAttributes) XXX_Merge added in v1.17.3 

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

func (*NotPredicateAttributes) XXX_Size added in v1.17.3 

func (m *NotPredicateAttributes) XXX_Size() int

func (*NotPredicateAttributes) XXX_Unmarshal added in v1.17.3 

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

type OrPredicateAttributes added in v1.17.3 

type OrPredicateAttributes struct {
	Predicates []*Predicate `protobuf:"bytes,1,rep,name=predicates,proto3" json:"predicates,omitempty"`
}

func (*OrPredicateAttributes) Descriptor added in v1.17.3 

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

func (*OrPredicateAttributes) Equal added in v1.17.3 

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

func (*OrPredicateAttributes) GetPredicates added in v1.17.3 

func (m *OrPredicateAttributes) GetPredicates() []*Predicate

func (*OrPredicateAttributes) GoString added in v1.17.3 

func (this *OrPredicateAttributes) GoString() string

func (*OrPredicateAttributes) Marshal added in v1.17.3 

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

func (*OrPredicateAttributes) MarshalTo added in v1.17.3 

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

func (*OrPredicateAttributes) MarshalToSizedBuffer added in v1.17.3 

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

func (*OrPredicateAttributes) ProtoMessage added in v1.17.3 

func (*OrPredicateAttributes) ProtoMessage()

func (*OrPredicateAttributes) Reset added in v1.17.3 

func (m *OrPredicateAttributes) Reset()

func (*OrPredicateAttributes) Size added in v1.17.3 

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

func (*OrPredicateAttributes) String added in v1.17.3 

func (this *OrPredicateAttributes) String() string

func (*OrPredicateAttributes) Unmarshal added in v1.17.3 

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

func (*OrPredicateAttributes) XXX_DiscardUnknown added in v1.17.3 

func (m *OrPredicateAttributes) XXX_DiscardUnknown()

func (*OrPredicateAttributes) XXX_Marshal added in v1.17.3 

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

func (*OrPredicateAttributes) XXX_Merge added in v1.17.3 

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

func (*OrPredicateAttributes) XXX_Size added in v1.17.3 

func (m *OrPredicateAttributes) XXX_Size() int

func (*OrPredicateAttributes) XXX_Unmarshal added in v1.17.3 

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

type Predicate added in v1.17.3 

type Predicate struct {
	PredicateType v1.PredicateType `` /* 149-byte string literal not displayed */
	// Types that are valid to be assigned to Attributes:
	//	*Predicate_UniversalPredicateAttributes
	//	*Predicate_EmptyPredicateAttributes
	//	*Predicate_AndPredicateAttributes
	//	*Predicate_OrPredicateAttributes
	//	*Predicate_NotPredicateAttributes
	//	*Predicate_NamespaceIdPredicateAttributes
	//	*Predicate_TaskTypePredicateAttributes
	Attributes isPredicate_Attributes `protobuf_oneof:"attributes"`
}

func (*Predicate) Descriptor added in v1.17.3 

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

func (*Predicate) Equal added in v1.17.3 

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

func (*Predicate) GetAndPredicateAttributes added in v1.17.3 

func (m *Predicate) GetAndPredicateAttributes() *AndPredicateAttributes

func (*Predicate) GetAttributes added in v1.17.3 

func (m *Predicate) GetAttributes() isPredicate_Attributes

func (*Predicate) GetEmptyPredicateAttributes added in v1.17.3 

func (m *Predicate) GetEmptyPredicateAttributes() *EmptyPredicateAttributes

func (*Predicate) GetNamespaceIdPredicateAttributes added in v1.17.3 

func (m *Predicate) GetNamespaceIdPredicateAttributes() *NamespaceIdPredicateAttributes

func (*Predicate) GetNotPredicateAttributes added in v1.17.3 

func (m *Predicate) GetNotPredicateAttributes() *NotPredicateAttributes

func (*Predicate) GetOrPredicateAttributes added in v1.17.3 

func (m *Predicate) GetOrPredicateAttributes() *OrPredicateAttributes

func (*Predicate) GetPredicateType added in v1.17.3 

func (m *Predicate) GetPredicateType() v1.PredicateType

func (*Predicate) GetTaskTypePredicateAttributes added in v1.17.3 

func (m *Predicate) GetTaskTypePredicateAttributes() *TaskTypePredicateAttributes

func (*Predicate) GetUniversalPredicateAttributes added in v1.17.3 

func (m *Predicate) GetUniversalPredicateAttributes() *UniversalPredicateAttributes

func (*Predicate) GoString added in v1.17.3 

func (this *Predicate) GoString() string

func (*Predicate) Marshal added in v1.17.3 

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

func (*Predicate) MarshalTo added in v1.17.3 

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

func (*Predicate) MarshalToSizedBuffer added in v1.17.3 

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

func (*Predicate) ProtoMessage added in v1.17.3 

func (*Predicate) ProtoMessage()

func (*Predicate) Reset added in v1.17.3 

func (m *Predicate) Reset()

func (*Predicate) Size added in v1.17.3 

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

func (*Predicate) String added in v1.17.3 

func (this *Predicate) String() string

func (*Predicate) Unmarshal added in v1.17.3 

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

func (*Predicate) XXX_DiscardUnknown added in v1.17.3 

func (m *Predicate) XXX_DiscardUnknown()

func (*Predicate) XXX_Marshal added in v1.17.3 

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

func (*Predicate) XXX_Merge added in v1.17.3 

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

func (*Predicate) XXX_OneofWrappers added in v1.17.3 

func (*Predicate) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Predicate) XXX_Size added in v1.17.3 

func (m *Predicate) XXX_Size() int

func (*Predicate) XXX_Unmarshal added in v1.17.3 

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

type Predicate_AndPredicateAttributes added in v1.17.3 

type Predicate_AndPredicateAttributes struct {
	AndPredicateAttributes *AndPredicateAttributes `` /* 135-byte string literal not displayed */
}

func (*Predicate_AndPredicateAttributes) Equal added in v1.17.3 

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

func (*Predicate_AndPredicateAttributes) GoString added in v1.17.3 

func (this *Predicate_AndPredicateAttributes) GoString() string

func (*Predicate_AndPredicateAttributes) MarshalTo added in v1.17.3 

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

func (*Predicate_AndPredicateAttributes) MarshalToSizedBuffer added in v1.17.3 

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

func (*Predicate_AndPredicateAttributes) Size added in v1.17.3 

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

func (*Predicate_AndPredicateAttributes) String added in v1.17.3 

func (this *Predicate_AndPredicateAttributes) String() string

type Predicate_EmptyPredicateAttributes added in v1.17.3 

type Predicate_EmptyPredicateAttributes struct {
	EmptyPredicateAttributes *EmptyPredicateAttributes `` /* 141-byte string literal not displayed */
}

func (*Predicate_EmptyPredicateAttributes) Equal added in v1.17.3 

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

func (*Predicate_EmptyPredicateAttributes) GoString added in v1.17.3 

func (this *Predicate_EmptyPredicateAttributes) GoString() string

func (*Predicate_EmptyPredicateAttributes) MarshalTo added in v1.17.3 

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

func (*Predicate_EmptyPredicateAttributes) MarshalToSizedBuffer added in v1.17.3 

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

func (*Predicate_EmptyPredicateAttributes) Size added in v1.17.3 

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

func (*Predicate_EmptyPredicateAttributes) String added in v1.17.3 

func (this *Predicate_EmptyPredicateAttributes) String() string

type Predicate_NamespaceIdPredicateAttributes added in v1.17.3 

type Predicate_NamespaceIdPredicateAttributes struct {
	NamespaceIdPredicateAttributes *NamespaceIdPredicateAttributes `` /* 161-byte string literal not displayed */
}

func (*Predicate_NamespaceIdPredicateAttributes) Equal added in v1.17.3 

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

func (*Predicate_NamespaceIdPredicateAttributes) GoString added in v1.17.3 

func (this *Predicate_NamespaceIdPredicateAttributes) GoString() string

func (*Predicate_NamespaceIdPredicateAttributes) MarshalTo added in v1.17.3 

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

func (*Predicate_NamespaceIdPredicateAttributes) MarshalToSizedBuffer added in v1.17.3 

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

func (*Predicate_NamespaceIdPredicateAttributes) Size added in v1.17.3 

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

func (*Predicate_NamespaceIdPredicateAttributes) String added in v1.17.3 

func (this *Predicate_NamespaceIdPredicateAttributes) String() string

type Predicate_NotPredicateAttributes added in v1.17.3 

type Predicate_NotPredicateAttributes struct {
	NotPredicateAttributes *NotPredicateAttributes `` /* 135-byte string literal not displayed */
}

func (*Predicate_NotPredicateAttributes) Equal added in v1.17.3 

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

func (*Predicate_NotPredicateAttributes) GoString added in v1.17.3 

func (this *Predicate_NotPredicateAttributes) GoString() string

func (*Predicate_NotPredicateAttributes) MarshalTo added in v1.17.3 

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

func (*Predicate_NotPredicateAttributes) MarshalToSizedBuffer added in v1.17.3 

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

func (*Predicate_NotPredicateAttributes) Size added in v1.17.3 

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

func (*Predicate_NotPredicateAttributes) String added in v1.17.3 

func (this *Predicate_NotPredicateAttributes) String() string

type Predicate_OrPredicateAttributes added in v1.17.3 

type Predicate_OrPredicateAttributes struct {
	OrPredicateAttributes *OrPredicateAttributes `` /* 132-byte string literal not displayed */
}

func (*Predicate_OrPredicateAttributes) Equal added in v1.17.3 

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

func (*Predicate_OrPredicateAttributes) GoString added in v1.17.3 

func (this *Predicate_OrPredicateAttributes) GoString() string

func (*Predicate_OrPredicateAttributes) MarshalTo added in v1.17.3 

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

func (*Predicate_OrPredicateAttributes) MarshalToSizedBuffer added in v1.17.3 

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

func (*Predicate_OrPredicateAttributes) Size added in v1.17.3 

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

func (*Predicate_OrPredicateAttributes) String added in v1.17.3 

func (this *Predicate_OrPredicateAttributes) String() string

type Predicate_TaskTypePredicateAttributes added in v1.17.3 

type Predicate_TaskTypePredicateAttributes struct {
	TaskTypePredicateAttributes *TaskTypePredicateAttributes `` /* 152-byte string literal not displayed */
}

func (*Predicate_TaskTypePredicateAttributes) Equal added in v1.17.3 

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

func (*Predicate_TaskTypePredicateAttributes) GoString added in v1.17.3 

func (this *Predicate_TaskTypePredicateAttributes) GoString() string

func (*Predicate_TaskTypePredicateAttributes) MarshalTo added in v1.17.3 

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

func (*Predicate_TaskTypePredicateAttributes) MarshalToSizedBuffer added in v1.17.3 

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

func (*Predicate_TaskTypePredicateAttributes) Size added in v1.17.3 

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

func (*Predicate_TaskTypePredicateAttributes) String added in v1.17.3 

func (this *Predicate_TaskTypePredicateAttributes) String() string

type Predicate_UniversalPredicateAttributes added in v1.17.3 

type Predicate_UniversalPredicateAttributes struct {
	UniversalPredicateAttributes *UniversalPredicateAttributes `` /* 153-byte string literal not displayed */
}

func (*Predicate_UniversalPredicateAttributes) Equal added in v1.17.3 

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

func (*Predicate_UniversalPredicateAttributes) GoString added in v1.17.3 

func (this *Predicate_UniversalPredicateAttributes) GoString() string

func (*Predicate_UniversalPredicateAttributes) MarshalTo added in v1.17.3 

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

func (*Predicate_UniversalPredicateAttributes) MarshalToSizedBuffer added in v1.17.3 

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

func (*Predicate_UniversalPredicateAttributes) Size added in v1.17.3 

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

func (*Predicate_UniversalPredicateAttributes) String added in v1.17.3 

func (this *Predicate_UniversalPredicateAttributes) String() string

type QueueAckLevel added in v1.16.0 

type QueueAckLevel struct {
	AckLevel        int64            `protobuf:"varint,1,opt,name=ack_level,json=ackLevel,proto3" json:"ack_level,omitempty"`
	ClusterAckLevel map[string]int64 `` /* 197-byte string literal not displayed */
}

func (*QueueAckLevel) Descriptor added in v1.16.0 

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

func (*QueueAckLevel) Equal added in v1.16.0 

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

func (*QueueAckLevel) GetAckLevel added in v1.16.0 

func (m *QueueAckLevel) GetAckLevel() int64

func (*QueueAckLevel) GetClusterAckLevel added in v1.16.0 

func (m *QueueAckLevel) GetClusterAckLevel() map[string]int64

func (*QueueAckLevel) GoString added in v1.16.0 

func (this *QueueAckLevel) GoString() string

func (*QueueAckLevel) Marshal added in v1.16.0 

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

func (*QueueAckLevel) MarshalTo added in v1.16.0 

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

func (*QueueAckLevel) MarshalToSizedBuffer added in v1.16.0 

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

func (*QueueAckLevel) ProtoMessage added in v1.16.0 

func (*QueueAckLevel) ProtoMessage()

func (*QueueAckLevel) Reset added in v1.16.0 

func (m *QueueAckLevel) Reset()

func (*QueueAckLevel) Size added in v1.16.0 

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

func (*QueueAckLevel) String added in v1.16.0 

func (this *QueueAckLevel) String() string

func (*QueueAckLevel) Unmarshal added in v1.16.0 

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

func (*QueueAckLevel) XXX_DiscardUnknown added in v1.16.0 

func (m *QueueAckLevel) XXX_DiscardUnknown()

func (*QueueAckLevel) XXX_Marshal added in v1.16.0 

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

func (*QueueAckLevel) XXX_Merge added in v1.16.0 

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

func (*QueueAckLevel) XXX_Size added in v1.16.0 

func (m *QueueAckLevel) XXX_Size() int

func (*QueueAckLevel) XXX_Unmarshal added in v1.16.0 

func (m *QueueAckLevel) 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 QueueReaderState added in v1.17.3 

type QueueReaderState struct {
	Scopes []*QueueSliceScope `protobuf:"bytes,1,rep,name=scopes,proto3" json:"scopes,omitempty"`
}

func (*QueueReaderState) Descriptor added in v1.17.3 

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

func (*QueueReaderState) Equal added in v1.17.3 

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

func (*QueueReaderState) GetScopes added in v1.17.3 

func (m *QueueReaderState) GetScopes() []*QueueSliceScope

func (*QueueReaderState) GoString added in v1.17.3 

func (this *QueueReaderState) GoString() string

func (*QueueReaderState) Marshal added in v1.17.3 

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

func (*QueueReaderState) MarshalTo added in v1.17.3 

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

func (*QueueReaderState) MarshalToSizedBuffer added in v1.17.3 

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

func (*QueueReaderState) ProtoMessage added in v1.17.3 

func (*QueueReaderState) ProtoMessage()

func (*QueueReaderState) Reset added in v1.17.3 

func (m *QueueReaderState) Reset()

func (*QueueReaderState) Size added in v1.17.3 

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

func (*QueueReaderState) String added in v1.17.3 

func (this *QueueReaderState) String() string

func (*QueueReaderState) Unmarshal added in v1.17.3 

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

func (*QueueReaderState) XXX_DiscardUnknown added in v1.17.3 

func (m *QueueReaderState) XXX_DiscardUnknown()

func (*QueueReaderState) XXX_Marshal added in v1.17.3 

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

func (*QueueReaderState) XXX_Merge added in v1.17.3 

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

func (*QueueReaderState) XXX_Size added in v1.17.3 

func (m *QueueReaderState) XXX_Size() int

func (*QueueReaderState) XXX_Unmarshal added in v1.17.3 

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

type QueueSliceRange added in v1.17.3 

type QueueSliceRange struct {
	InclusiveMin *TaskKey `protobuf:"bytes,1,opt,name=inclusive_min,json=inclusiveMin,proto3" json:"inclusive_min,omitempty"`
	ExclusiveMax *TaskKey `protobuf:"bytes,2,opt,name=exclusive_max,json=exclusiveMax,proto3" json:"exclusive_max,omitempty"`
}

func (*QueueSliceRange) Descriptor added in v1.17.3 

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

func (*QueueSliceRange) Equal added in v1.17.3 

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

func (*QueueSliceRange) GetExclusiveMax added in v1.17.3 

func (m *QueueSliceRange) GetExclusiveMax() *TaskKey

func (*QueueSliceRange) GetInclusiveMin added in v1.17.3 

func (m *QueueSliceRange) GetInclusiveMin() *TaskKey

func (*QueueSliceRange) GoString added in v1.17.3 

func (this *QueueSliceRange) GoString() string

func (*QueueSliceRange) Marshal added in v1.17.3 

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

func (*QueueSliceRange) MarshalTo added in v1.17.3 

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

func (*QueueSliceRange) MarshalToSizedBuffer added in v1.17.3 

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

func (*QueueSliceRange) ProtoMessage added in v1.17.3 

func (*QueueSliceRange) ProtoMessage()

func (*QueueSliceRange) Reset added in v1.17.3 

func (m *QueueSliceRange) Reset()

func (*QueueSliceRange) Size added in v1.17.3 

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

func (*QueueSliceRange) String added in v1.17.3 

func (this *QueueSliceRange) String() string

func (*QueueSliceRange) Unmarshal added in v1.17.3 

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

func (*QueueSliceRange) XXX_DiscardUnknown added in v1.17.3 

func (m *QueueSliceRange) XXX_DiscardUnknown()

func (*QueueSliceRange) XXX_Marshal added in v1.17.3 

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

func (*QueueSliceRange) XXX_Merge added in v1.17.3 

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

func (*QueueSliceRange) XXX_Size added in v1.17.3 

func (m *QueueSliceRange) XXX_Size() int

func (*QueueSliceRange) XXX_Unmarshal added in v1.17.3 

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

type QueueSliceScope added in v1.17.3 

type QueueSliceScope struct {
	Range     *QueueSliceRange `protobuf:"bytes,1,opt,name=range,proto3" json:"range,omitempty"`
	Predicate *Predicate       `protobuf:"bytes,2,opt,name=predicate,proto3" json:"predicate,omitempty"`
}

func (*QueueSliceScope) Descriptor added in v1.17.3 

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

func (*QueueSliceScope) Equal added in v1.17.3 

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

func (*QueueSliceScope) GetPredicate added in v1.17.3 

func (m *QueueSliceScope) GetPredicate() *Predicate

func (*QueueSliceScope) GetRange added in v1.17.3 

func (m *QueueSliceScope) GetRange() *QueueSliceRange

func (*QueueSliceScope) GoString added in v1.17.3 

func (this *QueueSliceScope) GoString() string

func (*QueueSliceScope) Marshal added in v1.17.3 

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

func (*QueueSliceScope) MarshalTo added in v1.17.3 

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

func (*QueueSliceScope) MarshalToSizedBuffer added in v1.17.3 

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

func (*QueueSliceScope) ProtoMessage added in v1.17.3 

func (*QueueSliceScope) ProtoMessage()

func (*QueueSliceScope) Reset added in v1.17.3 

func (m *QueueSliceScope) Reset()

func (*QueueSliceScope) Size added in v1.17.3 

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

func (*QueueSliceScope) String added in v1.17.3 

func (this *QueueSliceScope) String() string

func (*QueueSliceScope) Unmarshal added in v1.17.3 

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

func (*QueueSliceScope) XXX_DiscardUnknown added in v1.17.3 

func (m *QueueSliceScope) XXX_DiscardUnknown()

func (*QueueSliceScope) XXX_Marshal added in v1.17.3 

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

func (*QueueSliceScope) XXX_Merge added in v1.17.3 

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

func (*QueueSliceScope) XXX_Size added in v1.17.3 

func (m *QueueSliceScope) XXX_Size() int

func (*QueueSliceScope) XXX_Unmarshal added in v1.17.3 

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

type QueueState added in v1.17.3 

type QueueState struct {
	ReaderStates                 map[int32]*QueueReaderState `` /* 186-byte string literal not displayed */
	ExclusiveReaderHighWatermark *TaskKey                    `` /* 149-byte string literal not displayed */
}

func (*QueueState) Descriptor added in v1.17.3 

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

func (*QueueState) Equal added in v1.17.3 

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

func (*QueueState) GetExclusiveReaderHighWatermark added in v1.17.3 

func (m *QueueState) GetExclusiveReaderHighWatermark() *TaskKey

func (*QueueState) GetReaderStates added in v1.17.3 

func (m *QueueState) GetReaderStates() map[int32]*QueueReaderState

func (*QueueState) GoString added in v1.17.3 

func (this *QueueState) GoString() string

func (*QueueState) Marshal added in v1.17.3 

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

func (*QueueState) MarshalTo added in v1.17.3 

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

func (*QueueState) MarshalToSizedBuffer added in v1.17.3 

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

func (*QueueState) ProtoMessage added in v1.17.3 

func (*QueueState) ProtoMessage()

func (*QueueState) Reset added in v1.17.3 

func (m *QueueState) Reset()

func (*QueueState) Size added in v1.17.3 

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

func (*QueueState) String added in v1.17.3 

func (this *QueueState) String() string

func (*QueueState) Unmarshal added in v1.17.3 

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

func (*QueueState) XXX_DiscardUnknown added in v1.17.3 

func (m *QueueState) XXX_DiscardUnknown()

func (*QueueState) XXX_Marshal added in v1.17.3 

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

func (*QueueState) XXX_Merge added in v1.17.3 

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

func (*QueueState) XXX_Size added in v1.17.3 

func (m *QueueState) XXX_Size() int

func (*QueueState) XXX_Unmarshal added in v1.17.3 

func (m *QueueState) 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"`
	ScheduledEventId  int64        `protobuf:"varint,8,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_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"`
	VisibilityTime    *time.Time   `protobuf:"bytes,16,opt,name=visibility_time,json=visibilityTime,proto3,stdtime" json:"visibility_time,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) GetScheduledEventId added in v1.17.0 

func (m *ReplicationTaskInfo) GetScheduledEventId() 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) GetVisibilityTime added in v1.14.0 

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

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"`
	InitiatedEventId      int64  `protobuf:"varint,4,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_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) GetInitiatedEventId added in v1.17.0 

func (m *RequestCancelInfo) GetInitiatedEventId() 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"`
	// (-- 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"`
	NamespaceNotificationVersion int64            `` /* 148-byte string literal not displayed */
	ReplicationDlqAckLevel       map[string]int64 `` /* 221-byte string literal not displayed */
	// Map from task category to ack levels of the corresponding queue processor
	QueueAckLevels map[int32]*QueueAckLevel `` /* 195-byte string literal not displayed */
	QueueStates    map[int32]*QueueState    `` /* 184-byte string literal not displayed */
}

shard column

func (*ShardInfo) Descriptor 

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

func (*ShardInfo) Equal 

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

func (*ShardInfo) GetNamespaceNotificationVersion 

func (m *ShardInfo) GetNamespaceNotificationVersion() int64

func (*ShardInfo) GetOwner 

func (m *ShardInfo) GetOwner() string

func (*ShardInfo) GetQueueAckLevels added in v1.16.0 

func (m *ShardInfo) GetQueueAckLevels() map[int32]*QueueAckLevel

func (*ShardInfo) GetQueueStates added in v1.17.3 

func (m *ShardInfo) GetQueueStates() map[int32]*QueueState

func (*ShardInfo) GetRangeId 

func (m *ShardInfo) GetRangeId() 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) GetUpdateTime 

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

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"`
	InitiatedEventId      int64  `protobuf:"varint,7,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_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) GetInitiatedEventBatchId 

func (m *SignalInfo) GetInitiatedEventBatchId() int64

func (*SignalInfo) GetInitiatedEventId added in v1.17.0 

func (m *SignalInfo) GetInitiatedEventId() int64

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"`
	ScheduledEventId int64           `protobuf:"varint,4,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_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"`
	Clock            *v1.VectorClock `protobuf:"bytes,7,opt,name=clock,proto3" json:"clock,omitempty"`
}

func (*TaskInfo) Descriptor 

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

func (*TaskInfo) Equal 

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

func (*TaskInfo) GetClock added in v1.17.0 

func (m *TaskInfo) GetClock() *v1.VectorClock

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) GetScheduledEventId added in v1.17.0 

func (m *TaskInfo) GetScheduledEventId() 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 TaskKey added in v1.17.3 

type TaskKey struct {
	FireTime *time.Time `protobuf:"bytes,1,opt,name=fire_time,json=fireTime,proto3,stdtime" json:"fire_time,omitempty"`
	TaskId   int64      `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
}

func (*TaskKey) Descriptor added in v1.17.3 

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

func (*TaskKey) Equal added in v1.17.3 

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

func (*TaskKey) GetFireTime added in v1.17.3 

func (m *TaskKey) GetFireTime() *time.Time

func (*TaskKey) GetTaskId added in v1.17.3 

func (m *TaskKey) GetTaskId() int64

func (*TaskKey) GoString added in v1.17.3 

func (this *TaskKey) GoString() string

func (*TaskKey) Marshal added in v1.17.3 

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

func (*TaskKey) MarshalTo added in v1.17.3 

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

func (*TaskKey) MarshalToSizedBuffer added in v1.17.3 

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

func (*TaskKey) ProtoMessage added in v1.17.3 

func (*TaskKey) ProtoMessage()

func (*TaskKey) Reset added in v1.17.3 

func (m *TaskKey) Reset()

func (*TaskKey) Size added in v1.17.3 

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

func (*TaskKey) String added in v1.17.3 

func (this *TaskKey) String() string

func (*TaskKey) Unmarshal added in v1.17.3 

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

func (*TaskKey) XXX_DiscardUnknown added in v1.17.3 

func (m *TaskKey) XXX_DiscardUnknown()

func (*TaskKey) XXX_Marshal added in v1.17.3 

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

func (*TaskKey) XXX_Merge added in v1.17.3 

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

func (*TaskKey) XXX_Size added in v1.17.3 

func (m *TaskKey) XXX_Size() int

func (*TaskKey) XXX_Unmarshal added in v1.17.3 

func (m *TaskKey) 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       v11.TaskQueueType `` /* 127-byte string literal not displayed */
	Kind           v11.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"`
	VersioningData *VersioningData   `protobuf:"bytes,8,opt,name=versioning_data,json=versioningData,proto3" json:"versioning_data,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() v11.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() v11.TaskQueueType

func (*TaskQueueInfo) GetVersioningData added in v1.17.3 

func (m *TaskQueueInfo) GetVersioningData() *VersioningData

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 TaskTypePredicateAttributes added in v1.17.3 

type TaskTypePredicateAttributes struct {
	TaskTypes []v1.TaskType `` /* 139-byte string literal not displayed */
}

func (*TaskTypePredicateAttributes) Descriptor added in v1.17.3 

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

func (*TaskTypePredicateAttributes) Equal added in v1.17.3 

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

func (*TaskTypePredicateAttributes) GetTaskTypes added in v1.17.3 

func (m *TaskTypePredicateAttributes) GetTaskTypes() []v1.TaskType

func (*TaskTypePredicateAttributes) GoString added in v1.17.3 

func (this *TaskTypePredicateAttributes) GoString() string

func (*TaskTypePredicateAttributes) Marshal added in v1.17.3 

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

func (*TaskTypePredicateAttributes) MarshalTo added in v1.17.3 

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

func (*TaskTypePredicateAttributes) MarshalToSizedBuffer added in v1.17.3 

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

func (*TaskTypePredicateAttributes) ProtoMessage added in v1.17.3 

func (*TaskTypePredicateAttributes) ProtoMessage()

func (*TaskTypePredicateAttributes) Reset added in v1.17.3 

func (m *TaskTypePredicateAttributes) Reset()

func (*TaskTypePredicateAttributes) Size added in v1.17.3 

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

func (*TaskTypePredicateAttributes) String added in v1.17.3 

func (this *TaskTypePredicateAttributes) String() string

func (*TaskTypePredicateAttributes) Unmarshal added in v1.17.3 

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

func (*TaskTypePredicateAttributes) XXX_DiscardUnknown added in v1.17.3 

func (m *TaskTypePredicateAttributes) XXX_DiscardUnknown()

func (*TaskTypePredicateAttributes) XXX_Marshal added in v1.17.3 

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

func (*TaskTypePredicateAttributes) XXX_Merge added in v1.17.3 

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

func (*TaskTypePredicateAttributes) XXX_Size added in v1.17.3 

func (m *TaskTypePredicateAttributes) XXX_Size() int

func (*TaskTypePredicateAttributes) XXX_Unmarshal added in v1.17.3 

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

type TimerInfo 

type TimerInfo struct {
	Version        int64      `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	StartedEventId int64      `protobuf:"varint,2,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_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) GetStartedEventId added in v1.17.0 

func (m *TimerInfo) GetStartedEventId() 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"`
	BranchToken         []byte                  `protobuf:"bytes,12,opt,name=branch_token,json=branchToken,proto3" json:"branch_token,omitempty"`
}

timer column

func (*TimerTaskInfo) Descriptor 

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

func (*TimerTaskInfo) Equal 

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

func (*TimerTaskInfo) GetBranchToken added in v1.16.0 

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

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 */
	ScheduledEventId        int64        `protobuf:"varint,10,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_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"`
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "after" is used to indicate sequence of actions. --)
	DeleteAfterClose bool `protobuf:"varint,15,opt,name=delete_after_close,json=deleteAfterClose,proto3" json:"delete_after_close,omitempty"`
}

transfer column

func (*TransferTaskInfo) Descriptor 

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

func (*TransferTaskInfo) Equal 

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

func (*TransferTaskInfo) GetDeleteAfterClose added in v1.17.0 

func (m *TransferTaskInfo) GetDeleteAfterClose() bool

func (*TransferTaskInfo) GetNamespaceId 

func (m *TransferTaskInfo) GetNamespaceId() string

func (*TransferTaskInfo) GetRunId 

func (m *TransferTaskInfo) GetRunId() string

func (*TransferTaskInfo) GetScheduledEventId added in v1.17.0 

func (m *TransferTaskInfo) GetScheduledEventId() 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 UniversalPredicateAttributes added in v1.17.3 

type UniversalPredicateAttributes struct {
}

func (*UniversalPredicateAttributes) Descriptor added in v1.17.3 

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

func (*UniversalPredicateAttributes) Equal added in v1.17.3 

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

func (*UniversalPredicateAttributes) GoString added in v1.17.3 

func (this *UniversalPredicateAttributes) GoString() string

func (*UniversalPredicateAttributes) Marshal added in v1.17.3 

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

func (*UniversalPredicateAttributes) MarshalTo added in v1.17.3 

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

func (*UniversalPredicateAttributes) MarshalToSizedBuffer added in v1.17.3 

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

func (*UniversalPredicateAttributes) ProtoMessage added in v1.17.3 

func (*UniversalPredicateAttributes) ProtoMessage()

func (*UniversalPredicateAttributes) Reset added in v1.17.3 

func (m *UniversalPredicateAttributes) Reset()

func (*UniversalPredicateAttributes) Size added in v1.17.3 

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

func (*UniversalPredicateAttributes) String added in v1.17.3 

func (this *UniversalPredicateAttributes) String() string

func (*UniversalPredicateAttributes) Unmarshal added in v1.17.3 

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

func (*UniversalPredicateAttributes) XXX_DiscardUnknown added in v1.17.3 

func (m *UniversalPredicateAttributes) XXX_DiscardUnknown()

func (*UniversalPredicateAttributes) XXX_Marshal added in v1.17.3 

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

func (*UniversalPredicateAttributes) XXX_Merge added in v1.17.3 

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

func (*UniversalPredicateAttributes) XXX_Size added in v1.17.3 

func (m *UniversalPredicateAttributes) XXX_Size() int

func (*UniversalPredicateAttributes) XXX_Unmarshal added in v1.17.3 

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

type VersioningData added in v1.17.3 

type VersioningData struct {
	// The currently established default worker build id version.
	CurrentDefault *v12.VersionIdNode `protobuf:"bytes,1,opt,name=current_default,json=currentDefault,proto3" json:"current_default,omitempty"`
	// Other current latest-compatible versions who are not the overall default. These are the
	// versions that will be used when generating new tasks by following the graph from the
	// version of the last task out to a leaf.
	CompatibleLeaves []*v12.VersionIdNode `protobuf:"bytes,2,rep,name=compatible_leaves,json=compatibleLeaves,proto3" json:"compatible_leaves,omitempty"`
}

Holds all the data related to worker versioning for a task queue. Backwards-incompatible changes cannot be made, as this would make existing stored data unreadable

func (*VersioningData) Descriptor added in v1.17.3 

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

func (*VersioningData) Equal added in v1.17.3 

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

func (*VersioningData) GetCompatibleLeaves added in v1.17.3 

func (m *VersioningData) GetCompatibleLeaves() []*v12.VersionIdNode

func (*VersioningData) GetCurrentDefault added in v1.17.3 

func (m *VersioningData) GetCurrentDefault() *v12.VersionIdNode

func (*VersioningData) GoString added in v1.17.3 

func (this *VersioningData) GoString() string

func (*VersioningData) Marshal added in v1.17.3 

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

func (*VersioningData) MarshalTo added in v1.17.3 

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

func (*VersioningData) MarshalToSizedBuffer added in v1.17.3 

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

func (*VersioningData) ProtoMessage added in v1.17.3 

func (*VersioningData) ProtoMessage()

func (*VersioningData) Reset added in v1.17.3 

func (m *VersioningData) Reset()

func (*VersioningData) Size added in v1.17.3 

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

func (*VersioningData) String added in v1.17.3 

func (this *VersioningData) String() string

func (*VersioningData) Unmarshal added in v1.17.3 

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

func (*VersioningData) XXX_DiscardUnknown added in v1.17.3 

func (m *VersioningData) XXX_DiscardUnknown()

func (*VersioningData) XXX_Marshal added in v1.17.3 

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

func (*VersioningData) XXX_Merge added in v1.17.3 

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

func (*VersioningData) XXX_Size added in v1.17.3 

func (m *VersioningData) XXX_Size() int

func (*VersioningData) XXX_Unmarshal added in v1.17.3 

func (m *VersioningData) 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"`
	CloseTime      *time.Time   `protobuf:"bytes,8,opt,name=close_time,json=closeTime,proto3,stdtime" json:"close_time,omitempty"`
	StartTime      *time.Time   `protobuf:"bytes,9,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_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) GetCloseTime added in v1.15.0 

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

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) GetStartTime added in v1.16.0 

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

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"`
	ParentInitiatedId                 int64          `protobuf:"varint,6,opt,name=parent_initiated_id,json=parentInitiatedId,proto3" json:"parent_initiated_id,omitempty"`
	CompletionEventBatchId            int64          `` /* 132-byte string literal not displayed */
	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 */
	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"`
	LastWorkflowTaskStartedEventId    int64          `` /* 161-byte string literal not displayed */
	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"`
	WorkflowTaskScheduledEventId      int64          `` /* 153-byte string literal not displayed */
	WorkflowTaskStartedEventId        int64          `` /* 147-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"`
	AutoResetPoints                 *v1.ResetPoints         `protobuf:"bytes,51,opt,name=auto_reset_points,json=autoResetPoints,proto3" json:"auto_reset_points,omitempty"`
	SearchAttributes                map[string]*v11.Payload `` /* 198-byte string literal not displayed */
	Memo                            map[string]*v11.Payload `` /* 150-byte string literal not displayed */
	VersionHistories                *v12.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 */
	StateTransitionCount int64      `protobuf:"varint,59,opt,name=state_transition_count,json=stateTransitionCount,proto3" json:"state_transition_count,omitempty"`
	ExecutionTime        *time.Time `protobuf:"bytes,60,opt,name=execution_time,json=executionTime,proto3,stdtime" json:"execution_time,omitempty"`
	// If continued-as-new, or retried, or cron, holds the new run id.
	NewExecutionRunId string           `protobuf:"bytes,61,opt,name=new_execution_run_id,json=newExecutionRunId,proto3" json:"new_execution_run_id,omitempty"`
	ParentClock       *v13.VectorClock `protobuf:"bytes,62,opt,name=parent_clock,json=parentClock,proto3" json:"parent_clock,omitempty"`
	// version of child execution initiated event in parent workflow
	ParentInitiatedVersion int64 `` /* 131-byte string literal not displayed */
	// Used to check if transfer close task is processed before deleting the workflow execution.
	CloseTransferTaskId int64 `protobuf:"varint,64,opt,name=close_transfer_task_id,json=closeTransferTaskId,proto3" json:"close_transfer_task_id,omitempty"`
	// Used to check if visibility close task is processed before deleting the workflow execution.
	CloseVisibilityTaskId int64      `` /* 130-byte string literal not displayed */
	CloseTime             *time.Time `protobuf:"bytes,66,opt,name=close_time,json=closeTime,proto3,stdtime" json:"close_time,omitempty"`
}

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

func (*WorkflowExecutionInfo) GetCancelRequestId 

func (m *WorkflowExecutionInfo) GetCancelRequestId() string

func (*WorkflowExecutionInfo) GetCancelRequested 

func (m *WorkflowExecutionInfo) GetCancelRequested() bool

func (*WorkflowExecutionInfo) GetCloseTime added in v1.17.0 

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

func (*WorkflowExecutionInfo) GetCloseTransferTaskId added in v1.17.0 

func (m *WorkflowExecutionInfo) GetCloseTransferTaskId() int64

func (*WorkflowExecutionInfo) GetCloseVisibilityTaskId added in v1.17.0 

func (m *WorkflowExecutionInfo) GetCloseVisibilityTaskId() int64

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) GetExecutionTime added in v1.11.0 

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

func (*WorkflowExecutionInfo) GetFirstExecutionRunId 

func (m *WorkflowExecutionInfo) GetFirstExecutionRunId() string

func (*WorkflowExecutionInfo) GetHasRetryPolicy 

func (m *WorkflowExecutionInfo) GetHasRetryPolicy() bool

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

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

func (*WorkflowExecutionInfo) GetLastWorkflowTaskStartedEventId added in v1.17.0 

func (m *WorkflowExecutionInfo) GetLastWorkflowTaskStartedEventId() int64

func (*WorkflowExecutionInfo) GetMemo 

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

func (*WorkflowExecutionInfo) GetNamespaceId 

func (m *WorkflowExecutionInfo) GetNamespaceId() string

func (*WorkflowExecutionInfo) GetNewExecutionRunId added in v1.13.0 

func (m *WorkflowExecutionInfo) GetNewExecutionRunId() string

func (*WorkflowExecutionInfo) GetParentClock added in v1.17.0 

func (m *WorkflowExecutionInfo) GetParentClock() *v13.VectorClock

func (*WorkflowExecutionInfo) GetParentInitiatedId added in v1.17.0 

func (m *WorkflowExecutionInfo) GetParentInitiatedId() int64

func (*WorkflowExecutionInfo) GetParentInitiatedVersion added in v1.17.0 

func (m *WorkflowExecutionInfo) GetParentInitiatedVersion() int64

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]*v11.Payload

func (*WorkflowExecutionInfo) GetSignalCount 

func (m *WorkflowExecutionInfo) GetSignalCount() int64

func (*WorkflowExecutionInfo) GetStartTime 

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

func (*WorkflowExecutionInfo) GetStateTransitionCount added in v1.10.0 

func (m *WorkflowExecutionInfo) GetStateTransitionCount() 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() *v12.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) GetWorkflowTaskScheduledEventId added in v1.17.0 

func (m *WorkflowExecutionInfo) GetWorkflowTaskScheduledEventId() int64

func (*WorkflowExecutionInfo) GetWorkflowTaskScheduledTime 

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

func (*WorkflowExecutionInfo) GetWorkflowTaskStartedEventId added in v1.17.0 

func (m *WorkflowExecutionInfo) GetWorkflowTaskStartedEventId() 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.