Documentation
¶
Overview ¶
Package bqexporter handles the export of test variant analysis results to BigQuery.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client provides methods to export clustered failures to BigQuery via the BigQuery Write API.
func NewClient ¶
NewClient creates a new client for exporting test variant branches via the BigQuery Write API. projectID is the project ID of the GCP project.
type Exporter ¶
type Exporter struct {
// contains filtered or unexported fields
}
Exporter provides methods to export test variant branches to BigQuery.
func NewExporter ¶
func NewExporter(client InsertClient) *Exporter
NewExporter instantiates a new Exporter. The given client is used to insert rows into BigQuery.
type FakeClient ¶
type FakeClient struct {
Insertions []*bqp.TestVariantBranchRow
}
FakeClient represents a fake implementation of the test variant branch exporter, for testing.
func NewFakeClient ¶
func NewFakeClient() *FakeClient
NewFakeClient creates a new FakeClient for exporting test variant branches.
func (*FakeClient) Insert ¶
func (fc *FakeClient) Insert(ctx context.Context, rows []*bqp.TestVariantBranchRow) error
Insert inserts the given rows in BigQuery.
type InsertClient ¶
type InsertClient interface {
// Insert inserts the given rows into BigQuery.
Insert(ctx context.Context, rows []*bqpb.TestVariantBranchRow) error
}
InsertClient defines an interface for inserting TestVariantBranchRow into BigQuery.
type PartialBigQueryRow ¶
type PartialBigQueryRow struct {
// contains filtered or unexported fields
}
PartialBigQueryRow represents a partially constructed BigQuery export row. Call Complete(...) on the row to finish its construction.
func ToPartialBigQueryRow ¶
func ToPartialBigQueryRow(tvb *testvariantbranch.Entry, inputBufferSegments []*inputbuffer.Segment) (PartialBigQueryRow, error)
ToPartialBigQueryRow starts building a BigQuery TestVariantBranchRow. All fields except those dependent on the commit timestamp, (i.e. Version and HasRecentUnexpectedResults) are populated.
inputBufferSegments is the remaining segments in the input buffer of TestVariantBranch, after changepoint analysis and eviction process. Segments are sorted by commit position (lowest/oldest first).
To support re-use of the *testvariantbranch.Entry buffer, no reference to tvb or inputBufferSegments or their fields (except immutable strings) will be retained by this method or its result. (All data will be copied.)
func (PartialBigQueryRow) Complete ¶
func (r PartialBigQueryRow) Complete(commitTimestamp time.Time) *bqpb.TestVariantBranchRow
Complete finishes creating the BigQuery export row, returning it.
type RowInputs ¶
type RowInputs struct {
Rows []PartialBigQueryRow
CommitTimestamp time.Time
}
RowInputs is the contains the rows to be exported to BigQuery, together with the Spanner commit timestamp.
Source Files