taskqueue

package
v1.9.8 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2026 License: MIT Imports: 13 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

View Source 
var File_temporal_server_api_taskqueue_v1_message_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BuildIdRedirectInfo 

type BuildIdRedirectInfo struct {

	// build ID asked by History in the directive or the one calculated based on the assignment rules.
	// this is the source of the redirect rule chain applied. (the target of the redirect rule chain is
	// the poller's build ID reported in WorkerVersionCapabilities)
	AssignedBuildId string `protobuf:"bytes,1,opt,name=assigned_build_id,json=assignedBuildId,proto3" json:"assigned_build_id,omitempty"`
	// contains filtered or unexported fields
}

Information about redirect intention sent by Matching to History in Record*TaskStarted calls. Deprecated.

func (*BuildIdRedirectInfo) Descriptor deprecated 

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

Deprecated: Use BuildIdRedirectInfo.ProtoReflect.Descriptor instead.

func (*BuildIdRedirectInfo) Equal 

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

Equal returns whether two BuildIdRedirectInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*BuildIdRedirectInfo) GetAssignedBuildId 

func (x *BuildIdRedirectInfo) GetAssignedBuildId() string

func (*BuildIdRedirectInfo) Marshal 

func (val *BuildIdRedirectInfo) Marshal() ([]byte, error)

Marshal an object of type BuildIdRedirectInfo to the protobuf v3 wire format

func (*BuildIdRedirectInfo) ProtoMessage 

func (*BuildIdRedirectInfo) ProtoMessage()

func (*BuildIdRedirectInfo) ProtoReflect 

func (x *BuildIdRedirectInfo) ProtoReflect() protoreflect.Message

func (*BuildIdRedirectInfo) Reset 

func (x *BuildIdRedirectInfo) Reset()

func (*BuildIdRedirectInfo) Size 

func (val *BuildIdRedirectInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*BuildIdRedirectInfo) String 

func (x *BuildIdRedirectInfo) String() string

func (*BuildIdRedirectInfo) Unmarshal 

func (val *BuildIdRedirectInfo) Unmarshal(buf []byte) error

Unmarshal an object of type BuildIdRedirectInfo from the protobuf v3 wire format

type EphemeralData 

