- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for AuditTargets (0.11 sec)
-
internal/logger/targets.go
systemTargets = newTargetsList() // auditTargets is the list of enabled audit loggers auditTargets = newTargetsList() // This is always set represent /dev/console target consoleTgt Target ) // SystemTargets returns active targets. // Returned slice may not be modified in any way. func SystemTargets() []Target { return systemTargets.get() } // AuditTargets returns active audit targets.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 03 15:44:50 UTC 2024 - 6K bytes - Viewed (0) -
internal/logger/audit.go
} return nil } // AuditLog - logs audit logs to all audit targets. func AuditLog(ctx context.Context, w http.ResponseWriter, r *http.Request, reqClaims map[string]interface{}, filterKeys ...string) { auditTgts := AuditTargets() if len(auditTgts) == 0 { return } var entry audit.Entry if w != nil && r != nil { reqInfo := GetReqInfo(ctx) if reqInfo == nil { return } reqInfo.RLock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 17:13:00 UTC 2024 - 4.6K bytes - Viewed (0) -
cmd/utils.go
VersionID string Error string Tags map[string]string } // sends audit logs for internal subsystem activity func auditLogInternal(ctx context.Context, opts AuditLogOptions) { if len(logger.AuditTargets()) == 0 { return } entry := audit.NewEntry(globalDeploymentID()) entry.Trigger = opts.Event entry.Event = opts.Event entry.Error = opts.Error entry.API.Name = opts.APIName
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:22:04 UTC 2024 - 31.9K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
} func auditTierActions(ctx context.Context, tier string, bytes int64) func(err error) { startTime := time.Now() return func(err error) { // Record only when audit targets configured. if len(logger.AuditTargets()) == 0 { return } op := auditTierOp{ Tier: tier, OutputBytes: bytes, } if err == nil { since := time.Since(startTime)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 23 15:35:37 UTC 2024 - 33.7K bytes - Viewed (0) -
cmd/erasure-healing.go
_, ok := fi.Metadata[xMinIODataMov] return ok } func (er *erasureObjects) auditHealObject(ctx context.Context, bucket, object, versionID string, result madmin.HealResultItem, err error) { if len(logger.AuditTargets()) == 0 { return } opts := AuditLogOptions{ Event: "HealObject", Bucket: bucket, Object: decodeDirObject(object), VersionID: versionID, } if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 02 17:50:41 UTC 2024 - 34.4K bytes - Viewed (0) -
cmd/erasure-sets.go
} // Add erasure set information to the current context func auditObjectErasureSet(ctx context.Context, api, object string, set *erasureObjects) { if len(logger.AuditTargets()) == 0 { return } op := auditObjectOp{ Name: decodeDirObject(object), Pool: set.poolIndex + 1, Set: set.setIndex + 1, } logger.GetReqInfo(ctx).AppendTags(api, op.String())
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 27 10:41:37 UTC 2024 - 37K bytes - Viewed (1) -
cmd/admin-handlers.go
for _, tgt := range logger.SystemTargets() { if tgt.Endpoint() != "" { loggerInfo = append(loggerInfo, madmin.Logger{tgt.String(): targetStatus(ctx, tgt)}) } } for _, tgt := range logger.AuditTargets() { if tgt.Endpoint() != "" { auditloggerInfo = append(auditloggerInfo, madmin.Audit{tgt.String(): targetStatus(ctx, tgt)}) } } return loggerInfo, auditloggerInfo }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 99.7K bytes - Viewed (0) -
cmd/erasure-object.go
} return er.getObjectInfo(ctx, bucket, object, opts) } func auditDanglingObjectDeletion(ctx context.Context, bucket, object, versionID string, tags map[string]string) { if len(logger.AuditTargets()) == 0 { return } opts := AuditLogOptions{ Event: "DeleteDanglingObject", Bucket: bucket, Object: object, VersionID: versionID, Tags: tags, }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 78.8K bytes - Viewed (0) -
cmd/metrics-v2.go
func getWebhookMetrics() *MetricsGroupV2 { mg := &MetricsGroupV2{ cacheInterval: 10 * time.Second, } mg.RegisterRead(func(ctx context.Context) []MetricV2 { tgts := append(logger.SystemTargets(), logger.AuditTargets()...) metrics := make([]MetricV2, 0, len(tgts)*4) for _, t := range tgts { isOnline := 0 if t.IsOnline(ctx) { isOnline = 1 } labels := map[string]string{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 131.9K bytes - Viewed (0)