taskqueue

package
v0.15.1 Latest Latest
Warning

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

Go to latest
Published: Jun 1, 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL