mock

Documentation

Overview

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Index

• type MockAnalyserServices
  • func NewMockAnalyserServices(ctrl *gomock.Controller) *MockAnalyserServices
  • func (m *MockAnalyserServices) Close()
  • func (m *MockAnalyserServices) EXPECT() *MockAnalyserServicesMockRecorder
  • func (m *MockAnalyserServices) NewClusterConsumer(groupID, topic string) (*sarama_cluster.Consumer, error)
  • func (m *MockAnalyserServices) SetUpClient(config *sarama.Config) (sarama.Client, error)
  • func (m *MockAnalyserServices) SetUpConfig() sarama_cluster.Config
  • func (m *MockAnalyserServices) Start() error
• type MockAnalyserServicesMockRecorder
  • func (mr *MockAnalyserServicesMockRecorder) Close() *gomock.Call
  • func (mr *MockAnalyserServicesMockRecorder) NewClusterConsumer(groupID, topic interface{}) *gomock.Call
  • func (mr *MockAnalyserServicesMockRecorder) SetUpClient(config interface{}) *gomock.Call
  • func (mr *MockAnalyserServicesMockRecorder) SetUpConfig() *gomock.Call
  • func (mr *MockAnalyserServicesMockRecorder) Start() *gomock.Call
• type MockClusterAnalyser
  • func NewMockClusterAnalyser(ctrl *gomock.Controller) *MockClusterAnalyser
  • func (m *MockClusterAnalyser) Close() error
  • func (m *MockClusterAnalyser) EXPECT() *MockClusterAnalyserMockRecorder
  • func (m *MockClusterAnalyser) Errors() <-chan error
  • func (m *MockClusterAnalyser) MarkOffset(message *sarama.ConsumerMessage, metadata string)
  • func (m *MockClusterAnalyser) Messages() <-chan *sarama.ConsumerMessage
  • func (m *MockClusterAnalyser) Notifications() <-chan *sarama_cluster.Notification
• type MockClusterAnalyserMockRecorder
  • func (mr *MockClusterAnalyserMockRecorder) Close() *gomock.Call
  • func (mr *MockClusterAnalyserMockRecorder) Errors() *gomock.Call
  • func (mr *MockClusterAnalyserMockRecorder) MarkOffset(message, metadata interface{}) *gomock.Call
  • func (mr *MockClusterAnalyserMockRecorder) Messages() *gomock.Call
  • func (mr *MockClusterAnalyserMockRecorder) Notifications() *gomock.Call
• type MockInfluxDB
  • func NewMockInfluxDB(ctrl *gomock.Controller) *MockInfluxDB
  • func (m *MockInfluxDB) EXPECT() *MockInfluxDBMockRecorder
  • func (m *MockInfluxDB) GetFieldValueIfExist(MyDB, columnName, measurement string, roundedTime time.Time) int
  • func (m *MockInfluxDB) InitDB() error
  • func (m *MockInfluxDB) InsertToInflux(MyDB, measurement, columnName string, value int, roundedTime time.Time)
• type MockInfluxDBMockRecorder
  • func (mr *MockInfluxDBMockRecorder) GetFieldValueIfExist(MyDB, columnName, measurement, roundedTime interface{}) *gomock.Call
  • func (mr *MockInfluxDBMockRecorder) InitDB() *gomock.Call
  • func (mr *MockInfluxDBMockRecorder) InsertToInflux(MyDB, measurement, columnName, value, roundedTime interface{}) *gomock.Call

Types

type MockAnalyserServices

type MockAnalyserServices struct {
	// contains filtered or unexported fields
}

MockAnalyserServices is a mock of AnalyserServices interface

func NewMockAnalyserServices

func NewMockAnalyserServices(ctrl *gomock.Controller) *MockAnalyserServices

NewMockAnalyserServices creates a new mock instance

func (*MockAnalyserServices) Close

func (m *MockAnalyserServices) Close()

Close mocks base method

func (*MockAnalyserServices) EXPECT

func (m *MockAnalyserServices) EXPECT() *MockAnalyserServicesMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockAnalyserServices) NewClusterConsumer

func (m *MockAnalyserServices) NewClusterConsumer(groupID, topic string) (*sarama_cluster.Consumer, error)

NewClusterConsumer mocks base method

func (*MockAnalyserServices) SetUpClient

func (m *MockAnalyserServices) SetUpClient(config *sarama.Config) (sarama.Client, error)

SetUpClient mocks base method

func (*MockAnalyserServices) SetUpConfig

func (m *MockAnalyserServices) SetUpConfig() sarama_cluster.Config

SetUpConfig mocks base method

func (*MockAnalyserServices) Start

func (m *MockAnalyserServices) Start() error

Start mocks base method

type MockAnalyserServicesMockRecorder

type MockAnalyserServicesMockRecorder struct {
	// contains filtered or unexported fields
}

MockAnalyserServicesMockRecorder is the mock recorder for MockAnalyserServices

func (*MockAnalyserServicesMockRecorder) Close

func (mr *MockAnalyserServicesMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockAnalyserServicesMockRecorder) NewClusterConsumer

