Versions in this module Expand all Collapse all v1 v1.3.19 Jun 6, 2023 v1.3.18 Jun 6, 2023 Changes in this version + const CreationPhase + const DSortName + const DSorterGeneralType + const DSorterMemType + const ExtractionPhase + const PrefixJobID + const SortKindAlphanumeric + const SortKindContent + const SortKindMD5 + const SortKindNone + const SortKindShuffle + const SortingPhase + func InitManagers(db kvdb.Driver) + func ProxyAbortSortHandler(w http.ResponseWriter, r *http.Request) + func ProxyGetHandler(w http.ResponseWriter, r *http.Request) + func ProxyRemoveSortHandler(w http.ResponseWriter, r *http.Request) + func ProxyStartSortHandler(w http.ResponseWriter, r *http.Request, parsedRS *ParsedRequestSpec) + func RegisterNode(smapOwner meta.Sowner, bmdOwner meta.Bowner, snode *meta.Snode, ...) + func TargetHandler(w http.ResponseWriter, r *http.Request) + type CreationPhaseMetadata struct + SendOrder map[string]*extract.Shard + Shards []*extract.Shard + func (z *CreationPhaseMetadata) DecodeMsg(dc *msgp.Reader) (err error) + func (z *CreationPhaseMetadata) EncodeMsg(en *msgp.Writer) (err error) + func (z *CreationPhaseMetadata) Msgsize() (s int) + type DetailedStats struct + type JobInfo struct + Aborted bool + Archived bool + CreationDuration time.Duration + Description string + ExtractedDuration time.Duration + FinishTime time.Time + ID string + SortingDuration time.Duration + StartedTime time.Time + func (j *JobInfo) Aggregate(other *JobInfo) + func (j *JobInfo) IsFinished() bool + func (j *JobInfo) IsRunning() bool + type LocalExtraction struct + ExtractedCnt int64 + ExtractedRecordCnt int64 + ExtractedSize int64 + ExtractedToDiskCnt int64 + ExtractedToDiskSize int64 + ShardExtractionStats *DetailedStats + TotalCnt int64 + type Manager struct + ManagerUUID string + Metrics *Metrics + func (m *Manager) ListenSmapChanged() + func (m *Manager) String() string + type ManagerGroup struct + var Managers *ManagerGroup + func NewManagerGroup(db kvdb.Driver, skipHk bool) *ManagerGroup + func (mg *ManagerGroup) AbortAll(err error) + func (mg *ManagerGroup) Add(managerUUID string) (*Manager, error) + func (mg *ManagerGroup) Get(managerUUID string, ap ...bool) (*Manager, bool) + func (mg *ManagerGroup) List(descRegex *regexp.Regexp, onlyActive bool) []JobInfo + func (mg *ManagerGroup) Remove(managerUUID string) error + type MetaSorting struct + RecvStats *TimeStats + SentStats *TimeStats + type Metrics struct + Aborted atomic.Bool + Archived atomic.Bool + Creation *ShardCreation + Description string + Errors []string + Extraction *LocalExtraction + Sorting *MetaSorting + Warnings []string + func (m *Metrics) ElapsedTime() time.Duration + func (m *Metrics) Marshal() []byte + func (m *Metrics) ToJobInfo(id string) JobInfo + type ParsedRequestSpec struct + Algorithm *SortAlgorithm + Bck cmn.Bck + CreateConcMaxLimit int + DSorterType string + Description string + DryRun bool + ExtendedMetrics bool + Extension string + ExtractConcMaxLimit int + InputFormat *parsedInputTemplate + MaxMemUsage cos.ParsedQuantity + OrderFileSep string + OrderFileURL string + OutputBck cmn.Bck + OutputFormat *parsedOutputTemplate + OutputShardSize int64 + StreamMultiplier int + TargetOrderSalt []byte + type PhaseInfo struct + Elapsed time.Duration + End time.Time + Finished bool + Running bool + Start time.Time + type RemoteResponse struct + Record *extract.Record + RecordObj *extract.RecordObj + func (z *RemoteResponse) DecodeMsg(dc *msgp.Reader) (err error) + func (z *RemoteResponse) EncodeMsg(en *msgp.Writer) (err error) + func (z *RemoteResponse) Msgsize() (s int) + type RequestSpec struct + Algorithm SortAlgorithm + Bck cmn.Bck + CreateConcMaxLimit int + DSorterType string + Description string + DryRun bool + ExtendedMetrics bool + Extension string + ExtractConcMaxLimit int + InputFormat string + MaxMemUsage string + OrderFileSep string + OrderFileURL string + OutputBck cmn.Bck + OutputFormat string + OutputShardSize string + StreamMultiplier int + func (rs *RequestSpec) Parse() (*ParsedRequestSpec, error) + type ShardCreation struct + CreatedCnt int64 + LocalRecvStats *DetailedStats + LocalSendStats *DetailedStats + MovedShardCnt int64 + RequestStats *TimeStats + ResponseStats *TimeStats + ShardCreationStats *DetailedStats + ToCreate int64 + type SortAlgorithm struct + Decreasing bool + Extension string + FormatType string + Kind string + Seed string + type ThroughputStats struct + AvgTp int64 + MaxTp int64 + MinTp int64 + type TimeStats struct + AvgMs int64 + Count int64 + MaxMs int64 + MinMs int64 + Total int64