taskqueue

package
v1.19.0 Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2023 License: MIT Imports: 13 Imported by: 35

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type CompatibleVersionSet added in v1.19.0 

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

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

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

func (*CompatibleVersionSet) Equal added in v1.19.0 

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

func (*CompatibleVersionSet) GetBuildIds added in v1.19.0 

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

func (*CompatibleVersionSet) GetVersionSetId added in v1.19.0 

func (m *CompatibleVersionSet) GetVersionSetId() string

func (*CompatibleVersionSet) GoString added in v1.19.0 

func (this *CompatibleVersionSet) GoString() string

func (*CompatibleVersionSet) Marshal added in v1.19.0 

func (m *CompatibleVersionSet) Marshal() (dAtA []byte, err error)

func (*CompatibleVersionSet) MarshalTo added in v1.19.0 

func (m *CompatibleVersionSet) MarshalTo(dAtA []byte) (int, error)

func (*CompatibleVersionSet) MarshalToSizedBuffer added in v1.19.0 

func (m *CompatibleVersionSet) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CompatibleVersionSet) ProtoMessage added in v1.19.0 

func (*CompatibleVersionSet) ProtoMessage()

func (*CompatibleVersionSet) Reset added in v1.19.0 

func (m *CompatibleVersionSet) Reset()

func (*CompatibleVersionSet) Size added in v1.19.0 

func (m *CompatibleVersionSet) Size() (n int)

func (*CompatibleVersionSet) String added in v1.19.0 

func (this *CompatibleVersionSet) String() string

func (*CompatibleVersionSet) Unmarshal added in v1.19.0 

func (m *CompatibleVersionSet) Unmarshal(dAtA []byte) error

func (*CompatibleVersionSet) XXX_DiscardUnknown added in v1.19.0 

func (m *CompatibleVersionSet) XXX_DiscardUnknown()

func (*CompatibleVersionSet) XXX_Marshal added in v1.19.0 

func (m *CompatibleVersionSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CompatibleVersionSet) XXX_Merge added in v1.19.0 

func (m *CompatibleVersionSet) XXX_Merge(src proto.Message)

func (*CompatibleVersionSet) XXX_Size added in v1.19.0 

func (m *CompatibleVersionSet) XXX_Size() int

func (*CompatibleVersionSet) XXX_Unmarshal added in v1.19.0 

func (m *CompatibleVersionSet) XXX_Unmarshal(b []byte) error

type PollerInfo 

