Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. internal/logger/targets.go

    	swapSystemMuRW.RLock()
    	defer swapSystemMuRW.RUnlock()
    
    	res := systemTargets
    	return res
    }
    
    // AuditTargets returns active audit targets.
    // Returned slice may not be modified in any way.
    func AuditTargets() []Target {
    	swapAuditMuRW.RLock()
    	defer swapAuditMuRW.RUnlock()
    
    	res := auditTargets
    	return res
    }
    
    // CurrentStats returns the current statistics.
    func CurrentStats() map[string]types.TargetStats {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Apr 02 22:56:14 GMT 2024
    - 6.1K 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()
    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)
  3. 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)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  4. cmd/utils.go

    	VersionID string
    	Error     string
    	Tags      map[string]interface{}
    }
    
    // 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
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 31.3K bytes
    - Viewed (0)
  5. cmd/erasure-healing.go

    	_, ok := fi.Metadata[xMinIODataMov]
    	return ok
    }
    
    func 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:    object,
    		VersionID: versionID,
    	}
    	if err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  6. cmd/erasure-sets.go

    	Disks []string `json:"disks"`
    }
    
    // Add erasure set information to the current context
    func auditObjectErasureSet(ctx context.Context, object string, set *erasureObjects) {
    	if len(logger.AuditTargets()) == 0 {
    		return
    	}
    
    	op := auditObjectOp{
    		Name:  decodeDirObject(object),
    		Pool:  set.poolIndex + 1,
    		Set:   set.setIndex + 1,
    		Disks: set.getEndpointStrings(),
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 37.5K bytes
    - Viewed (5)
  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
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 97.3K bytes
    - Viewed (2)
  8. cmd/erasure-object.go

    	}
    
    	return er.getObjectInfo(ctx, bucket, object, opts)
    }
    
    func auditDanglingObjectDeletion(ctx context.Context, bucket, object, versionID string, tags map[string]interface{}) {
    	if len(logger.AuditTargets()) == 0 {
    		return
    	}
    
    	opts := AuditLogOptions{
    		Event:     "DeleteDanglingObject",
    		Bucket:    bucket,
    		Object:    object,
    		VersionID: versionID,
    		Tags:      tags,
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 76.9K bytes
    - Viewed (2)
  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{
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
Back to top