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.