type EphemeralData struct {
	Partition []*EphemeralData_ByPartition `protobuf:"bytes,1,rep,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

EphemeralData is data that we want to propagate among task queue partitions, but is not persisted. Ephemeral data is propagated alongside "task queue user data", but while user data applies to a task queue family (all queues with the same name, across types), ephemeral data applies only to one type at a time.

func (*EphemeralData) Descriptor deprecated 

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

Deprecated: Use EphemeralData.ProtoReflect.Descriptor instead.

func (*EphemeralData) Equal 

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

Equal returns whether two EphemeralData values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*EphemeralData) GetPartition 

func (x *EphemeralData) GetPartition() []*EphemeralData_ByPartition

func (*EphemeralData) Marshal 

func (val *EphemeralData) Marshal() ([]byte, error)

Marshal an object of type EphemeralData to the protobuf v3 wire format

func (*EphemeralData) ProtoMessage 

func (*EphemeralData) ProtoMessage()

func (*EphemeralData) ProtoReflect 

func (x *EphemeralData) ProtoReflect() protoreflect.Message

func (*EphemeralData) Reset 

func (x *EphemeralData) Reset()

func (*EphemeralData) Size 

func (val *EphemeralData) Size() int

Size returns the size of the object, in bytes, once serialized

func (*EphemeralData) String 

func (x *EphemeralData) String() string

func (*EphemeralData) Unmarshal 

func (val *EphemeralData) Unmarshal(buf []byte) error

Unmarshal an object of type EphemeralData from the protobuf v3 wire format

type EphemeralData_ByPartition 

type EphemeralData_ByPartition struct {
	Partition int32                      `protobuf:"varint,1,opt,name=partition,proto3" json:"partition,omitempty"`
	Version   []*EphemeralData_ByVersion `protobuf:"bytes,2,rep,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*EphemeralData_ByPartition) Descriptor deprecated 

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

Deprecated: Use EphemeralData_ByPartition.ProtoReflect.Descriptor instead.

func (*EphemeralData_ByPartition) GetPartition 

func (x *EphemeralData_ByPartition) GetPartition() int32

func (*EphemeralData_ByPartition) GetVersion 

func (x *EphemeralData_ByPartition) GetVersion() []*EphemeralData_ByVersion

func (*EphemeralData_ByPartition) ProtoMessage 

func (*EphemeralData_ByPartition) ProtoMessage()

func (*EphemeralData_ByPartition) ProtoReflect 

func (x *EphemeralData_ByPartition) ProtoReflect() protoreflect.Message

func (*EphemeralData_ByPartition) Reset 

func (x *EphemeralData_ByPartition) Reset()

func (*EphemeralData_ByPartition) String 

func (x *EphemeralData_ByPartition) String() string

type EphemeralData_ByVersion 

type EphemeralData_ByVersion struct {

	// Key for this data. Data for the unversioned queue has no version field present.
	// All following fields are data associated with this versioned queue.
	Version *v12.WorkerDeploymentVersion `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// This is a bit field of priority levels that have "significant" backlog (defined by
	// the server configuration). Priority key k corresponds to 1<<k.
	BacklogPriorityLevels int64 `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EphemeralData_ByVersion) Descriptor deprecated 

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

Deprecated: Use EphemeralData_ByVersion.ProtoReflect.Descriptor instead.

func (*EphemeralData_ByVersion) GetBacklogPriorityLevels 

func (x *EphemeralData_ByVersion) GetBacklogPriorityLevels() int64

func (*EphemeralData_ByVersion) GetVersion 

func (x *EphemeralData_ByVersion) GetVersion() *v12.WorkerDeploymentVersion

func (*EphemeralData_ByVersion) ProtoMessage 

func (*EphemeralData_ByVersion) ProtoMessage()

func (*EphemeralData_ByVersion) ProtoReflect 

func (x *EphemeralData_ByVersion) ProtoReflect() protoreflect.Message

func (*EphemeralData_ByVersion) Reset 

func (x *EphemeralData_ByVersion) Reset()

func (*EphemeralData_ByVersion) String 

func (x *EphemeralData_ByVersion) String() string

type FairLevel 

type FairLevel struct {
	TaskPass int64 `protobuf:"varint,1,opt,name=task_pass,json=taskPass,proto3" json:"task_pass,omitempty"`
	TaskId   int64 `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*FairLevel) Descriptor deprecated 

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

Deprecated: Use FairLevel.ProtoReflect.Descriptor instead.

func (*FairLevel) Equal 

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

Equal returns whether two FairLevel values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*FairLevel) GetTaskId 

func (x *FairLevel) GetTaskId() int64

func (*FairLevel) GetTaskPass 

func (x *FairLevel) GetTaskPass() int64

func (*FairLevel) Marshal 

func (val *FairLevel) Marshal() ([]byte, error)

Marshal an object of type FairLevel to the protobuf v3 wire format

func (*FairLevel) ProtoMessage 

func (*FairLevel) ProtoMessage()

func (*FairLevel) ProtoReflect 

func (x *FairLevel) ProtoReflect() protoreflect.Message

func (*FairLevel) Reset 

func (x *FairLevel) Reset()

func (*FairLevel) Size 

func (val *FairLevel) Size() int

Size returns the size of the object, in bytes, once serialized

func (*FairLevel) String 

func (x *FairLevel) String() string

func (*FairLevel) Unmarshal 

func (val *FairLevel) Unmarshal(buf []byte) error

Unmarshal an object of type FairLevel from the protobuf v3 wire format

type InternalTaskQueueStatus 

type InternalTaskQueueStatus struct {
	ReadLevel               int64            `protobuf:"varint,1,opt,name=read_level,json=readLevel,proto3" json:"read_level,omitempty"`
	FairReadLevel           *FairLevel       `protobuf:"bytes,7,opt,name=fair_read_level,json=fairReadLevel,proto3" json:"fair_read_level,omitempty"`
	AckLevel                int64            `protobuf:"varint,2,opt,name=ack_level,json=ackLevel,proto3" json:"ack_level,omitempty"`
	FairAckLevel            *FairLevel       `protobuf:"bytes,8,opt,name=fair_ack_level,json=fairAckLevel,proto3" json:"fair_ack_level,omitempty"`
	TaskIdBlock             *v13.TaskIdBlock `protobuf:"bytes,3,opt,name=task_id_block,json=taskIdBlock,proto3" json:"task_id_block,omitempty"`
	LoadedTasks             int64            `protobuf:"varint,4,opt,name=loaded_tasks,json=loadedTasks,proto3" json:"loaded_tasks,omitempty"`
	ApproximateBacklogCount int64            `` /* 133-byte string literal not displayed */
	MaxReadLevel            int64            `protobuf:"varint,6,opt,name=max_read_level,json=maxReadLevel,proto3" json:"max_read_level,omitempty"`
	FairMaxReadLevel        *FairLevel       `protobuf:"bytes,9,opt,name=fair_max_read_level,json=fairMaxReadLevel,proto3" json:"fair_max_read_level,omitempty"`
	// Draining means that this status is from a draining queue.
	Draining bool `protobuf:"varint,10,opt,name=draining,proto3" json:"draining,omitempty"`
	// contains filtered or unexported fields
}

func (*InternalTaskQueueStatus) Descriptor deprecated 

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

Deprecated: Use InternalTaskQueueStatus.ProtoReflect.Descriptor instead.

func (*InternalTaskQueueStatus) Equal 

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

Equal returns whether two InternalTaskQueueStatus values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*InternalTaskQueueStatus) GetAckLevel 

func (x *InternalTaskQueueStatus) GetAckLevel() int64

func (*InternalTaskQueueStatus) GetApproximateBacklogCount 

func (x *InternalTaskQueueStatus) GetApproximateBacklogCount() int64

func (*InternalTaskQueueStatus) GetDraining 

func (x *InternalTaskQueueStatus) GetDraining() bool

func (*InternalTaskQueueStatus) GetFairAckLevel 

func (x *InternalTaskQueueStatus) GetFairAckLevel() *FairLevel

func (*InternalTaskQueueStatus) GetFairMaxReadLevel 

func (x *InternalTaskQueueStatus) GetFairMaxReadLevel() *FairLevel

func (*InternalTaskQueueStatus) GetFairReadLevel 

func (x *InternalTaskQueueStatus) GetFairReadLevel() *FairLevel

func (*InternalTaskQueueStatus) GetLoadedTasks 

func (x *InternalTaskQueueStatus) GetLoadedTasks() int64

func (*InternalTaskQueueStatus) GetMaxReadLevel 

func (x *InternalTaskQueueStatus) GetMaxReadLevel() int64

func (*InternalTaskQueueStatus) GetReadLevel 

func (x *InternalTaskQueueStatus) GetReadLevel() int64

func (*InternalTaskQueueStatus) GetTaskIdBlock 

func (x *InternalTaskQueueStatus) GetTaskIdBlock() *v13.TaskIdBlock

func (*InternalTaskQueueStatus) Marshal 

func (val *InternalTaskQueueStatus) Marshal() ([]byte, error)

Marshal an object of type InternalTaskQueueStatus to the protobuf v3 wire format

func (*InternalTaskQueueStatus) ProtoMessage 

func (*InternalTaskQueueStatus) ProtoMessage()

func (*InternalTaskQueueStatus) ProtoReflect 

func (x *InternalTaskQueueStatus) ProtoReflect() protoreflect.Message

func (*InternalTaskQueueStatus) Reset 

func (x *InternalTaskQueueStatus) Reset()

func (*InternalTaskQueueStatus) Size 

func (val *InternalTaskQueueStatus) Size() int

Size returns the size of the object, in bytes, once serialized

func (*InternalTaskQueueStatus) String 

func (x *InternalTaskQueueStatus) String() string

func (*InternalTaskQueueStatus) Unmarshal 

func (val *InternalTaskQueueStatus) Unmarshal(buf []byte) error

Unmarshal an object of type InternalTaskQueueStatus from the protobuf v3 wire format

type PhysicalTaskQueueInfo 

type PhysicalTaskQueueInfo struct {

	// Unversioned workers (with `useVersioning=false`) are reported in unversioned result even if they set a Build ID.
	Pollers                 []*v13.PollerInfo          `protobuf:"bytes,1,rep,name=pollers,proto3" json:"pollers,omitempty"`
	InternalTaskQueueStatus []*InternalTaskQueueStatus `` /* 134-byte string literal not displayed */
	TaskQueueStats          *v13.TaskQueueStats        `protobuf:"bytes,2,opt,name=task_queue_stats,json=taskQueueStats,proto3" json:"task_queue_stats,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "by" is used to clarify the keys. --)
	TaskQueueStatsByPriorityKey map[int32]*v13.TaskQueueStats `` /* 225-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PhysicalTaskQueueInfo) Descriptor deprecated 

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

Deprecated: Use PhysicalTaskQueueInfo.ProtoReflect.Descriptor instead.

func (*PhysicalTaskQueueInfo) Equal 

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

Equal returns whether two PhysicalTaskQueueInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*PhysicalTaskQueueInfo) GetInternalTaskQueueStatus 

func (x *PhysicalTaskQueueInfo) GetInternalTaskQueueStatus() []*InternalTaskQueueStatus

func (*PhysicalTaskQueueInfo) GetPollers 

func (x *PhysicalTaskQueueInfo) GetPollers() []*v13.PollerInfo

func (*PhysicalTaskQueueInfo) GetTaskQueueStats 

func (x *PhysicalTaskQueueInfo) GetTaskQueueStats() *v13.TaskQueueStats

func (*PhysicalTaskQueueInfo) GetTaskQueueStatsByPriorityKey 

func (x *PhysicalTaskQueueInfo) GetTaskQueueStatsByPriorityKey() map[int32]*v13.TaskQueueStats

func (*PhysicalTaskQueueInfo) Marshal 

func (val *PhysicalTaskQueueInfo) Marshal() ([]byte, error)

Marshal an object of type PhysicalTaskQueueInfo to the protobuf v3 wire format

func (*PhysicalTaskQueueInfo) ProtoMessage 

func (*PhysicalTaskQueueInfo) ProtoMessage()

func (*PhysicalTaskQueueInfo) ProtoReflect 

func (x *PhysicalTaskQueueInfo) ProtoReflect() protoreflect.Message

func (*PhysicalTaskQueueInfo) Reset 

func (x *PhysicalTaskQueueInfo) Reset()

func (*PhysicalTaskQueueInfo) Size 

func (val *PhysicalTaskQueueInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*PhysicalTaskQueueInfo) String 

func (x *PhysicalTaskQueueInfo) String() string

func (*PhysicalTaskQueueInfo) Unmarshal 

func (val *PhysicalTaskQueueInfo) Unmarshal(buf []byte) error

Unmarshal an object of type PhysicalTaskQueueInfo from the protobuf v3 wire format

type TaskForwardInfo 

type TaskForwardInfo struct {

	// RPC name of the partition forwarded the task.
	// In case of multiple hops, this is the source partition of the last hop.
	SourcePartition string         `protobuf:"bytes,1,opt,name=source_partition,json=sourcePartition,proto3" json:"source_partition,omitempty"`
	TaskSource      v14.TaskSource `` /* 137-byte string literal not displayed */
	// The partition where the task was initially forwarded from.
	// Unlike source_partition which gets overwritten at each hop, origin_partition
	// persists across all forwarding hops.
	OriginPartition string `protobuf:"bytes,6,opt,name=origin_partition,json=originPartition,proto3" json:"origin_partition,omitempty"`
	// For tasks that are forwarded, we should keep the original creation time that comes from the
	// source partition. Used for dispatch latency metrics.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Redirect info is not present for Query and Nexus tasks. Versioning decisions for activity/workflow
	// tasks are made at the source partition and sent to the parent partition in this message so that parent partition
	// does not have to make versioning decision again. For Query/Nexus tasks, this works differently as the child's
	// versioning decision is ignored and the parent partition makes a fresh decision.
	// Deprecated. [cleanup-old-wv]
	RedirectInfo *BuildIdRedirectInfo `protobuf:"bytes,3,opt,name=redirect_info,json=redirectInfo,proto3" json:"redirect_info,omitempty"`
	// Build ID that should be used to dispatch the task to. Ignored in Query and Nexus tasks.
	// Deprecated. [cleanup-old-wv]
	DispatchBuildId string `protobuf:"bytes,4,opt,name=dispatch_build_id,json=dispatchBuildId,proto3" json:"dispatch_build_id,omitempty"`
	// Only used for old versioning. [cleanup-old-wv]
	// Deprecated. [cleanup-old-wv]
	DispatchVersionSet string `protobuf:"bytes,5,opt,name=dispatch_version_set,json=dispatchVersionSet,proto3" json:"dispatch_version_set,omitempty"`
	// contains filtered or unexported fields
}

Information about task forwarding from one partition to its parent.

func (*TaskForwardInfo) Descriptor deprecated 

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

Deprecated: Use TaskForwardInfo.ProtoReflect.Descriptor instead.

func (*TaskForwardInfo) Equal 

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

Equal returns whether two TaskForwardInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*TaskForwardInfo) GetCreateTime 

