Versions in this module Expand all Collapse all v0 v0.1.0 Dec 9, 2019 Changes in this version + type ClusterAdmin interface + ListTopics func() (map[string]sarama.TopicDetail, error) + type Consumer interface + ConsumePartition func(topic string, partition int32, offset int64) (sarama.PartitionConsumer, error) + Partitions func(topic string) ([]int32, error) + type Decoder interface + Decode func(ctx context.Context, id uint32, message []byte) (string, error) + type Service struct + func NewService(admin ClusterAdmin, consumer Consumer, protoDecoder Decoder) *Service + func (s *Service) GetTopics() ([]*models.Topic, error) + func (s *Service) Subscribe(ctx context.Context, topic string, key string) (<-chan *models.Record, error)
Go to main page