- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for LoadInt32 (0.17 sec)
-
internal/logger/target/kafka/kafka.go
atomic.StoreInt32(&h.status, statusOnline) } return nil } // IsOnline returns true if the target is online. func (h *Target) IsOnline(_ context.Context) bool { return atomic.LoadInt32(&h.status) == statusOnline } // Send log message 'e' to kafka target. func (h *Target) Send(ctx context.Context, entry interface{}) error { if h.store != nil {
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)