func (x *TaskForwardInfo) GetCreateTime() *timestamppb.Timestamp

func (*TaskForwardInfo) GetDispatchBuildId 

func (x *TaskForwardInfo) GetDispatchBuildId() string

func (*TaskForwardInfo) GetDispatchVersionSet 

func (x *TaskForwardInfo) GetDispatchVersionSet() string

func (*TaskForwardInfo) GetOriginPartition 

func (x *TaskForwardInfo) GetOriginPartition() string

func (*TaskForwardInfo) GetRedirectInfo 

func (x *TaskForwardInfo) GetRedirectInfo() *BuildIdRedirectInfo

func (*TaskForwardInfo) GetSourcePartition 

func (x *TaskForwardInfo) GetSourcePartition() string

func (*TaskForwardInfo) GetTaskSource 

func (x *TaskForwardInfo) GetTaskSource() v14.TaskSource

func (*TaskForwardInfo) Marshal 

func (val *TaskForwardInfo) Marshal() ([]byte, error)

Marshal an object of type TaskForwardInfo to the protobuf v3 wire format

func (*TaskForwardInfo) ProtoMessage 

func (*TaskForwardInfo) ProtoMessage()

func (*TaskForwardInfo) ProtoReflect 

func (x *TaskForwardInfo) ProtoReflect() protoreflect.Message

