processor

Documentation

Index

• func MigrateData(runsProcessor Runs)
• func ProcessRun(ctx context.Context, runsProcessor Runs, dsClient *datastore.Client, ...)
• type ConditionUnsatisfied
  • func (e ConditionUnsatisfied) Error() string
• type Runs

Functions

func MigrateData

func MigrateData(runsProcessor Runs)

MigrateData handles all the loading and transactions across the full datastore. It should be called from a main(), e.g.

func main() {
  p := experimentalLabeller{}
  processor.MigrateData(p)
}

func ProcessRun

func ProcessRun(ctx context.Context, runsProcessor Runs, dsClient *datastore.Client, key *datastore.Key, wg *sync.WaitGroup)

Types

type ConditionUnsatisfied

type ConditionUnsatisfied struct{}

ConditionUnsatisfied is a non-fatal error when a run does not need to be processed.

func (ConditionUnsatisfied) Error

func (e ConditionUnsatisfied) Error() string

type Runs

type Runs interface {
	ShouldProcessRun(run *shared.TestRun) bool
	ProcessRun(tx *datastore.Transaction, key *datastore.Key, run *shared.TestRun) error
}

Runs is an interface for processors of TestRun entities.