Merge pull request #360 from lovoo/tester-improvements

tester: implement listing topics and partitions + getoffset

tester/consumer.go

@@ -34,11 +34,19 @@ func (cm *consumerMock) catchup() int {
 }
 
 func (cm *consumerMock) Topics() ([]string, error) {
-	return nil, fmt.Errorf("Not implemented")
+	cm.tester.mCodecs.RLock()
+	defer cm.tester.mCodecs.RUnlock()
+
+	var topics []string
+
+	for topic := range cm.tester.codecs {
+		topics = append(topics, topic)
+	}
+	return topics, nil
 }
 
 func (cm *consumerMock) Partitions(topic string) ([]int32, error) {
-	return nil, fmt.Errorf("not implemented")
+	return []int32{0}, nil
 }
 
 func (cm *consumerMock) ConsumePartition(topic string, partition int32, offset int64) (sarama.PartitionConsumer, error) {

tester/topic_manager.go

@@ -54,7 +54,9 @@ func (tm *MockTopicManager) GetOffset(topicName string, partitionID int32, time
 	case sarama.OffsetNewest:
 		return topic.Hwm(), nil
 	default:
-		return 0, fmt.Errorf("only oldest and newest are supported in the mock")
+		// always return from oldest, because the tester does not store
+		// timestamps
+		return 0, nil
 	}
 }