persistence

package
v1.21.5-rc2 Latest Latest
Warning

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

 Go to latest Published: Aug 14, 2023 License: MIT Imports: 27 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 (
	ErrInvalidLengthTaskQueues        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTaskQueues          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTaskQueues = 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")
)
View Source 
var BuildId_State_name = map[int32]string{
	0: "StateUnspecified",
	1: "StateActive",
	2: "StateDeleted",
}
View Source 
var BuildId_State_value = map[string]int32{
	"StateUnspecified": 0,
	"StateActive":      1,
	"StateDeleted":     2,
}

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            *v18.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 */
	ScheduledEventId            int64          `protobuf:"varint,30,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
	LastHeartbeatDetails        *v12.Payloads  `protobuf:"bytes,31,opt,name=last_heartbeat_details,json=lastHeartbeatDetails,proto3" json:"last_heartbeat_details,omitempty"`
	LastHeartbeatUpdateTime     *time.Time     `` /* 143-byte string literal not displayed */
	UseCompatibleVersion        bool           `protobuf:"varint,33,opt,name=use_compatible_version,json=useCompatibleVersion,proto3" json:"use_compatible_version,omitempty"`
}

activity_map column

func (*ActivityInfo) Descriptor 

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

func (*ActivityInfo) Equal 

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

func (*ActivityInfo) GetActivityId 

func (m *ActivityInfo) GetActivityId() string

func (*ActivityInfo) GetAttempt 

func (m *ActivityInfo) GetAttempt() int32

func (*ActivityInfo) GetCancelRequestId 

func (m *ActivityInfo) GetCancelRequestId() int64

func (*ActivityInfo) GetCancelRequested 

func (m *ActivityInfo) GetCancelRequested() bool

func (*ActivityInfo) GetHasRetryPolicy 

func (m *ActivityInfo) GetHasRetryPolicy() bool

func (*ActivityInfo) GetHeartbeatTimeout 

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

func (*ActivityInfo) GetLastHeartbeatDetails 

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

func (*ActivityInfo) GetLastHeartbeatUpdateTime 

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

func (*ActivityInfo) 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() *v18.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) GetUseCompatibleVersion added in v1.21.0 

func (m *ActivityInfo) GetUseCompatibleVersion() bool

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 ArchivalTaskInfo added in v1.19.0 

type ArchivalTaskInfo struct {
	TaskId         int64       `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	NamespaceId    string      `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId     string      `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId          string      `protobuf:"bytes,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	TaskType       v1.TaskType `` /* 129-byte string literal not displayed */
	Version        int64       `protobuf:"varint,6,opt,name=version,proto3" json:"version,omitempty"`
	VisibilityTime *time.Time  `protobuf:"bytes,7,opt,name=visibility_time,json=visibilityTime,proto3,stdtime" json:"visibility_time,omitempty"`
}

func (*ArchivalTaskInfo) Descriptor added in v1.19.0 

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

func (*ArchivalTaskInfo) Equal added in v1.19.0 

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

func (*ArchivalTaskInfo) GetNamespaceId added in v1.19.0 

func (m *ArchivalTaskInfo) GetNamespaceId() string

func (*ArchivalTaskInfo) GetRunId added in v1.19.0 

func (m *ArchivalTaskInfo) GetRunId() string

func (*ArchivalTaskInfo) GetTaskId added in v1.19.0 

func (m *ArchivalTaskInfo) GetTaskId() int64

func (*ArchivalTaskInfo) GetTaskType added in v1.19.0 

func (m *ArchivalTaskInfo) GetTaskType() v1.TaskType

func (*ArchivalTaskInfo) GetVersion added in v1.19.0 

func (m *ArchivalTaskInfo) GetVersion() int64

func (*ArchivalTaskInfo) GetVisibilityTime added in v1.19.0 

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

func (*ArchivalTaskInfo) GetWorkflowId added in v1.19.0 

func (m *ArchivalTaskInfo) GetWorkflowId() string

func (*ArchivalTaskInfo) GoString added in v1.19.0 

func (this *ArchivalTaskInfo) GoString() string

func (*ArchivalTaskInfo) Marshal added in v1.19.0 

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

func (*ArchivalTaskInfo) MarshalTo added in v1.19.0 

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

func (*ArchivalTaskInfo) MarshalToSizedBuffer added in v1.19.0 

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

func (*ArchivalTaskInfo) ProtoMessage added in v1.19.0 

func (*ArchivalTaskInfo) ProtoMessage()

func (*ArchivalTaskInfo) Reset added in v1.19.0 

func (m *ArchivalTaskInfo) Reset()

func (*ArchivalTaskInfo) Size added in v1.19.0 

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

func (*ArchivalTaskInfo) String added in v1.19.0 

func (this *ArchivalTaskInfo) String() string

func (*ArchivalTaskInfo) Unmarshal added in v1.19.0 

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

func (*ArchivalTaskInfo) XXX_DiscardUnknown added in v1.19.0 

func (m *ArchivalTaskInfo) XXX_DiscardUnknown()

func (*ArchivalTaskInfo) XXX_Marshal added in v1.19.0 

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

func (*ArchivalTaskInfo) XXX_Merge added in v1.19.0 

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

func (*ArchivalTaskInfo) XXX_Size added in v1.19.0 

func (m *ArchivalTaskInfo) XXX_Size() int

func (*ArchivalTaskInfo) XXX_Unmarshal added in v1.19.0 

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

type BuildId added in v1.21.0 

type BuildId struct {
	Id    string        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State BuildId_State `protobuf:"varint,2,opt,name=state,proto3,enum=temporal.server.api.persistence.v1.BuildId_State" json:"state,omitempty"`
	// HLC timestamp representing when the state was updated or the when build ID was originally inserted.
	// (-- api-linter: core::0142::time-field-type=disabled
	//     aip.dev/not-precedent: Using HLC instead of wall clock. --)
	StateUpdateTimestamp *v1.HybridLogicalClock `protobuf:"bytes,3,opt,name=state_update_timestamp,json=stateUpdateTimestamp,proto3" json:"state_update_timestamp,omitempty"`
	// HLC timestamp representing when this build id was last made default in its version set.
	// (-- api-linter: core::0142::time-field-type=disabled
	//     aip.dev/not-precedent: Using HLC instead of wall clock. --)
	BecameDefaultTimestamp *v1.HybridLogicalClock `` /* 129-byte string literal not displayed */
}

BuildId is an identifier with a timestamped status used to identify workers for task queue versioning purposes.

func (*BuildId) Descriptor added in v1.21.0 

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

func (*BuildId) Equal added in v1.21.0 

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

func (*BuildId) GetBecameDefaultTimestamp added in v1.21.0 

func (m *BuildId) GetBecameDefaultTimestamp() *v1.HybridLogicalClock

func (*BuildId) GetId added in v1.21.0 

func (m *BuildId) GetId() string

func (*BuildId) GetState added in v1.21.0 

func (m *BuildId) GetState() BuildId_State

func (*BuildId) GetStateUpdateTimestamp added in v1.21.0 

func (m *BuildId) GetStateUpdateTimestamp() *v1.HybridLogicalClock

func (*BuildId) GoString added in v1.21.0 

func (this *BuildId) GoString() string

func (*BuildId) Marshal added in v1.21.0 

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

func (*BuildId) MarshalTo added in v1.21.0 

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

func (*BuildId) MarshalToSizedBuffer added in v1.21.0 

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

func (*BuildId) ProtoMessage added in v1.21.0 

func (*BuildId) ProtoMessage()

func (*BuildId) Reset added in v1.21.0 

func (m *BuildId) Reset()

func (*BuildId) Size added in v1.21.0 

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

func (*BuildId) String added in v1.21.0 

func (this *BuildId) String() string

func (*BuildId) Unmarshal added in v1.21.0 

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

func (*BuildId) XXX_DiscardUnknown added in v1.21.0 

func (m *BuildId) XXX_DiscardUnknown()

func (*BuildId) XXX_Marshal added in v1.21.0 

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

func (*BuildId) XXX_Merge added in v1.21.0 

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

func (*BuildId) XXX_Size added in v1.21.0 

func (m *BuildId) XXX_Size() int

func (*BuildId) XXX_Unmarshal added in v1.21.0 

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

type BuildId_State added in v1.21.0 

type BuildId_State int32
const (
	STATE_UNSPECIFIED BuildId_State = 0
	STATE_ACTIVE      BuildId_State = 1
	STATE_DELETED     BuildId_State = 2
)

func (BuildId_State) EnumDescriptor added in v1.21.0 

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

func (BuildId_State) String added in v1.21.0 

func (x BuildId_State) String() string

type Checksum 

type Checksum struct {
	Version int32             `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Flavor  v1.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() v1.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     v17.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                 *v14.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() *v14.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() v17.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"`
	UseClusterIdMembership   bool                              `` /* 133-byte string literal not displayed */
}

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) GetUseClusterIdMembership added in v1.19.0 

