- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for startKafkaLogger (0.21 sec)
-
internal/logger/target/kafka/kafka.go
if err := h.initQueueStoreOnce.DoWithContext(ctx, h.initQueueStore); err != nil { return err } return h.initKafkaOnce.Do(h.init) } if err := h.init(); err != nil { return err } go h.startKafkaLogger() return nil } func (h *Target) initQueueStore(ctx context.Context) (err error) { var queueStore store.Store[interface{}] queueDir := filepath.Join(h.kconfig.QueueDir, h.Name())
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1)