func (*TaskForwardInfo) Reset 

func (x *TaskForwardInfo) Reset()

func (*TaskForwardInfo) Size 

func (val *TaskForwardInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*TaskForwardInfo) String 

func (x *TaskForwardInfo) String() string

func (*TaskForwardInfo) Unmarshal 

func (val *TaskForwardInfo) Unmarshal(buf []byte) error

Unmarshal an object of type TaskForwardInfo from the protobuf v3 wire format

type TaskQueuePartition 

type TaskQueuePartition struct {

	// This is the user-facing name for this task queue
	TaskQueue     string           `protobuf:"bytes,1,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	TaskQueueType v1.TaskQueueType `` /* 144-byte string literal not displayed */
	// Absent means normal root partition (normal_partition_id=0)
	//
	// Types that are valid to be assigned to PartitionId:
	//
	//	*TaskQueuePartition_NormalPartitionId
	//	*TaskQueuePartition_StickyName
	PartitionId isTaskQueuePartition_PartitionId `protobuf_oneof:"partition_id"`
	// contains filtered or unexported fields
}

Represents a normal or sticky partition of a task queue.

func (*TaskQueuePartition) Descriptor deprecated 

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

Deprecated: Use TaskQueuePartition.ProtoReflect.Descriptor instead.

func (*TaskQueuePartition) Equal 

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

Equal returns whether two TaskQueuePartition values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*TaskQueuePartition) GetNormalPartitionId 

func (x *TaskQueuePartition) GetNormalPartitionId() int32

func (*TaskQueuePartition) GetPartitionId 

func (x *TaskQueuePartition) GetPartitionId() isTaskQueuePartition_PartitionId

func (*TaskQueuePartition) GetStickyName 

func (x *TaskQueuePartition) GetStickyName() string

func (*TaskQueuePartition) GetTaskQueue 

func (x *TaskQueuePartition) GetTaskQueue() string

func (*TaskQueuePartition) GetTaskQueueType 

func (x *TaskQueuePartition) GetTaskQueueType() v1.TaskQueueType

func (*TaskQueuePartition) Marshal 

func (val *TaskQueuePartition) Marshal() ([]byte, error)

Marshal an object of type TaskQueuePartition to the protobuf v3 wire format

func (*TaskQueuePartition) ProtoMessage 

func (*TaskQueuePartition) ProtoMessage()

func (*TaskQueuePartition) ProtoReflect 

func (x *TaskQueuePartition) ProtoReflect() protoreflect.Message

func (*TaskQueuePartition) Reset 

func (x *TaskQueuePartition) Reset()

func (*TaskQueuePartition) Size 

func (val *TaskQueuePartition) Size() int

Size returns the size of the object, in bytes, once serialized

func (*TaskQueuePartition) String 

func (x *TaskQueuePartition) String() string

func (*TaskQueuePartition) Unmarshal 

func (val *TaskQueuePartition) Unmarshal(buf []byte) error

Unmarshal an object of type TaskQueuePartition from the protobuf v3 wire format

type TaskQueuePartition_NormalPartitionId 

type TaskQueuePartition_NormalPartitionId struct {
	NormalPartitionId int32 `protobuf:"varint,3,opt,name=normal_partition_id,json=normalPartitionId,proto3,oneof"`
}

type TaskQueuePartition_StickyName 

type TaskQueuePartition_StickyName struct {
	StickyName string `protobuf:"bytes,4,opt,name=sticky_name,json=stickyName,proto3,oneof"`
}

type TaskQueueVersionInfoInternal 

type TaskQueueVersionInfoInternal struct {
	PhysicalTaskQueueInfo *PhysicalTaskQueueInfo `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TaskQueueVersionInfoInternal) Descriptor deprecated 

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

