- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for Content (0.81 sec)
-
internal/event/target/kafka.go
if err != nil { if !errors.Is(err, sarama.ErrOutOfBrokers) { target.loggerOnce(context.Background(), err, target.ID().String()) } return err } producer, err := sarama.NewSyncProducerFromClient(client) if err != nil { if !errors.Is(err, sarama.ErrOutOfBrokers) { target.loggerOnce(context.Background(), err, target.ID().String()) } return err } target.client = client
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
} 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 { // save the entry to the queue store which will be replayed to the target.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1)