func (m *ClusterMetadata) GetUseClusterIdMembership() 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 CompatibleVersionSet added in v1.21.0 

type CompatibleVersionSet struct {
	// Set IDs are used internally by matching.
	// A set typically has one set ID and extra care is taken to enforce this.
	// In split brain scenarios, there may be conflicting concurrent writes to the task queue versioning data, in which
	// case a set might end up with more than one ID.
	SetIds []string `protobuf:"bytes,1,rep,name=set_ids,json=setIds,proto3" json:"set_ids,omitempty"`
	// All the compatible versions, unordered except for the last element, which is considered the set "default".
	BuildIds []*BuildId `protobuf:"bytes,2,rep,name=build_ids,json=buildIds,proto3" json:"build_ids,omitempty"`
	// HLC timestamp representing when this set was last made the default for the queue.
	// (-- api-linter: core::0142::time-field-type=disabled
	//     aip.dev/not-precedent: Using HLC instead of wall clock. --)
	BecameDefaultTimestamp *v1.HybridLogicalClock `` /* 129-byte string literal not displayed */
}

An internal represenation of temporal.api.taskqueue.v1.CompatibleVersionSet

func (*CompatibleVersionSet) Descriptor added in v1.21.0 

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

func (*CompatibleVersionSet) Equal added in v1.21.0 

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

