32 lines
547 B
Go
32 lines
547 B
Go
package mocks
|
|
|
|
import (
|
|
"github.com/Shopify/sarama"
|
|
"github.com/stretchr/testify/mock"
|
|
)
|
|
|
|
type ConsumerGroupClaim struct {
|
|
mock.Mock
|
|
}
|
|
|
|
func (c *ConsumerGroupClaim) Topic() string {
|
|
return ""
|
|
}
|
|
|
|
func (c *ConsumerGroupClaim) Partition() int32 {
|
|
return 0
|
|
}
|
|
|
|
func (c *ConsumerGroupClaim) InitialOffset() int64 {
|
|
return 0
|
|
}
|
|
|
|
func (c *ConsumerGroupClaim) HighWaterMarkOffset() int64 {
|
|
return 0
|
|
}
|
|
|
|
func (c *ConsumerGroupClaim) Messages() <-chan *sarama.ConsumerMessage {
|
|
args := c.Called()
|
|
return args.Get(0).(<-chan *sarama.ConsumerMessage)
|
|
}
|