type PollerInfo struct {
	LastAccessTime *time.Time `protobuf:"bytes,1,opt,name=last_access_time,json=lastAccessTime,proto3,stdtime" 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 */
}

func (*PollerInfo) Descriptor 

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

func (*PollerInfo) Equal 

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

func (*PollerInfo) GetIdentity 

func (m *PollerInfo) GetIdentity() string

func (*PollerInfo) GetLastAccessTime 

func (m *PollerInfo) GetLastAccessTime() *time.Time

func (*PollerInfo) GetRatePerSecond 

func (m *PollerInfo) GetRatePerSecond() float64

func (*PollerInfo) GetWorkerVersionCapabilities added in v1.19.0 

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

func (*PollerInfo) GoString 

func (this *PollerInfo) GoString() string

func (*PollerInfo) Marshal 

func (m *PollerInfo) Marshal() (dAtA []byte, err error)

func (*PollerInfo) MarshalTo 

func (m *PollerInfo) MarshalTo(dAtA []byte) (int, error)

func (*PollerInfo) MarshalToSizedBuffer 

func (m *PollerInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PollerInfo) ProtoMessage 

func (*PollerInfo) ProtoMessage()

func (*PollerInfo) Reset 

func (m *PollerInfo) Reset()

func (*PollerInfo) Size 

func (m *PollerInfo) Size() (n int)

func (*PollerInfo) String 

func (this *PollerInfo) String() string

func (*PollerInfo) Unmarshal 

func (m *PollerInfo) Unmarshal(dAtA []byte) error

func (*PollerInfo) XXX_DiscardUnknown 

func (m *PollerInfo) XXX_DiscardUnknown()

func (*PollerInfo) XXX_Marshal 

func (m *PollerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PollerInfo) XXX_Merge 

func (m *PollerInfo) XXX_Merge(src proto.Message)

func (*PollerInfo) XXX_Size 

func (m *PollerInfo) XXX_Size() int

func (*PollerInfo) XXX_Unmarshal 

func (m *PollerInfo) XXX_Unmarshal(b []byte) error

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 *time.Duration `` /* 143-byte string literal not displayed */
}

func (*StickyExecutionAttributes) Descriptor 

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

func (*StickyExecutionAttributes) Equal 

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

func (*StickyExecutionAttributes) GetScheduleToStartTimeout added in v0.28.0 

func (m *StickyExecutionAttributes) GetScheduleToStartTimeout() *time.Duration

func (*StickyExecutionAttributes) GetWorkerTaskQueue 

func (m *StickyExecutionAttributes) GetWorkerTaskQueue() *TaskQueue

func (*StickyExecutionAttributes) GoString 

func (this *StickyExecutionAttributes) GoString() string

func (*StickyExecutionAttributes) Marshal 

func (m *StickyExecutionAttributes) Marshal() (dAtA []byte, err error)

func (*StickyExecutionAttributes) MarshalTo 

func (m *StickyExecutionAttributes) MarshalTo(dAtA []byte) (int, error)

func (*StickyExecutionAttributes) MarshalToSizedBuffer 

func (m *StickyExecutionAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StickyExecutionAttributes) ProtoMessage 

func (*StickyExecutionAttributes) ProtoMessage()

func (*StickyExecutionAttributes) Reset 

func (m *StickyExecutionAttributes) Reset()

func (*StickyExecutionAttributes) Size 

func (m *StickyExecutionAttributes) Size() (n int)

func (*StickyExecutionAttributes) String 

func (this *StickyExecutionAttributes) String() string

func (*StickyExecutionAttributes) Unmarshal 

func (m *StickyExecutionAttributes) Unmarshal(dAtA []byte) error

func (*StickyExecutionAttributes) XXX_DiscardUnknown 

func (m *StickyExecutionAttributes) XXX_DiscardUnknown()

func (*StickyExecutionAttributes) XXX_Marshal 

func (m *StickyExecutionAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StickyExecutionAttributes) XXX_Merge 

func (m *StickyExecutionAttributes) XXX_Merge(src proto.Message)

func (*StickyExecutionAttributes) XXX_Size 

func (m *StickyExecutionAttributes) XXX_Size() int

func (*StickyExecutionAttributes) XXX_Unmarshal 

func (m *StickyExecutionAttributes) XXX_Unmarshal(b []byte) error

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

func (*TaskIdBlock) Descriptor 

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

func (*TaskIdBlock) Equal 

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

func (*TaskIdBlock) GetEndId 

func (m *TaskIdBlock) GetEndId() int64

func (*TaskIdBlock) GetStartId 

func (m *TaskIdBlock) GetStartId() int64

func (*TaskIdBlock) GoString 

func (this *TaskIdBlock) GoString() string

func (*TaskIdBlock) Marshal 

func (m *TaskIdBlock) Marshal() (dAtA []byte, err error)

func (*TaskIdBlock) MarshalTo 

func (m *TaskIdBlock) MarshalTo(dAtA []byte) (int, error)

func (*TaskIdBlock) MarshalToSizedBuffer 

func (m *TaskIdBlock) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TaskIdBlock) ProtoMessage 

func (*TaskIdBlock) ProtoMessage()

func (*TaskIdBlock) Reset 

func (m *TaskIdBlock) Reset()

func (*TaskIdBlock) Size 

func (m *TaskIdBlock) Size() (n int)

func (*TaskIdBlock) String 

func (this *TaskIdBlock) String() string

func (*TaskIdBlock) Unmarshal 

func (m *TaskIdBlock) Unmarshal(dAtA []byte) error

func (*TaskIdBlock) XXX_DiscardUnknown 

func (m *TaskIdBlock) XXX_DiscardUnknown()

func (*TaskIdBlock) XXX_Marshal 

func (m *TaskIdBlock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskIdBlock) XXX_Merge 

func (m *TaskIdBlock) XXX_Merge(src proto.Message)

func (*TaskIdBlock) XXX_Size 

func (m *TaskIdBlock) XXX_Size() int

func (*TaskIdBlock) XXX_Unmarshal 

func (m *TaskIdBlock) XXX_Unmarshal(b []byte) error

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

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

func (*TaskQueue) Descriptor 

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

func (*TaskQueue) Equal 

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

func (*TaskQueue) GetKind 

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

func (*TaskQueue) GetName 

func (m *TaskQueue) GetName() string

func (*TaskQueue) GoString 

func (this *TaskQueue) GoString() string

func (*TaskQueue) Marshal 

func (m *TaskQueue) Marshal() (dAtA []byte, err error)

func (*TaskQueue) MarshalTo 

func (m *TaskQueue) MarshalTo(dAtA []byte) (int, error)

func (*TaskQueue) MarshalToSizedBuffer 

func (m *TaskQueue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TaskQueue) ProtoMessage 

func (*TaskQueue) ProtoMessage()

func (*TaskQueue) Reset 

func (m *TaskQueue) Reset()

func (*TaskQueue) Size 

func (m *TaskQueue) Size() (n int)

func (*TaskQueue) String 

func (this *TaskQueue) String() string

func (*TaskQueue) Unmarshal 

func (m *TaskQueue) Unmarshal(dAtA []byte) error

func (*TaskQueue) XXX_DiscardUnknown 

func (m *TaskQueue) XXX_DiscardUnknown()

func (*TaskQueue) XXX_Marshal 

func (m *TaskQueue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueue) XXX_Merge 

func (m *TaskQueue) XXX_Merge(src proto.Message)

func (*TaskQueue) XXX_Size 

func (m *TaskQueue) XXX_Size() int

func (*TaskQueue) XXX_Unmarshal 

func (m *TaskQueue) XXX_Unmarshal(b []byte) error

type TaskQueueMetadata 

type TaskQueueMetadata struct {
	// Allows throttling dispatch of tasks from this queue
	MaxTasksPerSecond *types.DoubleValue `protobuf:"bytes,1,opt,name=max_tasks_per_second,json=maxTasksPerSecond,proto3" json:"max_tasks_per_second,omitempty"`
}

Only applies to activity task queues

func (*TaskQueueMetadata) Descriptor 

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

func (*TaskQueueMetadata) Equal 

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

func (*TaskQueueMetadata) GetMaxTasksPerSecond 

func (m *TaskQueueMetadata) GetMaxTasksPerSecond() *types.DoubleValue

func (*TaskQueueMetadata) GoString 

func (this *TaskQueueMetadata) GoString() string

func (*TaskQueueMetadata) Marshal 

func (m *TaskQueueMetadata) Marshal() (dAtA []byte, err error)

func (*TaskQueueMetadata) MarshalTo 

func (m *TaskQueueMetadata) MarshalTo(dAtA []byte) (int, error)

func (*TaskQueueMetadata) MarshalToSizedBuffer 

func (m *TaskQueueMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TaskQueueMetadata) ProtoMessage 

func (*TaskQueueMetadata) ProtoMessage()

func (*TaskQueueMetadata) Reset 

func (m *TaskQueueMetadata) Reset()

func (*TaskQueueMetadata) Size 

func (m *TaskQueueMetadata) Size() (n int)

func (*TaskQueueMetadata) String 

func (this *TaskQueueMetadata) String() string

func (*TaskQueueMetadata) Unmarshal 

func (m *TaskQueueMetadata) Unmarshal(dAtA []byte) error

func (*TaskQueueMetadata) XXX_DiscardUnknown 

func (m *TaskQueueMetadata) XXX_DiscardUnknown()

func (*TaskQueueMetadata) XXX_Marshal 

func (m *TaskQueueMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueMetadata) XXX_Merge 

func (m *TaskQueueMetadata) XXX_Merge(src proto.Message)

func (*TaskQueueMetadata) XXX_Size 

func (m *TaskQueueMetadata) XXX_Size() int

func (*TaskQueueMetadata) XXX_Unmarshal 

func (m *TaskQueueMetadata) XXX_Unmarshal(b []byte) error

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

func (*TaskQueuePartitionMetadata) Descriptor 

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

func (*TaskQueuePartitionMetadata) Equal 

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

func (*TaskQueuePartitionMetadata) GetKey 

func (m *TaskQueuePartitionMetadata) GetKey() string

func (*TaskQueuePartitionMetadata) GetOwnerHostName 

func (m *TaskQueuePartitionMetadata) GetOwnerHostName() string

func (*TaskQueuePartitionMetadata) GoString 

func (this *TaskQueuePartitionMetadata) GoString() string

func (*TaskQueuePartitionMetadata) Marshal 

func (m *TaskQueuePartitionMetadata) Marshal() (dAtA []byte, err error)

func (*TaskQueuePartitionMetadata) MarshalTo 

func (m *TaskQueuePartitionMetadata) MarshalTo(dAtA []byte) (int, error)

func (*TaskQueuePartitionMetadata) MarshalToSizedBuffer 

func (m *TaskQueuePartitionMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TaskQueuePartitionMetadata) ProtoMessage 

func (*TaskQueuePartitionMetadata) ProtoMessage()

func (*TaskQueuePartitionMetadata) Reset 

func (m *TaskQueuePartitionMetadata) Reset()

func (*TaskQueuePartitionMetadata) Size 

func (m *TaskQueuePartitionMetadata) Size() (n int)

func (*TaskQueuePartitionMetadata) String 

func (this *TaskQueuePartitionMetadata) String() string

func (*TaskQueuePartitionMetadata) Unmarshal 

func (m *TaskQueuePartitionMetadata) Unmarshal(dAtA []byte) error

func (*TaskQueuePartitionMetadata) XXX_DiscardUnknown 

func (m *TaskQueuePartitionMetadata) XXX_DiscardUnknown()

func (*TaskQueuePartitionMetadata) XXX_Marshal 

func (m *TaskQueuePartitionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueuePartitionMetadata) XXX_Merge 

func (m *TaskQueuePartitionMetadata) XXX_Merge(src proto.Message)

func (*TaskQueuePartitionMetadata) XXX_Size 

func (m *TaskQueuePartitionMetadata) XXX_Size() int

func (*TaskQueuePartitionMetadata) XXX_Unmarshal 

func (m *TaskQueuePartitionMetadata) XXX_Unmarshal(b []byte) error

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

func (*TaskQueueStatus) Descriptor 

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

func (*TaskQueueStatus) Equal 

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

func (*TaskQueueStatus) GetAckLevel 

func (m *TaskQueueStatus) GetAckLevel() int64

func (*TaskQueueStatus) GetBacklogCountHint 

func (m *TaskQueueStatus) GetBacklogCountHint() int64

func (*TaskQueueStatus) GetRatePerSecond 

func (m *TaskQueueStatus) GetRatePerSecond() float64

func (*TaskQueueStatus) GetReadLevel 

func (m *TaskQueueStatus) GetReadLevel() int64

func (*TaskQueueStatus) GetTaskIdBlock 

func (m *TaskQueueStatus) GetTaskIdBlock() *TaskIdBlock

func (*TaskQueueStatus) GoString 

func (this *TaskQueueStatus) GoString() string

func (*TaskQueueStatus) Marshal 

func (m *TaskQueueStatus) Marshal() (dAtA []byte, err error)

func (*TaskQueueStatus) MarshalTo 

func (m *TaskQueueStatus) MarshalTo(dAtA []byte) (int, error)

func (*TaskQueueStatus) MarshalToSizedBuffer 

func (m *TaskQueueStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TaskQueueStatus) ProtoMessage 

func (*TaskQueueStatus) ProtoMessage()

func (*TaskQueueStatus) Reset 

func (m *TaskQueueStatus) Reset()

func (*TaskQueueStatus) Size 

func (m *TaskQueueStatus) Size() (n int)

func (*TaskQueueStatus) String 

func (this *TaskQueueStatus) String() string

func (*TaskQueueStatus) Unmarshal 

func (m *TaskQueueStatus) Unmarshal(dAtA []byte) error

func (*TaskQueueStatus) XXX_DiscardUnknown 

func (m *TaskQueueStatus) XXX_DiscardUnknown()

func (*TaskQueueStatus) XXX_Marshal 

func (m *TaskQueueStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueStatus) XXX_Merge 

func (m *TaskQueueStatus) XXX_Merge(src proto.Message)

func (*TaskQueueStatus) XXX_Size 

func (m *TaskQueueStatus) XXX_Size() int

func (*TaskQueueStatus) XXX_Unmarshal 

func (m *TaskQueueStatus) XXX_Unmarshal(b []byte) error

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.