func (*CompatibleVersionSet) GetBecameDefaultTimestamp added in v1.21.0 

func (m *CompatibleVersionSet) GetBecameDefaultTimestamp() *v1.HybridLogicalClock

func (*CompatibleVersionSet) GetBuildIds added in v1.21.0 

func (m *CompatibleVersionSet) GetBuildIds() []*BuildId

func (*CompatibleVersionSet) GetSetIds added in v1.21.0 

func (m *CompatibleVersionSet) GetSetIds() []string

func (*CompatibleVersionSet) GoString added in v1.21.0 

func (this *CompatibleVersionSet) GoString() string

func (*CompatibleVersionSet) Marshal added in v1.21.0 

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

func (*CompatibleVersionSet) MarshalTo added in v1.21.0 

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

func (*CompatibleVersionSet) MarshalToSizedBuffer added in v1.21.0 

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

func (*CompatibleVersionSet) ProtoMessage added in v1.21.0 

func (*CompatibleVersionSet) ProtoMessage()

func (*CompatibleVersionSet) Reset added in v1.21.0 

func (m *CompatibleVersionSet) Reset()

func (*CompatibleVersionSet) Size added in v1.21.0 

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

func (*CompatibleVersionSet) String added in v1.21.0 

func (this *CompatibleVersionSet) String() string

func (*CompatibleVersionSet) Unmarshal added in v1.21.0 

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

func (*CompatibleVersionSet) XXX_DiscardUnknown added in v1.21.0 

func (m *CompatibleVersionSet) XXX_DiscardUnknown()

func (*CompatibleVersionSet) XXX_Marshal added in v1.21.0 

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

func (*CompatibleVersionSet) XXX_Merge added in v1.21.0 

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

func (*CompatibleVersionSet) XXX_Size added in v1.21.0 

func (m *CompatibleVersionSet) XXX_Size() int

func (*CompatibleVersionSet) XXX_Unmarshal added in v1.21.0 

func (m *CompatibleVersionSet) 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 {
	// Deprecating branch info in favor of branch token.
	BranchInfo *HistoryBranch `protobuf:"bytes,1,opt,name=branch_info,json=branchInfo,proto3" json:"branch_info,omitempty"` // Deprecated: Do not use.
	// 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"`
	// The opaque branch token replaces the deprecated branch info.
	BranchToken []byte `protobuf:"bytes,4,opt,name=branch_token,json=branchToken,proto3" json:"branch_token,omitempty"`
}

branch column

func (*HistoryTreeInfo) Descriptor 

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

func (*HistoryTreeInfo) Equal 

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

func (*HistoryTreeInfo) GetBranchInfo deprecated 

func (m *HistoryTreeInfo) GetBranchInfo() *HistoryBranch

Deprecated: Do not use.

