Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ArrayCachedStatus ¶
type ArrayCachedStatus struct {
CachedJobs *bitarray.BitSet `json:"cachedJobs"`
NumCached uint `json:"numCached"`
}
This is a status object that is returned after we make Catalog calls to see if subtasks are Cached
type ArrayStatus ¶
type ArrayStatus struct {
// Summary of the array job. It's a map of phases and how many jobs are in that phase.
Summary ArraySummary `json:"summary"`
// Status of every job in the array.
Detailed bitarray.CompactArray `json:"details"`
}
func (ArrayStatus) HashCode ¶ added in v0.10.19
func (a ArrayStatus) HashCode() (uint64, error)
HashCode computes a hash of the phase indicies stored in the Detailed array to uniquely represent a collection of subtask phases.
type ArraySummary ¶
func (ArraySummary) Dec ¶
func (in ArraySummary) Dec(phase core.Phase)
func (ArraySummary) Inc ¶
func (in ArraySummary) Inc(phase core.Phase)
func (ArraySummary) IncByCount ¶
func (in ArraySummary) IncByCount(phase core.Phase, count int64)
func (ArraySummary) MergeFrom ¶
func (in ArraySummary) MergeFrom(other ArraySummary) (updated bool)
Source Files
Click to show internal directories.
Click to hide internal directories.