rdb_lib

Documentation

Index

• Constants
• Variables
• func Deserialize(data string) (map[string]*Invocation, error)
• func ParseInvocationIds(invIds []string) ([]string, error)
• type Invocation
• type RdbLib
  • func (rdblib *RdbLib) ApplyExonerations(ctx context.Context, invocationIds []string, ...) error
  • func (rdblib *RdbLib) Exonerate(ctx context.Context, testExonerations []*rdb_pb.TestExoneration) error
  • func (rdblib *RdbLib) ReportMissingTestCases(ctx context.Context, testNames []string, baseVariant map[string]string, ...) error
  • func (rdblib *RdbLib) UploadInvocationArtifacts(ctx context.Context, artifact *rdb_pb.Artifact) error
  • func (rdblib *RdbLib) UploadTestResults(ctx context.Context, rdbStreamConfig *rdb_client.RdbStreamConfig) error

Constants

const (
	// Max size allowed is 500. Keeping it 490 to be safer.
	RpcBatchSize = 490

	// Resultdb service name
	RdbServiceName = "luci.resultdb.v1.Recorder"

	// Artifacts method name
	ArtifactsMethodName = "BatchCreateArtifacts"

	// Test results method name
	TestResultsMethodName = "BatchCreateTestResults"

	// Test exoneration method name
	TestExonerationMethodName = "BatchCreateTestExonerations"

	// Missing test cases upload retries
	MissingTestCasesUploadRetries = 2

	// Rdb query result limit
	RdbQueryResultLimit = 1000
)

const (
	InvocationIdPrefix = "invocations/"
)

Variables

var (
	SupportedResultAdapterFormats = map[string]bool{"gtest": true, "json": true, "single": true, "tast": true, "skylab-test-runner": true, "cros-test-result": true}
)

Functions

func Deserialize

func Deserialize(data string) (map[string]*Invocation, error)

Deserialize deserializes data to Invocation data

func ParseInvocationIds

func ParseInvocationIds(invIds []string) ([]string, error)

ParseInvocationIds returns the invocation ids without InvocationIdPrefix

Types

type Invocation

type Invocation struct {
	// contains filtered or unexported fields
}

type RdbLib

type RdbLib struct {
	CurrentInvocation string
	RdbClient         *rdb_client.RdbClient
}

func (*RdbLib) ApplyExonerations

func (rdblib *RdbLib) ApplyExonerations(ctx context.Context, invocationIds []string, defaultBehavior test_platform.Request_Params_TestExecutionBehavior, behaviorOverrideMap map[string]test_platform.Request_Params_TestExecutionBehavior, variantFilter map[string]string) error

ApplyExonerations applies exoneration to test results

func (*RdbLib) Exonerate

func (rdblib *RdbLib) Exonerate(ctx context.Context, testExonerations []*rdb_pb.TestExoneration) error

Exonerate exonerates test results based on provided exoneration info

func (*RdbLib) ReportMissingTestCases

func (rdblib *RdbLib) ReportMissingTestCases(ctx context.Context, testNames []string, baseVariant map[string]string, buildbucketId string) error

ReportMissingTestCases uploads missing test cases info to rdb

func (*RdbLib) UploadInvocationArtifacts

func (rdblib *RdbLib) UploadInvocationArtifacts(ctx context.Context, artifact *rdb_pb.Artifact) error

UploadInvocationArtifacts uploads invocation artifacts to rdb

func (*RdbLib) UploadTestResults

func (rdblib *RdbLib) UploadTestResults(ctx context.Context, rdbStreamConfig *rdb_client.RdbStreamConfig) error

UploadTestResults uploads test results to rdb