Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for AuditTargets (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
Back to top