Deprecated: Use TaskQueueVersionInfoInternal.ProtoReflect.Descriptor instead.

func (*TaskQueueVersionInfoInternal) Equal 

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

Equal returns whether two TaskQueueVersionInfoInternal values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*TaskQueueVersionInfoInternal) GetPhysicalTaskQueueInfo 

func (x *TaskQueueVersionInfoInternal) GetPhysicalTaskQueueInfo() *PhysicalTaskQueueInfo

func (*TaskQueueVersionInfoInternal) Marshal 

func (val *TaskQueueVersionInfoInternal) Marshal() ([]byte, error)

Marshal an object of type TaskQueueVersionInfoInternal to the protobuf v3 wire format

func (*TaskQueueVersionInfoInternal) ProtoMessage 

func (*TaskQueueVersionInfoInternal) ProtoMessage()

func (*TaskQueueVersionInfoInternal) ProtoReflect 

func (x *TaskQueueVersionInfoInternal) ProtoReflect() protoreflect.Message

func (*TaskQueueVersionInfoInternal) Reset 

func (x *TaskQueueVersionInfoInternal) Reset()

func (*TaskQueueVersionInfoInternal) Size 

func (val *TaskQueueVersionInfoInternal) Size() int

Size returns the size of the object, in bytes, once serialized

