mocks

Sep 7, 2017

Changes in this version

+ type MockMonitor struct

+ func (m MockMonitor) Brokers() []kafka.Broker

+ func (m MockMonitor) Close()

+ func (m MockMonitor) Collect()

+ func (m MockMonitor) IsHealthy() bool

type MockReporter

+ func (m *MockReporter) ReportBrokerMetadata(v *store.BrokerMetadata)

type MockStore

+ func (m *MockStore) BrokerMetadata() store.BrokerMetadata

+ func (m *MockStore) SetState(v interface{}) error

Jun 9, 2017

Changes in this version

type MockKafka

+ func (m MockKafka) Brokers() []kage.KafkaBroker

+ type MockKafkaBroker struct

+ func (m MockKafkaBroker) Connected() bool

+ func (m MockKafkaBroker) ID() int32

May 23, 2017

Changes in this version

+ type MockKafka struct

+ func (m MockKafka) Close()

+ func (m MockKafka) IsHealthy() bool

+ type MockStore struct

+ func (m *MockStore) AddOffset(o *kage.PartitionOffset)

+ func (m *MockStore) BrokerOffsets() kage.BrokerOffsets

+ func (m *MockStore) Channel() chan *kage.PartitionOffset

+ func (m *MockStore) Close()

+ func (m *MockStore) ConsumerOffsets() kage.ConsumerOffsets

Mar 20, 2017

Changes in this version

+ type MockInfluxClient struct

+ BatchPoints client.BatchPoints

+ Connected bool

+ func (c *MockInfluxClient) Close() error

+ func (c *MockInfluxClient) Ping(timeout time.Duration) (time.Duration, string, error)

+ func (c *MockInfluxClient) Query(q client.Query) (*client.Response, error)

+ func (c *MockInfluxClient) Write(bp client.BatchPoints) error

+ type MockReporter struct

+ BrokerOffsets *kage.BrokerOffsets

+ ConsumerOffsets *kage.ConsumerOffsets

+ func (r *MockReporter) IsHealthy() bool

+ func (r *MockReporter) ReportBrokerOffsets(o *kage.BrokerOffsets)

+ func (r *MockReporter) ReportConsumerOffsets(o *kage.ConsumerOffsets)

+ type MockService struct

+ Health bool

+ func (m MockService) IsHealthy() bool