taskqueue

package
v1.30.0-149.0 Latest Latest
Warning

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

 Go to latest Published: Jan 24, 2026 License: MIT Imports: 12 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 added in v1.25.0 

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

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

Deprecated: Use BuildIdRedirectInfo.ProtoReflect.Descriptor instead.

func (*BuildIdRedirectInfo) Equal added in v1.25.0 

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

func (x *BuildIdRedirectInfo) GetAssignedBuildId() string

func (*BuildIdRedirectInfo) Marshal added in v1.25.0 

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

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

func (*BuildIdRedirectInfo) ProtoMessage added in v1.25.0 

func (*BuildIdRedirectInfo) ProtoMessage()

func (*BuildIdRedirectInfo) ProtoReflect added in v1.25.0 

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

func (*BuildIdRedirectInfo) Reset added in v1.25.0 

func (x *BuildIdRedirectInfo) Reset()

func (*BuildIdRedirectInfo) Size added in v1.25.0 

func (val *BuildIdRedirectInfo) Size() int

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

func (*BuildIdRedirectInfo) String added in v1.25.0 

func (x *BuildIdRedirectInfo) String() string

func (*BuildIdRedirectInfo) Unmarshal added in v1.25.0 

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

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

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

Deprecated: Use FairLevel.ProtoReflect.Descriptor instead.

func (*FairLevel) Equal added in v1.29.0 

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

func (x *FairLevel) GetTaskId() int64

func (*FairLevel) GetTaskPass added in v1.29.0 

func (x *FairLevel) GetTaskPass() int64

func (*FairLevel) Marshal added in v1.29.0 

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

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

func (*FairLevel) ProtoMessage added in v1.29.0 

func (*FairLevel) ProtoMessage()

func (*FairLevel) ProtoReflect added in v1.29.0 

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

func (*FairLevel) Reset added in v1.29.0 

func (x *FairLevel) Reset()

func (*FairLevel) Size added in v1.29.0 

func (val *FairLevel) Size() int

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

func (*FairLevel) String added in v1.29.0 

func (x *FairLevel) String() string

func (*FairLevel) Unmarshal added in v1.29.0 

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

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

type InternalTaskQueueStatus added in v1.26.0 

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

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

Deprecated: Use InternalTaskQueueStatus.ProtoReflect.Descriptor instead.

func (*InternalTaskQueueStatus) Equal added in v1.26.0 

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

func (x *InternalTaskQueueStatus) GetAckLevel() int64

func (*InternalTaskQueueStatus) GetApproximateBacklogCount added in v1.28.0 

func (x *InternalTaskQueueStatus) GetApproximateBacklogCount() int64

func (*InternalTaskQueueStatus) GetDraining 

func (x *InternalTaskQueueStatus) GetDraining() bool

func (*InternalTaskQueueStatus) GetFairAckLevel added in v1.29.0 

func (x *InternalTaskQueueStatus) GetFairAckLevel() *FairLevel

func (*InternalTaskQueueStatus) GetFairMaxReadLevel added in v1.29.0 

func (x *InternalTaskQueueStatus) GetFairMaxReadLevel() *FairLevel

func (*InternalTaskQueueStatus) GetFairReadLevel added in v1.29.0 

func (x *InternalTaskQueueStatus) GetFairReadLevel() *FairLevel

func (*InternalTaskQueueStatus) GetLoadedTasks added in v1.28.0 

func (x *InternalTaskQueueStatus) GetLoadedTasks() int64

func (*InternalTaskQueueStatus) GetMaxReadLevel added in v1.28.0 

func (x *InternalTaskQueueStatus) GetMaxReadLevel() int64

func (*InternalTaskQueueStatus) GetReadLevel added in v1.26.0 

func (x *InternalTaskQueueStatus) GetReadLevel() int64

func (*InternalTaskQueueStatus) GetTaskIdBlock added in v1.26.0 

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

func (*InternalTaskQueueStatus) Marshal added in v1.26.0 

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

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

func (*InternalTaskQueueStatus) ProtoMessage added in v1.26.0 

func (*InternalTaskQueueStatus) ProtoMessage()

func (*InternalTaskQueueStatus) ProtoReflect added in v1.26.0 

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

func (*InternalTaskQueueStatus) Reset added in v1.26.0 

func (x *InternalTaskQueueStatus) Reset()

func (*InternalTaskQueueStatus) Size added in v1.26.0 

func (val *InternalTaskQueueStatus) Size() int

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

func (*InternalTaskQueueStatus) String added in v1.26.0 

func (x *InternalTaskQueueStatus) String() string

func (*InternalTaskQueueStatus) Unmarshal added in v1.26.0 

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

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

type PhysicalTaskQueueInfo added in v1.24.0 

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

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

Deprecated: Use PhysicalTaskQueueInfo.ProtoReflect.Descriptor instead.

func (*PhysicalTaskQueueInfo) Equal added in v1.24.0 

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

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

func (*PhysicalTaskQueueInfo) GetPollers added in v1.24.0 

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

func (*PhysicalTaskQueueInfo) GetTaskQueueStats added in v1.25.0 

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

func (*PhysicalTaskQueueInfo) GetTaskQueueStatsByPriorityKey added in v1.29.0 

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

func (*PhysicalTaskQueueInfo) Marshal added in v1.24.0 

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

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

func (*PhysicalTaskQueueInfo) ProtoMessage added in v1.24.0 

func (*PhysicalTaskQueueInfo) ProtoMessage()

func (*PhysicalTaskQueueInfo) ProtoReflect added in v1.24.0 

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

func (*PhysicalTaskQueueInfo) Reset added in v1.24.0 

func (x *PhysicalTaskQueueInfo) Reset()