func (*TaskQueueVersionInfoInternal) String 

func (x *TaskQueueVersionInfoInternal) String() string

func (*TaskQueueVersionInfoInternal) Unmarshal 

func (val *TaskQueueVersionInfoInternal) Unmarshal(buf []byte) error

Unmarshal an object of type TaskQueueVersionInfoInternal from the protobuf v3 wire format

type TaskVersionDirective 

type TaskVersionDirective struct {

	// Default (if build_id is not present) is "unversioned":
	// Use the unversioned task queue, even if the task queue has versioning data.
	// Absent value means the task is the non-starting task of an unversioned execution so it should remain unversioned.
	// Deprecated. Use deployment_version.
	//
	// Types that are valid to be assigned to BuildId:
	//
	//	*TaskVersionDirective_UseAssignmentRules
	//	*TaskVersionDirective_AssignedBuildId
	BuildId isTaskVersionDirective_BuildId `protobuf_oneof:"build_id"`
	// Workflow's effective behavior when the task is scheduled.
	Behavior v1.VersioningBehavior `protobuf:"varint,3,opt,name=behavior,proto3,enum=temporal.api.enums.v1.VersioningBehavior" json:"behavior,omitempty"`
	// Workflow's effective deployment when the task is scheduled.
	// Deprecated. Use deployment_version.
	Deployment *v11.Deployment `protobuf:"bytes,4,opt,name=deployment,proto3" json:"deployment,omitempty"`
	// Workflow's effective deployment version when the task is scheduled.
	DeploymentVersion *v12.WorkerDeploymentVersion `protobuf:"bytes,5,opt,name=deployment_version,json=deploymentVersion,proto3" json:"deployment_version,omitempty"`
	// Counter copied from the workflow execution's WorkflowExecutionVersioningInfo
	// during enqueue time.
	RevisionNumber int64 `protobuf:"varint,6,opt,name=revision_number,json=revisionNumber,proto3" json:"revision_number,omitempty"`
	// contains filtered or unexported fields
}

TaskVersionDirective controls how matching should direct a task.

func (*TaskVersionDirective) Descriptor deprecated 

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

Deprecated: Use TaskVersionDirective.ProtoReflect.Descriptor instead.

func (*TaskVersionDirective) Equal 

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

Equal returns whether two TaskVersionDirective values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*TaskVersionDirective) GetAssignedBuildId 

