- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for doWithContext (0.21 sec)
-
internal/once/init.go
atomic.StoreUint32(&l.done, 1) } return nil } // DoWithContext is similar to Do except that it accepts a context as an argument to be passed. func (l *Init) DoWithContext(ctx context.Context, f func(context.Context) error) error { if atomic.LoadUint32(&l.done) == 0 { return l.doWithContext(ctx, f) } return nil } func (l *Init) doWithContext(ctx context.Context, f func(context.Context) error) error { l.m.Lock()
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue May 09 04:20:31 UTC 2023 - 2.1K bytes - Viewed (0) -
internal/logger/target/http/http.go
} // Init validate and initialize the http target func (h *Target) Init(ctx context.Context) (err error) { if h.config.QueueDir != "" { return h.initQueueOnce.DoWithContext(ctx, h.initDiskStore) } return h.initQueueOnce.DoWithContext(ctx, h.initMemoryStore) } func (h *Target) initDiskStore(ctx context.Context) (err error) { ctx, cancel := context.WithCancel(ctx) h.storeCtxCancel = cancel
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Sep 11 22:20:42 UTC 2024 - 15.6K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
if !h.kconfig.Enabled { return nil } if err := h.validate(); err != nil { return err } if h.kconfig.QueueDir != "" { 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 }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10.2K bytes - Viewed (0)