- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for jt (0.15 sec)
-
cmd/global-heal.go
agreed: func(entry metaCacheEntry) { jt.Take() go healEntry(bucket, entry) }, partial: func(entries metaCacheEntries, _ []error) { entry, ok := entries.resolve(&resolver) if !ok { // check if we can get one entry at least // proceed to heal nonetheless. entry, _ = entries.firstFound() } jt.Take() go healEntry(bucket, *entry) },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (1) -
cmd/batch-handlers_gen.go
err = msgp.WrapError(err, "Version") return } case "jid": z.JobID, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "JobID") return } case "jt": z.JobType, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "JobType") return } case "st": z.StartTime, err = dc.ReadTime() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 07 18:58:22 GMT 2024 - 18.1K bytes - Viewed (0) -
cmd/batch-handlers.go
type batchJobInfo struct { mu sync.RWMutex `json:"-" msg:"-"` Version int `json:"-" msg:"v"` JobID string `json:"jobID" msg:"jid"` JobType string `json:"jobType" msg:"jt"` StartTime time.Time `json:"startTime" msg:"st"` LastUpdate time.Time `json:"lastUpdate" msg:"lu"` RetryAttempts int `json:"retryAttempts" msg:"ra"` Complete bool `json:"complete" msg:"cmp"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 55.2K bytes - Viewed (0)