taskspb

Documentation

Overview

Package taskspb contains the definition for LUCI Source Index's task payloads for commit ingestion.

Index

• Variables
• type IngestCommits
  • func (*IngestCommits) Descriptor() ([]byte, []int)
  • func (x *IngestCommits) GetBackfill() bool
  • func (x *IngestCommits) GetCommitish() string
  • func (x *IngestCommits) GetHost() string
  • func (x *IngestCommits) GetPageToken() string
  • func (x *IngestCommits) GetRepository() string
  • func (x *IngestCommits) GetTaskIndex() int64
  • func (*IngestCommits) ProtoMessage()
  • func (x *IngestCommits) ProtoReflect() protoreflect.Message
  • func (x *IngestCommits) Reset()
  • func (x *IngestCommits) String() string

Variables

var File_go_chromium_org_luci_source_index_internal_commitingester_internal_taskspb_tasks_proto protoreflect.FileDescriptor

Types

type IngestCommits

type IngestCommits struct {

	// Required. The gitiles host. Must be a subdomain of `.googlesource.com`
	// (e.g. chromium.googlesource.com).
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Required. The Git project (e.g. chromium/src).
	Repository string `protobuf:"bytes,2,opt,name=repository,proto3" json:"repository,omitempty"`
	// Required. The commit to start the ingestion from. This commit and all of
	// its ancestors will all be ingested.
	//
	// In practice, the ingestion will stop
	//  1. when it reaches a commit that is already ingested, or
	//  2. when it reaches the first commit (the commit with no ancestors).
	//
	// See documentation on proto message `gitiles.Gitiles.LogRequest.commitish`
	// for the list of acceptable values.
	Commitish string `protobuf:"bytes,3,opt,name=commitish,proto3" json:"commitish,omitempty"`
	// The page token value to use when calling Gitiles.Log.
	//   - For the first task, this should be "".
	//   - For subsequent tasks, this is the next_page_token value returned by the
	//     last call.
	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Optional. The task number of IngestCommits task.
	//
	// This is only used for logging/monitoring purpose.
	TaskIndex int64 `protobuf:"varint,5,opt,name=task_index,json=taskIndex,proto3" json:"task_index,omitempty"`
	// Optional. Whether the task should be sent to the backfill task queue, which
	// has lower rate limits and lower SLO target.
	//
	// Defaults to false.
	Backfill bool `protobuf:"varint,6,opt,name=backfill,proto3" json:"backfill,omitempty"`
	// contains filtered or unexported fields
}

Payload of IngestCommits task.

Must be kept in sync with IngestCommitsBackfill.

func (*IngestCommits) Descriptor

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

Deprecated: Use IngestCommits.ProtoReflect.Descriptor instead.

func (*IngestCommits) GetBackfill

func (x *IngestCommits) GetBackfill() bool

func (*IngestCommits) GetCommitish

func (x *IngestCommits) GetCommitish() string

func (*IngestCommits) GetHost

func (x *IngestCommits) GetHost() string

func (*IngestCommits) GetPageToken

func (x *IngestCommits) GetPageToken() string

func (*IngestCommits) GetRepository

func (x *IngestCommits) GetRepository() string

func (*IngestCommits) GetTaskIndex

func (x *IngestCommits) GetTaskIndex() int64

func (*IngestCommits) ProtoMessage

func (*IngestCommits) ProtoMessage()

func (*IngestCommits) ProtoReflect

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

func (*IngestCommits) Reset

func (x *IngestCommits) Reset()

func (*IngestCommits) String

func (x *IngestCommits) String() string