Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for audit_kafka (0.06 sec)

  1. internal/logger/config.go

    	AuditKafka   map[string]kafka.Config `json:"audit_kafka"`
    }
    
    // NewConfig - initialize new logger config.
    func NewConfig() Config {
    	cfg := Config{
    		// Console logging is on by default
    		Console: Console{
    			Enabled: true,
    		},
    		HTTP:         make(map[string]http.Config),
    		AuditWebhook: make(map[string]http.Config),
    		AuditKafka:   make(map[string]kafka.Config),
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 20 16:02:50 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  2. cmd/config-current.go

    		if err != nil {
    			configLogIf(ctx, fmt.Errorf("Unable to load audit kafka config: %w", err))
    		}
    		for n, l := range loggerCfg.AuditKafka {
    			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 {
    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