taskqueuev1

package
v1.33.0-20230419173345... Latest Latest
Warning

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

 Go to latest Published: unknown License: MIT Imports: 10 Imported by: 0

Documentation

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 CompatibleVersionSet 

type CompatibleVersionSet struct {

	// A unique identifier for this version set. Users don't need to understand or care about this
	// value, but it has value for debugging purposes.
	VersionSetId string `protobuf:"bytes,1,opt,name=version_set_id,json=versionSetId,proto3" json:"version_set_id,omitempty"`
	// All the compatible versions, ordered from oldest to newest
	BuildIds []string `protobuf:"bytes,2,rep,name=build_ids,json=buildIds,proto3" json:"build_ids,omitempty"`
	// contains filtered or unexported fields
}

Used by the worker versioning APIs, represents an ordering 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 

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

Deprecated: Use CompatibleVersionSet.ProtoReflect.Descriptor instead.

func (*CompatibleVersionSet) GetBuildIds 

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

func (*CompatibleVersionSet) GetVersionSetId 

func (x *CompatibleVersionSet) GetVersionSetId() string

func (*CompatibleVersionSet) ProtoMessage 

func (*CompatibleVersionSet) ProtoMessage()

func (*CompatibleVersionSet) ProtoReflect 

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

func (*CompatibleVersionSet) Reset 

func (x *CompatibleVersionSet) Reset()

func (*CompatibleVersionSet) String 

func (x *CompatibleVersionSet) String() string

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) 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 

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

func (*PollerInfo) ProtoMessage 

func (*PollerInfo) ProtoMessage()

func (*PollerInfo) ProtoReflect 

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

func (*PollerInfo) Reset 

func (x *PollerInfo) Reset()

func (*PollerInfo) String 

func (x *PollerInfo) String() string

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) GetScheduleToStartTimeout 

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

func (*StickyExecutionAttributes) GetWorkerTaskQueue 

func (x *StickyExecutionAttributes) GetWorkerTaskQueue() *TaskQueue

func (*StickyExecutionAttributes) ProtoMessage 

func (*StickyExecutionAttributes) ProtoMessage()

func (*StickyExecutionAttributes) ProtoReflect 

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

func (*StickyExecutionAttributes) Reset 

func (x *StickyExecutionAttributes) Reset()

func (*StickyExecutionAttributes) String 

func (x *StickyExecutionAttributes) String() string

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) GetEndId 

func (x *TaskIdBlock) GetEndId() int64

func (*TaskIdBlock) GetStartId 

func (x *TaskIdBlock) GetStartId() int64

func (*TaskIdBlock) ProtoMessage 

func (*TaskIdBlock) ProtoMessage()

func (*TaskIdBlock) ProtoReflect 

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

func (*TaskIdBlock) Reset 

func (x *TaskIdBlock) Reset()

func (*TaskIdBlock) String 

func (x *TaskIdBlock) String() string

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"`
	// 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) GetKind 

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

func (*TaskQueue) GetName 

func (x *TaskQueue) GetName() string

func (*TaskQueue) ProtoMessage 

func (*TaskQueue) ProtoMessage()

func (*TaskQueue) ProtoReflect 

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

func (*TaskQueue) Reset 

func (x *TaskQueue) Reset()

func (*TaskQueue) String 

func (x *TaskQueue) String() string

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) GetMaxTasksPerSecond 

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

func (*TaskQueueMetadata) ProtoMessage 

func (*TaskQueueMetadata) ProtoMessage()

func (*TaskQueueMetadata) ProtoReflect 

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

func (*TaskQueueMetadata) Reset 

func (x *TaskQueueMetadata) Reset()

func (*TaskQueueMetadata) String 

func (x *TaskQueueMetadata) String() string

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) GetKey 

func (x *TaskQueuePartitionMetadata) GetKey() string

func (*TaskQueuePartitionMetadata) GetOwnerHostName 

func (x *TaskQueuePartitionMetadata) GetOwnerHostName() string

func (*TaskQueuePartitionMetadata) ProtoMessage 

func (*TaskQueuePartitionMetadata) ProtoMessage()

func (*TaskQueuePartitionMetadata) ProtoReflect 

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

func (*TaskQueuePartitionMetadata) Reset 

func (x *TaskQueuePartitionMetadata) Reset()

func (*TaskQueuePartitionMetadata) String 

func (x *TaskQueuePartitionMetadata) String() string

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) 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) ProtoMessage 

func (*TaskQueueStatus) ProtoMessage()

func (*TaskQueueStatus) ProtoReflect 

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

func (*TaskQueueStatus) Reset 

func (x *TaskQueueStatus) Reset()

func (*TaskQueueStatus) String 

func (x *TaskQueueStatus) String() string

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.