Documentation ¶
Index ¶
- Variables
- type CompatibleVersionSet
- func (*CompatibleVersionSet) Descriptor() ([]byte, []int)deprecated
- func (x *CompatibleVersionSet) GetBuildIds() []string
- func (x *CompatibleVersionSet) GetVersionSetId() string
- func (*CompatibleVersionSet) ProtoMessage()
- func (x *CompatibleVersionSet) ProtoReflect() protoreflect.Message
- func (x *CompatibleVersionSet) Reset()
- func (x *CompatibleVersionSet) String() string
- type PollerInfo
- func (*PollerInfo) Descriptor() ([]byte, []int)deprecated
- func (x *PollerInfo) GetIdentity() string
- func (x *PollerInfo) GetLastAccessTime() *timestamppb.Timestamp
- func (x *PollerInfo) GetRatePerSecond() float64
- func (x *PollerInfo) GetWorkerVersionCapabilities() *v11.WorkerVersionCapabilities
- func (*PollerInfo) ProtoMessage()
- func (x *PollerInfo) ProtoReflect() protoreflect.Message
- func (x *PollerInfo) Reset()
- func (x *PollerInfo) String() string
- type StickyExecutionAttributes
- func (*StickyExecutionAttributes) Descriptor() ([]byte, []int)deprecated
- func (x *StickyExecutionAttributes) GetScheduleToStartTimeout() *durationpb.Duration
- func (x *StickyExecutionAttributes) GetWorkerTaskQueue() *TaskQueue
- func (*StickyExecutionAttributes) ProtoMessage()
- func (x *StickyExecutionAttributes) ProtoReflect() protoreflect.Message
- func (x *StickyExecutionAttributes) Reset()
- func (x *StickyExecutionAttributes) String() string
- type TaskIdBlock
- type TaskQueue
- type TaskQueueMetadata
- func (*TaskQueueMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *TaskQueueMetadata) GetMaxTasksPerSecond() *wrapperspb.DoubleValue
- func (*TaskQueueMetadata) ProtoMessage()
- func (x *TaskQueueMetadata) ProtoReflect() protoreflect.Message
- func (x *TaskQueueMetadata) Reset()
- func (x *TaskQueueMetadata) String() string
- type TaskQueuePartitionMetadata
- func (*TaskQueuePartitionMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *TaskQueuePartitionMetadata) GetKey() string
- func (x *TaskQueuePartitionMetadata) GetOwnerHostName() string
- func (*TaskQueuePartitionMetadata) ProtoMessage()
- func (x *TaskQueuePartitionMetadata) ProtoReflect() protoreflect.Message
- func (x *TaskQueuePartitionMetadata) Reset()
- func (x *TaskQueuePartitionMetadata) String() string
- type TaskQueueStatus
- func (*TaskQueueStatus) Descriptor() ([]byte, []int)deprecated
- func (x *TaskQueueStatus) GetAckLevel() int64
- func (x *TaskQueueStatus) GetBacklogCountHint() int64
- func (x *TaskQueueStatus) GetRatePerSecond() float64
- func (x *TaskQueueStatus) GetReadLevel() int64
- func (x *TaskQueueStatus) GetTaskIdBlock() *TaskIdBlock
- func (*TaskQueueStatus) ProtoMessage()
- func (x *TaskQueueStatus) ProtoReflect() protoreflect.Message
- func (x *TaskQueueStatus) Reset()
- func (x *TaskQueueStatus) String() string
Constants ¶
This section is empty.
Variables ¶
var File_temporal_api_taskqueue_v1_message_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type CompatibleVersionSet ¶
type CompatibleVersionSet struct { // A unique identifier for this version set. Users don't need to understand or care about this // value, but it has value for debugging purposes. VersionSetId string `protobuf:"bytes,1,opt,name=version_set_id,json=versionSetId,proto3" json:"version_set_id,omitempty"` // All the compatible versions, ordered from oldest to newest BuildIds []string `protobuf:"bytes,2,rep,name=build_ids,json=buildIds,proto3" json:"build_ids,omitempty"` // contains filtered or unexported fields }
Used by the worker versioning APIs, represents an ordering of one or more versions which are considered to be compatible with each other. Currently the versions are always worker build ids.
func (*CompatibleVersionSet) Descriptor
deprecated
func (*CompatibleVersionSet) Descriptor() ([]byte, []int)
Deprecated: Use CompatibleVersionSet.ProtoReflect.Descriptor instead.
func (*CompatibleVersionSet) GetBuildIds ¶
func (x *CompatibleVersionSet) GetBuildIds() []string
func (*CompatibleVersionSet) GetVersionSetId ¶
func (x *CompatibleVersionSet) GetVersionSetId() string
func (*CompatibleVersionSet) ProtoMessage ¶
func (*CompatibleVersionSet) ProtoMessage()
func (*CompatibleVersionSet) ProtoReflect ¶
func (x *CompatibleVersionSet) ProtoReflect() protoreflect.Message
func (*CompatibleVersionSet) Reset ¶
func (x *CompatibleVersionSet) Reset()
func (*CompatibleVersionSet) String ¶
func (x *CompatibleVersionSet) String() string
type PollerInfo ¶
type PollerInfo struct { LastAccessTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=last_access_time,json=lastAccessTime,proto3" json:"last_access_time,omitempty"` Identity string `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"` RatePerSecond float64 `protobuf:"fixed64,3,opt,name=rate_per_second,json=ratePerSecond,proto3" json:"rate_per_second,omitempty"` // If a worker has opted into the worker versioning feature while polling, its capabilities will // appear here. WorkerVersionCapabilities *v11.WorkerVersionCapabilities `` /* 138-byte string literal not displayed */ // contains filtered or unexported fields }
func (*PollerInfo) Descriptor
deprecated
func (*PollerInfo) Descriptor() ([]byte, []int)
Deprecated: Use PollerInfo.ProtoReflect.Descriptor instead.
func (*PollerInfo) GetIdentity ¶
func (x *PollerInfo) GetIdentity() string
func (*PollerInfo) GetLastAccessTime ¶
func (x *PollerInfo) GetLastAccessTime() *timestamppb.Timestamp
func (*PollerInfo) GetRatePerSecond ¶
func (x *PollerInfo) GetRatePerSecond() float64
func (*PollerInfo) GetWorkerVersionCapabilities ¶
func (x *PollerInfo) GetWorkerVersionCapabilities() *v11.WorkerVersionCapabilities
func (*PollerInfo) ProtoMessage ¶
func (*PollerInfo) ProtoMessage()
func (*PollerInfo) ProtoReflect ¶
func (x *PollerInfo) ProtoReflect() protoreflect.Message
func (*PollerInfo) Reset ¶
func (x *PollerInfo) Reset()
func (*PollerInfo) String ¶
func (x *PollerInfo) String() string
type StickyExecutionAttributes ¶
type StickyExecutionAttributes struct { WorkerTaskQueue *TaskQueue `protobuf:"bytes,1,opt,name=worker_task_queue,json=workerTaskQueue,proto3" json:"worker_task_queue,omitempty"` // (-- api-linter: core::0140::prepositions=disabled // // aip.dev/not-precedent: "to" is used to indicate interval. --) ScheduleToStartTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */ // contains filtered or unexported fields }
func (*StickyExecutionAttributes) Descriptor
deprecated
func (*StickyExecutionAttributes) Descriptor() ([]byte, []int)
Deprecated: Use StickyExecutionAttributes.ProtoReflect.Descriptor instead.
func (*StickyExecutionAttributes) GetScheduleToStartTimeout ¶
func (x *StickyExecutionAttributes) GetScheduleToStartTimeout() *durationpb.Duration
func (*StickyExecutionAttributes) GetWorkerTaskQueue ¶
func (x *StickyExecutionAttributes) GetWorkerTaskQueue() *TaskQueue
func (*StickyExecutionAttributes) ProtoMessage ¶
func (*StickyExecutionAttributes) ProtoMessage()
func (*StickyExecutionAttributes) ProtoReflect ¶
func (x *StickyExecutionAttributes) ProtoReflect() protoreflect.Message
func (*StickyExecutionAttributes) Reset ¶
func (x *StickyExecutionAttributes) Reset()
func (*StickyExecutionAttributes) String ¶
func (x *StickyExecutionAttributes) String() string
type TaskIdBlock ¶
type TaskIdBlock struct { StartId int64 `protobuf:"varint,1,opt,name=start_id,json=startId,proto3" json:"start_id,omitempty"` EndId int64 `protobuf:"varint,2,opt,name=end_id,json=endId,proto3" json:"end_id,omitempty"` // contains filtered or unexported fields }
func (*TaskIdBlock) Descriptor
deprecated
func (*TaskIdBlock) Descriptor() ([]byte, []int)
Deprecated: Use TaskIdBlock.ProtoReflect.Descriptor instead.
func (*TaskIdBlock) GetEndId ¶
func (x *TaskIdBlock) GetEndId() int64
func (*TaskIdBlock) GetStartId ¶
func (x *TaskIdBlock) GetStartId() int64
func (*TaskIdBlock) ProtoMessage ¶
func (*TaskIdBlock) ProtoMessage()
func (*TaskIdBlock) ProtoReflect ¶
func (x *TaskIdBlock) ProtoReflect() protoreflect.Message
func (*TaskIdBlock) Reset ¶
func (x *TaskIdBlock) Reset()
func (*TaskIdBlock) String ¶
func (x *TaskIdBlock) String() string
type TaskQueue ¶
type TaskQueue struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Default: TASK_QUEUE_KIND_NORMAL. Kind v1.TaskQueueKind `protobuf:"varint,2,opt,name=kind,proto3,enum=temporal.api.enums.v1.TaskQueueKind" json:"kind,omitempty"` // contains filtered or unexported fields }
See https://docs.temporal.io/docs/concepts/task-queues/
func (*TaskQueue) GetKind ¶
func (x *TaskQueue) GetKind() v1.TaskQueueKind
func (*TaskQueue) ProtoReflect ¶
func (x *TaskQueue) ProtoReflect() protoreflect.Message
type TaskQueueMetadata ¶
type TaskQueueMetadata struct { // Allows throttling dispatch of tasks from this queue MaxTasksPerSecond *wrapperspb.DoubleValue `protobuf:"bytes,1,opt,name=max_tasks_per_second,json=maxTasksPerSecond,proto3" json:"max_tasks_per_second,omitempty"` // contains filtered or unexported fields }
Only applies to activity task queues
func (*TaskQueueMetadata) Descriptor
deprecated
func (*TaskQueueMetadata) Descriptor() ([]byte, []int)
Deprecated: Use TaskQueueMetadata.ProtoReflect.Descriptor instead.
func (*TaskQueueMetadata) GetMaxTasksPerSecond ¶
func (x *TaskQueueMetadata) GetMaxTasksPerSecond() *wrapperspb.DoubleValue
func (*TaskQueueMetadata) ProtoMessage ¶
func (*TaskQueueMetadata) ProtoMessage()
func (*TaskQueueMetadata) ProtoReflect ¶
func (x *TaskQueueMetadata) ProtoReflect() protoreflect.Message
func (*TaskQueueMetadata) Reset ¶
func (x *TaskQueueMetadata) Reset()
func (*TaskQueueMetadata) String ¶
func (x *TaskQueueMetadata) String() string
type TaskQueuePartitionMetadata ¶
type TaskQueuePartitionMetadata struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` OwnerHostName string `protobuf:"bytes,2,opt,name=owner_host_name,json=ownerHostName,proto3" json:"owner_host_name,omitempty"` // contains filtered or unexported fields }
func (*TaskQueuePartitionMetadata) Descriptor
deprecated
func (*TaskQueuePartitionMetadata) Descriptor() ([]byte, []int)
Deprecated: Use TaskQueuePartitionMetadata.ProtoReflect.Descriptor instead.
func (*TaskQueuePartitionMetadata) GetKey ¶
func (x *TaskQueuePartitionMetadata) GetKey() string
func (*TaskQueuePartitionMetadata) GetOwnerHostName ¶
func (x *TaskQueuePartitionMetadata) GetOwnerHostName() string
func (*TaskQueuePartitionMetadata) ProtoMessage ¶
func (*TaskQueuePartitionMetadata) ProtoMessage()
func (*TaskQueuePartitionMetadata) ProtoReflect ¶
func (x *TaskQueuePartitionMetadata) ProtoReflect() protoreflect.Message
func (*TaskQueuePartitionMetadata) Reset ¶
func (x *TaskQueuePartitionMetadata) Reset()
func (*TaskQueuePartitionMetadata) String ¶
func (x *TaskQueuePartitionMetadata) String() string
type TaskQueueStatus ¶
type TaskQueueStatus struct { BacklogCountHint int64 `protobuf:"varint,1,opt,name=backlog_count_hint,json=backlogCountHint,proto3" json:"backlog_count_hint,omitempty"` ReadLevel int64 `protobuf:"varint,2,opt,name=read_level,json=readLevel,proto3" json:"read_level,omitempty"` AckLevel int64 `protobuf:"varint,3,opt,name=ack_level,json=ackLevel,proto3" json:"ack_level,omitempty"` RatePerSecond float64 `protobuf:"fixed64,4,opt,name=rate_per_second,json=ratePerSecond,proto3" json:"rate_per_second,omitempty"` TaskIdBlock *TaskIdBlock `protobuf:"bytes,5,opt,name=task_id_block,json=taskIdBlock,proto3" json:"task_id_block,omitempty"` // contains filtered or unexported fields }
func (*TaskQueueStatus) Descriptor
deprecated
func (*TaskQueueStatus) Descriptor() ([]byte, []int)
Deprecated: Use TaskQueueStatus.ProtoReflect.Descriptor instead.
func (*TaskQueueStatus) GetAckLevel ¶
func (x *TaskQueueStatus) GetAckLevel() int64
func (*TaskQueueStatus) GetBacklogCountHint ¶
func (x *TaskQueueStatus) GetBacklogCountHint() int64
func (*TaskQueueStatus) GetRatePerSecond ¶
func (x *TaskQueueStatus) GetRatePerSecond() float64
func (*TaskQueueStatus) GetReadLevel ¶
func (x *TaskQueueStatus) GetReadLevel() int64
func (*TaskQueueStatus) GetTaskIdBlock ¶
func (x *TaskQueueStatus) GetTaskIdBlock() *TaskIdBlock
func (*TaskQueueStatus) ProtoMessage ¶
func (*TaskQueueStatus) ProtoMessage()
func (*TaskQueueStatus) ProtoReflect ¶
func (x *TaskQueueStatus) ProtoReflect() protoreflect.Message
func (*TaskQueueStatus) Reset ¶
func (x *TaskQueueStatus) Reset()
func (*TaskQueueStatus) String ¶
func (x *TaskQueueStatus) String() string