taskqueue

package
v1.26.2-124.0 Latest Latest
Warning

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

 Go to latest Published: Nov 9, 2024 License: MIT Imports: 9 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

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      *v1.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() *v1.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                 []*v1.PollerInfo         `protobuf:"bytes,1,rep,name=pollers,proto3" json:"pollers,omitempty"`
	TaskQueueStats          *v1.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() []*v1.PollerInfo

func (*PhysicalTaskQueueInfo) GetTaskQueueStats added in v1.25.0 

func (x *PhysicalTaskQueueInfo) GetTaskQueueStats() *v1.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      v12.TaskSource `` /* 137-byte string literal not displayed */
	// Redirect info is not present for Query and Nexus tasks.
	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.
	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]
	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. 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.

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() v12.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 v11.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() v11.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"`
	// 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) GetBuildId 

func (m *TaskVersionDirective) GetBuildId() isTaskVersionDirective_BuildId

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.