taskqueue

package
v1.28.0 Latest Latest
Warning

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

 Go to latest Published: Feb 23, 2024 License: MIT Imports: 10 Imported by: 47

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

View Source 
var File_temporal_api_taskqueue_v1_message_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BuildIdReachability added in v1.21.0 

type BuildIdReachability struct {

	// A build id or empty if unversioned.
	BuildId string `protobuf:"bytes,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// Reachability per task queue.
	TaskQueueReachability []*TaskQueueReachability `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

Reachability of tasks for a worker by build id, in one or more task queues.

func (*BuildIdReachability) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use BuildIdReachability.ProtoReflect.Descriptor instead.

func (*BuildIdReachability) Equal added in v1.21.0 

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

Equal returns whether two BuildIdReachability 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 (*BuildIdReachability) GetBuildId added in v1.21.0 

func (x *BuildIdReachability) GetBuildId() string

func (*BuildIdReachability) GetTaskQueueReachability added in v1.21.0 

func (x *BuildIdReachability) GetTaskQueueReachability() []*TaskQueueReachability

func (*BuildIdReachability) Marshal added in v1.21.0 

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

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

func (*BuildIdReachability) ProtoMessage added in v1.21.0 

func (*BuildIdReachability) ProtoMessage()

func (*BuildIdReachability) ProtoReflect added in v1.26.1 

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

func (*BuildIdReachability) Reset added in v1.21.0 

func (x *BuildIdReachability) Reset()

func (*BuildIdReachability) Size added in v1.21.0 

func (val *BuildIdReachability) Size() int

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

func (*BuildIdReachability) String added in v1.21.0 

func (x *BuildIdReachability) String() string

func (*BuildIdReachability) Unmarshal added in v1.21.0 

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

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

type CompatibleVersionSet added in v1.19.0 

type CompatibleVersionSet struct {

	// All the compatible versions, unordered, except for the last element, which is considered the set "default".
	BuildIds []string `protobuf:"bytes,1,rep,name=build_ids,json=buildIds,proto3" json:"build_ids,omitempty"`
	// contains filtered or unexported fields
}

Used by the worker versioning APIs, represents an unordered set of one or more versions which are considered to be compatible with each other. Currently the versions are always worker build IDs.

func (*CompatibleVersionSet) Descriptor deprecated added in v1.19.0 

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

Deprecated: Use CompatibleVersionSet.ProtoReflect.Descriptor instead.

func (*CompatibleVersionSet) Equal added in v1.19.0 

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

Equal returns whether two CompatibleVersionSet 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 (*CompatibleVersionSet) GetBuildIds added in v1.19.0 

func (x *CompatibleVersionSet) GetBuildIds() []string

func (*CompatibleVersionSet) Marshal added in v1.19.0 

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

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

func (*CompatibleVersionSet) ProtoMessage added in v1.19.0 

func (*CompatibleVersionSet) ProtoMessage()

func (*CompatibleVersionSet) ProtoReflect added in v1.26.1 

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

func (*CompatibleVersionSet) Reset added in v1.19.0 

func (x *CompatibleVersionSet) Reset()

func (*CompatibleVersionSet) Size added in v1.19.0 

func (val *CompatibleVersionSet) Size() int

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

func (*CompatibleVersionSet) String added in v1.19.0 

func (x *CompatibleVersionSet) String() string

func (*CompatibleVersionSet) Unmarshal added in v1.19.0 

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

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

type PollerInfo 

type PollerInfo struct {
	LastAccessTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=last_access_time,json=lastAccessTime,proto3" json:"last_access_time,omitempty"`
	Identity       string                 `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
	RatePerSecond  float64                `protobuf:"fixed64,3,opt,name=rate_per_second,json=ratePerSecond,proto3" json:"rate_per_second,omitempty"`
	// If a worker has opted into the worker versioning feature while polling, its capabilities will
	// appear here.
	WorkerVersionCapabilities *v11.WorkerVersionCapabilities `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PollerInfo) Descriptor deprecated 

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

Deprecated: Use PollerInfo.ProtoReflect.Descriptor instead.

func (*PollerInfo) Equal 

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

Equal returns whether two PollerInfo 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 (*PollerInfo) GetIdentity 

func (x *PollerInfo) GetIdentity() string

func (*PollerInfo) GetLastAccessTime 

func (x *PollerInfo) GetLastAccessTime() *timestamppb.Timestamp

func (*PollerInfo) GetRatePerSecond 

func (x *PollerInfo) GetRatePerSecond() float64

func (*PollerInfo) GetWorkerVersionCapabilities added in v1.19.0 

func (x *PollerInfo) GetWorkerVersionCapabilities() *v11.WorkerVersionCapabilities

func (*PollerInfo) Marshal 

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

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

func (*PollerInfo) ProtoMessage 

func (*PollerInfo) ProtoMessage()

func (*PollerInfo) ProtoReflect added in v1.26.1 

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

func (*PollerInfo) Reset 

func (x *PollerInfo) Reset()

func (*PollerInfo) Size 

func (val *PollerInfo) Size() int

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

func (*PollerInfo) String 

func (x *PollerInfo) String() string

func (*PollerInfo) Unmarshal 

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

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

type StickyExecutionAttributes 

type StickyExecutionAttributes struct {
	WorkerTaskQueue *TaskQueue `protobuf:"bytes,1,opt,name=worker_task_queue,json=workerTaskQueue,proto3" json:"worker_task_queue,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToStartTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StickyExecutionAttributes) Descriptor deprecated 

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

Deprecated: Use StickyExecutionAttributes.ProtoReflect.Descriptor instead.

func (*StickyExecutionAttributes) Equal 

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

Equal returns whether two StickyExecutionAttributes 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 (*StickyExecutionAttributes) GetScheduleToStartTimeout added in v0.28.0 

func (x *StickyExecutionAttributes) GetScheduleToStartTimeout() *durationpb.Duration

func (*StickyExecutionAttributes) GetWorkerTaskQueue 

func (x *StickyExecutionAttributes) GetWorkerTaskQueue() *TaskQueue

func (*StickyExecutionAttributes) Marshal 

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

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

func (*StickyExecutionAttributes) ProtoMessage 

func (*StickyExecutionAttributes) ProtoMessage()

func (*StickyExecutionAttributes) ProtoReflect added in v1.26.1 

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

func (*StickyExecutionAttributes) Reset 

func (x *StickyExecutionAttributes) Reset()

func (*StickyExecutionAttributes) Size 

func (val *StickyExecutionAttributes) Size() int

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

func (*StickyExecutionAttributes) String 

func (x *StickyExecutionAttributes) String() string

func (*StickyExecutionAttributes) Unmarshal 

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

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

type TaskIdBlock 

type TaskIdBlock struct {
	StartId int64 `protobuf:"varint,1,opt,name=start_id,json=startId,proto3" json:"start_id,omitempty"`
	EndId   int64 `protobuf:"varint,2,opt,name=end_id,json=endId,proto3" json:"end_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskIdBlock) Descriptor deprecated 

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

Deprecated: Use TaskIdBlock.ProtoReflect.Descriptor instead.

func (*TaskIdBlock) Equal 

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

Equal returns whether two TaskIdBlock 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 (*TaskIdBlock) GetEndId 

func (x *TaskIdBlock) GetEndId() int64

func (*TaskIdBlock) GetStartId 

func (x *TaskIdBlock) GetStartId() int64

func (*TaskIdBlock) Marshal 

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

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

func (*TaskIdBlock) ProtoMessage 

func (*TaskIdBlock) ProtoMessage()

func (*TaskIdBlock) ProtoReflect added in v1.26.1 

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

func (*TaskIdBlock) Reset 

func (x *TaskIdBlock) Reset()

func (*TaskIdBlock) Size 

func (val *TaskIdBlock) Size() int

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

func (*TaskIdBlock) String 

func (x *TaskIdBlock) String() string

func (*TaskIdBlock) Unmarshal 

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

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

type TaskQueue 

type TaskQueue struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Default: TASK_QUEUE_KIND_NORMAL.
	Kind v1.TaskQueueKind `protobuf:"varint,2,opt,name=kind,proto3,enum=temporal.api.enums.v1.TaskQueueKind" json:"kind,omitempty"`
	// Iff kind == TASK_QUEUE_KIND_STICKY, then this field contains the name of
	// the normal task queue that the sticky worker is running on.
	NormalName string `protobuf:"bytes,3,opt,name=normal_name,json=normalName,proto3" json:"normal_name,omitempty"`
	// contains filtered or unexported fields
}

See https://docs.temporal.io/docs/concepts/task-queues/

func (*TaskQueue) Descriptor deprecated 

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

Deprecated: Use TaskQueue.ProtoReflect.Descriptor instead.

func (*TaskQueue) Equal 

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

Equal returns whether two TaskQueue 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 (*TaskQueue) GetKind 

func (x *TaskQueue) GetKind() v1.TaskQueueKind

func (*TaskQueue) GetName 

func (x *TaskQueue) GetName() string

func (*TaskQueue) GetNormalName added in v1.21.0 

func (x *TaskQueue) GetNormalName() string

func (*TaskQueue) Marshal 

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

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

func (*TaskQueue) ProtoMessage 

func (*TaskQueue) ProtoMessage()

func (*TaskQueue) ProtoReflect added in v1.26.1 

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

func (*TaskQueue) Reset 

func (x *TaskQueue) Reset()

func (*TaskQueue) Size 

func (val *TaskQueue) Size() int

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

func (*TaskQueue) String 

func (x *TaskQueue) String() string

func (*TaskQueue) Unmarshal 

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

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

type TaskQueueMetadata 

type TaskQueueMetadata struct {

	// Allows throttling dispatch of tasks from this queue
	MaxTasksPerSecond *wrapperspb.DoubleValue `protobuf:"bytes,1,opt,name=max_tasks_per_second,json=maxTasksPerSecond,proto3" json:"max_tasks_per_second,omitempty"`
	// contains filtered or unexported fields
}

Only applies to activity task queues

func (*TaskQueueMetadata) Descriptor deprecated 

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

Deprecated: Use TaskQueueMetadata.ProtoReflect.Descriptor instead.

func (*TaskQueueMetadata) Equal 

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

Equal returns whether two TaskQueueMetadata 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 (*TaskQueueMetadata) GetMaxTasksPerSecond 

func (x *TaskQueueMetadata) GetMaxTasksPerSecond() *wrapperspb.DoubleValue

func (*TaskQueueMetadata) Marshal 

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

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

func (*TaskQueueMetadata) ProtoMessage 

func (*TaskQueueMetadata) ProtoMessage()

func (*TaskQueueMetadata) ProtoReflect added in v1.26.1 

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

func (*TaskQueueMetadata) Reset 

func (x *TaskQueueMetadata) Reset()

func (*TaskQueueMetadata) Size 

func (val *TaskQueueMetadata) Size() int

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

func (*TaskQueueMetadata) String 

func (x *TaskQueueMetadata) String() string

func (*TaskQueueMetadata) Unmarshal 

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

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

type TaskQueuePartitionMetadata 

type TaskQueuePartitionMetadata struct {
	Key           string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	OwnerHostName string `protobuf:"bytes,2,opt,name=owner_host_name,json=ownerHostName,proto3" json:"owner_host_name,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueuePartitionMetadata) Descriptor deprecated 

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

Deprecated: Use TaskQueuePartitionMetadata.ProtoReflect.Descriptor instead.

func (*TaskQueuePartitionMetadata) Equal 

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

Equal returns whether two TaskQueuePartitionMetadata 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 (*TaskQueuePartitionMetadata) GetKey 

func (x *TaskQueuePartitionMetadata) GetKey() string

func (*TaskQueuePartitionMetadata) GetOwnerHostName 

func (x *TaskQueuePartitionMetadata) GetOwnerHostName() string

func (*TaskQueuePartitionMetadata) Marshal 

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

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

func (*TaskQueuePartitionMetadata) ProtoMessage 

func (*TaskQueuePartitionMetadata) ProtoMessage()

func (*TaskQueuePartitionMetadata) ProtoReflect added in v1.26.1 

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

func (*TaskQueuePartitionMetadata) Reset 

func (x *TaskQueuePartitionMetadata) Reset()

func (*TaskQueuePartitionMetadata) Size 

func (val *TaskQueuePartitionMetadata) Size() int

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

func (*TaskQueuePartitionMetadata) String 

func (x *TaskQueuePartitionMetadata) String() string

func (*TaskQueuePartitionMetadata) Unmarshal 

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

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

type TaskQueueReachability added in v1.21.0 

type TaskQueueReachability struct {
	TaskQueue string `protobuf:"bytes,1,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// Task reachability for a worker in a single task queue.
	// See the TaskReachability docstring for information about each enum variant.
	// If reachability is empty, this worker is considered unreachable in this task queue.
	Reachability []v1.TaskReachability `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

Reachability of tasks for a worker on a single task queue.

func (*TaskQueueReachability) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use TaskQueueReachability.ProtoReflect.Descriptor instead.

func (*TaskQueueReachability) Equal added in v1.21.0 

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

Equal returns whether two TaskQueueReachability 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 (*TaskQueueReachability) GetReachability added in v1.21.0 

func (x *TaskQueueReachability) GetReachability() []v1.TaskReachability

func (*TaskQueueReachability) GetTaskQueue added in v1.21.0 

func (x *TaskQueueReachability) GetTaskQueue() string

func (*TaskQueueReachability) Marshal added in v1.21.0 

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

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

func (*TaskQueueReachability) ProtoMessage added in v1.21.0 

func (*TaskQueueReachability) ProtoMessage()

func (*TaskQueueReachability) ProtoReflect added in v1.26.1 

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

func (*TaskQueueReachability) Reset added in v1.21.0 

func (x *TaskQueueReachability) Reset()

func (*TaskQueueReachability) Size added in v1.21.0 

func (val *TaskQueueReachability) Size() int

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

func (*TaskQueueReachability) String added in v1.21.0 

func (x *TaskQueueReachability) String() string

func (*TaskQueueReachability) Unmarshal added in v1.21.0 

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

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

type TaskQueueStatus 

type TaskQueueStatus struct {
	BacklogCountHint int64        `protobuf:"varint,1,opt,name=backlog_count_hint,json=backlogCountHint,proto3" json:"backlog_count_hint,omitempty"`
	ReadLevel        int64        `protobuf:"varint,2,opt,name=read_level,json=readLevel,proto3" json:"read_level,omitempty"`
	AckLevel         int64        `protobuf:"varint,3,opt,name=ack_level,json=ackLevel,proto3" json:"ack_level,omitempty"`
	RatePerSecond    float64      `protobuf:"fixed64,4,opt,name=rate_per_second,json=ratePerSecond,proto3" json:"rate_per_second,omitempty"`
	TaskIdBlock      *TaskIdBlock `protobuf:"bytes,5,opt,name=task_id_block,json=taskIdBlock,proto3" json:"task_id_block,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueStatus) Descriptor deprecated 

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

Deprecated: Use TaskQueueStatus.ProtoReflect.Descriptor instead.

func (*TaskQueueStatus) Equal 

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

Equal returns whether two TaskQueueStatus 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 (*TaskQueueStatus) GetAckLevel 

func (x *TaskQueueStatus) GetAckLevel() int64

func (*TaskQueueStatus) GetBacklogCountHint 

func (x *TaskQueueStatus) GetBacklogCountHint() int64

func (*TaskQueueStatus) GetRatePerSecond 

func (x *TaskQueueStatus) GetRatePerSecond() float64

func (*TaskQueueStatus) GetReadLevel 

func (x *TaskQueueStatus) GetReadLevel() int64

func (*TaskQueueStatus) GetTaskIdBlock 

func (x *TaskQueueStatus) GetTaskIdBlock() *TaskIdBlock

func (*TaskQueueStatus) Marshal 

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

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

func (*TaskQueueStatus) ProtoMessage 

func (*TaskQueueStatus) ProtoMessage()

func (*TaskQueueStatus) ProtoReflect added in v1.26.1 

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

func (*TaskQueueStatus) Reset 

func (x *TaskQueueStatus) Reset()

func (*TaskQueueStatus) Size 

func (val *TaskQueueStatus) Size() int

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

func (*TaskQueueStatus) String 

func (x *TaskQueueStatus) String() string

func (*TaskQueueStatus) Unmarshal 

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

Unmarshal an object of type TaskQueueStatus 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.