move from v4 enabled tracer && added fieldalignment struct && upd deps
Some checks failed
lint / lint (pull_request) Failing after 1m41s
test / test (pull_request) Failing after 18m1s

This commit is contained in:
2025-05-20 14:22:58 +03:00
parent 69fe6994ae
commit 8475922d42
6 changed files with 52 additions and 43 deletions

View File

@@ -24,34 +24,44 @@ type tp struct {
}
type consumer struct {
topic string
topic string
c *kgo.Client
htracer *hookTracer
quit chan struct{}
done chan struct{}
recs chan kgo.FetchTopicPartition
kopts broker.Options
partition int32
opts broker.SubscribeOptions
handler broker.Handler
connected *atomic.Uint32
quit chan struct{}
done chan struct{}
recs chan kgo.FetchTopicPartition
handler broker.Handler
kopts broker.Options
opts broker.SubscribeOptions
partition int32
}
type Subscriber struct {
topic string
consumers map[tp]*consumer
c *kgo.Client
htracer *hookTracer
topic string
connected *atomic.Uint32
handler broker.Handler
done chan struct{}
kopts broker.Options
opts broker.SubscribeOptions
connected *atomic.Uint32
sync.RWMutex
done chan struct{}
kopts broker.Options
opts broker.SubscribeOptions
closed bool
fatalOnError bool
sync.RWMutex
}
func (s *Subscriber) Client() *kgo.Client {