- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 66 for track (0.13 sec)
-
cmd/admin-router.go
adminRouter.Methods(http.MethodPost).Path(adminVersion + adminAPIClientDevExtraTime).HandlerFunc(adminMiddleware(adminAPI.ClientDevNullExtraTime, noGZFlag)) // HTTP Trace adminRouter.Methods(http.MethodGet).Path(adminVersion + "/trace").HandlerFunc(adminMiddleware(adminAPI.TraceHandler, noObjLayerFlag)) // Console Logs
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 25.5K bytes - Viewed (0) -
cmd/api-router.go
// // The passed in handler function must be a method of `objectAPIHandlers` for // the name displayed in logs and trace to be accurate. The name is extracted // via reflection. // // When **no** flags are passed, the behavior is to trace both headers and body, // gzip the response and throttle the handler via `maxClients`. Each of these // can be disabled via the corresponding `s3HFlag`. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 22.8K bytes - Viewed (0) -
cmd/metacache-walk.go
} send := func(entry metaCacheEntry) error { objReturned(entry.metadata) select { case <-ctx.Done(): return ctx.Err() case out <- entry: } return nil } // Fast exit track to check if we are listing an object with // a trailing slash, this will avoid to list the object content. if HasSuffix(opts.BaseDir, SlashSeparator) { metadata, err := s.readMetadata(ctx, pathJoin(volumeDir,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/peer-rest-server.go
} } } // TraceHandler sends http trace messages back to peer rest client func (s *peerRESTServer) TraceHandler(ctx context.Context, payload []byte, _ <-chan []byte, out chan<- []byte) *grid.RemoteErr { var traceOpts madmin.ServiceTraceOpts err := json.Unmarshal(payload, &traceOpts) if err != nil { return grid.NewRemoteErr(err) } var wg sync.WaitGroup
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
cmd/batch-rotate.go
continue } wk.Take() go func() { defer wk.Give() for attempts := 1; attempts <= retryAttempts; attempts++ { attempts := attempts stopFn := globalBatchJobsMetrics.trace(batchJobMetricKeyRotation, job.ID, attempts) success := true if err := r.KeyRotate(ctx, api, result); err != nil { stopFn(result, err) batchLogIf(ctx, err) success = false } else {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/s3select/json/preader.go
kvDstPool sync.Pool // pool of []jstream.KV used for output close chan struct{} // used for shutting down the splitter before end of stream readerWg sync.WaitGroup // used to keep track of async reader. } // queueItem is an item in the queue. type queueItem struct { input []byte // raw input sent to the worker dst chan []jstream.KVS // result of block decode
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 6.4K bytes - Viewed (0) -
internal/grid/handlers.go
if err != nil { return resp, err } switch any(req).(type) { case *MSS, *URLValues: ctx = context.WithValue(ctx, TraceParamsKey{}, req) case *NoPayload, *Bytes: // do not need to trace nopayload and bytes payload default: ctx = context.WithValue(ctx, TraceParamsKey{}, fmt.Sprintf("type=%T", req)) } if h.callReuseReq { defer h.recycleReq(req) } res, err := c.Request(ctx, h.id, payload)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
cmd/test-utils_test.go
// Disable printing console messages during tests. color.Output = io.Discard // Disable Error logging in testing. logger.DisableErrorLog = true // Uncomment the following line to see trace logs during unit tests. // logger.AddTarget(console.New()) // Set system resources to maximum. setMaxResources(nil) // Initialize globalConsoleSys system
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/data-scanner-metric.go
scannerMetricCleanAbandoned scannerMetricApplyNonCurrent scannerMetricHealAbandonedVersion // START Trace metrics: scannerMetricStartTrace scannerMetricScanObject // Scan object. All operations included. scannerMetricHealAbandonedObject // END realtime metrics: scannerMetricLastRealtime // Trace only metrics: scannerMetricScanFolder // Scan a folder on disk, recursively.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 25 05:15:31 GMT 2023 - 9.1K bytes - Viewed (0) -
cmd/bucket-replication.go
defer wg.Done() for roi := range workers[idx] { select { case <-ctx.Done(): return case <-s.resyncCancelCh: default: } traceFn := s.trace(tgt.ResetID, fmt.Sprintf("%s/%s (%s)", opts.bucket, roi.Name, roi.VersionID)) if roi.DeleteMarker || !roi.VersionPurgeStatus.Empty() { versionID := "" dmVersionID := ""
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1)