Add ConsumerRequest struct

maximepeschard · Jun 13, 2020 · 9c264c0 · 9c264c0
1 parent 561d764
commit 9c264c0
Showing 1 changed file with 18 additions and 0 deletions.
diff --git a/client/consumer.go b/client/consumer.go
@@ -8,6 +8,24 @@ import (
 	"github.com/Shopify/sarama"
 )
 
+// A ConsumerRequest specifies what to consume and how.
+type ConsumerRequest struct {
+	Topic     string
+	StartTime int64
+	Quit      bool
+}
+
+// NewConsumerRequest returns a ConsumerRequest.
+func NewConsumerRequest(topic string, startTime int64, quit bool) ConsumerRequest {
+	cr := ConsumerRequest{
+		Topic:     topic,
+		StartTime: startTime,
+		Quit:      quit,
+	}
+
+	return cr
+}
+
 // Consumer is a high level API for a Kafka consumer.
 type Consumer struct {
 	broker   string