- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for LogIf (0.15 sec)
-
cmd/logging.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 6.6K bytes - Viewed (0) -
internal/logger/logger.go
if err == nil { return } logIf(ctx, subsystem, 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, subsystem string, err error, errKind ...interface{}) { if logIgnoreError(err) { return } logIf(ctx, subsystem, err, errKind...) }
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) -
cmd/tier-journal.go
if err := jd.rotate(); err != nil { logger.LogIf(ctx, fmt.Errorf("tier-journal: failed to rotate pending deletes journal %s", err)) return } ro, err := jd.OpenRO() switch { case errors.Is(err, os.ErrNotExist): return // No read-only journal to process; nothing to do. case err != nil: logger.LogIf(ctx, fmt.Errorf("tier-journal: failed open read-only journal for processing %s", err))
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
cmd/tier-mem-journal.go
entries: make(chan jentry, nevents), } } func (j *tierMemJournal) processEntries(ctx context.Context) { for { select { case <-ctx.Done(): return case entry := <-j.entries: logger.LogIf(ctx, deleteObjectFromRemoteTier(ctx, entry.ObjName, entry.VersionID, entry.TierName)) } } } func (j *tierMemJournal) AddEntry(je jentry) error { select { case j.entries <- je: default:
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Aug 03 21:16:15 GMT 2023 - 1.5K bytes - Viewed (0) -
cmd/tier-sweeper.go
// os.SetTransitionState(goi) // } // // // After the overwriting object operation is complete. // // if jentry, ok := os.ShouldRemoveRemoteObject(); ok { // err := globalTierJournal.AddEntry(jentry) // logger.LogIf(ctx, err) // } type objSweeper struct { Object string Bucket string VersionID string // version ID set by application, applies only to DeleteObject and DeleteObjects APIs
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 4.7K bytes - Viewed (0) -
internal/logger/reqinfo.go
for _, t := range r.tags { tagsMap[t.Key] = t.Val } return } // SetReqInfo sets ReqInfo in the context. func SetReqInfo(ctx context.Context, req *ReqInfo) context.Context { if ctx == nil { LogIf(context.Background(), "", fmt.Errorf("context is nil")) return nil } return context.WithValue(ctx, contextLogKey, req) } // GetReqInfo returns ReqInfo if set. func GetReqInfo(ctx context.Context) *ReqInfo {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.4K bytes - Viewed (0) -
internal/logger/logonce.go
Count: 1, } } else if prev.Err.Error() == nerr.Error() { // if errors are equal do not log. prev.Count++ l.IDMap[id] = prev shouldLog = false } l.Unlock() if shouldLog { logIf(ctx, subsystem, err, errKind...) } } // Cleanup the map every one hour so that the log message is printed again for the user to notice. func (l *logOnceType) cleanupRoutine() { for { time.Sleep(time.Hour)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.8K bytes - Viewed (0) -
internal/logger/audit.go
) const contextAuditKey = contextKeyType("audit-entry") // SetAuditEntry sets Audit info in the context. func SetAuditEntry(ctx context.Context, audit *audit.Entry) context.Context { if ctx == nil { LogIf(context.Background(), "audit", fmt.Errorf("context is nil")) return nil } return context.WithValue(ctx, contextAuditKey, audit) } // GetAuditEntry returns Audit entry if set.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.6K bytes - Viewed (0) -
internal/kms/kes.go
} return results } // Logger interface permits access to module specific logging, in this case, for KMS type Logger interface { LogOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) LogIf(ctx context.Context, err error, errKind ...interface{}) } // RefreshKey checks the validity of the KMS Master Key func (c *kesClient) RefreshKey(ctx context.Context, logger Logger) bool { c.lock.RLock()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 14.9K bytes - Viewed (0) -
internal/bucket/object/lock/lock.go
"github.com/minio/minio/internal/logger" "github.com/minio/pkg/v2/env" ) const ( logSubsys = "locking" ) func lockLogIf(ctx context.Context, err error) { logger.LogIf(ctx, logSubsys, err) } // Enabled indicates object locking is enabled const Enabled = "Enabled" // RetMode - object retention mode. type RetMode string const ( // RetGovernance - governance mode.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 17.1K bytes - Viewed (0)