taskqueue

package
v0.14.1 Latest Latest
Warning

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

 Go to latest Published: May 16, 2022 License: MIT Imports: 12 Imported by: 0

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 PollerInfo 

type PollerInfo struct {
	// Unix Nano
	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"`
}

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

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.