- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for jobID (0.19 sec)
-
cmd/batch-handlers.go
} m.RUnlock() for _, jobID := range toDeleteJobMetrics { m.delete(jobID) } } } } func (m *batchJobMetrics) delete(jobID string) { m.Lock() defer m.Unlock() delete(m.metrics, jobID) } func (m *batchJobMetrics) save(jobID string, ri *batchJobInfo) { m.Lock() defer m.Unlock() m.metrics[jobID] = ri.clone() }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 08 14:11:38 GMT 2024 - 55.2K bytes - Viewed (0) -
cmd/batch-handlers_gen.go
case "v": z.Version, err = dc.ReadInt() if err != nil { 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":
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Mar 07 18:58:22 GMT 2024 - 18.1K bytes - Viewed (0) -
cmd/metrics-realtime.go
"github.com/minio/minio/internal/net" c "github.com/shirou/gopsutil/v3/cpu" "github.com/shirou/gopsutil/v3/load" ) type collectMetricsOpts struct { hosts map[string]struct{} disks map[string]struct{} jobID string depID string } func collectLocalMetrics(types madmin.MetricType, opts collectMetricsOpts) (m madmin.RealtimeMetrics) { if types == madmin.MetricsNone { return } byHostName := globalMinioAddr
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Apr 10 16:28:08 GMT 2024 - 6.1K bytes - Viewed (0) -
cmd/batch-expire.go
for attempts := 1; attempts <= retryAttempts; attempts++ { select { case <-ctx.Done(): done = true default: } stopFn := globalBatchJobsMetrics.trace(batchJobMetricExpire, ri.JobID, attempts) _, err := api.DeleteObject(ctx, exp.Bucket, encodeDirObject(exp.Name), ObjectOptions{ DeletePrefix: true,
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
cmd/admin-handlers.go
hosts: hostMap, disks: diskMap, jobID: jobID, depID: dID, }) m.Merge(&mLocal) // Allow half the interval for collecting remote... cctx, cancel := context.WithTimeout(ctx, interval/2) mRemote := collectRemoteMetrics(cctx, types, collectMetricsOpts{ hosts: hostMap, disks: diskMap, jobID: jobID, depID: dID, }) cancel() m.Merge(&mRemote)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
cmd/batch-rotate.go
) // Start the batch key rottion job, resumes if there was a pending job via "job.ID" func (r *BatchJobKeyRotateV1) Start(ctx context.Context, api ObjectLayer, job BatchJobRequest) error { ri := &batchJobInfo{ JobID: job.ID, JobType: string(job.Type()), StartTime: job.Started, } if err := ri.load(ctx, api, job); err != nil { return err } if ri.Complete { return nil }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/metrics-v2.go
Help: "Get successfully completed batch job " + jtype + "objects", Type: counterMetric, }, Value: objects, VariableLabels: map[string]string{"bucket": bucket, "jobId": mj.JobID}, }, MetricV2{ Description: MetricDescription{ Namespace: bucketMetricNamespace, Subsystem: "batch", Name: MetricName(jtype + "_objects_failed"),
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 11 21:22:15 GMT 2024 - 132.1K bytes - Viewed (0) -
cmd/peer-rest-client.go
for disk := range opts.disks { values.Add(peerRESTDisk, disk) } for host := range opts.hosts { values.Add(peerRESTHost, host) } values.Set(peerRESTJobID, opts.jobID) values.Set(peerRESTDepID, opts.depID) v, err := getMetricsRPC.Call(ctx, client.gridConn(), grid.NewURLValuesWith(values)) return v.ValueOrZero(), err }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
cmd/peer-rest-server.go
for _, host := range values[peerRESTHost] { hostMap[host] = struct{}{} } info := collectLocalMetrics(types, collectMetricsOpts{ disks: diskMap, hosts: hostMap, jobID: values.Get(peerRESTJobID), depID: values.Get(peerRESTDepID), }) return madminRealtimeMetrics.NewJSONWith(&info), nil } // GetSysConfigHandler - returns system config information.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0)