- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for isKafkaConnErr (0.1 sec)
-
internal/event/target/kafka.go
// Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(eErr) { return nil } return eErr } if err := target.send(eventData); err != nil { if isKafkaConnErr(err) { return store.ErrNotConnected } return err } // Delete the event from store. return target.store.Del(key.Name) } func (target *KafkaTarget) addToBatch(key store.Key) error {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 15:02:59 UTC 2024 - 13.1K bytes - Viewed (0)