mocks

Documentation

Index

• type MockInfluxClient
  • func (m *MockInfluxClient) Close() error
  • func (m *MockInfluxClient) Ping(timeout time.Duration) (time.Duration, string, error)
  • func (m *MockInfluxClient) Query(q client.Query) (*client.Response, error)
  • func (m *MockInfluxClient) Write(bp client.BatchPoints) error
• type MockKafka
  • func (m MockKafka) Brokers() []kage.KafkaBroker
  • func (m MockKafka) Close()
  • func (m MockKafka) IsHealthy() bool
• type MockKafkaBroker
  • func (m MockKafkaBroker) Connected() bool
  • func (m MockKafkaBroker) ID() int32
• type MockReporter
  • func (m *MockReporter) ReportBrokerOffsets(o *kage.BrokerOffsets)
  • func (m *MockReporter) ReportConsumerOffsets(o *kage.ConsumerOffsets)
• type MockStore
  • 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

Types

type MockInfluxClient

type MockInfluxClient struct {
	mock.Mock
}

MockInfluxClient represents a mock InfluxDB client.

func (*MockInfluxClient) Close

func (m *MockInfluxClient) Close() error

Close releases any resources a Client may be using.

func (*MockInfluxClient) Ping

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

Ping checks that status of cluster, and will always return 0 time and no error for UDP clients.

func (*MockInfluxClient) Query

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

Query makes an InfluxDB Query on the database. This will fail if using the UDP client.

func (*MockInfluxClient) Write

func (m *MockInfluxClient) Write(bp client.BatchPoints) error

Write takes a BatchPoints object and writes all Points to InfluxDB.

type MockKafka

type MockKafka struct {
	mock.Mock
}

MockKafka represents a mock Kafka client.

func (MockKafka) Brokers

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

Brokers returns a list of Kafka brokers.

func (MockKafka) Close

func (m MockKafka) Close()

Close gracefully stops the Kafka client.

func (MockKafka) IsHealthy

func (m MockKafka) IsHealthy() bool

IsHealthy checks the health of the Kafka client.

type MockKafkaBroker

type MockKafkaBroker struct {
	mock.Mock
}

MockKafkaBroker represents a mock Kafka broker.

func (MockKafkaBroker) Connected

func (m MockKafkaBroker) Connected() bool

Connected returns the Broker connection status.

func (MockKafkaBroker) ID

func (m MockKafkaBroker) ID() int32

ID returns the Broker id.

type MockReporter

type MockReporter struct {
	mock.Mock
}

MockReporter represents a mock Reporter.

func (*MockReporter) ReportBrokerOffsets

func (m *MockReporter) ReportBrokerOffsets(o *kage.BrokerOffsets)

ReportBrokerOffsets reports a snapshot of the broker offsets.

func (*MockReporter) ReportConsumerOffsets

func (m *MockReporter) ReportConsumerOffsets(o *kage.ConsumerOffsets)

ReportConsumerOffsets reports a snapshot of the consumer group offsets.

type MockStore

type MockStore struct {
	mock.Mock
}

MockStore represents a mock offset store.

func (*MockStore) AddOffset

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

AddOffset adds an offset into the store.

func (*MockStore) BrokerOffsets

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

BrokerOffsets returns a snapshot of the current broker offsets.

func (*MockStore) Channel

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

Channel get the offset channel.

func (*MockStore) Close

func (m *MockStore) Close()

Close gracefully stops the Store.

func (*MockStore) ConsumerOffsets

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

ConsumerOffsets returns a snapshot of the current consumer group offsets.