func (*PhysicalTaskQueueInfo) Size added in v1.24.0 

func (val *PhysicalTaskQueueInfo) Size() int

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

func (*PhysicalTaskQueueInfo) String added in v1.24.0 

func (x *PhysicalTaskQueueInfo) String() string

func (*PhysicalTaskQueueInfo) Unmarshal added in v1.24.0 

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

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

type TaskForwardInfo added in v1.25.0 

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 */
	// 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 added in v1.25.0 

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

Deprecated: Use TaskForwardInfo.ProtoReflect.Descriptor instead.

func (*TaskForwardInfo) Equal added in v1.25.0 

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) GetDispatchBuildId added in v1.25.0 

func (x *TaskForwardInfo) GetDispatchBuildId() string

func (*TaskForwardInfo) GetDispatchVersionSet added in v1.25.0 

func (x *TaskForwardInfo) GetDispatchVersionSet() string

func (*TaskForwardInfo) GetRedirectInfo added in v1.25.0 

func (x *TaskForwardInfo) GetRedirectInfo() *BuildIdRedirectInfo

func (*TaskForwardInfo) GetSourcePartition added in v1.25.0 

func (x *TaskForwardInfo) GetSourcePartition() string

func (*TaskForwardInfo) GetTaskSource added in v1.25.0 

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

func (*TaskForwardInfo) Marshal added in v1.25.0 

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

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

func (*TaskForwardInfo) ProtoMessage added in v1.25.0 

func (*TaskForwardInfo) ProtoMessage()

func (*TaskForwardInfo) ProtoReflect added in v1.25.0 

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

func (*TaskForwardInfo) Reset added in v1.25.0 

func (x *TaskForwardInfo) Reset()

func (*TaskForwardInfo) Size added in v1.25.0 

func (val *TaskForwardInfo) Size() int

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

func (*TaskForwardInfo) String added in v1.25.0 

func (x *TaskForwardInfo) String() string

func (*TaskForwardInfo) Unmarshal added in v1.25.0 

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

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

type TaskQueuePartition added in v1.24.0 

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

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

Deprecated: Use TaskQueuePartition.ProtoReflect.Descriptor instead.

func (*TaskQueuePartition) Equal added in v1.24.0 

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

func (x *TaskQueuePartition) GetNormalPartitionId() int32

func (*TaskQueuePartition) GetPartitionId added in v1.24.0 

func (x *TaskQueuePartition) GetPartitionId() isTaskQueuePartition_PartitionId

func (*TaskQueuePartition) GetStickyName added in v1.24.0 

func (x *TaskQueuePartition) GetStickyName() string

func (*TaskQueuePartition) GetTaskQueue added in v1.24.0 

func (x *TaskQueuePartition) GetTaskQueue() string

func (*TaskQueuePartition) GetTaskQueueType added in v1.24.0 

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

func (*TaskQueuePartition) Marshal added in v1.24.0 

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

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

func (*TaskQueuePartition) ProtoMessage added in v1.24.0 

func (*TaskQueuePartition) ProtoMessage()

func (*TaskQueuePartition) ProtoReflect added in v1.24.0 

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

func (*TaskQueuePartition) Reset added in v1.24.0 

func (x *TaskQueuePartition) Reset()

func (*TaskQueuePartition) Size added in v1.24.0 

func (val *TaskQueuePartition) Size() int

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

func (*TaskQueuePartition) String added in v1.24.0 

func (x *TaskQueuePartition) String() string

func (*TaskQueuePartition) Unmarshal added in v1.24.0 

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

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

type TaskQueuePartition_NormalPartitionId added in v1.24.0 

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

type TaskQueuePartition_StickyName added in v1.24.0 

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

type TaskQueueVersionInfoInternal added in v1.24.0 

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

func (*TaskQueueVersionInfoInternal) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use TaskQueueVersionInfoInternal.ProtoReflect.Descriptor instead.

func (*TaskQueueVersionInfoInternal) Equal added in v1.24.0 

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

func (x *TaskQueueVersionInfoInternal) GetPhysicalTaskQueueInfo() *PhysicalTaskQueueInfo

func (*TaskQueueVersionInfoInternal) Marshal added in v1.24.0 

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

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

func (*TaskQueueVersionInfoInternal) ProtoMessage added in v1.24.0 

func (*TaskQueueVersionInfoInternal) ProtoMessage()

func (*TaskQueueVersionInfoInternal) ProtoReflect added in v1.24.0 

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

func (*TaskQueueVersionInfoInternal) Reset added in v1.24.0 

func (x *TaskQueueVersionInfoInternal) Reset()

func (*TaskQueueVersionInfoInternal) Size added in v1.24.0 

func (val *TaskQueueVersionInfoInternal) Size() int

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

func (*TaskQueueVersionInfoInternal) String added in v1.24.0 

func (x *TaskQueueVersionInfoInternal) String() string

func (*TaskQueueVersionInfoInternal) Unmarshal added in v1.24.0 

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

func (x *TaskVersionDirective) GetAssignedBuildId() string

func (*TaskVersionDirective) GetBehavior added in v1.26.2 

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

func (*TaskVersionDirective) GetBuildId 

func (x *TaskVersionDirective) GetBuildId() isTaskVersionDirective_BuildId

func (*TaskVersionDirective) GetDeployment added in v1.26.2 

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

func (*TaskVersionDirective) GetDeploymentVersion added in v1.27.0 

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

func (*TaskVersionDirective) GetRevisionNumber 

func (x *TaskVersionDirective) GetRevisionNumber() int64

func (*TaskVersionDirective) GetUseAssignmentRules added in v1.24.0 

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

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

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

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.