func (*HistoryTreeInfo) GetBranchToken added in v1.19.0 

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

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 */
	CustomSearchAttributeAliases map[string]string `` /* 237-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) GetCustomSearchAttributeAliases added in v1.20.0 

func (m *NamespaceConfig) GetCustomSearchAttributeAliases() map[string]string

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[int64]*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[int64]*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          v1.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"`
	NewRunId          string      `protobuf:"bytes,17,opt,name=new_run_id,json=newRunId,proto3" json:"new_run_id,omitempty"`
}

replication column

func (*ReplicationTaskInfo) Descriptor 

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

func (*ReplicationTaskInfo) Equal 

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

func (*ReplicationTaskInfo) GetBranchToken 

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

func (*ReplicationTaskInfo) GetFirstEventId 

func (m *ReplicationTaskInfo) GetFirstEventId() int64

func (*ReplicationTaskInfo) GetNamespaceId 

func (m *ReplicationTaskInfo) GetNamespaceId() string

func (*ReplicationTaskInfo) GetNewRunBranchToken 

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

func (*ReplicationTaskInfo) GetNewRunId added in v1.18.1 

func (m *ReplicationTaskInfo) GetNewRunId() string

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() v1.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"`
	ReplicationDlqAckLevel map[string]int64 `` /* 221-byte string literal not displayed */
	// Map from task category to ack levels of the corresponding queue processor
	// Deprecated. Use queue_states instead.
	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) 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"`
	// How this task should be directed. (Missing means the default for
	// TaskVersionDirective, which is unversioned.)
	VersionDirective *v11.TaskVersionDirective `protobuf:"bytes,8,opt,name=version_directive,json=versionDirective,proto3" json:"version_directive,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) GetVersionDirective added in v1.21.0 

func (m *TaskInfo) GetVersionDirective() *v11.TaskVersionDirective

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

task_queue column

func (*TaskQueueInfo) Descriptor 

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

func (*TaskQueueInfo) Equal 

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

func (*TaskQueueInfo) GetAckLevel 

func (m *TaskQueueInfo) GetAckLevel() int64

func (*TaskQueueInfo) GetExpiryTime 

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

func (*TaskQueueInfo) GetKind 

func (m *TaskQueueInfo) GetKind() v12.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() v12.TaskQueueType

func (*TaskQueueInfo) GoString 

func (this *TaskQueueInfo) GoString() string

func (*TaskQueueInfo) Marshal 

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

func (*TaskQueueInfo) MarshalTo 

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

func (*TaskQueueInfo) MarshalToSizedBuffer 

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

func (*TaskQueueInfo) ProtoMessage 

func (*TaskQueueInfo) ProtoMessage()

func (*TaskQueueInfo) Reset 

func (m *TaskQueueInfo) Reset()

func (*TaskQueueInfo) Size 

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

func (*TaskQueueInfo) String 

func (this *TaskQueueInfo) String() string

func (*TaskQueueInfo) Unmarshal 

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

func (*TaskQueueInfo) XXX_DiscardUnknown 

func (m *TaskQueueInfo) XXX_DiscardUnknown()

func (*TaskQueueInfo) XXX_Marshal 

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

func (*TaskQueueInfo) XXX_Merge 

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

func (*TaskQueueInfo) XXX_Size 

func (m *TaskQueueInfo) XXX_Size() int

func (*TaskQueueInfo) XXX_Unmarshal 

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

type TaskQueueUserData added in v1.21.0 

type TaskQueueUserData struct {
	// The last recorded cluster-local Hybrid Logical Clock timestamp for _this_ task queue.
	// Updated whenever user data is directly updated due to a user action but not when applying replication events.
	// The clock is referenced when new timestamps are generated to ensure it produces monotonically increasing
	// timestamps.
	Clock          *v1.HybridLogicalClock `protobuf:"bytes,1,opt,name=clock,proto3" json:"clock,omitempty"`
	VersioningData *VersioningData        `protobuf:"bytes,2,opt,name=versioning_data,json=versioningData,proto3" json:"versioning_data,omitempty"`
}

Container for all persistent user provided data for a task queue. Task queue as a named concept here is close to how users interpret them, rather than relating to some specific type (workflow vs activity, etc) and thus, as a consequence, any data that applies to a specific type (say, activity rate limiting) should be defined as such within this structure. This data must all fit in a single DB column and is kept cached in-memory, take extra care to ensure data added here has reasonable size limits imposed on it.

func (*TaskQueueUserData) Descriptor added in v1.21.0 

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

func (*TaskQueueUserData) Equal added in v1.21.0 

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

func (*TaskQueueUserData) GetClock added in v1.21.0 

func (m *TaskQueueUserData) GetClock() *v1.HybridLogicalClock

func (*TaskQueueUserData) GetVersioningData added in v1.21.0 

func (m *TaskQueueUserData) GetVersioningData() *VersioningData

func (*TaskQueueUserData) GoString added in v1.21.0 

func (this *TaskQueueUserData) GoString() string

func (*TaskQueueUserData) Marshal added in v1.21.0 

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

func (*TaskQueueUserData) MarshalTo added in v1.21.0 

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

func (*TaskQueueUserData) MarshalToSizedBuffer added in v1.21.0 

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

func (*TaskQueueUserData) ProtoMessage added in v1.21.0 

func (*TaskQueueUserData) ProtoMessage()

func (*TaskQueueUserData) Reset added in v1.21.0 

func (m *TaskQueueUserData) Reset()

func (*TaskQueueUserData) Size added in v1.21.0 

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

func (*TaskQueueUserData) String added in v1.21.0 

func (this *TaskQueueUserData) String() string

func (*TaskQueueUserData) Unmarshal added in v1.21.0 

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

func (*TaskQueueUserData) XXX_DiscardUnknown added in v1.21.0 

func (m *TaskQueueUserData) XXX_DiscardUnknown()

func (*TaskQueueUserData) XXX_Marshal added in v1.21.0 

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

func (*TaskQueueUserData) XXX_Merge added in v1.21.0 

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

func (*TaskQueueUserData) XXX_Size added in v1.21.0 

func (m *TaskQueueUserData) XXX_Size() int

func (*TaskQueueUserData) XXX_Unmarshal added in v1.21.0 

func (m *TaskQueueUserData) 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            v1.TaskType            `` /* 129-byte string literal not displayed */
	TimeoutType         v17.TimeoutType        `` /* 134-byte string literal not displayed */
	WorkflowBackoffType v1.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"`
	// If this is true, we can bypass archival before deleting. Only defined for DeleteHistoryEventTasks.
	AlreadyArchived bool `protobuf:"varint,13,opt,name=already_archived,json=alreadyArchived,proto3" json:"already_archived,omitempty"`
}

