Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ArtifactTasks = tq.RegisterTaskClass(tq.TaskClass{ ID: "bq-artifact-export", Prototype: &taskspb.ExportInvocationArtifactsToBQ{}, Kind: tq.Transactional, Queue: "bqartifactexports", RoutingPrefix: "/internal/tasks/bqexporter", })
ArtifactTasks describes how to route bq artifact export tasks.
View Source
var TestResultTasks = tq.RegisterTaskClass(tq.TaskClass{ ID: "bq-test-result-export", Prototype: &taskspb.ExportInvocationTestResultsToBQ{}, Kind: tq.Transactional, Queue: "bqtestresultexports", RoutingPrefix: "/internal/tasks/bqexporter", })
TestResultTasks describes how to route bq test result export tasks.
Functions ¶
func InitServer ¶
InitServer initializes a bqexporter server.
Types ¶
type Options ¶
type Options struct {
// Whether to use InsertIDs in BigQuery Streaming Inserts.
UseInsertIDs bool
// Maximum number of rows in a batch.
MaxBatchRowCount int
// Maximum size of a batch in bytes, approximate.
MaxBatchSizeApprox int
// Maximum size of all batches held in memory, approximate.
MaxBatchTotalSizeApprox int
// Maximum rate for BigQuery Streaming Inserts.
RateLimit rate.Limit
// ArtifactRBEInstance is the name of the RBE instance to use for artifact
// storage. Example: "projects/luci-resultdb/instances/artifacts".
ArtifactRBEInstance string
}
Options is bqexporter configuration.
func DefaultOptions ¶
func DefaultOptions() Options
DefaultOptions returns Options with default values.
Source Files
Click to show internal directories.
Click to hide internal directories.