func (x *TaskVersionDirective) GetAssignedBuildId() string

func (*TaskVersionDirective) GetBehavior 

func (x *TaskVersionDirective) GetBehavior() v1.VersioningBehavior

func (*TaskVersionDirective) GetBuildId 

func (x *TaskVersionDirective) GetBuildId() isTaskVersionDirective_BuildId

func (*TaskVersionDirective) GetDeployment 

func (x *TaskVersionDirective) GetDeployment() *v11.Deployment

func (*TaskVersionDirective) GetDeploymentVersion 

func (x *TaskVersionDirective) GetDeploymentVersion() *v12.WorkerDeploymentVersion

func (*TaskVersionDirective) GetRevisionNumber 

func (x *TaskVersionDirective) GetRevisionNumber() int64

func (*TaskVersionDirective) GetUseAssignmentRules 

func (x *TaskVersionDirective) GetUseAssignmentRules() *emptypb.Empty

func (*TaskVersionDirective) Marshal 

func (val *TaskVersionDirective) Marshal() ([]byte, error)

Marshal an object of type TaskVersionDirective to the protobuf v3 wire format

func (*TaskVersionDirective) ProtoMessage 

func (*TaskVersionDirective) ProtoMessage()

func (*TaskVersionDirective) ProtoReflect 

func (x *TaskVersionDirective) ProtoReflect() protoreflect.Message

func (*TaskVersionDirective) Reset 

func (x *TaskVersionDirective) Reset()

func (*TaskVersionDirective) Size 

func (val *TaskVersionDirective) Size() int

Size returns the size of the object, in bytes, once serialized

func (*TaskVersionDirective) String 

func (x *TaskVersionDirective) String() string

func (*TaskVersionDirective) Unmarshal 

func (val *TaskVersionDirective) Unmarshal(buf []byte) error

Unmarshal an object of type TaskVersionDirective from the protobuf v3 wire format

type TaskVersionDirective_AssignedBuildId 

type TaskVersionDirective_AssignedBuildId struct {
	// This means the task is already assigned to `build_id`
	// WV1: If assigned_build_id is present, use the default version in the compatible set
	// containing this build ID. [cleanup-old-wv]
	AssignedBuildId string `protobuf:"bytes,2,opt,name=assigned_build_id,json=assignedBuildId,proto3,oneof"`
}

type TaskVersionDirective_UseAssignmentRules 

type TaskVersionDirective_UseAssignmentRules struct {
	// If use_assignment_rules is present, matching should use the assignment rules
	// to determine the build ID.
	// WV1: the task should be assigned the default version for the task queue. [cleanup-old-wv]
	UseAssignmentRules *emptypb.Empty `protobuf:"bytes,1,opt,name=use_assignment_rules,json=useAssignmentRules,proto3,oneof"`
}

type VersionedEphemeralData 

type VersionedEphemeralData struct {
	Data    *EphemeralData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Version int64          `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionedEphemeralData) Descriptor deprecated 

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

Deprecated: Use VersionedEphemeralData.ProtoReflect.Descriptor instead.

func (*VersionedEphemeralData) Equal 

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

Equal returns whether two VersionedEphemeralData values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*VersionedEphemeralData) GetData 

func (x *VersionedEphemeralData) GetData() *EphemeralData

func (*VersionedEphemeralData) GetVersion 

func (x *VersionedEphemeralData) GetVersion() int64

func (*VersionedEphemeralData) Marshal 

func (val *VersionedEphemeralData) Marshal() ([]byte, error)

Marshal an object of type VersionedEphemeralData to the protobuf v3 wire format

func (*VersionedEphemeralData) ProtoMessage 

func (*VersionedEphemeralData) ProtoMessage()

func (*VersionedEphemeralData) ProtoReflect 

func (x *VersionedEphemeralData) ProtoReflect() protoreflect.Message

func (*VersionedEphemeralData) Reset 

func (x *VersionedEphemeralData) Reset()

func (*VersionedEphemeralData) Size 

func (val *VersionedEphemeralData) Size() int

Size returns the size of the object, in bytes, once serialized

func (*VersionedEphemeralData) String 

func (x *VersionedEphemeralData) String() string

func (*VersionedEphemeralData) Unmarshal 

func (val *VersionedEphemeralData) Unmarshal(buf []byte) error

Unmarshal an object of type VersionedEphemeralData from the protobuf v3 wire format

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.