taskqueue

package
v1.26.2-125.1 Latest Latest
Warning

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

 Go to latest Published: Dec 5, 2024 License: MIT Imports: 10 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 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"`
	AckLevel         int64            `protobuf:"varint,2,opt,name=ack_level,json=ackLevel,proto3" json:"ack_level,omitempty"`
	TaskIdBlock      *v12.TaskIdBlock `protobuf:"bytes,3,opt,name=task_id_block,json=taskIdBlock,proto3" json:"task_id_block,omitempty"`
	ReadBufferLength int64            `protobuf:"varint,4,opt,name=read_buffer_length,json=readBufferLength,proto3" json:"read_buffer_length,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) GetReadBufferLength added in v1.26.0 

func (x *InternalTaskQueueStatus) GetReadBufferLength() 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() *v12.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                 []*v12.PollerInfo        `protobuf:"bytes,1,rep,name=pollers,proto3" json:"pollers,omitempty"`
	TaskQueueStats          *v12.TaskQueueStats      `protobuf:"bytes,2,opt,name=task_queue_stats,json=taskQueueStats,proto3" json:"task_queue_stats,omitempty"`
	InternalTaskQueueStatus *InternalTaskQueueStatus `` /* 134-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() []*v12.PollerInfo

func (*PhysicalTaskQueueInfo) GetTaskQueueStats added in v1.25.0 

func (x *PhysicalTaskQueueInfo) GetTaskQueueStats() *v12.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      v13.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() v13.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 assignable 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 (m *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.
	//
	// Types that are assignable 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.
	Deployment *v11.Deployment `protobuf:"bytes,4,opt,name=deployment,proto3" json:"deployment,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 (m *TaskVersionDirective) GetBuildId() isTaskVersionDirective_BuildId

func (*TaskVersionDirective) GetDeployment added in v1.26.2 

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

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"`
}

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.