timer column

func (*TimerTaskInfo) Descriptor 

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

func (*TimerTaskInfo) Equal 

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

func (*TimerTaskInfo) GetAlreadyArchived added in v1.19.0 

func (m *TimerTaskInfo) GetAlreadyArchived() 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() v1.TaskType

func (*TimerTaskInfo) GetTimeoutType 

func (m *TimerTaskInfo) GetTimeoutType() v17.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() v1.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                v1.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"`
	// Types that are valid to be assigned to TaskDetails:
	//	*TransferTaskInfo_CloseExecutionTaskDetails_
	TaskDetails isTransferTaskInfo_TaskDetails `protobuf_oneof:"task_details"`
}

transfer column

func (*TransferTaskInfo) Descriptor 

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

func (*TransferTaskInfo) Equal 

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

func (*TransferTaskInfo) GetCloseExecutionTaskDetails added in v1.19.0 

func (m *TransferTaskInfo) GetCloseExecutionTaskDetails() *TransferTaskInfo_CloseExecutionTaskDetails

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) GetTaskDetails added in v1.19.0 

func (m *TransferTaskInfo) GetTaskDetails() isTransferTaskInfo_TaskDetails

func (*TransferTaskInfo) GetTaskId 

func (m *TransferTaskInfo) GetTaskId() int64

func (*TransferTaskInfo) GetTaskQueue 

func (m *TransferTaskInfo) GetTaskQueue() string

func (*TransferTaskInfo) GetTaskType 

func (m *TransferTaskInfo) GetTaskType() v1.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_OneofWrappers added in v1.19.0 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*TransferTaskInfo) XXX_Size 

func (m *TransferTaskInfo) XXX_Size() int

func (*TransferTaskInfo) XXX_Unmarshal 

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

type TransferTaskInfo_CloseExecutionTaskDetails added in v1.19.0 

type TransferTaskInfo_CloseExecutionTaskDetails struct {
	// can_skip_visibility_archival is set to true when we can guarantee that visibility records will be archived
	// by some other task, so this task doesn't need to worry about it.
	CanSkipVisibilityArchival bool `` /* 141-byte string literal not displayed */
}

func (*TransferTaskInfo_CloseExecutionTaskDetails) Descriptor added in v1.19.0 

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

func (*TransferTaskInfo_CloseExecutionTaskDetails) Equal added in v1.19.0 

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

func (*TransferTaskInfo_CloseExecutionTaskDetails) GetCanSkipVisibilityArchival added in v1.19.0 

func (m *TransferTaskInfo_CloseExecutionTaskDetails) GetCanSkipVisibilityArchival() bool

func (*TransferTaskInfo_CloseExecutionTaskDetails) GoString added in v1.19.0 

func (this *TransferTaskInfo_CloseExecutionTaskDetails) GoString() string

func (*TransferTaskInfo_CloseExecutionTaskDetails) Marshal added in v1.19.0 

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

func (*TransferTaskInfo_CloseExecutionTaskDetails) MarshalTo added in v1.19.0 

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

