Searched defs:OutputClientDataConsumer (Results 1 – 1 of 1) sorted by relevance
34 type OutputClientDataConsumer struct { struct35 clientAPIConsumer *internal.ContinualConsumer36 db storage.Database37 stream types.StreamProvider38 notifier *notifier.Notifier69 func (s *OutputClientDataConsumer) Start() error {76 func (s *OutputClientDataConsumer) onMessage(msg *sarama.ConsumerMessage) error {