luci: go.chromium.org/luci/server/tq/internal/tqpb Index | Files

package tqpb

import "go.chromium.org/luci/server/tq/internal/tqpb"

Index

Package Files

gen.go payload.pb.go tasks.pb.go

Variables

var File_go_chromium_org_luci_server_tq_internal_tqpb_payload_proto protoreflect.FileDescriptor
var File_go_chromium_org_luci_server_tq_internal_tqpb_tasks_proto protoreflect.FileDescriptor

type Payload Uses

type Payload struct {

    // Fields used for monitoring and logging only.
    TaskClass string               `protobuf:"bytes,1,opt,name=task_class,json=taskClass,proto3" json:"task_class,omitempty"` // corresponding TaskClass.ID
    Created   *timestamp.Timestamp `protobuf:"bytes,2,opt,name=created,proto3" json:"created,omitempty"`                      // when AddTask was called
    // Actual payload. We store them as blobs to avoid depending on Google Cloud
    // raw *.proto files which are not quite trivial to link to without Bazel.
    //
    // Types that are assignable to Payload:
    //	*Payload_CreateTaskRequest
    //	*Payload_PublishRequest
    Payload isPayload_Payload `protobuf_oneof:"payload"`
    // contains filtered or unexported fields
}

Payload is stored inside reminder records.

It is prepared by the dispatcher and consumed by the sweeper and submitters.

func (*Payload) Descriptor Uses

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

Deprecated: Use Payload.ProtoReflect.Descriptor instead.

func (*Payload) GetCreateTaskRequest Uses

func (x *Payload) GetCreateTaskRequest() []byte

func (*Payload) GetCreated Uses

func (x *Payload) GetCreated() *timestamp.Timestamp

func (*Payload) GetPayload Uses

func (m *Payload) GetPayload() isPayload_Payload

func (*Payload) GetPublishRequest Uses

func (x *Payload) GetPublishRequest() []byte

func (*Payload) GetTaskClass Uses

func (x *Payload) GetTaskClass() string

func (*Payload) ProtoMessage Uses

func (*Payload) ProtoMessage()

func (*Payload) ProtoReflect Uses

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

func (*Payload) Reset Uses

func (x *Payload) Reset()

func (*Payload) String Uses

func (x *Payload) String() string

type Payload_CreateTaskRequest Uses

type Payload_CreateTaskRequest struct {
    CreateTaskRequest []byte `protobuf:"bytes,20,opt,name=create_task_request,json=createTaskRequest,proto3,oneof"` // serialized cloud.tasks.v2.CreateTaskRequest
}

type Payload_PublishRequest Uses

type Payload_PublishRequest struct {
    PublishRequest []byte `protobuf:"bytes,21,opt,name=publish_request,json=publishRequest,proto3,oneof"` // serialized pubsub.v1.PublishRequest
}

type SweepTask Uses

type SweepTask struct {

    // DB is an identifier of the database used for reminders.
    //
    // It must be registered in the process that does the sweeping.
    Db  string `protobuf:"bytes,1,opt,name=db,proto3" json:"db,omitempty"`
    // Partition specifies the range of keys to scan as [Low..High).
    //
    // It is a string of the form "<hex-low>_<hex-high>".
    Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
    // Identifies a registered Lessor implementation to grab leases through.
    LessorId string `protobuf:"bytes,3,opt,name=lessor_id,json=lessorId,proto3" json:"lessor_id,omitempty"`
    // Identifier of a lease section ID to grab leases on sub-partitions through.
    LeaseSectionId string `protobuf:"bytes,4,opt,name=lease_section_id,json=leaseSectionId,proto3" json:"lease_section_id,omitempty"`
    // Total number of shards used when this task was generated.
    //
    // Used FYI only in logs.
    ShardCount int32 `protobuf:"varint,5,opt,name=shard_count,json=shardCount,proto3" json:"shard_count,omitempty"`
    // Shard number in the range of [0 .. Shards).
    //
    // Used FYI only in logs.
    ShardIndex int32 `protobuf:"varint,6,opt,name=shard_index,json=shardIndex,proto3" json:"shard_index,omitempty"`
    // Level counts recursion level for monitoring/debugging purposes.
    //
    // The root sweeper triggers tasks at level=0. If there is a big backlog,
    // level=0 task will offload some work to level=1 tasks. level > 1 should not
    // normally happen and indicates either a bug or a very overloaded system.
    //
    // level > 2 won't be executed at all.
    Level int32 `protobuf:"varint,7,opt,name=level,proto3" json:"level,omitempty"`
    // Length of the reminder keys in the partition.
    //
    // Used to figure out the upper bound of the scan. Usually 16.
    KeySpaceBytes int32 `protobuf:"varint,8,opt,name=key_space_bytes,json=keySpaceBytes,proto3" json:"key_space_bytes,omitempty"`
    // Caps maximum number of reminders to process.
    //
    // Usually in hundreds.
    TasksPerScan int32 `protobuf:"varint,9,opt,name=tasks_per_scan,json=tasksPerScan,proto3" json:"tasks_per_scan,omitempty"`
    // Caps the number of follow-up scans.
    //
    // Usually 16.
    SecondaryScanShards int32 `protobuf:"varint,10,opt,name=secondary_scan_shards,json=secondaryScanShards,proto3" json:"secondary_scan_shards,omitempty"`
    // contains filtered or unexported fields
}

SweepTask is used to distribute sweeping work items and options when doing distributed sweeps.

All fields are required.

func (*SweepTask) Descriptor Uses

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

Deprecated: Use SweepTask.ProtoReflect.Descriptor instead.

func (*SweepTask) GetDb Uses

func (x *SweepTask) GetDb() string

func (*SweepTask) GetKeySpaceBytes Uses

func (x *SweepTask) GetKeySpaceBytes() int32

func (*SweepTask) GetLeaseSectionId Uses

func (x *SweepTask) GetLeaseSectionId() string

func (*SweepTask) GetLessorId Uses

func (x *SweepTask) GetLessorId() string

func (*SweepTask) GetLevel Uses

func (x *SweepTask) GetLevel() int32

func (*SweepTask) GetPartition Uses

func (x *SweepTask) GetPartition() string

func (*SweepTask) GetSecondaryScanShards Uses

func (x *SweepTask) GetSecondaryScanShards() int32

func (*SweepTask) GetShardCount Uses

func (x *SweepTask) GetShardCount() int32

func (*SweepTask) GetShardIndex Uses

func (x *SweepTask) GetShardIndex() int32

func (*SweepTask) GetTasksPerScan Uses

func (x *SweepTask) GetTasksPerScan() int32

func (*SweepTask) ProtoMessage Uses

func (*SweepTask) ProtoMessage()

func (*SweepTask) ProtoReflect Uses

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

func (*SweepTask) Reset Uses

func (x *SweepTask) Reset()

func (*SweepTask) String Uses

func (x *SweepTask) String() string

Package tqpb imports 6 packages (graph) and is imported by 3 packages. Updated 2020-09-30. Refresh now. Tools for package owners.