Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for UpdateAuditKafkaTargets (0.1 sec)

  1. internal/logger/targets.go

    			errs = append(errs, err)
    		}
    	}
    
    	targetsList.set(newWebhooks)
    
    	cancelTargets(oldTargets)
    
    	return errs
    }
    
    // UpdateAuditKafkaTargets swaps audit kafka targets with newly loaded ones from the cfg
    func UpdateAuditKafkaTargets(ctx context.Context, cfg Config) []error {
    	newKafkaTgts, errs := initKafkaTargets(ctx, cfg.AuditKafka)
    
    	// Retain webhook 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. cmd/config-current.go

    			if l.Enabled {
    				if l.TLS.Enable {
    					l.TLS.RootCAs = globalRootCAs
    				}
    				l.LogOnce = configLogOnceIf
    				loggerCfg.AuditKafka[n] = l
    			}
    		}
    		if errs := logger.UpdateAuditKafkaTargets(ctx, loggerCfg); len(errs) > 0 {
    			configLogIf(ctx, fmt.Errorf("Unable to update audit kafka targets: %v", errs))
    		}
    	case config.StorageClassSubSys:
    		for i, setDriveCount := range setDriveCounts {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 30.1K bytes
    - Viewed (0)
Back to top