func (*TransferTaskInfo_CloseExecutionTaskDetails) MarshalToSizedBuffer added in v1.19.0 

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

func (*TransferTaskInfo_CloseExecutionTaskDetails) ProtoMessage added in v1.19.0 

func (*TransferTaskInfo_CloseExecutionTaskDetails) ProtoMessage()

func (*TransferTaskInfo_CloseExecutionTaskDetails) Reset added in v1.19.0 

func (m *TransferTaskInfo_CloseExecutionTaskDetails) Reset()

func (*TransferTaskInfo_CloseExecutionTaskDetails) Size added in v1.19.0 

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

func (*TransferTaskInfo_CloseExecutionTaskDetails) String added in v1.19.0 

func (this *TransferTaskInfo_CloseExecutionTaskDetails) String() string

func (*TransferTaskInfo_CloseExecutionTaskDetails) Unmarshal added in v1.19.0 

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

func (*TransferTaskInfo_CloseExecutionTaskDetails) XXX_DiscardUnknown added in v1.19.0 

func (m *TransferTaskInfo_CloseExecutionTaskDetails) XXX_DiscardUnknown()

func (*TransferTaskInfo_CloseExecutionTaskDetails) XXX_Marshal added in v1.19.0 

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

func (*TransferTaskInfo_CloseExecutionTaskDetails) XXX_Merge added in v1.19.0 

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

func (*TransferTaskInfo_CloseExecutionTaskDetails) XXX_Size added in v1.19.0 

func (m *TransferTaskInfo_CloseExecutionTaskDetails) XXX_Size() int

func (*TransferTaskInfo_CloseExecutionTaskDetails) XXX_Unmarshal added in v1.19.0 

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

type TransferTaskInfo_CloseExecutionTaskDetails_ added in v1.19.0 

type TransferTaskInfo_CloseExecutionTaskDetails_ struct {
	CloseExecutionTaskDetails *TransferTaskInfo_CloseExecutionTaskDetails `` /* 147-byte string literal not displayed */
}

func (*TransferTaskInfo_CloseExecutionTaskDetails_) Equal added in v1.19.0 

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

func (*TransferTaskInfo_CloseExecutionTaskDetails_) GoString added in v1.19.0 

func (this *TransferTaskInfo_CloseExecutionTaskDetails_) GoString() string

func (*TransferTaskInfo_CloseExecutionTaskDetails_) MarshalTo added in v1.19.0 

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

func (*TransferTaskInfo_CloseExecutionTaskDetails_) MarshalToSizedBuffer added in v1.19.0 

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

func (*TransferTaskInfo_CloseExecutionTaskDetails_) Size added in v1.19.0 

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

func (*TransferTaskInfo_CloseExecutionTaskDetails_) String added in v1.19.0 

func (this *TransferTaskInfo_CloseExecutionTaskDetails_) String() string

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 VersionedTaskQueueUserData added in v1.21.0 

type VersionedTaskQueueUserData struct {
	Data    *TaskQueueUserData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Version int64              `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
}

Simple wrapper that includes a TaskQueueUserData and its storage version.

func (*VersionedTaskQueueUserData) Descriptor added in v1.21.0 

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

func (*VersionedTaskQueueUserData) Equal added in v1.21.0 

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

func (*VersionedTaskQueueUserData) GetData added in v1.21.0 

func (m *VersionedTaskQueueUserData) GetData() *TaskQueueUserData

func (*VersionedTaskQueueUserData) GetVersion added in v1.21.0 

func (m *VersionedTaskQueueUserData) GetVersion() int64

func (*VersionedTaskQueueUserData) GoString added in v1.21.0 

func (this *VersionedTaskQueueUserData) GoString() string

func (*VersionedTaskQueueUserData) Marshal added in v1.21.0 

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

func (*VersionedTaskQueueUserData) MarshalTo added in v1.21.0 

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

func (*VersionedTaskQueueUserData) MarshalToSizedBuffer added in v1.21.0 

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

func (*VersionedTaskQueueUserData) ProtoMessage added in v1.21.0 

func (*VersionedTaskQueueUserData) ProtoMessage()

func (*VersionedTaskQueueUserData) Reset added in v1.21.0 

func (m *VersionedTaskQueueUserData) Reset()

func (*VersionedTaskQueueUserData) Size added in v1.21.0 

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

func (*VersionedTaskQueueUserData) String added in v1.21.0 

func (this *VersionedTaskQueueUserData) String() string

func (*VersionedTaskQueueUserData) Unmarshal added in v1.21.0 

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

func (*VersionedTaskQueueUserData) XXX_DiscardUnknown added in v1.21.0 

func (m *VersionedTaskQueueUserData) XXX_DiscardUnknown()

func (*VersionedTaskQueueUserData) XXX_Marshal added in v1.21.0 

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

func (*VersionedTaskQueueUserData) XXX_Merge added in v1.21.0 

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

func (*VersionedTaskQueueUserData) XXX_Size added in v1.21.0 

func (m *VersionedTaskQueueUserData) XXX_Size() int

func (*VersionedTaskQueueUserData) XXX_Unmarshal added in v1.21.0 

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

type VersioningData added in v1.17.3 

type VersioningData struct {
	// All the incompatible version sets, unordered except for the last element, which is considered the set "default".
	VersionSets []*CompatibleVersionSet `protobuf:"bytes,1,rep,name=version_sets,json=versionSets,proto3" json:"version_sets,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) GetVersionSets added in v1.21.0 

func (m *VersioningData) GetVersionSets() []*CompatibleVersionSet

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              v1.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"`
	CloseVisibilityTaskId int64       `` /* 130-byte string literal not displayed */
}

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) GetCloseVisibilityTaskId added in v1.18.0 

