sharding

Documentation

Overview

Package sharding implements the test sharding algorithm.

Index

• type Shard
  • func ComputeAlpha(tests []*driver.BundleEntity, shardIndex, totalShards int) *Shard
  • func ComputeHash(tests []*driver.BundleEntity, shardIndex, totalShards int) *Shard

Types

type Shard

type Shard struct {
	// Included is a list of tests in the shard and to be requested to run.
	// This may include tests that will be skipped due to unsatisfied
	// dependencies.
	Included []*driver.BundleEntity

	// Excluded is a list of tests not in the shard and to be ignored.
	Excluded []*driver.BundleEntity
}

Shard represents a set of tests included/excluded in a shard.

func ComputeAlpha

func ComputeAlpha(tests []*driver.BundleEntity, shardIndex, totalShards int) *Shard

ComputeAlpha computes a set of tests to include/exclude in the specified shard by lexiographic.

func ComputeHash

func ComputeHash(tests []*driver.BundleEntity, shardIndex, totalShards int) *Shard

ComputeHash computes a set of tests to include/exclude in the specified shard by hash. This is experimental for now, and will potentially produce empty shards. If you see issues when this is rolling out please file a buganizer issue to component 1152900.