- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 109 for LogIf (0.17 sec)
-
cmd/admin-handlers-site-replication.go
writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } opts := getSRAddOptions(r) status, err := globalSiteReplicationSys.AddPeerClusters(ctx, sites, opts) if err != nil { logger.LogIf(ctx, err) writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } body, err := json.Marshal(status) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Fri Nov 24 17:46:55 GMT 2023 - 19.1K bytes - Viewed (0) -
internal/grid/connection.go
if err != nil { logger.LogIf(ctx, fmt.Errorf("ws writeMessage: %w", err)) return } PutByteBuffer(toSend) err = conn.SetWriteDeadline(time.Now().Add(connWriteTimeout)) if err != nil { logger.LogIf(ctx, fmt.Errorf("conn.SetWriteDeadline: %w", err)) return } _, err = buf.WriteTo(conn) if err != nil { logger.LogIf(ctx, fmt.Errorf("ws write: %w", err))
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 42.3K bytes - Viewed (0) -
internal/logger/logger.go
if err == nil { return } logIf(ctx, err, errKind...) } // LogIf prints a detailed error message during // the execution of the server, if it is not an // ignored error. func LogIf(ctx context.Context, err error, errKind ...interface{}) { if logIgnoreError(err) { return } logIf(ctx, err, errKind...) } // LogIfNot prints a detailed error message during
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Mar 21 17:19:36 GMT 2024 - 11.9K bytes - Viewed (0) -
cmd/config-current.go
if err != nil { logger.LogIf(ctx, fmt.Errorf("Unable to initialize remote webhook DNS config %w", err)) } if err == nil && dnsURL != "" { bootstrapTraceMsg("initialize remote bucket DNS store") globalDNSConfig, err = dns.NewOperatorDNS(dnsURL, dns.Authentication(dnsUser, dnsPass), dns.RootCAs(globalRootCAs)) if err != nil {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Tue Mar 05 02:50:24 GMT 2024 - 30.8K bytes - Viewed (0) -
cmd/etcd.go
} _, err := client.Put(timeoutCtx, key, string(data)) logger.LogIf(ctx, err) return etcdErrToErr(err, client.Endpoints()) } func deleteKeyEtcd(ctx context.Context, client *etcd.Client, key string) error { timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout) defer cancel() _, err := client.Delete(timeoutCtx, key) logger.LogIf(ctx, err) return etcdErrToErr(err, client.Endpoints()) }
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sun Jun 25 03:29:13 GMT 2023 - 2.9K bytes - Viewed (0) -
cmd/global-heal.go
if time.Since(tracker.getLastUpdate()) > time.Minute { logger.LogIf(ctx, tracker.update(ctx)) } continue } tracker.updateProgress(res.success, res.skipped, res.bytes) } }() send := func(result healEntryResult) bool { select { case <-ctx.Done(): if !contextCanceled(ctx) { logger.LogIf(ctx, ctx.Err()) } return false case results <- result:
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 17:05:40 GMT 2024 - 13.9K bytes - Viewed (1) -
cmd/signals.go
if err := httpServer.Shutdown(); err != nil && !errors.Is(err, http.ErrServerClosed) { logger.LogIf(context.Background(), err) } } if objAPI := newObjectLayerFn(); objAPI != nil { logger.LogIf(context.Background(), objAPI.Shutdown(context.Background())) } if srv := newConsoleServerFn(); srv != nil { logger.LogIf(context.Background(), srv.Shutdown()) } if globalEventNotifier != nil {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Jul 12 14:18:30 GMT 2023 - 2.7K bytes - Viewed (0) -
cmd/prepare-storage.go
tmpOld, diskPath); err != nil && !errors.Is(err, errFileNotFound) { logger.LogIf(GlobalContext, fmt.Errorf("unable to rename (%s -> %s) %w, drive may be faulty please investigate", pathJoin(diskPath, minioMetaTmpBucket), tmpOld, osErrToFileErr(err))) } if err := mkdirAll(pathJoin(diskPath, minioMetaTmpDeletedBucket), 0o777, diskPath); err != nil {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Feb 14 18:37:34 GMT 2024 - 11.4K bytes - Viewed (0) -
cmd/metrics-v3-cluster-usage.go
// // This is a `MetricsLoaderFn`. func loadClusterUsageObjectMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { dataUsageInfo, err := c.dataUsageInfo.Get() if err != nil { logger.LogIf(ctx, err) return nil } // data usage has not captured any data yet. if dataUsageInfo.LastUpdate.IsZero() { return nil } var ( clusterSize uint64
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 6.6K bytes - Viewed (0) -
cmd/callhome.go
}{Version: healthInfo.Version} enc := json.NewEncoder(gzWriter) if e := enc.Encode(header); e != nil { logger.LogIf(ctx, fmt.Errorf("Could not encode health info header: %w", e)) return nil } if e := enc.Encode(healthInfo); e != nil { logger.LogIf(ctx, fmt.Errorf("Could not encode health info: %w", e)) return nil } gzWriter.Flush() gzWriter.Close() return b.Bytes()
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.1K bytes - Viewed (1)