Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 28 for trac (0.14 sec)

  1. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 02 22:54:54 GMT 2024
    - 4K bytes
    - Viewed (0)
  2. internal/logger/console.go

    		message = fmt.Sprintf(msg, args...)
    	} else {
    		message = fmt.Sprint(args...)
    	}
    	logJSON, err := json.Marshal(&log.Entry{
    		Level:   FatalKind,
    		Message: message,
    		Time:    time.Now().UTC(),
    		Trace:   &log.Trace{Message: message, Source: []string{getSource(6)}},
    	})
    	if err != nil {
    		panic(err)
    	}
    	fmt.Fprintln(Output, string(logJSON))
    	ExitFunc(1)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  3. internal/rest/rpc-stats.go

    	var dialStart, dialEnd int64
    
    	trace := &httptrace.ClientTrace{
    		ConnectStart: func(network, addr string) {
    			atomic.StoreInt64(&dialStart, time.Now().UnixNano())
    		},
    		ConnectDone: func(network, addr string, err error) {
    			if err == nil {
    				atomic.StoreInt64(&dialEnd, time.Now().UnixNano())
    			}
    		},
    	}
    
    	return req.WithContext(httptrace.WithClientTrace(req.Context(), trace)), func() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 16:27:58 GMT 2022
    - 2.3K bytes
    - Viewed (0)
  4. internal/mcontext/ctxt.go

    )
    
    // ContextTraceType represents the type of golang Context key
    type ContextTraceType string
    
    // ContextTraceKey is the key of TraceCtxt saved in a Golang context
    const ContextTraceKey = ContextTraceType("ctx-trace-info")
    
    // TraceCtxt holds related tracing data of a http request.
    type TraceCtxt struct {
    	RequestRecorder  *xhttp.RequestRecorder
    	ResponseRecorder *xhttp.ResponseRecorder
    
    	FuncName string
    	AmzReqID string
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Dec 06 17:27:26 GMT 2022
    - 1.3K bytes
    - Viewed (0)
  5. buildscripts/minio-upgrade.sh

    #!/bin/bash
    
    trap 'cleanup $LINENO' ERR
    
    # shellcheck disable=SC2120
    cleanup() {
    	MINIO_VERSION=dev docker-compose \
    		-f "buildscripts/upgrade-tests/compose.yml" \
    		rm -s -f
    	docker volume prune -f
    }
    
    verify_checksum_after_heal() {
    	local sum1
    	sum1=$(curl -s "$2" | sha256sum)
    	mc admin heal --json -r "$1" >/dev/null # test after healing
    	local sum1_heal
    	sum1_heal=$(curl -s "$2" | sha256sum)
    
    Shell Script
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 05 11:39:55 GMT 2024
    - 2.2K bytes
    - Viewed (0)
  6. cmd/bootstrap-peer-server.go

    	}
    
    	return errors.New(strings.TrimSpace(msg))
    }
    
    var skipEnvs = map[string]struct{}{
    	"MINIO_OPTS":          {},
    	"MINIO_CERT_PASSWD":   {},
    	"MINIO_SERVER_DEBUG":  {},
    	"MINIO_DSYNC_TRACE":   {},
    	"MINIO_ROOT_USER":     {},
    	"MINIO_ROOT_PASSWORD": {},
    	"MINIO_ACCESS_KEY":    {},
    	"MINIO_SECRET_KEY":    {},
    }
    
    func getServerSystemCfg() *ServerSystemConfig {
    	envs := env.List("MINIO_")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  7. internal/logger/target/console/console.go

    		return nil
    	}
    
    	traceLength := len(entry.Trace.Source)
    	trace := make([]string, traceLength)
    
    	// Add a sequence number and formatting for each stack trace
    	// No formatting is required for the first entry
    	for i, element := range entry.Trace.Source {
    		trace[i] = fmt.Sprintf("%8v: %s", traceLength-i, element)
    	}
    
    	tagString := ""
    	for key, value := range entry.Trace.Variables {
    		if value != "" {
    			if tagString != "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  8. internal/logger/logrotate.go

    				Message: msg,
    				Time:    time.Now().UTC(),
    				Trace:   &log.Trace{Message: msg},
    			})
    		}
    		if err := w.rotate(); err != nil {
    			msg := fmt.Sprintf("unable to rotate log file %v: %v", w.f.Name(), err)
    			stdErrEnc.Encode(&log.Entry{
    				Level:   ErrorKind,
    				Message: msg,
    				Time:    time.Now().UTC(),
    				Trace:   &log.Trace{Message: msg},
    			})
    		}
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 11:38:40 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  9. internal/logger/target/testlogger/testlogger.go

    				fmt.Fprintf(os.Stdout, format+"\n", args...)
    			}
    		}
    	}
    
    	switch v := entry.(type) {
    	case log.Entry:
    		if v.Trace == nil {
    			logf("%s: %s", v.Level, v.Message)
    		} else {
    			msg := fmt.Sprintf("%s: %+v", v.Level, v.Trace.Message)
    			for i, m := range v.Trace.Source {
    				if i == 0 && strings.Contains(m, "logger.go:") {
    					continue
    				}
    				msg += fmt.Sprintf("\n%s", m)
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 4K bytes
    - Viewed (0)
  10. internal/http/listener.go

    	}
    
    	for i, serverAddr := range serverAddrs {
    		l, e := listenCfg.Listen(ctx, "tcp", serverAddr)
    		if e != nil {
    			if opts.Trace != nil {
    				opts.Trace(fmt.Sprint("listenCfg.Listen: ", e))
    			}
    
    			listenErrs[i] = e
    			continue
    		}
    
    		if opts.Trace != nil {
    			opts.Trace(fmt.Sprint("adding listener to ", l.Addr()))
    		}
    
    		listeners = append(listeners, l)
    	}
    
    	if len(listeners) == 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 5.6K bytes
    - Viewed (0)
Back to top