- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for storeCtxCancel (0.18 sec)
-
internal/logger/target/kafka/kafka.go
logCh chan interface{} logChMu sync.RWMutex // store to persist and replay the logs to the target // to avoid missing events when the target is down. store store.Store[interface{}] storeCtxCancel context.CancelFunc initKafkaOnce once.Init initQueueStoreOnce once.Init client sarama.Client producer sarama.SyncProducer kconfig Config config *sarama.Config }
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) -
internal/logger/target/http/http.go
ctx, cancel := context.WithCancel(ctx) h.storeCtxCancel = cancel h.lastStarted = time.Now() go h.startQueueProcessor(ctx, true) store.StreamItems(h.store, h, ctx.Done(), h.config.LogOnceIf) return nil } func (h *Target) initMemoryStore(ctx context.Context) (err error) { ctx, cancel := context.WithCancel(ctx) h.storeCtxCancel = cancel h.lastStarted = time.Now()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0)