- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 248 for traceCh (0.2 sec)
-
cmd/peer-rest-client.go
time.Sleep(5 * time.Second) } } }() } // Trace - send http trace request to peer nodes func (client *peerRESTClient) Trace(ctx context.Context, traceCh chan<- []byte, traceOpts madmin.ServiceTraceOpts) { go func() { for { // Blocks until context is canceled or an error occurs. client.doTrace(ctx, traceCh, traceOpts) select { case <-ctx.Done(): return default:
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/admin-handlers.go
if peer == nil { continue } peer.Trace(ctx, traceCh, traceOpts) } keepAliveTicker := time.NewTicker(time.Second) defer keepAliveTicker.Stop() for { select { case entry := <-traceCh: if _, err := w.Write(entry); err != nil { return } grid.PutByteBuffer(entry) if len(traceCh) == 0 { // Flush if nothing is queued
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) -
internal/grid/trace.go
v := ctx.Value(TraceParamsKey{}) // Should match SingleHandler.Call checks. switch typed := v.(type) { case *MSS: trace.Path += typed.ToQuery() case map[string]string: m := MSS(typed) trace.Path += m.ToQuery() case *URLValues: trace.Path += typed.Values().Encode() case *NoPayload, *Bytes: trace.Path = fmt.Sprintf("%s?payload=%T", trace.Path, typed)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Feb 02 22:54:54 GMT 2024 - 4K bytes - Viewed (0) -
cmd/http-tracer.go
h.ServeHTTP(respRecorder, r) reqEndTime := time.Now().UTC() if globalTrace.NumSubscribers(madmin.TraceS3|madmin.TraceInternal) == 0 { // no subscribers nothing to trace. return } tt := madmin.TraceInternal if strings.HasPrefix(tc.FuncName, "s3.") { tt = madmin.TraceS3 } // Calculate input body size with headers reqHeaders := r.Header.Clone() reqHeaders.Set("Host", r.Host)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 5.9K bytes - Viewed (0) -
tests/tracer_test.go
func (S Tracer) Warn(ctx context.Context, s string, i ...interface{}) { S.Logger.Warn(ctx, s, i...) } func (S Tracer) Error(ctx context.Context, s string, i ...interface{}) { S.Logger.Error(ctx, s, i...) } func (S Tracer) Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error) { S.Logger.Trace(ctx, begin, fc, err) S.Test(ctx, begin, fc, err)
Go - Registered: Sun Apr 21 09:35:09 GMT 2024 - Last Modified: Tue Oct 18 09:28:06 GMT 2022 - 830 bytes - Viewed (0) -
common/scripts/tracing.sh
# Usage: tracing::extract_prow_trace. # If running in a prow job, this sets the parent trace to the same value Prow tracing will use, as defined in https://github.com/kubernetes/test-infra/issues/30010 function tracing::extract_prow_trace() { if [[ "${PROW_JOB_ID:-}" != "" ]]; then local trace trace="$(<<< "$PROW_JOB_ID" tr -d '\-')" local span span="${trace:0:16}" export TRACEPARENT="01-${trace}-${span}-00"
Shell Script - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Jul 28 15:25:47 GMT 2023 - 4.1K bytes - Viewed (0) -
doc/go1.22.html
Execution traces are now partitioned regularly on-the-fly and as a result may be processed in a streamable way. Execution traces now contain complete durations for all system calls. Execution traces now contain information about the operating system threads that goroutines executed on. The latency impact of starting and stopping execution traces has been dramatically reduced.
HTML - Registered: Tue Feb 06 11:13:10 GMT 2024 - Last Modified: Wed Jan 31 20:51:56 GMT 2024 - 45.6K bytes - Viewed (0) -
manifests/charts/istiod-remote/templates/configmap.yaml
{{- end }} {{- if not (eq .Values.global.proxy.tracer "none") }} tracing: {{- if eq .Values.global.proxy.tracer "lightstep" }} lightstep: # Address of the LightStep Satellite pool address: {{ .Values.global.tracer.lightstep.address }} # Access Token used to communicate with the Satellite pool accessToken: {{ .Values.global.tracer.lightstep.accessToken }}
Others - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Thu Mar 07 16:59:18 GMT 2024 - 4.9K bytes - Viewed (0) -
manifests/charts/istio-control/istio-discovery/templates/configmap.yaml
{{- end }} {{- if not (eq .Values.global.proxy.tracer "none") }} tracing: {{- if eq .Values.global.proxy.tracer "lightstep" }} lightstep: # Address of the LightStep Satellite pool address: {{ .Values.global.tracer.lightstep.address }} # Access Token used to communicate with the Satellite pool accessToken: {{ .Values.global.tracer.lightstep.accessToken }}
Others - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Thu Mar 07 16:59:18 GMT 2024 - 4.9K bytes - Viewed (0) -
internal/logger/logger.go
if !strings.HasPrefix(file, "<autogenerated>") && !strings.HasPrefix(funcName, "runtime.") { // Form and append a line of stack trace into a // collection, 'trace', to build full stack trace trace = append(trace, fmt.Sprintf("%v:%v:%v()", file, lineNumber, funcName)) // Ignore trace logs beyond the following conditions for _, name := range matchingFuncNames {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.2K bytes - Viewed (0)