func (mr *MockAnalyserServicesMockRecorder) NewClusterConsumer(groupID, topic interface{}) *gomock.Call

NewClusterConsumer indicates an expected call of NewClusterConsumer

func (*MockAnalyserServicesMockRecorder) SetUpClient

func (mr *MockAnalyserServicesMockRecorder) SetUpClient(config interface{}) *gomock.Call

SetUpClient indicates an expected call of SetUpClient

func (*MockAnalyserServicesMockRecorder) SetUpConfig

func (mr *MockAnalyserServicesMockRecorder) SetUpConfig() *gomock.Call

SetUpConfig indicates an expected call of SetUpConfig

func (*MockAnalyserServicesMockRecorder) Start

func (mr *MockAnalyserServicesMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start

type MockClusterAnalyser

type MockClusterAnalyser struct {
	// contains filtered or unexported fields
}

MockClusterAnalyser is a mock of ClusterAnalyser interface

func NewMockClusterAnalyser

func NewMockClusterAnalyser(ctrl *gomock.Controller) *MockClusterAnalyser

NewMockClusterAnalyser creates a new mock instance

func (*MockClusterAnalyser) Close

func (m *MockClusterAnalyser) Close() error

Close mocks base method

func (*MockClusterAnalyser) EXPECT

func (m *MockClusterAnalyser) EXPECT() *MockClusterAnalyserMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockClusterAnalyser) Errors

func (m *MockClusterAnalyser) Errors() <-chan error

Errors mocks base method

func (*MockClusterAnalyser) MarkOffset

func (m *MockClusterAnalyser) MarkOffset(message *sarama.ConsumerMessage, metadata string)

MarkOffset mocks base method

func (*MockClusterAnalyser) Messages

func (m *MockClusterAnalyser) Messages() <-chan *sarama.ConsumerMessage

Messages mocks base method

func (*MockClusterAnalyser) Notifications

func (m *MockClusterAnalyser) Notifications() <-chan *sarama_cluster.Notification

Notifications mocks base method

type MockClusterAnalyserMockRecorder

type MockClusterAnalyserMockRecorder struct {
	// contains filtered or unexported fields
}

MockClusterAnalyserMockRecorder is the mock recorder for MockClusterAnalyser

func (*MockClusterAnalyserMockRecorder) Close

func (mr *MockClusterAnalyserMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockClusterAnalyserMockRecorder) Errors

func (mr *MockClusterAnalyserMockRecorder) Errors() *gomock.Call

Errors indicates an expected call of Errors

func (*MockClusterAnalyserMockRecorder) MarkOffset

func (mr *MockClusterAnalyserMockRecorder) MarkOffset(message, metadata interface{}) *gomock.Call

MarkOffset indicates an expected call of MarkOffset

func (*MockClusterAnalyserMockRecorder) Messages

func (mr *MockClusterAnalyserMockRecorder) Messages() *gomock.Call

Messages indicates an expected call of Messages

func (*MockClusterAnalyserMockRecorder) Notifications

func (mr *MockClusterAnalyserMockRecorder) Notifications() *gomock.Call

Notifications indicates an expected call of Notifications

type MockInfluxDB

type MockInfluxDB struct {
	// contains filtered or unexported fields
}

MockInfluxDB is a mock of InfluxDB interface

func NewMockInfluxDB

func NewMockInfluxDB(ctrl *gomock.Controller) *MockInfluxDB

NewMockInfluxDB creates a new mock instance

func (*MockInfluxDB) EXPECT

func (m *MockInfluxDB) EXPECT() *MockInfluxDBMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockInfluxDB) GetFieldValueIfExist

func (m *MockInfluxDB) GetFieldValueIfExist(MyDB, columnName, measurement string, roundedTime time.Time) int

GetFieldValueIfExist mocks base method

func (*MockInfluxDB) InitDB

func (m *MockInfluxDB) InitDB() error

InitDB mocks base method

func (*MockInfluxDB) InsertToInflux

func (m *MockInfluxDB) InsertToInflux(MyDB, measurement, columnName string, value int, roundedTime time.Time)

InsertToInflux mocks base method

type MockInfluxDBMockRecorder

type MockInfluxDBMockRecorder struct {
	// contains filtered or unexported fields
}

MockInfluxDBMockRecorder is the mock recorder for MockInfluxDB

func (*MockInfluxDBMockRecorder) GetFieldValueIfExist

func (mr *MockInfluxDBMockRecorder) GetFieldValueIfExist(MyDB, columnName, measurement, roundedTime interface{}) *gomock.Call

GetFieldValueIfExist indicates an expected call of GetFieldValueIfExist

func (*MockInfluxDBMockRecorder) InitDB

func (mr *MockInfluxDBMockRecorder) InitDB() *gomock.Call

InitDB indicates an expected call of InitDB

func (*MockInfluxDBMockRecorder) InsertToInflux

func (mr *MockInfluxDBMockRecorder) InsertToInflux(MyDB, measurement, columnName, value, roundedTime interface{}) *gomock.Call

InsertToInflux indicates an expected call of InsertToInflux