func (m *VisibilityTaskInfo) GetCloseVisibilityTaskId() int64

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() v1.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"`
	// Workflow task fields.
	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 */
	WorkflowTaskOriginalScheduledTime *time.Time          `` /* 175-byte string literal not displayed */
	WorkflowTaskRequestId             string              `` /* 129-byte string literal not displayed */
	WorkflowTaskType                  v1.WorkflowTaskType `` /* 164-byte string literal not displayed */
	WorkflowTaskSuggestContinueAsNew  bool                `` /* 167-byte string literal not displayed */
	WorkflowTaskHistorySizeBytes      int64               `` /* 153-byte string literal not displayed */
	CancelRequested                   bool                `protobuf:"varint,29,opt,name=cancel_requested,json=cancelRequested,proto3" json:"cancel_requested,omitempty"`
	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"`
	ActivityCount                   int64                   `protobuf:"varint,71,opt,name=activity_count,json=activityCount,proto3" json:"activity_count,omitempty"`
	ChildExecutionCount             int64                   `protobuf:"varint,72,opt,name=child_execution_count,json=childExecutionCount,proto3" json:"child_execution_count,omitempty"`
	UserTimerCount                  int64                   `protobuf:"varint,73,opt,name=user_timer_count,json=userTimerCount,proto3" json:"user_timer_count,omitempty"`
	RequestCancelExternalCount      int64                   `` /* 145-byte string literal not displayed */
	SignalExternalCount             int64                   `protobuf:"varint,75,opt,name=signal_external_count,json=signalExternalCount,proto3" json:"signal_external_count,omitempty"`
	UpdateCount                     int64                   `protobuf:"varint,77,opt,name=update_count,json=updateCount,proto3" json:"update_count,omitempty"`
	AutoResetPoints                 *v11.ResetPoints        `protobuf:"bytes,51,opt,name=auto_reset_points,json=autoResetPoints,proto3" json:"auto_reset_points,omitempty"`
	SearchAttributes                map[string]*v12.Payload `` /* 198-byte string literal not displayed */
	Memo                            map[string]*v12.Payload `` /* 150-byte string literal not displayed */
	VersionHistories                *v13.VersionHistories   `protobuf:"bytes,54,opt,name=version_histories,json=versionHistories,proto3" json:"version_histories,omitempty"`
	FirstExecutionRunId             string                  `protobuf:"bytes,55,opt,name=first_execution_run_id,json=firstExecutionRunId,proto3" json:"first_execution_run_id,omitempty"`
	ExecutionStats                  *ExecutionStats         `protobuf:"bytes,56,opt,name=execution_stats,json=executionStats,proto3" json:"execution_stats,omitempty"`
	WorkflowRunExpirationTime       *time.Time              `` /* 149-byte string literal not displayed */
	// Transaction Id of the first event in the last batch of events.
	LastFirstEventTxnId  int64      `` /* 126-byte string literal not displayed */
	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       *v14.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"`
	CloseVisibilityTaskCompleted bool                   `` /* 151-byte string literal not displayed */
	BaseExecutionInfo            *v15.BaseExecutionInfo `protobuf:"bytes,76,opt,name=base_execution_info,json=baseExecutionInfo,proto3" json:"base_execution_info,omitempty"`
	// If using build-id based versioning: version stamp of the last worker to process a
	// workflow taks for this workflow.
	WorkerVersionStamp *v12.WorkerVersionStamp `protobuf:"bytes,78,opt,name=worker_version_stamp,json=workerVersionStamp,proto3" json:"worker_version_stamp,omitempty"`
	// index of update IDs and pointers to associated history events.
	UpdateInfos map[string]*v16.UpdateInfo `` /* 183-byte string literal not displayed */
}

