Versions in this module Expand all Collapse all v0 v0.2.1 Dec 8, 2022 v0.2.0 Jun 5, 2022 Changes in this version + func GenerateIndexes(spec *execution.ParallelismSpec) []execution.ParallelIndex + func GetDefaultIndex() execution.ParallelIndex + func GetParallelStatus(job *execution.Job, tasks []execution.TaskRef) (execution.ParallelStatus, error) + func GetParallelStatusCounters(indexes []execution.ParallelIndexStatus) execution.ParallelStatusCounters + func GetParallelTaskSummary(job *execution.Job, tasks []execution.TaskRef) (execution.ParallelStatusSummary, error) + func HashIndex(index execution.ParallelIndex) (string, error) + func HashIndexes(indexes []execution.ParallelIndex) (map[int]string, map[string]int, error) + type IndexCreationRequest struct + Earliest time.Time + ParallelIndex execution.ParallelIndex + RetryIndex int64 + func ComputeMissingIndexesForCreation(job *execution.Job, indexes []execution.ParallelIndex) ([]IndexCreationRequest, error)