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 MockMonitor
  • 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)
  • func (m *MockReporter) ReportBrokerOffsets(v *store.BrokerOffsets)
  • func (m *MockReporter) ReportConsumerOffsets(v *store.ConsumerOffsets)
• type MockStore
  • func (m *MockStore) BrokerMetadata() store.BrokerMetadata
  • func (m *MockStore) BrokerOffsets() store.BrokerOffsets
  • func (m *MockStore) Channel() chan interface{}
  • func (m *MockStore) Close()
  • func (m *MockStore) ConsumerOffsets() store.ConsumerOffsets
  • func (m *MockStore) SetState(v interface{}) error

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 MockMonitor

type MockMonitor struct {
	mock.Mock
}

MockMonitor represents a mock Kafka client.

func (MockMonitor) Brokers

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

Brokers returns a list of Kafka brokers.

func (MockMonitor) Close

func (m MockMonitor) Close()

Close gracefully stops the Kafka client.

func (MockMonitor) Collect

func (m MockMonitor) Collect()

Collect collects the state of Monitor.

func (MockMonitor) IsHealthy

func (m MockMonitor) IsHealthy() bool

IsHealthy checks the health of the Kafka client.

type MockReporter

type MockReporter struct {
	mock.Mock
}

MockReporter represents a mock Reporter.

func (*MockReporter) ReportBrokerMetadata

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

ReportBrokerMetadata reports a snapshot of the broker metadata.

func (*MockReporter) ReportBrokerOffsets

func (m *MockReporter) ReportBrokerOffsets(v *store.BrokerOffsets)

ReportBrokerOffsets reports a snapshot of the broker offsets.

func (*MockReporter) ReportConsumerOffsets

func (m *MockReporter) ReportConsumerOffsets(v *store.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) BrokerMetadata

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

BrokerMetadata returns a snapshot of the current broker metadata.

func (*MockStore) BrokerOffsets

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

BrokerOffsets returns a snapshot of the current broker offsets.

func (*MockStore) Channel

func (m *MockStore) Channel() chan interface{}

Channel get the offset channel.

func (*MockStore) Close

func (m *MockStore) Close()

Close gracefully stops the Store.

func (*MockStore) ConsumerOffsets

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

ConsumerOffsets returns a snapshot of the current consumer group offsets.

func (*MockStore) SetState

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

SetState adds a state into the store.