Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for Grace (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. callbacks.go

    		}
    		if !stmt.ReflectValue.IsValid() {
    			db.AddError(ErrInvalidValue)
    		}
    	}
    
    	for _, f := range p.fns {
    		f(db)
    	}
    
    	if stmt.SQL.Len() > 0 {
    		db.Logger.Trace(stmt.Context, curTime, func() (string, int64) {
    			sql, vars := stmt.SQL.String(), stmt.Vars
    			if filter, ok := db.Logger.(ParamsFilter); ok {
    				sql, vars = filter.ParamsFilter(stmt.Context, stmt.SQL.String(), stmt.Vars...)
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Tue Mar 26 03:33:36 GMT 2024
    - 8.6K bytes
    - Viewed (1)
  5. 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)
  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. cni/pkg/config/config.go

    	AmbientIPv6 bool
    }
    
    // RepairConfig struct defines the Istio CNI race repair configuration
    type RepairConfig struct {
    	// Whether to enable CNI race repair
    	Enabled bool
    
    	// The node name that the CNI DaemonSet runs on
    	NodeName string
    
    	// Key and value for broken pod label
    	LabelKey   string
    	LabelValue string
    
    	// Whether to fix race condition by repairing them
    	RepairPods bool
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  8. cmd/background-heal-ops.go

    }
    
    // healRoutine receives heal tasks, to heal buckets, objects and format.json
    type healRoutine struct {
    	tasks   chan healTask
    	workers int
    }
    
    func activeListeners() int {
    	// Bucket notification and http trace are not costly, it is okay to ignore them
    	// while counting the number of concurrent connections
    	return int(globalHTTPListen.Subscribers()) + int(globalTrace.Subscribers())
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 4.6K bytes
    - Viewed (0)
Back to top