execution column

func (*WorkflowExecutionInfo) Descriptor 

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

func (*WorkflowExecutionInfo) Equal 

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

func (*WorkflowExecutionInfo) GetActivityCount added in v1.20.1 

func (m *WorkflowExecutionInfo) GetActivityCount() int64

func (*WorkflowExecutionInfo) GetAttempt 

func (m *WorkflowExecutionInfo) GetAttempt() int32

func (*WorkflowExecutionInfo) GetAutoResetPoints 

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

func (*WorkflowExecutionInfo) GetBaseExecutionInfo added in v1.21.0 

func (m *WorkflowExecutionInfo) GetBaseExecutionInfo() *v15.BaseExecutionInfo

func (*WorkflowExecutionInfo) GetCancelRequestId 

func (m *WorkflowExecutionInfo) GetCancelRequestId() string

func (*WorkflowExecutionInfo) GetCancelRequested 

func (m *WorkflowExecutionInfo) GetCancelRequested() bool

func (*WorkflowExecutionInfo) GetChildExecutionCount added in v1.20.1 

func (m *WorkflowExecutionInfo) GetChildExecutionCount() int64

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) GetCloseVisibilityTaskCompleted added in v1.19.0 

func (m *WorkflowExecutionInfo) GetCloseVisibilityTaskCompleted() bool

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]*v12.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() *v14.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) GetRequestCancelExternalCount added in v1.20.1 

func (m *WorkflowExecutionInfo) GetRequestCancelExternalCount() int64

func (*WorkflowExecutionInfo) GetRetryBackoffCoefficient 

func (m *WorkflowExecutionInfo) GetRetryBackoffCoefficient() float64

func (*WorkflowExecutionInfo) GetRetryInitialInterval 

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

func (*WorkflowExecutionInfo) GetRetryMaximumAttempts 

func (m *WorkflowExecutionInfo) GetRetryMaximumAttempts() int32

func (*WorkflowExecutionInfo) GetRetryMaximumInterval 

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

func (*WorkflowExecutionInfo) GetRetryNonRetryableErrorTypes 

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

func (*WorkflowExecutionInfo) GetSearchAttributes 

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

func (*WorkflowExecutionInfo) GetSignalCount 

func (m *WorkflowExecutionInfo) GetSignalCount() int64

func (*WorkflowExecutionInfo) GetSignalExternalCount added in v1.20.1 

func (m *WorkflowExecutionInfo) GetSignalExternalCount() 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) GetUpdateCount added in v1.21.0 

func (m *WorkflowExecutionInfo) GetUpdateCount() int64

func (*WorkflowExecutionInfo) GetUpdateInfos added in v1.21.0 

func (m *WorkflowExecutionInfo) GetUpdateInfos() map[string]*v16.UpdateInfo

func (*WorkflowExecutionInfo) GetUserTimerCount added in v1.20.1 

func (m *WorkflowExecutionInfo) GetUserTimerCount() int64

func (*WorkflowExecutionInfo) GetVersionHistories 

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

func (*WorkflowExecutionInfo) GetWorkerVersionStamp added in v1.21.0 

func (m *WorkflowExecutionInfo) GetWorkerVersionStamp() *v12.WorkerVersionStamp

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) GetWorkflowTaskHistorySizeBytes added in v1.20.0 

func (m *WorkflowExecutionInfo) GetWorkflowTaskHistorySizeBytes() int64

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) GetWorkflowTaskSuggestContinueAsNew added in v1.20.0 

func (m *WorkflowExecutionInfo) GetWorkflowTaskSuggestContinueAsNew() bool

func (*WorkflowExecutionInfo) GetWorkflowTaskTimeout 

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

func (*WorkflowExecutionInfo) GetWorkflowTaskType added in v1.20.0 

func (m *WorkflowExecutionInfo) GetWorkflowTaskType() v1.WorkflowTaskType

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           v1.WorkflowExecutionState   `protobuf:"varint,3,opt,name=state,proto3,enum=temporal.server.api.enums.v1.WorkflowExecutionState" json:"state,omitempty"`
	Status          v17.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() v1.WorkflowExecutionState

func (*WorkflowExecutionState) GetStatus 

func (m *WorkflowExecutionState) GetStatus() v17.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.