- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 829 for timme (0.04 sec)
-
cmd/server-main.go
} func bootstrapTrace(msg string, worker func()) { if serverDebugLog { fmt.Println(time.Now().Round(time.Millisecond).Format(time.RFC3339), " bootstrap: ", msg) } now := time.Now() worker() dur := time.Since(now) info := madmin.TraceInfo{ TraceType: madmin.TraceBootstrap, Time: UTCNow(), NodeName: globalLocalNodeName, FuncName: "BOOTSTRAP",
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Sep 24 21:50:11 UTC 2024 - 35.2K bytes - Viewed (3) -
cmd/iam.go
} if parentUser == "" { return auth.Credentials{}, time.Time{}, errInvalidArgument } if len(opts.accessKey) > 0 && len(opts.secretKey) == 0 { return auth.Credentials{}, time.Time{}, auth.ErrNoSecretKeyWithAccessKey } if len(opts.secretKey) > 0 && len(opts.accessKey) == 0 { return auth.Credentials{}, time.Time{}, auth.ErrNoAccessKeyWithSecretKey }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Sep 17 16:45:46 UTC 2024 - 74.6K bytes - Viewed (0) -
utils/utils_test.go
{"error not equal", errors.New("1"), errors.New("2"), false}, {"driver.Valuer equal", ModifyAt{Time: now, Valid: true}, ModifyAt{Time: now, Valid: true}, true}, {"driver.Valuer not equal", ModifyAt{Time: now, Valid: true}, ModifyAt{Time: now.Add(time.Second), Valid: true}, false}, {"driver.Valuer equal (ptr to nil ptr)", (*ModifyAt)(nil), &ModifyAt{}, false}, } for _, test := range assertEqualTests {
Registered: Sun Oct 27 09:35:08 UTC 2024 - Last Modified: Thu Aug 22 11:03:42 UTC 2024 - 4.9K bytes - Viewed (0) -
internal/grid/muxclient.go
var errState bool if debugPrint { start := time.Now() defer func() { fmt.Println("Mux", m.MuxID, "Request took", time.Since(start).Round(time.Millisecond)) }() } var pingTimer <-chan time.Time if m.deadline == 0 || m.deadline > m.clientPingInterval { ticker := time.NewTicker(m.clientPingInterval) defer ticker.Stop() pingTimer = ticker.C
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
internal/grid/connection.go
var wsw wsWriter var lastSetDeadline time.Time // Helper to write everything in buf. // Return false if an error occurred and the connection is unusable. // Buffer will be reset empty when returning successfully. writeBuffer := func() (ok bool) { now := time.Now() // Only set write deadline once every second if now.Sub(lastSetDeadline) > time.Second {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 46.7K bytes - Viewed (0) -
logger/logger.go
type traceRecorder struct { Interface BeginAt time.Time SQL string RowsAffected int64 Err error } // New trace recorder func (l *traceRecorder) New() *traceRecorder { return &traceRecorder{Interface: l.Interface, BeginAt: time.Now()} } // Trace implement logger interface func (l *traceRecorder) Trace(ctx context.Context, begin time.Time, fc func() (string, int64), err error) {
Registered: Sun Oct 27 09:35:08 UTC 2024 - Last Modified: Tue Nov 07 02:19:41 UTC 2023 - 5.8K bytes - Viewed (0) -
internal/bucket/lifecycle/expiration.go
if eDays == 0 { return nil } return e.EncodeElement(int(eDays), startElement) } // ExpirationDate is a embedded type containing time.Time to unmarshal // Date in Expiration type ExpirationDate struct { time.Time } // UnmarshalXML parses date from Expiration and validates date format func (eDate *ExpirationDate) UnmarshalXML(d *xml.Decoder, startElement xml.StartElement) error {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Feb 21 20:28:34 UTC 2024 - 6.6K bytes - Viewed (0) -
cmd/site-replication-metrics.go
s.XferRateSml.measure.updateExponentialMovingAverage(time.Now()) } } // SRMetric captures replication metrics for a deployment type SRMetric struct { DeploymentID string `json:"deploymentID"` Endpoint string `json:"endpoint"` TotalDowntime time.Duration `json:"totalDowntime"` LastOnline time.Time `json:"lastOnline"`
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 8.2K bytes - Viewed (0) -
cmd/data-scanner.go
go func() { r := rand.New(rand.NewSource(time.Now().UnixNano())) // Run the data scanner in a loop for { runDataScanner(ctx, objAPI) duration := time.Duration(r.Float64() * float64(scannerCycle.Load())) if duration < time.Second { // Make sure to sleep at least a second to avoid high CPU ticks. duration = time.Second } time.Sleep(duration) } }() }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Oct 22 21:10:34 UTC 2024 - 48.4K bytes - Viewed (0) -
buildscripts/gen-ldflags.go
} func commitTime() time.Time { // git log --format=%cD -n1 var ( commitUnix []byte err error ) cmdName := "git" cmdArgs := []string{"log", "--format=%cI", "-n1"} if commitUnix, err = exec.Command(cmdName, cmdArgs...).Output(); err != nil { fmt.Fprintln(os.Stderr, "Error generating git commit-time: ", err) os.Exit(1) }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Jun 16 23:10:48 UTC 2022 - 3.3K bytes - Viewed (0)