Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for UpdateAuditKafkaTargets (0.13 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)
Back to top