Documentation ¶
Index ¶
- type ClientMock
- func (mmGetGRPCConn *ClientMock) GetGRPCConn() (cp1 *grpc.ClientConn)
- func (mmGetGRPCConn *ClientMock) GetGRPCConnAfterCounter() uint64
- func (mmGetGRPCConn *ClientMock) GetGRPCConnBeforeCounter() uint64
- func (m *ClientMock) MinimockFinish()
- func (m *ClientMock) MinimockGetGRPCConnDone() bool
- func (m *ClientMock) MinimockGetGRPCConnInspect()
- func (m *ClientMock) MinimockNotifyShutdownDone() bool
- func (m *ClientMock) MinimockNotifyShutdownInspect()
- func (m *ClientMock) MinimockWait(timeout mm_time.Duration)
- func (mmNotifyShutdown *ClientMock) NotifyShutdown(ctx context.Context, stopChannel ..., waitForStateChange time.Duration)
- func (mmNotifyShutdown *ClientMock) NotifyShutdownAfterCounter() uint64
- func (mmNotifyShutdown *ClientMock) NotifyShutdownBeforeCounter() uint64
- type ClientMockGetGRPCConnExpectation
- type ClientMockGetGRPCConnResults
- type ClientMockNotifyShutdownExpectation
- type ClientMockNotifyShutdownParams
- type ConnectionManagerMock
- func (m *ConnectionManagerMock) MinimockFinish()
- func (m *ConnectionManagerMock) MinimockStartDone() bool
- func (m *ConnectionManagerMock) MinimockStartInspect()
- func (m *ConnectionManagerMock) MinimockStopDone() bool
- func (m *ConnectionManagerMock) MinimockStopInspect()
- func (m *ConnectionManagerMock) MinimockWait(timeout mm_time.Duration)
- func (mmStart *ConnectionManagerMock) Start(ctx context.Context) (err error)
- func (mmStart *ConnectionManagerMock) StartAfterCounter() uint64
- func (mmStart *ConnectionManagerMock) StartBeforeCounter() uint64
- func (mmStop *ConnectionManagerMock) Stop(ctx context.Context) (err error)
- func (mmStop *ConnectionManagerMock) StopAfterCounter() uint64
- func (mmStop *ConnectionManagerMock) StopBeforeCounter() uint64
- type ConnectionManagerMockStartExpectation
- type ConnectionManagerMockStartParams
- type ConnectionManagerMockStartResults
- type ConnectionManagerMockStopExpectation
- type ConnectionManagerMockStopParams
- type ConnectionManagerMockStopResults
- type ControllerMock
- func (m *ControllerMock) MinimockFinish()
- func (m *ControllerMock) MinimockSetJetDropDataDone() bool
- func (m *ControllerMock) MinimockSetJetDropDataInspect()
- func (m *ControllerMock) MinimockStartDone() bool
- func (m *ControllerMock) MinimockStartInspect()
- func (m *ControllerMock) MinimockStopDone() bool
- func (m *ControllerMock) MinimockStopInspect()
- func (m *ControllerMock) MinimockWait(timeout mm_time.Duration)
- func (mmSetJetDropData *ControllerMock) SetJetDropData(pulse types.Pulse, jetID string)
- func (mmSetJetDropData *ControllerMock) SetJetDropDataAfterCounter() uint64
- func (mmSetJetDropData *ControllerMock) SetJetDropDataBeforeCounter() uint64
- func (mmStart *ControllerMock) Start(ctx context.Context) (err error)
- func (mmStart *ControllerMock) StartAfterCounter() uint64
- func (mmStart *ControllerMock) StartBeforeCounter() uint64
- func (mmStop *ControllerMock) Stop(ctx context.Context) (err error)
- func (mmStop *ControllerMock) StopAfterCounter() uint64
- func (mmStop *ControllerMock) StopBeforeCounter() uint64
- type ControllerMockSetJetDropDataExpectation
- type ControllerMockSetJetDropDataParams
- type ControllerMockStartExpectation
- type ControllerMockStartParams
- type ControllerMockStartResults
- type ControllerMockStopExpectation
- type ControllerMockStopParams
- type ControllerMockStopResults
- type JetDropsExtractorMock
- func (mmGetJetDrops *JetDropsExtractorMock) GetJetDrops(ctx context.Context) (ch1 <-chan *types.PlatformPulseData)
- func (mmGetJetDrops *JetDropsExtractorMock) GetJetDropsAfterCounter() uint64
- func (mmGetJetDrops *JetDropsExtractorMock) GetJetDropsBeforeCounter() uint64
- func (mmLoadJetDrops *JetDropsExtractorMock) LoadJetDrops(ctx context.Context, fromPulseNumber int64, toPulseNumber int64) (err error)
- func (mmLoadJetDrops *JetDropsExtractorMock) LoadJetDropsAfterCounter() uint64
- func (mmLoadJetDrops *JetDropsExtractorMock) LoadJetDropsBeforeCounter() uint64
- func (m *JetDropsExtractorMock) MinimockFinish()
- func (m *JetDropsExtractorMock) MinimockGetJetDropsDone() bool
- func (m *JetDropsExtractorMock) MinimockGetJetDropsInspect()
- func (m *JetDropsExtractorMock) MinimockLoadJetDropsDone() bool
- func (m *JetDropsExtractorMock) MinimockLoadJetDropsInspect()
- func (m *JetDropsExtractorMock) MinimockStartDone() bool
- func (m *JetDropsExtractorMock) MinimockStartInspect()
- func (m *JetDropsExtractorMock) MinimockStopDone() bool
- func (m *JetDropsExtractorMock) MinimockStopInspect()
- func (m *JetDropsExtractorMock) MinimockWait(timeout mm_time.Duration)
- func (mmStart *JetDropsExtractorMock) Start(ctx context.Context) (err error)
- func (mmStart *JetDropsExtractorMock) StartAfterCounter() uint64
- func (mmStart *JetDropsExtractorMock) StartBeforeCounter() uint64
- func (mmStop *JetDropsExtractorMock) Stop(ctx context.Context) (err error)
- func (mmStop *JetDropsExtractorMock) StopAfterCounter() uint64
- func (mmStop *JetDropsExtractorMock) StopBeforeCounter() uint64
- type JetDropsExtractorMockGetJetDropsExpectation
- type JetDropsExtractorMockGetJetDropsParams
- type JetDropsExtractorMockGetJetDropsResults
- type JetDropsExtractorMockLoadJetDropsExpectation
- type JetDropsExtractorMockLoadJetDropsParams
- type JetDropsExtractorMockLoadJetDropsResults
- type JetDropsExtractorMockStartExpectation
- type JetDropsExtractorMockStartParams
- type JetDropsExtractorMockStartResults
- type JetDropsExtractorMockStopExpectation
- type JetDropsExtractorMockStopParams
- type JetDropsExtractorMockStopResults
- type PulseExtractorMock
- func (mmGetCurrentPulse *PulseExtractorMock) GetCurrentPulse(ctx context.Context) (u1 uint32, err error)
- func (mmGetCurrentPulse *PulseExtractorMock) GetCurrentPulseAfterCounter() uint64
- func (mmGetCurrentPulse *PulseExtractorMock) GetCurrentPulseBeforeCounter() uint64
- func (mmGetNextFinalizedPulse *PulseExtractorMock) GetNextFinalizedPulse(ctx context.Context, p int64) (fp1 *exporter.FullPulse, err error)
- func (mmGetNextFinalizedPulse *PulseExtractorMock) GetNextFinalizedPulseAfterCounter() uint64
- func (mmGetNextFinalizedPulse *PulseExtractorMock) GetNextFinalizedPulseBeforeCounter() uint64
- func (m *PulseExtractorMock) MinimockFinish()
- func (m *PulseExtractorMock) MinimockGetCurrentPulseDone() bool
- func (m *PulseExtractorMock) MinimockGetCurrentPulseInspect()
- func (m *PulseExtractorMock) MinimockGetNextFinalizedPulseDone() bool
- func (m *PulseExtractorMock) MinimockGetNextFinalizedPulseInspect()
- func (m *PulseExtractorMock) MinimockWait(timeout mm_time.Duration)
- type PulseExtractorMockGetCurrentPulseExpectation
- type PulseExtractorMockGetCurrentPulseParams
- type PulseExtractorMockGetCurrentPulseResults
- type PulseExtractorMockGetNextFinalizedPulseExpectation
- type PulseExtractorMockGetNextFinalizedPulseParams
- type PulseExtractorMockGetNextFinalizedPulseResults
- type RecordExporterClientMock
- func (mmExport *RecordExporterClientMock) Export(ctx context.Context, in *mm_exporter.GetRecords, opts ...grpc.CallOption) (r1 mm_exporter.RecordExporter_ExportClient, err error)
- func (mmExport *RecordExporterClientMock) ExportAfterCounter() uint64
- func (mmExport *RecordExporterClientMock) ExportBeforeCounter() uint64
- func (m *RecordExporterClientMock) MinimockExportDone() bool
- func (m *RecordExporterClientMock) MinimockExportInspect()
- func (m *RecordExporterClientMock) MinimockFinish()
- func (m *RecordExporterClientMock) MinimockWait(timeout mm_time.Duration)
- type RecordExporterClientMockExportExpectation
- type RecordExporterClientMockExportParams
- type RecordExporterClientMockExportResults
- type StarterMock
- func (m *StarterMock) MinimockFinish()
- func (m *StarterMock) MinimockStartDone() bool
- func (m *StarterMock) MinimockStartInspect()
- func (m *StarterMock) MinimockWait(timeout mm_time.Duration)
- func (mmStart *StarterMock) Start(ctx context.Context) (err error)
- func (mmStart *StarterMock) StartAfterCounter() uint64
- func (mmStart *StarterMock) StartBeforeCounter() uint64
- type StarterMockStartExpectation
- type StarterMockStartParams
- type StarterMockStartResults
- type StopperMock
- func (m *StopperMock) MinimockFinish()
- func (m *StopperMock) MinimockStopDone() bool
- func (m *StopperMock) MinimockStopInspect()
- func (m *StopperMock) MinimockWait(timeout mm_time.Duration)
- func (mmStop *StopperMock) Stop(ctx context.Context) (err error)
- func (mmStop *StopperMock) StopAfterCounter() uint64
- func (mmStop *StopperMock) StopBeforeCounter() uint64
- type StopperMockStopExpectation
- type StopperMockStopParams
- type StopperMockStopResults
- type StorageMock
- func (mmCompletePulse *StorageMock) CompletePulse(pulseNumber int64) (err error)
- func (mmCompletePulse *StorageMock) CompletePulseAfterCounter() uint64
- func (mmCompletePulse *StorageMock) CompletePulseBeforeCounter() uint64
- func (mmGetIncompletePulses *StorageMock) GetIncompletePulses() (pa1 []models.Pulse, err error)
- func (mmGetIncompletePulses *StorageMock) GetIncompletePulsesAfterCounter() uint64
- func (mmGetIncompletePulses *StorageMock) GetIncompletePulsesBeforeCounter() uint64
- func (mmGetJetDrops *StorageMock) GetJetDrops(pulse models.Pulse) (ja1 []models.JetDrop, err error)
- func (mmGetJetDrops *StorageMock) GetJetDropsAfterCounter() uint64
- func (mmGetJetDrops *StorageMock) GetJetDropsBeforeCounter() uint64
- func (mmGetNextCompletePulseFilterByPrototypeReference *StorageMock) GetNextCompletePulseFilterByPrototypeReference(prevPulse int64, prototypes [][]byte) (p1 models.Pulse, err error)
- func (mmGetNextCompletePulseFilterByPrototypeReference *StorageMock) GetNextCompletePulseFilterByPrototypeReferenceAfterCounter() uint64
- func (mmGetNextCompletePulseFilterByPrototypeReference *StorageMock) GetNextCompletePulseFilterByPrototypeReferenceBeforeCounter() uint64
- func (mmGetNextSavedPulse *StorageMock) GetNextSavedPulse(fromPulseNumber models.Pulse, completedOnly bool) (p1 models.Pulse, err error)
- func (mmGetNextSavedPulse *StorageMock) GetNextSavedPulseAfterCounter() uint64
- func (mmGetNextSavedPulse *StorageMock) GetNextSavedPulseBeforeCounter() uint64
- func (mmGetPulseByPrev *StorageMock) GetPulseByPrev(prevPulse models.Pulse) (p1 models.Pulse, err error)
- func (mmGetPulseByPrev *StorageMock) GetPulseByPrevAfterCounter() uint64
- func (mmGetPulseByPrev *StorageMock) GetPulseByPrevBeforeCounter() uint64
- func (mmGetSequentialPulse *StorageMock) GetSequentialPulse() (p1 models.Pulse, err error)
- func (mmGetSequentialPulse *StorageMock) GetSequentialPulseAfterCounter() uint64
- func (mmGetSequentialPulse *StorageMock) GetSequentialPulseBeforeCounter() uint64
- func (m *StorageMock) MinimockCompletePulseDone() bool
- func (m *StorageMock) MinimockCompletePulseInspect()
- func (m *StorageMock) MinimockFinish()
- func (m *StorageMock) MinimockGetIncompletePulsesDone() bool
- func (m *StorageMock) MinimockGetIncompletePulsesInspect()
- func (m *StorageMock) MinimockGetJetDropsDone() bool
- func (m *StorageMock) MinimockGetJetDropsInspect()
- func (m *StorageMock) MinimockGetNextCompletePulseFilterByPrototypeReferenceDone() bool
- func (m *StorageMock) MinimockGetNextCompletePulseFilterByPrototypeReferenceInspect()
- func (m *StorageMock) MinimockGetNextSavedPulseDone() bool
- func (m *StorageMock) MinimockGetNextSavedPulseInspect()
- func (m *StorageMock) MinimockGetPulseByPrevDone() bool
- func (m *StorageMock) MinimockGetPulseByPrevInspect()
- func (m *StorageMock) MinimockGetSequentialPulseDone() bool
- func (m *StorageMock) MinimockGetSequentialPulseInspect()
- func (m *StorageMock) MinimockSaveJetDropDataDone() bool
- func (m *StorageMock) MinimockSaveJetDropDataInspect()
- func (m *StorageMock) MinimockSavePulseDone() bool
- func (m *StorageMock) MinimockSavePulseInspect()
- func (m *StorageMock) MinimockSequencePulseDone() bool
- func (m *StorageMock) MinimockSequencePulseInspect()
- func (m *StorageMock) MinimockWait(timeout mm_time.Duration)
- func (mmSaveJetDropData *StorageMock) SaveJetDropData(jetDrop models.JetDrop, records []models.Record, pulseNumber int64) (err error)
- func (mmSaveJetDropData *StorageMock) SaveJetDropDataAfterCounter() uint64
- func (mmSaveJetDropData *StorageMock) SaveJetDropDataBeforeCounter() uint64
- func (mmSavePulse *StorageMock) SavePulse(pulse models.Pulse) (err error)
- func (mmSavePulse *StorageMock) SavePulseAfterCounter() uint64
- func (mmSavePulse *StorageMock) SavePulseBeforeCounter() uint64
- func (mmSequencePulse *StorageMock) SequencePulse(pulseNumber int64) (err error)
- func (mmSequencePulse *StorageMock) SequencePulseAfterCounter() uint64
- func (mmSequencePulse *StorageMock) SequencePulseBeforeCounter() uint64
- type StorageMockCompletePulseExpectation
- type StorageMockCompletePulseParams
- type StorageMockCompletePulseResults
- type StorageMockGetIncompletePulsesExpectation
- type StorageMockGetIncompletePulsesResults
- type StorageMockGetJetDropsExpectation
- type StorageMockGetJetDropsParams
- type StorageMockGetJetDropsResults
- type StorageMockGetNextCompletePulseFilterByPrototypeReferenceExpectation
- type StorageMockGetNextCompletePulseFilterByPrototypeReferenceParams
- type StorageMockGetNextCompletePulseFilterByPrototypeReferenceResults
- type StorageMockGetNextSavedPulseExpectation
- type StorageMockGetNextSavedPulseParams
- type StorageMockGetNextSavedPulseResults
- type StorageMockGetPulseByPrevExpectation
- type StorageMockGetPulseByPrevParams
- type StorageMockGetPulseByPrevResults
- type StorageMockGetSequentialPulseExpectation
- type StorageMockGetSequentialPulseResults
- type StorageMockSaveJetDropDataExpectation
- type StorageMockSaveJetDropDataParams
- type StorageMockSaveJetDropDataResults
- type StorageMockSavePulseExpectation
- type StorageMockSavePulseParams
- type StorageMockSavePulseResults
- type StorageMockSequencePulseExpectation
- type StorageMockSequencePulseParams
- type StorageMockSequencePulseResults
- type StorageSetterMock
- func (mmCompletePulse *StorageSetterMock) CompletePulse(pulseNumber int64) (err error)
- func (mmCompletePulse *StorageSetterMock) CompletePulseAfterCounter() uint64
- func (mmCompletePulse *StorageSetterMock) CompletePulseBeforeCounter() uint64
- func (m *StorageSetterMock) MinimockCompletePulseDone() bool
- func (m *StorageSetterMock) MinimockCompletePulseInspect()
- func (m *StorageSetterMock) MinimockFinish()
- func (m *StorageSetterMock) MinimockSaveJetDropDataDone() bool
- func (m *StorageSetterMock) MinimockSaveJetDropDataInspect()
- func (m *StorageSetterMock) MinimockSavePulseDone() bool
- func (m *StorageSetterMock) MinimockSavePulseInspect()
- func (m *StorageSetterMock) MinimockSequencePulseDone() bool
- func (m *StorageSetterMock) MinimockSequencePulseInspect()
- func (m *StorageSetterMock) MinimockWait(timeout mm_time.Duration)
- func (mmSaveJetDropData *StorageSetterMock) SaveJetDropData(jetDrop models.JetDrop, records []models.Record, pulseNumber int64) (err error)
- func (mmSaveJetDropData *StorageSetterMock) SaveJetDropDataAfterCounter() uint64
- func (mmSaveJetDropData *StorageSetterMock) SaveJetDropDataBeforeCounter() uint64
- func (mmSavePulse *StorageSetterMock) SavePulse(pulse models.Pulse) (err error)
- func (mmSavePulse *StorageSetterMock) SavePulseAfterCounter() uint64
- func (mmSavePulse *StorageSetterMock) SavePulseBeforeCounter() uint64
- func (mmSequencePulse *StorageSetterMock) SequencePulse(pulseNumber int64) (err error)
- func (mmSequencePulse *StorageSetterMock) SequencePulseAfterCounter() uint64
- func (mmSequencePulse *StorageSetterMock) SequencePulseBeforeCounter() uint64
- type StorageSetterMockCompletePulseExpectation
- type StorageSetterMockCompletePulseParams
- type StorageSetterMockCompletePulseResults
- type StorageSetterMockSaveJetDropDataExpectation
- type StorageSetterMockSaveJetDropDataParams
- type StorageSetterMockSaveJetDropDataResults
- type StorageSetterMockSavePulseExpectation
- type StorageSetterMockSavePulseParams
- type StorageSetterMockSavePulseResults
- type StorageSetterMockSequencePulseExpectation
- type StorageSetterMockSequencePulseParams
- type StorageSetterMockSequencePulseResults
- type TransformerMock
- func (mmGetJetDropsChannel *TransformerMock) GetJetDropsChannel() (ch1 <-chan *types.JetDrop)
- func (mmGetJetDropsChannel *TransformerMock) GetJetDropsChannelAfterCounter() uint64
- func (mmGetJetDropsChannel *TransformerMock) GetJetDropsChannelBeforeCounter() uint64
- func (m *TransformerMock) MinimockFinish()
- func (m *TransformerMock) MinimockGetJetDropsChannelDone() bool
- func (m *TransformerMock) MinimockGetJetDropsChannelInspect()
- func (m *TransformerMock) MinimockStartDone() bool
- func (m *TransformerMock) MinimockStartInspect()
- func (m *TransformerMock) MinimockStopDone() bool
- func (m *TransformerMock) MinimockStopInspect()
- func (m *TransformerMock) MinimockWait(timeout mm_time.Duration)
- func (mmStart *TransformerMock) Start(ctx context.Context) (err error)
- func (mmStart *TransformerMock) StartAfterCounter() uint64
- func (mmStart *TransformerMock) StartBeforeCounter() uint64
- func (mmStop *TransformerMock) Stop(ctx context.Context) (err error)
- func (mmStop *TransformerMock) StopAfterCounter() uint64
- func (mmStop *TransformerMock) StopBeforeCounter() uint64
- type TransformerMockGetJetDropsChannelExpectation
- type TransformerMockGetJetDropsChannelResults
- type TransformerMockStartExpectation
- type TransformerMockStartParams
- type TransformerMockStartResults
- type TransformerMockStopExpectation
- type TransformerMockStopParams
- type TransformerMockStopResults
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClientMock ¶
type ClientMock struct { GetGRPCConnMock mClientMockGetGRPCConn NotifyShutdownMock mClientMockNotifyShutdown // contains filtered or unexported fields }
ClientMock implements interfaces.Client
func NewClientMock ¶
func NewClientMock(t minimock.Tester) *ClientMock
NewClientMock returns a mock for interfaces.Client
func (*ClientMock) GetGRPCConn ¶
func (mmGetGRPCConn *ClientMock) GetGRPCConn() (cp1 *grpc.ClientConn)
GetGRPCConn implements interfaces.Client
func (*ClientMock) GetGRPCConnAfterCounter ¶
func (mmGetGRPCConn *ClientMock) GetGRPCConnAfterCounter() uint64
GetGRPCConnAfterCounter returns a count of finished ClientMock.GetGRPCConn invocations
func (*ClientMock) GetGRPCConnBeforeCounter ¶
func (mmGetGRPCConn *ClientMock) GetGRPCConnBeforeCounter() uint64
GetGRPCConnBeforeCounter returns a count of ClientMock.GetGRPCConn invocations
func (*ClientMock) MinimockFinish ¶
func (m *ClientMock) MinimockFinish()
MinimockFinish checks that all mocked methods have been called the expected number of times
func (*ClientMock) MinimockGetGRPCConnDone ¶
func (m *ClientMock) MinimockGetGRPCConnDone() bool
MinimockGetGRPCConnDone returns true if the count of the GetGRPCConn invocations corresponds the number of defined expectations
func (*ClientMock) MinimockGetGRPCConnInspect ¶
func (m *ClientMock) MinimockGetGRPCConnInspect()
MinimockGetGRPCConnInspect logs each unmet expectation
func (*ClientMock) MinimockNotifyShutdownDone ¶
func (m *ClientMock) MinimockNotifyShutdownDone() bool
MinimockNotifyShutdownDone returns true if the count of the NotifyShutdown invocations corresponds the number of defined expectations
func (*ClientMock) MinimockNotifyShutdownInspect ¶
func (m *ClientMock) MinimockNotifyShutdownInspect()
MinimockNotifyShutdownInspect logs each unmet expectation
func (*ClientMock) MinimockWait ¶
func (m *ClientMock) MinimockWait(timeout mm_time.Duration)
MinimockWait waits for all mocked methods to be called the expected number of times
func (*ClientMock) NotifyShutdown ¶
func (mmNotifyShutdown *ClientMock) NotifyShutdown(ctx context.Context, stopChannel chan<- struct { }, waitForStateChange time.Duration)
NotifyShutdown implements interfaces.Client
func (*ClientMock) NotifyShutdownAfterCounter ¶
func (mmNotifyShutdown *ClientMock) NotifyShutdownAfterCounter() uint64
NotifyShutdownAfterCounter returns a count of finished ClientMock.NotifyShutdown invocations
func (*ClientMock) NotifyShutdownBeforeCounter ¶
func (mmNotifyShutdown *ClientMock) NotifyShutdownBeforeCounter() uint64
NotifyShutdownBeforeCounter returns a count of ClientMock.NotifyShutdown invocations
type ClientMockGetGRPCConnExpectation ¶
type ClientMockGetGRPCConnExpectation struct { Counter uint64 // contains filtered or unexported fields }
ClientMockGetGRPCConnExpectation specifies expectation struct of the Client.GetGRPCConn
type ClientMockGetGRPCConnResults ¶
type ClientMockGetGRPCConnResults struct {
// contains filtered or unexported fields
}
ClientMockGetGRPCConnResults contains results of the Client.GetGRPCConn
type ClientMockNotifyShutdownExpectation ¶
type ClientMockNotifyShutdownExpectation struct { Counter uint64 // contains filtered or unexported fields }
ClientMockNotifyShutdownExpectation specifies expectation struct of the Client.NotifyShutdown
type ClientMockNotifyShutdownParams ¶
type ClientMockNotifyShutdownParams struct {
// contains filtered or unexported fields
}
ClientMockNotifyShutdownParams contains parameters of the Client.NotifyShutdown
type ConnectionManagerMock ¶
type ConnectionManagerMock struct { StartMock mConnectionManagerMockStart StopMock mConnectionManagerMockStop // contains filtered or unexported fields }
ConnectionManagerMock implements interfaces.ConnectionManager
func NewConnectionManagerMock ¶
func NewConnectionManagerMock(t minimock.Tester) *ConnectionManagerMock
NewConnectionManagerMock returns a mock for interfaces.ConnectionManager
func (*ConnectionManagerMock) MinimockFinish ¶
func (m *ConnectionManagerMock) MinimockFinish()
MinimockFinish checks that all mocked methods have been called the expected number of times
func (*ConnectionManagerMock) MinimockStartDone ¶
func (m *ConnectionManagerMock) MinimockStartDone() bool
MinimockStartDone returns true if the count of the Start invocations corresponds the number of defined expectations
func (*ConnectionManagerMock) MinimockStartInspect ¶
func (m *ConnectionManagerMock) MinimockStartInspect()
MinimockStartInspect logs each unmet expectation
func (*ConnectionManagerMock) MinimockStopDone ¶
func (m *ConnectionManagerMock) MinimockStopDone() bool
MinimockStopDone returns true if the count of the Stop invocations corresponds the number of defined expectations
func (*ConnectionManagerMock) MinimockStopInspect ¶
func (m *ConnectionManagerMock) MinimockStopInspect()
MinimockStopInspect logs each unmet expectation
func (*ConnectionManagerMock) MinimockWait ¶
func (m *ConnectionManagerMock) MinimockWait(timeout mm_time.Duration)
MinimockWait waits for all mocked methods to be called the expected number of times
func (*ConnectionManagerMock) Start ¶
func (mmStart *ConnectionManagerMock) Start(ctx context.Context) (err error)
Start implements interfaces.ConnectionManager
func (*ConnectionManagerMock) StartAfterCounter ¶
func (mmStart *ConnectionManagerMock) StartAfterCounter() uint64
StartAfterCounter returns a count of finished ConnectionManagerMock.Start invocations
func (*ConnectionManagerMock) StartBeforeCounter ¶
func (mmStart *ConnectionManagerMock) StartBeforeCounter() uint64
StartBeforeCounter returns a count of ConnectionManagerMock.Start invocations
func (*ConnectionManagerMock) Stop ¶
func (mmStop *ConnectionManagerMock) Stop(ctx context.Context) (err error)
Stop implements interfaces.ConnectionManager
func (*ConnectionManagerMock) StopAfterCounter ¶
func (mmStop *ConnectionManagerMock) StopAfterCounter() uint64
StopAfterCounter returns a count of finished ConnectionManagerMock.Stop invocations
func (*ConnectionManagerMock) StopBeforeCounter ¶
func (mmStop *ConnectionManagerMock) StopBeforeCounter() uint64
StopBeforeCounter returns a count of ConnectionManagerMock.Stop invocations
type ConnectionManagerMockStartExpectation ¶
type ConnectionManagerMockStartExpectation struct { Counter uint64 // contains filtered or unexported fields }
ConnectionManagerMockStartExpectation specifies expectation struct of the ConnectionManager.Start
func (*ConnectionManagerMockStartExpectation) Then ¶
func (e *ConnectionManagerMockStartExpectation) Then(err error) *ConnectionManagerMock
Then sets up ConnectionManager.Start return parameters for the expectation previously defined by the When method
type ConnectionManagerMockStartParams ¶
type ConnectionManagerMockStartParams struct {
// contains filtered or unexported fields
}
ConnectionManagerMockStartParams contains parameters of the ConnectionManager.Start
type ConnectionManagerMockStartResults ¶
type ConnectionManagerMockStartResults struct {
// contains filtered or unexported fields
}
ConnectionManagerMockStartResults contains results of the ConnectionManager.Start
type ConnectionManagerMockStopExpectation ¶
type ConnectionManagerMockStopExpectation struct { Counter uint64 // contains filtered or unexported fields }
ConnectionManagerMockStopExpectation specifies expectation struct of the ConnectionManager.Stop
func (*ConnectionManagerMockStopExpectation) Then ¶
func (e *ConnectionManagerMockStopExpectation) Then(err error) *ConnectionManagerMock
Then sets up ConnectionManager.Stop return parameters for the expectation previously defined by the When method
type ConnectionManagerMockStopParams ¶
type ConnectionManagerMockStopParams struct {
// contains filtered or unexported fields
}
ConnectionManagerMockStopParams contains parameters of the ConnectionManager.Stop
type ConnectionManagerMockStopResults ¶
type ConnectionManagerMockStopResults struct {
// contains filtered or unexported fields
}
ConnectionManagerMockStopResults contains results of the ConnectionManager.Stop
type ControllerMock ¶
type ControllerMock struct { SetJetDropDataMock mControllerMockSetJetDropData StartMock mControllerMockStart StopMock mControllerMockStop // contains filtered or unexported fields }
ControllerMock implements interfaces.Controller
func NewControllerMock ¶
func NewControllerMock(t minimock.Tester) *ControllerMock
NewControllerMock returns a mock for interfaces.Controller
func (*ControllerMock) MinimockFinish ¶
func (m *ControllerMock) MinimockFinish()
MinimockFinish checks that all mocked methods have been called the expected number of times
func (*ControllerMock) MinimockSetJetDropDataDone ¶
func (m *ControllerMock) MinimockSetJetDropDataDone() bool
MinimockSetJetDropDataDone returns true if the count of the SetJetDropData invocations corresponds the number of defined expectations
func (*ControllerMock) MinimockSetJetDropDataInspect ¶
func (m *ControllerMock) MinimockSetJetDropDataInspect()
MinimockSetJetDropDataInspect logs each unmet expectation
func (*ControllerMock) MinimockStartDone ¶
func (m *ControllerMock) MinimockStartDone() bool
MinimockStartDone returns true if the count of the Start invocations corresponds the number of defined expectations
func (*ControllerMock) MinimockStartInspect ¶
func (m *ControllerMock) MinimockStartInspect()
MinimockStartInspect logs each unmet expectation
func (*ControllerMock) MinimockStopDone ¶
func (m *ControllerMock) MinimockStopDone() bool
MinimockStopDone returns true if the count of the Stop invocations corresponds the number of defined expectations
func (*ControllerMock) MinimockStopInspect ¶
func (m *ControllerMock) MinimockStopInspect()
MinimockStopInspect logs each unmet expectation
func (*ControllerMock) MinimockWait ¶
func (m *ControllerMock) MinimockWait(timeout mm_time.Duration)
MinimockWait waits for all mocked methods to be called the expected number of times
func (*ControllerMock) SetJetDropData ¶
func (mmSetJetDropData *ControllerMock) SetJetDropData(pulse types.Pulse, jetID string)
SetJetDropData implements interfaces.Controller
func (*ControllerMock) SetJetDropDataAfterCounter ¶
func (mmSetJetDropData *ControllerMock) SetJetDropDataAfterCounter() uint64
SetJetDropDataAfterCounter returns a count of finished ControllerMock.SetJetDropData invocations
func (*ControllerMock) SetJetDropDataBeforeCounter ¶
func (mmSetJetDropData *ControllerMock) SetJetDropDataBeforeCounter() uint64
SetJetDropDataBeforeCounter returns a count of ControllerMock.SetJetDropData invocations
func (*ControllerMock) Start ¶
func (mmStart *ControllerMock) Start(ctx context.Context) (err error)
Start implements interfaces.Controller
func (*ControllerMock) StartAfterCounter ¶
func (mmStart *ControllerMock) StartAfterCounter() uint64
StartAfterCounter returns a count of finished ControllerMock.Start invocations
func (*ControllerMock) StartBeforeCounter ¶
func (mmStart *ControllerMock) StartBeforeCounter() uint64
StartBeforeCounter returns a count of ControllerMock.Start invocations
func (*ControllerMock) Stop ¶
func (mmStop *ControllerMock) Stop(ctx context.Context) (err error)
Stop implements interfaces.Controller
func (*ControllerMock) StopAfterCounter ¶
func (mmStop *ControllerMock) StopAfterCounter() uint64
StopAfterCounter returns a count of finished ControllerMock.Stop invocations
func (*ControllerMock) StopBeforeCounter ¶
func (mmStop *ControllerMock) StopBeforeCounter() uint64
StopBeforeCounter returns a count of ControllerMock.Stop invocations
type ControllerMockSetJetDropDataExpectation ¶
type ControllerMockSetJetDropDataExpectation struct { Counter uint64 // contains filtered or unexported fields }
ControllerMockSetJetDropDataExpectation specifies expectation struct of the Controller.SetJetDropData
type ControllerMockSetJetDropDataParams ¶
type ControllerMockSetJetDropDataParams struct {
// contains filtered or unexported fields
}
ControllerMockSetJetDropDataParams contains parameters of the Controller.SetJetDropData
type ControllerMockStartExpectation ¶
type ControllerMockStartExpectation struct { Counter uint64 // contains filtered or unexported fields }
ControllerMockStartExpectation specifies expectation struct of the Controller.Start
func (*ControllerMockStartExpectation) Then ¶
func (e *ControllerMockStartExpectation) Then(err error) *ControllerMock
Then sets up Controller.Start return parameters for the expectation previously defined by the When method
type ControllerMockStartParams ¶
type ControllerMockStartParams struct {
// contains filtered or unexported fields
}
ControllerMockStartParams contains parameters of the Controller.Start
type ControllerMockStartResults ¶
type ControllerMockStartResults struct {
// contains filtered or unexported fields
}
ControllerMockStartResults contains results of the Controller.Start
type ControllerMockStopExpectation ¶
type ControllerMockStopExpectation struct { Counter uint64 // contains filtered or unexported fields }
ControllerMockStopExpectation specifies expectation struct of the Controller.Stop
func (*ControllerMockStopExpectation) Then ¶
func (e *ControllerMockStopExpectation) Then(err error) *ControllerMock
Then sets up Controller.Stop return parameters for the expectation previously defined by the When method
type ControllerMockStopParams ¶
type ControllerMockStopParams struct {
// contains filtered or unexported fields
}
ControllerMockStopParams contains parameters of the Controller.Stop
type ControllerMockStopResults ¶
type ControllerMockStopResults struct {
// contains filtered or unexported fields
}
ControllerMockStopResults contains results of the Controller.Stop
type JetDropsExtractorMock ¶
type JetDropsExtractorMock struct { GetJetDropsMock mJetDropsExtractorMockGetJetDrops LoadJetDropsMock mJetDropsExtractorMockLoadJetDrops StartMock mJetDropsExtractorMockStart StopMock mJetDropsExtractorMockStop // contains filtered or unexported fields }
JetDropsExtractorMock implements interfaces.JetDropsExtractor
func NewJetDropsExtractorMock ¶
func NewJetDropsExtractorMock(t minimock.Tester) *JetDropsExtractorMock
NewJetDropsExtractorMock returns a mock for interfaces.JetDropsExtractor
func (*JetDropsExtractorMock) GetJetDrops ¶
func (mmGetJetDrops *JetDropsExtractorMock) GetJetDrops(ctx context.Context) (ch1 <-chan *types.PlatformPulseData)
GetJetDrops implements interfaces.JetDropsExtractor
func (*JetDropsExtractorMock) GetJetDropsAfterCounter ¶
func (mmGetJetDrops *JetDropsExtractorMock) GetJetDropsAfterCounter() uint64
GetJetDropsAfterCounter returns a count of finished JetDropsExtractorMock.GetJetDrops invocations
func (*JetDropsExtractorMock) GetJetDropsBeforeCounter ¶
func (mmGetJetDrops *JetDropsExtractorMock) GetJetDropsBeforeCounter() uint64
GetJetDropsBeforeCounter returns a count of JetDropsExtractorMock.GetJetDrops invocations
func (*JetDropsExtractorMock) LoadJetDrops ¶
func (mmLoadJetDrops *JetDropsExtractorMock) LoadJetDrops(ctx context.Context, fromPulseNumber int64, toPulseNumber int64) (err error)
LoadJetDrops implements interfaces.JetDropsExtractor
func (*JetDropsExtractorMock) LoadJetDropsAfterCounter ¶
func (mmLoadJetDrops *JetDropsExtractorMock) LoadJetDropsAfterCounter() uint64
LoadJetDropsAfterCounter returns a count of finished JetDropsExtractorMock.LoadJetDrops invocations
func (*JetDropsExtractorMock) LoadJetDropsBeforeCounter ¶
func (mmLoadJetDrops *JetDropsExtractorMock) LoadJetDropsBeforeCounter() uint64
LoadJetDropsBeforeCounter returns a count of JetDropsExtractorMock.LoadJetDrops invocations
func (*JetDropsExtractorMock) MinimockFinish ¶
func (m *JetDropsExtractorMock) MinimockFinish()
MinimockFinish checks that all mocked methods have been called the expected number of times
func (*JetDropsExtractorMock) MinimockGetJetDropsDone ¶
func (m *JetDropsExtractorMock) MinimockGetJetDropsDone() bool
MinimockGetJetDropsDone returns true if the count of the GetJetDrops invocations corresponds the number of defined expectations
func (*JetDropsExtractorMock) MinimockGetJetDropsInspect ¶
func (m *JetDropsExtractorMock) MinimockGetJetDropsInspect()
MinimockGetJetDropsInspect logs each unmet expectation
func (*JetDropsExtractorMock) MinimockLoadJetDropsDone ¶
func (m *JetDropsExtractorMock) MinimockLoadJetDropsDone() bool
MinimockLoadJetDropsDone returns true if the count of the LoadJetDrops invocations corresponds the number of defined expectations
func (*JetDropsExtractorMock) MinimockLoadJetDropsInspect ¶
func (m *JetDropsExtractorMock) MinimockLoadJetDropsInspect()
MinimockLoadJetDropsInspect logs each unmet expectation
func (*JetDropsExtractorMock) MinimockStartDone ¶
func (m *JetDropsExtractorMock) MinimockStartDone() bool
MinimockStartDone returns true if the count of the Start invocations corresponds the number of defined expectations
func (*JetDropsExtractorMock) MinimockStartInspect ¶
func (m *JetDropsExtractorMock) MinimockStartInspect()
MinimockStartInspect logs each unmet expectation
func (*JetDropsExtractorMock) MinimockStopDone ¶
func (m *JetDropsExtractorMock) MinimockStopDone() bool
MinimockStopDone returns true if the count of the Stop invocations corresponds the number of defined expectations
func (*JetDropsExtractorMock) MinimockStopInspect ¶
func (m *JetDropsExtractorMock) MinimockStopInspect()
MinimockStopInspect logs each unmet expectation
func (*JetDropsExtractorMock) MinimockWait ¶
func (m *JetDropsExtractorMock) MinimockWait(timeout mm_time.Duration)
MinimockWait waits for all mocked methods to be called the expected number of times
func (*JetDropsExtractorMock) Start ¶
func (mmStart *JetDropsExtractorMock) Start(ctx context.Context) (err error)
Start implements interfaces.JetDropsExtractor
func (*JetDropsExtractorMock) StartAfterCounter ¶
func (mmStart *JetDropsExtractorMock) StartAfterCounter() uint64
StartAfterCounter returns a count of finished JetDropsExtractorMock.Start invocations
func (*JetDropsExtractorMock) StartBeforeCounter ¶
func (mmStart *JetDropsExtractorMock) StartBeforeCounter() uint64
StartBeforeCounter returns a count of JetDropsExtractorMock.Start invocations
func (*JetDropsExtractorMock) Stop ¶
func (mmStop *JetDropsExtractorMock) Stop(ctx context.Context) (err error)
Stop implements interfaces.JetDropsExtractor
func (*JetDropsExtractorMock) StopAfterCounter ¶
func (mmStop *JetDropsExtractorMock) StopAfterCounter() uint64
StopAfterCounter returns a count of finished JetDropsExtractorMock.Stop invocations
func (*JetDropsExtractorMock) StopBeforeCounter ¶
func (mmStop *JetDropsExtractorMock) StopBeforeCounter() uint64
StopBeforeCounter returns a count of JetDropsExtractorMock.Stop invocations
type JetDropsExtractorMockGetJetDropsExpectation ¶
type JetDropsExtractorMockGetJetDropsExpectation struct { Counter uint64 // contains filtered or unexported fields }
JetDropsExtractorMockGetJetDropsExpectation specifies expectation struct of the JetDropsExtractor.GetJetDrops
func (*JetDropsExtractorMockGetJetDropsExpectation) Then ¶
func (e *JetDropsExtractorMockGetJetDropsExpectation) Then(ch1 <-chan *types.PlatformPulseData) *JetDropsExtractorMock
Then sets up JetDropsExtractor.GetJetDrops return parameters for the expectation previously defined by the When method
type JetDropsExtractorMockGetJetDropsParams ¶
type JetDropsExtractorMockGetJetDropsParams struct {
// contains filtered or unexported fields
}
JetDropsExtractorMockGetJetDropsParams contains parameters of the JetDropsExtractor.GetJetDrops
type JetDropsExtractorMockGetJetDropsResults ¶
type JetDropsExtractorMockGetJetDropsResults struct {
// contains filtered or unexported fields
}
JetDropsExtractorMockGetJetDropsResults contains results of the JetDropsExtractor.GetJetDrops
type JetDropsExtractorMockLoadJetDropsExpectation ¶
type JetDropsExtractorMockLoadJetDropsExpectation struct { Counter uint64 // contains filtered or unexported fields }
JetDropsExtractorMockLoadJetDropsExpectation specifies expectation struct of the JetDropsExtractor.LoadJetDrops
func (*JetDropsExtractorMockLoadJetDropsExpectation) Then ¶
func (e *JetDropsExtractorMockLoadJetDropsExpectation) Then(err error) *JetDropsExtractorMock
Then sets up JetDropsExtractor.LoadJetDrops return parameters for the expectation previously defined by the When method
type JetDropsExtractorMockLoadJetDropsParams ¶
type JetDropsExtractorMockLoadJetDropsParams struct {
// contains filtered or unexported fields
}
JetDropsExtractorMockLoadJetDropsParams contains parameters of the JetDropsExtractor.LoadJetDrops
type JetDropsExtractorMockLoadJetDropsResults ¶
type JetDropsExtractorMockLoadJetDropsResults struct {
// contains filtered or unexported fields
}
JetDropsExtractorMockLoadJetDropsResults contains results of the JetDropsExtractor.LoadJetDrops
type JetDropsExtractorMockStartExpectation ¶
type JetDropsExtractorMockStartExpectation struct { Counter uint64 // contains filtered or unexported fields }
JetDropsExtractorMockStartExpectation specifies expectation struct of the JetDropsExtractor.Start
func (*JetDropsExtractorMockStartExpectation) Then ¶
func (e *JetDropsExtractorMockStartExpectation) Then(err error) *JetDropsExtractorMock
Then sets up JetDropsExtractor.Start return parameters for the expectation previously defined by the When method
type JetDropsExtractorMockStartParams ¶
type JetDropsExtractorMockStartParams struct {
// contains filtered or unexported fields
}
JetDropsExtractorMockStartParams contains parameters of the JetDropsExtractor.Start
type JetDropsExtractorMockStartResults ¶
type JetDropsExtractorMockStartResults struct {
// contains filtered or unexported fields
}
JetDropsExtractorMockStartResults contains results of the JetDropsExtractor.Start
type JetDropsExtractorMockStopExpectation ¶
type JetDropsExtractorMockStopExpectation struct { Counter uint64 // contains filtered or unexported fields }
JetDropsExtractorMockStopExpectation specifies expectation struct of the JetDropsExtractor.Stop
func (*JetDropsExtractorMockStopExpectation) Then ¶
func (e *JetDropsExtractorMockStopExpectation) Then(err error) *JetDropsExtractorMock
Then sets up JetDropsExtractor.Stop return parameters for the expectation previously defined by the When method
type JetDropsExtractorMockStopParams ¶
type JetDropsExtractorMockStopParams struct {
// contains filtered or unexported fields
}
JetDropsExtractorMockStopParams contains parameters of the JetDropsExtractor.Stop
type JetDropsExtractorMockStopResults ¶
type JetDropsExtractorMockStopResults struct {
// contains filtered or unexported fields
}
JetDropsExtractorMockStopResults contains results of the JetDropsExtractor.Stop
type PulseExtractorMock ¶
type PulseExtractorMock struct { GetCurrentPulseMock mPulseExtractorMockGetCurrentPulse GetNextFinalizedPulseMock mPulseExtractorMockGetNextFinalizedPulse // contains filtered or unexported fields }
PulseExtractorMock implements interfaces.PulseExtractor
func NewPulseExtractorMock ¶
func NewPulseExtractorMock(t minimock.Tester) *PulseExtractorMock
NewPulseExtractorMock returns a mock for interfaces.PulseExtractor
func (*PulseExtractorMock) GetCurrentPulse ¶
func (mmGetCurrentPulse *PulseExtractorMock) GetCurrentPulse(ctx context.Context) (u1 uint32, err error)
GetCurrentPulse implements interfaces.PulseExtractor
func (*PulseExtractorMock) GetCurrentPulseAfterCounter ¶
func (mmGetCurrentPulse *PulseExtractorMock) GetCurrentPulseAfterCounter() uint64
GetCurrentPulseAfterCounter returns a count of finished PulseExtractorMock.GetCurrentPulse invocations
func (*PulseExtractorMock) GetCurrentPulseBeforeCounter ¶
func (mmGetCurrentPulse *PulseExtractorMock) GetCurrentPulseBeforeCounter() uint64
GetCurrentPulseBeforeCounter returns a count of PulseExtractorMock.GetCurrentPulse invocations
func (*PulseExtractorMock) GetNextFinalizedPulse ¶
func (mmGetNextFinalizedPulse *PulseExtractorMock) GetNextFinalizedPulse(ctx context.Context, p int64) (fp1 *exporter.FullPulse, err error)
GetNextFinalizedPulse implements interfaces.PulseExtractor
func (*PulseExtractorMock) GetNextFinalizedPulseAfterCounter ¶
func (mmGetNextFinalizedPulse *PulseExtractorMock) GetNextFinalizedPulseAfterCounter() uint64
GetNextFinalizedPulseAfterCounter returns a count of finished PulseExtractorMock.GetNextFinalizedPulse invocations
func (*PulseExtractorMock) GetNextFinalizedPulseBeforeCounter ¶
func (mmGetNextFinalizedPulse *PulseExtractorMock) GetNextFinalizedPulseBeforeCounter() uint64
GetNextFinalizedPulseBeforeCounter returns a count of PulseExtractorMock.GetNextFinalizedPulse invocations
func (*PulseExtractorMock) MinimockFinish ¶
func (m *PulseExtractorMock) MinimockFinish()
MinimockFinish checks that all mocked methods have been called the expected number of times
func (*PulseExtractorMock) MinimockGetCurrentPulseDone ¶
func (m *PulseExtractorMock) MinimockGetCurrentPulseDone() bool
MinimockGetCurrentPulseDone returns true if the count of the GetCurrentPulse invocations corresponds the number of defined expectations
func (*PulseExtractorMock) MinimockGetCurrentPulseInspect ¶
func (m *PulseExtractorMock) MinimockGetCurrentPulseInspect()
MinimockGetCurrentPulseInspect logs each unmet expectation
func (*PulseExtractorMock) MinimockGetNextFinalizedPulseDone ¶
func (m *PulseExtractorMock) MinimockGetNextFinalizedPulseDone() bool
MinimockGetNextFinalizedPulseDone returns true if the count of the GetNextFinalizedPulse invocations corresponds the number of defined expectations
func (*PulseExtractorMock) MinimockGetNextFinalizedPulseInspect ¶
func (m *PulseExtractorMock) MinimockGetNextFinalizedPulseInspect()
MinimockGetNextFinalizedPulseInspect logs each unmet expectation
func (*PulseExtractorMock) MinimockWait ¶
func (m *PulseExtractorMock) MinimockWait(timeout mm_time.Duration)
MinimockWait waits for all mocked methods to be called the expected number of times
type PulseExtractorMockGetCurrentPulseExpectation ¶
type PulseExtractorMockGetCurrentPulseExpectation struct { Counter uint64 // contains filtered or unexported fields }
PulseExtractorMockGetCurrentPulseExpectation specifies expectation struct of the PulseExtractor.GetCurrentPulse
func (*PulseExtractorMockGetCurrentPulseExpectation) Then ¶
func (e *PulseExtractorMockGetCurrentPulseExpectation) Then(u1 uint32, err error) *PulseExtractorMock
Then sets up PulseExtractor.GetCurrentPulse return parameters for the expectation previously defined by the When method
type PulseExtractorMockGetCurrentPulseParams ¶
type PulseExtractorMockGetCurrentPulseParams struct {
// contains filtered or unexported fields
}
PulseExtractorMockGetCurrentPulseParams contains parameters of the PulseExtractor.GetCurrentPulse
type PulseExtractorMockGetCurrentPulseResults ¶
type PulseExtractorMockGetCurrentPulseResults struct {
// contains filtered or unexported fields
}
PulseExtractorMockGetCurrentPulseResults contains results of the PulseExtractor.GetCurrentPulse
type PulseExtractorMockGetNextFinalizedPulseExpectation ¶
type PulseExtractorMockGetNextFinalizedPulseExpectation struct { Counter uint64 // contains filtered or unexported fields }
PulseExtractorMockGetNextFinalizedPulseExpectation specifies expectation struct of the PulseExtractor.GetNextFinalizedPulse
func (*PulseExtractorMockGetNextFinalizedPulseExpectation) Then ¶
func (e *PulseExtractorMockGetNextFinalizedPulseExpectation) Then(fp1 *exporter.FullPulse, err error) *PulseExtractorMock
Then sets up PulseExtractor.GetNextFinalizedPulse return parameters for the expectation previously defined by the When method
type PulseExtractorMockGetNextFinalizedPulseParams ¶
type PulseExtractorMockGetNextFinalizedPulseParams struct {
// contains filtered or unexported fields
}
PulseExtractorMockGetNextFinalizedPulseParams contains parameters of the PulseExtractor.GetNextFinalizedPulse
type PulseExtractorMockGetNextFinalizedPulseResults ¶
type PulseExtractorMockGetNextFinalizedPulseResults struct {
// contains filtered or unexported fields
}
PulseExtractorMockGetNextFinalizedPulseResults contains results of the PulseExtractor.GetNextFinalizedPulse
type RecordExporterClientMock ¶
type RecordExporterClientMock struct { ExportMock mRecordExporterClientMockExport // contains filtered or unexported fields }
RecordExporterClientMock implements exporter.RecordExporterClient
func NewRecordExporterClientMock ¶
func NewRecordExporterClientMock(t minimock.Tester) *RecordExporterClientMock
NewRecordExporterClientMock returns a mock for exporter.RecordExporterClient
func (*RecordExporterClientMock) Export ¶
func (mmExport *RecordExporterClientMock) Export(ctx context.Context, in *mm_exporter.GetRecords, opts ...grpc.CallOption) (r1 mm_exporter.RecordExporter_ExportClient, err error)
Export implements exporter.RecordExporterClient
func (*RecordExporterClientMock) ExportAfterCounter ¶
func (mmExport *RecordExporterClientMock) ExportAfterCounter() uint64
ExportAfterCounter returns a count of finished RecordExporterClientMock.Export invocations
func (*RecordExporterClientMock) ExportBeforeCounter ¶
func (mmExport *RecordExporterClientMock) ExportBeforeCounter() uint64
ExportBeforeCounter returns a count of RecordExporterClientMock.Export invocations
func (*RecordExporterClientMock) MinimockExportDone ¶
func (m *RecordExporterClientMock) MinimockExportDone() bool
MinimockExportDone returns true if the count of the Export invocations corresponds the number of defined expectations
func (*RecordExporterClientMock) MinimockExportInspect ¶
func (m *RecordExporterClientMock) MinimockExportInspect()
MinimockExportInspect logs each unmet expectation
func (*RecordExporterClientMock) MinimockFinish ¶
func (m *RecordExporterClientMock) MinimockFinish()
MinimockFinish checks that all mocked methods have been called the expected number of times
func (*RecordExporterClientMock) MinimockWait ¶
func (m *RecordExporterClientMock) MinimockWait(timeout mm_time.Duration)
MinimockWait waits for all mocked methods to be called the expected number of times
type RecordExporterClientMockExportExpectation ¶
type RecordExporterClientMockExportExpectation struct { Counter uint64 // contains filtered or unexported fields }
RecordExporterClientMockExportExpectation specifies expectation struct of the RecordExporterClient.Export
func (*RecordExporterClientMockExportExpectation) Then ¶
func (e *RecordExporterClientMockExportExpectation) Then(r1 mm_exporter.RecordExporter_ExportClient, err error) *RecordExporterClientMock
Then sets up RecordExporterClient.Export return parameters for the expectation previously defined by the When method
type RecordExporterClientMockExportParams ¶
type RecordExporterClientMockExportParams struct {
// contains filtered or unexported fields
}
RecordExporterClientMockExportParams contains parameters of the RecordExporterClient.Export
type RecordExporterClientMockExportResults ¶
type RecordExporterClientMockExportResults struct {
// contains filtered or unexported fields
}
RecordExporterClientMockExportResults contains results of the RecordExporterClient.Export
type StarterMock ¶
type StarterMock struct { StartMock mStarterMockStart // contains filtered or unexported fields }
StarterMock implements interfaces.Starter
func NewStarterMock ¶
func NewStarterMock(t minimock.Tester) *StarterMock
NewStarterMock returns a mock for interfaces.Starter
func (*StarterMock) MinimockFinish ¶
func (m *StarterMock) MinimockFinish()
MinimockFinish checks that all mocked methods have been called the expected number of times
func (*StarterMock) MinimockStartDone ¶
func (m *StarterMock) MinimockStartDone() bool
MinimockStartDone returns true if the count of the Start invocations corresponds the number of defined expectations
func (*StarterMock) MinimockStartInspect ¶
func (m *StarterMock) MinimockStartInspect()
MinimockStartInspect logs each unmet expectation
func (*StarterMock) MinimockWait ¶
func (m *StarterMock) MinimockWait(timeout mm_time.Duration)
MinimockWait waits for all mocked methods to be called the expected number of times
func (*StarterMock) Start ¶
func (mmStart *StarterMock) Start(ctx context.Context) (err error)
Start implements interfaces.Starter
func (*StarterMock) StartAfterCounter ¶
func (mmStart *StarterMock) StartAfterCounter() uint64
StartAfterCounter returns a count of finished StarterMock.Start invocations
func (*StarterMock) StartBeforeCounter ¶
func (mmStart *StarterMock) StartBeforeCounter() uint64
StartBeforeCounter returns a count of StarterMock.Start invocations
type StarterMockStartExpectation ¶
type StarterMockStartExpectation struct { Counter uint64 // contains filtered or unexported fields }
StarterMockStartExpectation specifies expectation struct of the Starter.Start
func (*StarterMockStartExpectation) Then ¶
func (e *StarterMockStartExpectation) Then(err error) *StarterMock
Then sets up Starter.Start return parameters for the expectation previously defined by the When method
type StarterMockStartParams ¶
type StarterMockStartParams struct {
// contains filtered or unexported fields
}
StarterMockStartParams contains parameters of the Starter.Start
type StarterMockStartResults ¶
type StarterMockStartResults struct {
// contains filtered or unexported fields
}
StarterMockStartResults contains results of the Starter.Start
type StopperMock ¶
type StopperMock struct { StopMock mStopperMockStop // contains filtered or unexported fields }
StopperMock implements interfaces.Stopper
func NewStopperMock ¶
func NewStopperMock(t minimock.Tester) *StopperMock
NewStopperMock returns a mock for interfaces.Stopper
func (*StopperMock) MinimockFinish ¶
func (m *StopperMock) MinimockFinish()
MinimockFinish checks that all mocked methods have been called the expected number of times
func (*StopperMock) MinimockStopDone ¶
func (m *StopperMock) MinimockStopDone() bool
MinimockStopDone returns true if the count of the Stop invocations corresponds the number of defined expectations
func (*StopperMock) MinimockStopInspect ¶
func (m *StopperMock) MinimockStopInspect()
MinimockStopInspect logs each unmet expectation
func (*StopperMock) MinimockWait ¶
func (m *StopperMock) MinimockWait(timeout mm_time.Duration)
MinimockWait waits for all mocked methods to be called the expected number of times
func (*StopperMock) Stop ¶
func (mmStop *StopperMock) Stop(ctx context.Context) (err error)
Stop implements interfaces.Stopper
func (*StopperMock) StopAfterCounter ¶
func (mmStop *StopperMock) StopAfterCounter() uint64
StopAfterCounter returns a count of finished StopperMock.Stop invocations
func (*StopperMock) StopBeforeCounter ¶
func (mmStop *StopperMock) StopBeforeCounter() uint64
StopBeforeCounter returns a count of StopperMock.Stop invocations
type StopperMockStopExpectation ¶
type StopperMockStopExpectation struct { Counter uint64 // contains filtered or unexported fields }
StopperMockStopExpectation specifies expectation struct of the Stopper.Stop
func (*StopperMockStopExpectation) Then ¶
func (e *StopperMockStopExpectation) Then(err error) *StopperMock
Then sets up Stopper.Stop return parameters for the expectation previously defined by the When method
type StopperMockStopParams ¶
type StopperMockStopParams struct {
// contains filtered or unexported fields
}
StopperMockStopParams contains parameters of the Stopper.Stop
type StopperMockStopResults ¶
type StopperMockStopResults struct {
// contains filtered or unexported fields
}
StopperMockStopResults contains results of the Stopper.Stop
type StorageMock ¶
type StorageMock struct { CompletePulseMock mStorageMockCompletePulse GetIncompletePulsesMock mStorageMockGetIncompletePulses GetJetDropsMock mStorageMockGetJetDrops GetNextCompletePulseFilterByPrototypeReferenceMock mStorageMockGetNextCompletePulseFilterByPrototypeReference GetNextSavedPulseMock mStorageMockGetNextSavedPulse GetPulseByPrevMock mStorageMockGetPulseByPrev GetSequentialPulseMock mStorageMockGetSequentialPulse SaveJetDropDataMock mStorageMockSaveJetDropData SavePulseMock mStorageMockSavePulse SequencePulseMock mStorageMockSequencePulse // contains filtered or unexported fields }
StorageMock implements interfaces.Storage
func NewStorageMock ¶
func NewStorageMock(t minimock.Tester) *StorageMock
NewStorageMock returns a mock for interfaces.Storage
func (*StorageMock) CompletePulse ¶
func (mmCompletePulse *StorageMock) CompletePulse(pulseNumber int64) (err error)
CompletePulse implements interfaces.Storage
func (*StorageMock) CompletePulseAfterCounter ¶
func (mmCompletePulse *StorageMock) CompletePulseAfterCounter() uint64
CompletePulseAfterCounter returns a count of finished StorageMock.CompletePulse invocations
func (*StorageMock) CompletePulseBeforeCounter ¶
func (mmCompletePulse *StorageMock) CompletePulseBeforeCounter() uint64
CompletePulseBeforeCounter returns a count of StorageMock.CompletePulse invocations
func (*StorageMock) GetIncompletePulses ¶
func (mmGetIncompletePulses *StorageMock) GetIncompletePulses() (pa1 []models.Pulse, err error)
GetIncompletePulses implements interfaces.Storage
func (*StorageMock) GetIncompletePulsesAfterCounter ¶
func (mmGetIncompletePulses *StorageMock) GetIncompletePulsesAfterCounter() uint64
GetIncompletePulsesAfterCounter returns a count of finished StorageMock.GetIncompletePulses invocations
func (*StorageMock) GetIncompletePulsesBeforeCounter ¶
func (mmGetIncompletePulses *StorageMock) GetIncompletePulsesBeforeCounter() uint64
GetIncompletePulsesBeforeCounter returns a count of StorageMock.GetIncompletePulses invocations
func (*StorageMock) GetJetDrops ¶
GetJetDrops implements interfaces.Storage
func (*StorageMock) GetJetDropsAfterCounter ¶
func (mmGetJetDrops *StorageMock) GetJetDropsAfterCounter() uint64
GetJetDropsAfterCounter returns a count of finished StorageMock.GetJetDrops invocations
func (*StorageMock) GetJetDropsBeforeCounter ¶
func (mmGetJetDrops *StorageMock) GetJetDropsBeforeCounter() uint64
GetJetDropsBeforeCounter returns a count of StorageMock.GetJetDrops invocations
func (*StorageMock) GetNextCompletePulseFilterByPrototypeReference ¶
func (mmGetNextCompletePulseFilterByPrototypeReference *StorageMock) GetNextCompletePulseFilterByPrototypeReference(prevPulse int64, prototypes [][]byte) (p1 models.Pulse, err error)
GetNextCompletePulseFilterByPrototypeReference implements interfaces.Storage
func (*StorageMock) GetNextCompletePulseFilterByPrototypeReferenceAfterCounter ¶
func (mmGetNextCompletePulseFilterByPrototypeReference *StorageMock) GetNextCompletePulseFilterByPrototypeReferenceAfterCounter() uint64
GetNextCompletePulseFilterByPrototypeReferenceAfterCounter returns a count of finished StorageMock.GetNextCompletePulseFilterByPrototypeReference invocations
func (*StorageMock) GetNextCompletePulseFilterByPrototypeReferenceBeforeCounter ¶
func (mmGetNextCompletePulseFilterByPrototypeReference *StorageMock) GetNextCompletePulseFilterByPrototypeReferenceBeforeCounter() uint64
GetNextCompletePulseFilterByPrototypeReferenceBeforeCounter returns a count of StorageMock.GetNextCompletePulseFilterByPrototypeReference invocations
func (*StorageMock) GetNextSavedPulse ¶
func (mmGetNextSavedPulse *StorageMock) GetNextSavedPulse(fromPulseNumber models.Pulse, completedOnly bool) (p1 models.Pulse, err error)
GetNextSavedPulse implements interfaces.Storage
func (*StorageMock) GetNextSavedPulseAfterCounter ¶
func (mmGetNextSavedPulse *StorageMock) GetNextSavedPulseAfterCounter() uint64
GetNextSavedPulseAfterCounter returns a count of finished StorageMock.GetNextSavedPulse invocations
func (*StorageMock) GetNextSavedPulseBeforeCounter ¶
func (mmGetNextSavedPulse *StorageMock) GetNextSavedPulseBeforeCounter() uint64
GetNextSavedPulseBeforeCounter returns a count of StorageMock.GetNextSavedPulse invocations
func (*StorageMock) GetPulseByPrev ¶
func (mmGetPulseByPrev *StorageMock) GetPulseByPrev(prevPulse models.Pulse) (p1 models.Pulse, err error)
GetPulseByPrev implements interfaces.Storage
func (*StorageMock) GetPulseByPrevAfterCounter ¶
func (mmGetPulseByPrev *StorageMock) GetPulseByPrevAfterCounter() uint64
GetPulseByPrevAfterCounter returns a count of finished StorageMock.GetPulseByPrev invocations
func (*StorageMock) GetPulseByPrevBeforeCounter ¶
func (mmGetPulseByPrev *StorageMock) GetPulseByPrevBeforeCounter() uint64
GetPulseByPrevBeforeCounter returns a count of StorageMock.GetPulseByPrev invocations
func (*StorageMock) GetSequentialPulse ¶
func (mmGetSequentialPulse *StorageMock) GetSequentialPulse() (p1 models.Pulse, err error)
GetSequentialPulse implements interfaces.Storage
func (*StorageMock) GetSequentialPulseAfterCounter ¶
func (mmGetSequentialPulse *StorageMock) GetSequentialPulseAfterCounter() uint64
GetSequentialPulseAfterCounter returns a count of finished StorageMock.GetSequentialPulse invocations
func (*StorageMock) GetSequentialPulseBeforeCounter ¶
func (mmGetSequentialPulse *StorageMock) GetSequentialPulseBeforeCounter() uint64
GetSequentialPulseBeforeCounter returns a count of StorageMock.GetSequentialPulse invocations
func (*StorageMock) MinimockCompletePulseDone ¶
func (m *StorageMock) MinimockCompletePulseDone() bool
MinimockCompletePulseDone returns true if the count of the CompletePulse invocations corresponds the number of defined expectations
func (*StorageMock) MinimockCompletePulseInspect ¶
func (m *StorageMock) MinimockCompletePulseInspect()
MinimockCompletePulseInspect logs each unmet expectation
func (*StorageMock) MinimockFinish ¶
func (m *StorageMock) MinimockFinish()
MinimockFinish checks that all mocked methods have been called the expected number of times
func (*StorageMock) MinimockGetIncompletePulsesDone ¶
func (m *StorageMock) MinimockGetIncompletePulsesDone() bool
MinimockGetIncompletePulsesDone returns true if the count of the GetIncompletePulses invocations corresponds the number of defined expectations
func (*StorageMock) MinimockGetIncompletePulsesInspect ¶
func (m *StorageMock) MinimockGetIncompletePulsesInspect()
MinimockGetIncompletePulsesInspect logs each unmet expectation
func (*StorageMock) MinimockGetJetDropsDone ¶
func (m *StorageMock) MinimockGetJetDropsDone() bool
MinimockGetJetDropsDone returns true if the count of the GetJetDrops invocations corresponds the number of defined expectations
func (*StorageMock) MinimockGetJetDropsInspect ¶
func (m *StorageMock) MinimockGetJetDropsInspect()
MinimockGetJetDropsInspect logs each unmet expectation
func (*StorageMock) MinimockGetNextCompletePulseFilterByPrototypeReferenceDone ¶
func (m *StorageMock) MinimockGetNextCompletePulseFilterByPrototypeReferenceDone() bool
MinimockGetNextCompletePulseFilterByPrototypeReferenceDone returns true if the count of the GetNextCompletePulseFilterByPrototypeReference invocations corresponds the number of defined expectations
func (*StorageMock) MinimockGetNextCompletePulseFilterByPrototypeReferenceInspect ¶
func (m *StorageMock) MinimockGetNextCompletePulseFilterByPrototypeReferenceInspect()
MinimockGetNextCompletePulseFilterByPrototypeReferenceInspect logs each unmet expectation
func (*StorageMock) MinimockGetNextSavedPulseDone ¶
func (m *StorageMock) MinimockGetNextSavedPulseDone() bool
MinimockGetNextSavedPulseDone returns true if the count of the GetNextSavedPulse invocations corresponds the number of defined expectations
func (*StorageMock) MinimockGetNextSavedPulseInspect ¶
func (m *StorageMock) MinimockGetNextSavedPulseInspect()
MinimockGetNextSavedPulseInspect logs each unmet expectation
func (*StorageMock) MinimockGetPulseByPrevDone ¶
func (m *StorageMock) MinimockGetPulseByPrevDone() bool
MinimockGetPulseByPrevDone returns true if the count of the GetPulseByPrev invocations corresponds the number of defined expectations
func (*StorageMock) MinimockGetPulseByPrevInspect ¶
func (m *StorageMock) MinimockGetPulseByPrevInspect()
MinimockGetPulseByPrevInspect logs each unmet expectation
func (*StorageMock) MinimockGetSequentialPulseDone ¶
func (m *StorageMock) MinimockGetSequentialPulseDone() bool
MinimockGetSequentialPulseDone returns true if the count of the GetSequentialPulse invocations corresponds the number of defined expectations
func (*StorageMock) MinimockGetSequentialPulseInspect ¶
func (m *StorageMock) MinimockGetSequentialPulseInspect()
MinimockGetSequentialPulseInspect logs each unmet expectation
func (*StorageMock) MinimockSaveJetDropDataDone ¶
func (m *StorageMock) MinimockSaveJetDropDataDone() bool
MinimockSaveJetDropDataDone returns true if the count of the SaveJetDropData invocations corresponds the number of defined expectations
func (*StorageMock) MinimockSaveJetDropDataInspect ¶
func (m *StorageMock) MinimockSaveJetDropDataInspect()
MinimockSaveJetDropDataInspect logs each unmet expectation
func (*StorageMock) MinimockSavePulseDone ¶
func (m *StorageMock) MinimockSavePulseDone() bool
MinimockSavePulseDone returns true if the count of the SavePulse invocations corresponds the number of defined expectations
func (*StorageMock) MinimockSavePulseInspect ¶
func (m *StorageMock) MinimockSavePulseInspect()
MinimockSavePulseInspect logs each unmet expectation
func (*StorageMock) MinimockSequencePulseDone ¶
func (m *StorageMock) MinimockSequencePulseDone() bool
MinimockSequencePulseDone returns true if the count of the SequencePulse invocations corresponds the number of defined expectations
func (*StorageMock) MinimockSequencePulseInspect ¶
func (m *StorageMock) MinimockSequencePulseInspect()
MinimockSequencePulseInspect logs each unmet expectation
func (*StorageMock) MinimockWait ¶
func (m *StorageMock) MinimockWait(timeout mm_time.Duration)
MinimockWait waits for all mocked methods to be called the expected number of times
func (*StorageMock) SaveJetDropData ¶
func (mmSaveJetDropData *StorageMock) SaveJetDropData(jetDrop models.JetDrop, records []models.Record, pulseNumber int64) (err error)
SaveJetDropData implements interfaces.Storage
func (*StorageMock) SaveJetDropDataAfterCounter ¶
func (mmSaveJetDropData *StorageMock) SaveJetDropDataAfterCounter() uint64
SaveJetDropDataAfterCounter returns a count of finished StorageMock.SaveJetDropData invocations
func (*StorageMock) SaveJetDropDataBeforeCounter ¶
func (mmSaveJetDropData *StorageMock) SaveJetDropDataBeforeCounter() uint64
SaveJetDropDataBeforeCounter returns a count of StorageMock.SaveJetDropData invocations
func (*StorageMock) SavePulse ¶
func (mmSavePulse *StorageMock) SavePulse(pulse models.Pulse) (err error)
SavePulse implements interfaces.Storage
func (*StorageMock) SavePulseAfterCounter ¶
func (mmSavePulse *StorageMock) SavePulseAfterCounter() uint64
SavePulseAfterCounter returns a count of finished StorageMock.SavePulse invocations
func (*StorageMock) SavePulseBeforeCounter ¶
func (mmSavePulse *StorageMock) SavePulseBeforeCounter() uint64
SavePulseBeforeCounter returns a count of StorageMock.SavePulse invocations
func (*StorageMock) SequencePulse ¶
func (mmSequencePulse *StorageMock) SequencePulse(pulseNumber int64) (err error)
SequencePulse implements interfaces.Storage
func (*StorageMock) SequencePulseAfterCounter ¶
func (mmSequencePulse *StorageMock) SequencePulseAfterCounter() uint64
SequencePulseAfterCounter returns a count of finished StorageMock.SequencePulse invocations
func (*StorageMock) SequencePulseBeforeCounter ¶
func (mmSequencePulse *StorageMock) SequencePulseBeforeCounter() uint64
SequencePulseBeforeCounter returns a count of StorageMock.SequencePulse invocations
type StorageMockCompletePulseExpectation ¶
type StorageMockCompletePulseExpectation struct { Counter uint64 // contains filtered or unexported fields }
StorageMockCompletePulseExpectation specifies expectation struct of the Storage.CompletePulse
func (*StorageMockCompletePulseExpectation) Then ¶
func (e *StorageMockCompletePulseExpectation) Then(err error) *StorageMock
Then sets up Storage.CompletePulse return parameters for the expectation previously defined by the When method
type StorageMockCompletePulseParams ¶
type StorageMockCompletePulseParams struct {
// contains filtered or unexported fields
}
StorageMockCompletePulseParams contains parameters of the Storage.CompletePulse
type StorageMockCompletePulseResults ¶
type StorageMockCompletePulseResults struct {
// contains filtered or unexported fields
}
StorageMockCompletePulseResults contains results of the Storage.CompletePulse
type StorageMockGetIncompletePulsesExpectation ¶
type StorageMockGetIncompletePulsesExpectation struct { Counter uint64 // contains filtered or unexported fields }
StorageMockGetIncompletePulsesExpectation specifies expectation struct of the Storage.GetIncompletePulses
type StorageMockGetIncompletePulsesResults ¶
type StorageMockGetIncompletePulsesResults struct {
// contains filtered or unexported fields
}
StorageMockGetIncompletePulsesResults contains results of the Storage.GetIncompletePulses
type StorageMockGetJetDropsExpectation ¶
type StorageMockGetJetDropsExpectation struct { Counter uint64 // contains filtered or unexported fields }
StorageMockGetJetDropsExpectation specifies expectation struct of the Storage.GetJetDrops
func (*StorageMockGetJetDropsExpectation) Then ¶
func (e *StorageMockGetJetDropsExpectation) Then(ja1 []models.JetDrop, err error) *StorageMock
Then sets up Storage.GetJetDrops return parameters for the expectation previously defined by the When method
type StorageMockGetJetDropsParams ¶
type StorageMockGetJetDropsParams struct {
// contains filtered or unexported fields
}
StorageMockGetJetDropsParams contains parameters of the Storage.GetJetDrops
type StorageMockGetJetDropsResults ¶
type StorageMockGetJetDropsResults struct {
// contains filtered or unexported fields
}
StorageMockGetJetDropsResults contains results of the Storage.GetJetDrops
type StorageMockGetNextCompletePulseFilterByPrototypeReferenceExpectation ¶
type StorageMockGetNextCompletePulseFilterByPrototypeReferenceExpectation struct { Counter uint64 // contains filtered or unexported fields }
StorageMockGetNextCompletePulseFilterByPrototypeReferenceExpectation specifies expectation struct of the Storage.GetNextCompletePulseFilterByPrototypeReference
func (*StorageMockGetNextCompletePulseFilterByPrototypeReferenceExpectation) Then ¶
func (e *StorageMockGetNextCompletePulseFilterByPrototypeReferenceExpectation) Then(p1 models.Pulse, err error) *StorageMock
Then sets up Storage.GetNextCompletePulseFilterByPrototypeReference return parameters for the expectation previously defined by the When method
type StorageMockGetNextCompletePulseFilterByPrototypeReferenceParams ¶
type StorageMockGetNextCompletePulseFilterByPrototypeReferenceParams struct {
// contains filtered or unexported fields
}
StorageMockGetNextCompletePulseFilterByPrototypeReferenceParams contains parameters of the Storage.GetNextCompletePulseFilterByPrototypeReference
type StorageMockGetNextCompletePulseFilterByPrototypeReferenceResults ¶
type StorageMockGetNextCompletePulseFilterByPrototypeReferenceResults struct {
// contains filtered or unexported fields
}
StorageMockGetNextCompletePulseFilterByPrototypeReferenceResults contains results of the Storage.GetNextCompletePulseFilterByPrototypeReference
type StorageMockGetNextSavedPulseExpectation ¶
type StorageMockGetNextSavedPulseExpectation struct { Counter uint64 // contains filtered or unexported fields }
StorageMockGetNextSavedPulseExpectation specifies expectation struct of the Storage.GetNextSavedPulse
func (*StorageMockGetNextSavedPulseExpectation) Then ¶
func (e *StorageMockGetNextSavedPulseExpectation) Then(p1 models.Pulse, err error) *StorageMock
Then sets up Storage.GetNextSavedPulse return parameters for the expectation previously defined by the When method
type StorageMockGetNextSavedPulseParams ¶
type StorageMockGetNextSavedPulseParams struct {
// contains filtered or unexported fields
}
StorageMockGetNextSavedPulseParams contains parameters of the Storage.GetNextSavedPulse
type StorageMockGetNextSavedPulseResults ¶
type StorageMockGetNextSavedPulseResults struct {
// contains filtered or unexported fields
}
StorageMockGetNextSavedPulseResults contains results of the Storage.GetNextSavedPulse
type StorageMockGetPulseByPrevExpectation ¶
type StorageMockGetPulseByPrevExpectation struct { Counter uint64 // contains filtered or unexported fields }
StorageMockGetPulseByPrevExpectation specifies expectation struct of the Storage.GetPulseByPrev
func (*StorageMockGetPulseByPrevExpectation) Then ¶
func (e *StorageMockGetPulseByPrevExpectation) Then(p1 models.Pulse, err error) *StorageMock
Then sets up Storage.GetPulseByPrev return parameters for the expectation previously defined by the When method
type StorageMockGetPulseByPrevParams ¶
type StorageMockGetPulseByPrevParams struct {
// contains filtered or unexported fields
}
StorageMockGetPulseByPrevParams contains parameters of the Storage.GetPulseByPrev
type StorageMockGetPulseByPrevResults ¶
type StorageMockGetPulseByPrevResults struct {
// contains filtered or unexported fields
}
StorageMockGetPulseByPrevResults contains results of the Storage.GetPulseByPrev
type StorageMockGetSequentialPulseExpectation ¶
type StorageMockGetSequentialPulseExpectation struct { Counter uint64 // contains filtered or unexported fields }
StorageMockGetSequentialPulseExpectation specifies expectation struct of the Storage.GetSequentialPulse
type StorageMockGetSequentialPulseResults ¶
type StorageMockGetSequentialPulseResults struct {
// contains filtered or unexported fields
}
StorageMockGetSequentialPulseResults contains results of the Storage.GetSequentialPulse
type StorageMockSaveJetDropDataExpectation ¶
type StorageMockSaveJetDropDataExpectation struct { Counter uint64 // contains filtered or unexported fields }
StorageMockSaveJetDropDataExpectation specifies expectation struct of the Storage.SaveJetDropData
func (*StorageMockSaveJetDropDataExpectation) Then ¶
func (e *StorageMockSaveJetDropDataExpectation) Then(err error) *StorageMock
Then sets up Storage.SaveJetDropData return parameters for the expectation previously defined by the When method
type StorageMockSaveJetDropDataParams ¶
type StorageMockSaveJetDropDataParams struct {
// contains filtered or unexported fields
}
StorageMockSaveJetDropDataParams contains parameters of the Storage.SaveJetDropData
type StorageMockSaveJetDropDataResults ¶
type StorageMockSaveJetDropDataResults struct {
// contains filtered or unexported fields
}
StorageMockSaveJetDropDataResults contains results of the Storage.SaveJetDropData
type StorageMockSavePulseExpectation ¶
type StorageMockSavePulseExpectation struct { Counter uint64 // contains filtered or unexported fields }
StorageMockSavePulseExpectation specifies expectation struct of the Storage.SavePulse
func (*StorageMockSavePulseExpectation) Then ¶
func (e *StorageMockSavePulseExpectation) Then(err error) *StorageMock
Then sets up Storage.SavePulse return parameters for the expectation previously defined by the When method
type StorageMockSavePulseParams ¶
type StorageMockSavePulseParams struct {
// contains filtered or unexported fields
}
StorageMockSavePulseParams contains parameters of the Storage.SavePulse
type StorageMockSavePulseResults ¶
type StorageMockSavePulseResults struct {
// contains filtered or unexported fields
}
StorageMockSavePulseResults contains results of the Storage.SavePulse
type StorageMockSequencePulseExpectation ¶
type StorageMockSequencePulseExpectation struct { Counter uint64 // contains filtered or unexported fields }
StorageMockSequencePulseExpectation specifies expectation struct of the Storage.SequencePulse
func (*StorageMockSequencePulseExpectation) Then ¶
func (e *StorageMockSequencePulseExpectation) Then(err error) *StorageMock
Then sets up Storage.SequencePulse return parameters for the expectation previously defined by the When method
type StorageMockSequencePulseParams ¶
type StorageMockSequencePulseParams struct {
// contains filtered or unexported fields
}
StorageMockSequencePulseParams contains parameters of the Storage.SequencePulse
type StorageMockSequencePulseResults ¶
type StorageMockSequencePulseResults struct {
// contains filtered or unexported fields
}
StorageMockSequencePulseResults contains results of the Storage.SequencePulse
type StorageSetterMock ¶
type StorageSetterMock struct { CompletePulseMock mStorageSetterMockCompletePulse SaveJetDropDataMock mStorageSetterMockSaveJetDropData SavePulseMock mStorageSetterMockSavePulse SequencePulseMock mStorageSetterMockSequencePulse // contains filtered or unexported fields }
StorageSetterMock implements interfaces.StorageSetter
func NewStorageSetterMock ¶
func NewStorageSetterMock(t minimock.Tester) *StorageSetterMock
NewStorageSetterMock returns a mock for interfaces.StorageSetter
func (*StorageSetterMock) CompletePulse ¶
func (mmCompletePulse *StorageSetterMock) CompletePulse(pulseNumber int64) (err error)
CompletePulse implements interfaces.StorageSetter
func (*StorageSetterMock) CompletePulseAfterCounter ¶
func (mmCompletePulse *StorageSetterMock) CompletePulseAfterCounter() uint64
CompletePulseAfterCounter returns a count of finished StorageSetterMock.CompletePulse invocations
func (*StorageSetterMock) CompletePulseBeforeCounter ¶
func (mmCompletePulse *StorageSetterMock) CompletePulseBeforeCounter() uint64
CompletePulseBeforeCounter returns a count of StorageSetterMock.CompletePulse invocations
func (*StorageSetterMock) MinimockCompletePulseDone ¶
func (m *StorageSetterMock) MinimockCompletePulseDone() bool
MinimockCompletePulseDone returns true if the count of the CompletePulse invocations corresponds the number of defined expectations
func (*StorageSetterMock) MinimockCompletePulseInspect ¶
func (m *StorageSetterMock) MinimockCompletePulseInspect()
MinimockCompletePulseInspect logs each unmet expectation
func (*StorageSetterMock) MinimockFinish ¶
func (m *StorageSetterMock) MinimockFinish()
MinimockFinish checks that all mocked methods have been called the expected number of times
func (*StorageSetterMock) MinimockSaveJetDropDataDone ¶
func (m *StorageSetterMock) MinimockSaveJetDropDataDone() bool
MinimockSaveJetDropDataDone returns true if the count of the SaveJetDropData invocations corresponds the number of defined expectations
func (*StorageSetterMock) MinimockSaveJetDropDataInspect ¶
func (m *StorageSetterMock) MinimockSaveJetDropDataInspect()
MinimockSaveJetDropDataInspect logs each unmet expectation
func (*StorageSetterMock) MinimockSavePulseDone ¶
func (m *StorageSetterMock) MinimockSavePulseDone() bool
MinimockSavePulseDone returns true if the count of the SavePulse invocations corresponds the number of defined expectations
func (*StorageSetterMock) MinimockSavePulseInspect ¶
func (m *StorageSetterMock) MinimockSavePulseInspect()
MinimockSavePulseInspect logs each unmet expectation
func (*StorageSetterMock) MinimockSequencePulseDone ¶
func (m *StorageSetterMock) MinimockSequencePulseDone() bool
MinimockSequencePulseDone returns true if the count of the SequencePulse invocations corresponds the number of defined expectations
func (*StorageSetterMock) MinimockSequencePulseInspect ¶
func (m *StorageSetterMock) MinimockSequencePulseInspect()
MinimockSequencePulseInspect logs each unmet expectation
func (*StorageSetterMock) MinimockWait ¶
func (m *StorageSetterMock) MinimockWait(timeout mm_time.Duration)
MinimockWait waits for all mocked methods to be called the expected number of times
func (*StorageSetterMock) SaveJetDropData ¶
func (mmSaveJetDropData *StorageSetterMock) SaveJetDropData(jetDrop models.JetDrop, records []models.Record, pulseNumber int64) (err error)
SaveJetDropData implements interfaces.StorageSetter
func (*StorageSetterMock) SaveJetDropDataAfterCounter ¶
func (mmSaveJetDropData *StorageSetterMock) SaveJetDropDataAfterCounter() uint64
SaveJetDropDataAfterCounter returns a count of finished StorageSetterMock.SaveJetDropData invocations
func (*StorageSetterMock) SaveJetDropDataBeforeCounter ¶
func (mmSaveJetDropData *StorageSetterMock) SaveJetDropDataBeforeCounter() uint64
SaveJetDropDataBeforeCounter returns a count of StorageSetterMock.SaveJetDropData invocations
func (*StorageSetterMock) SavePulse ¶
func (mmSavePulse *StorageSetterMock) SavePulse(pulse models.Pulse) (err error)
SavePulse implements interfaces.StorageSetter
func (*StorageSetterMock) SavePulseAfterCounter ¶
func (mmSavePulse *StorageSetterMock) SavePulseAfterCounter() uint64
SavePulseAfterCounter returns a count of finished StorageSetterMock.SavePulse invocations
func (*StorageSetterMock) SavePulseBeforeCounter ¶
func (mmSavePulse *StorageSetterMock) SavePulseBeforeCounter() uint64
SavePulseBeforeCounter returns a count of StorageSetterMock.SavePulse invocations
func (*StorageSetterMock) SequencePulse ¶
func (mmSequencePulse *StorageSetterMock) SequencePulse(pulseNumber int64) (err error)
SequencePulse implements interfaces.StorageSetter
func (*StorageSetterMock) SequencePulseAfterCounter ¶
func (mmSequencePulse *StorageSetterMock) SequencePulseAfterCounter() uint64
SequencePulseAfterCounter returns a count of finished StorageSetterMock.SequencePulse invocations
func (*StorageSetterMock) SequencePulseBeforeCounter ¶
func (mmSequencePulse *StorageSetterMock) SequencePulseBeforeCounter() uint64
SequencePulseBeforeCounter returns a count of StorageSetterMock.SequencePulse invocations
type StorageSetterMockCompletePulseExpectation ¶
type StorageSetterMockCompletePulseExpectation struct { Counter uint64 // contains filtered or unexported fields }
StorageSetterMockCompletePulseExpectation specifies expectation struct of the StorageSetter.CompletePulse
func (*StorageSetterMockCompletePulseExpectation) Then ¶
func (e *StorageSetterMockCompletePulseExpectation) Then(err error) *StorageSetterMock
Then sets up StorageSetter.CompletePulse return parameters for the expectation previously defined by the When method
type StorageSetterMockCompletePulseParams ¶
type StorageSetterMockCompletePulseParams struct {
// contains filtered or unexported fields
}
StorageSetterMockCompletePulseParams contains parameters of the StorageSetter.CompletePulse
type StorageSetterMockCompletePulseResults ¶
type StorageSetterMockCompletePulseResults struct {
// contains filtered or unexported fields
}
StorageSetterMockCompletePulseResults contains results of the StorageSetter.CompletePulse
type StorageSetterMockSaveJetDropDataExpectation ¶
type StorageSetterMockSaveJetDropDataExpectation struct { Counter uint64 // contains filtered or unexported fields }
StorageSetterMockSaveJetDropDataExpectation specifies expectation struct of the StorageSetter.SaveJetDropData
func (*StorageSetterMockSaveJetDropDataExpectation) Then ¶
func (e *StorageSetterMockSaveJetDropDataExpectation) Then(err error) *StorageSetterMock
Then sets up StorageSetter.SaveJetDropData return parameters for the expectation previously defined by the When method
type StorageSetterMockSaveJetDropDataParams ¶
type StorageSetterMockSaveJetDropDataParams struct {
// contains filtered or unexported fields
}
StorageSetterMockSaveJetDropDataParams contains parameters of the StorageSetter.SaveJetDropData
type StorageSetterMockSaveJetDropDataResults ¶
type StorageSetterMockSaveJetDropDataResults struct {
// contains filtered or unexported fields
}
StorageSetterMockSaveJetDropDataResults contains results of the StorageSetter.SaveJetDropData
type StorageSetterMockSavePulseExpectation ¶
type StorageSetterMockSavePulseExpectation struct { Counter uint64 // contains filtered or unexported fields }
StorageSetterMockSavePulseExpectation specifies expectation struct of the StorageSetter.SavePulse
func (*StorageSetterMockSavePulseExpectation) Then ¶
func (e *StorageSetterMockSavePulseExpectation) Then(err error) *StorageSetterMock
Then sets up StorageSetter.SavePulse return parameters for the expectation previously defined by the When method
type StorageSetterMockSavePulseParams ¶
type StorageSetterMockSavePulseParams struct {
// contains filtered or unexported fields
}
StorageSetterMockSavePulseParams contains parameters of the StorageSetter.SavePulse
type StorageSetterMockSavePulseResults ¶
type StorageSetterMockSavePulseResults struct {
// contains filtered or unexported fields
}
StorageSetterMockSavePulseResults contains results of the StorageSetter.SavePulse
type StorageSetterMockSequencePulseExpectation ¶
type StorageSetterMockSequencePulseExpectation struct { Counter uint64 // contains filtered or unexported fields }
StorageSetterMockSequencePulseExpectation specifies expectation struct of the StorageSetter.SequencePulse
func (*StorageSetterMockSequencePulseExpectation) Then ¶
func (e *StorageSetterMockSequencePulseExpectation) Then(err error) *StorageSetterMock
Then sets up StorageSetter.SequencePulse return parameters for the expectation previously defined by the When method
type StorageSetterMockSequencePulseParams ¶
type StorageSetterMockSequencePulseParams struct {
// contains filtered or unexported fields
}
StorageSetterMockSequencePulseParams contains parameters of the StorageSetter.SequencePulse
type StorageSetterMockSequencePulseResults ¶
type StorageSetterMockSequencePulseResults struct {
// contains filtered or unexported fields
}
StorageSetterMockSequencePulseResults contains results of the StorageSetter.SequencePulse
type TransformerMock ¶
type TransformerMock struct { GetJetDropsChannelMock mTransformerMockGetJetDropsChannel StartMock mTransformerMockStart StopMock mTransformerMockStop // contains filtered or unexported fields }
TransformerMock implements interfaces.Transformer
func NewTransformerMock ¶
func NewTransformerMock(t minimock.Tester) *TransformerMock
NewTransformerMock returns a mock for interfaces.Transformer
func (*TransformerMock) GetJetDropsChannel ¶
func (mmGetJetDropsChannel *TransformerMock) GetJetDropsChannel() (ch1 <-chan *types.JetDrop)
GetJetDropsChannel implements interfaces.Transformer
func (*TransformerMock) GetJetDropsChannelAfterCounter ¶
func (mmGetJetDropsChannel *TransformerMock) GetJetDropsChannelAfterCounter() uint64
GetJetDropsChannelAfterCounter returns a count of finished TransformerMock.GetJetDropsChannel invocations
func (*TransformerMock) GetJetDropsChannelBeforeCounter ¶
func (mmGetJetDropsChannel *TransformerMock) GetJetDropsChannelBeforeCounter() uint64
GetJetDropsChannelBeforeCounter returns a count of TransformerMock.GetJetDropsChannel invocations
func (*TransformerMock) MinimockFinish ¶
func (m *TransformerMock) MinimockFinish()
MinimockFinish checks that all mocked methods have been called the expected number of times
func (*TransformerMock) MinimockGetJetDropsChannelDone ¶
func (m *TransformerMock) MinimockGetJetDropsChannelDone() bool
MinimockGetJetDropsChannelDone returns true if the count of the GetJetDropsChannel invocations corresponds the number of defined expectations
func (*TransformerMock) MinimockGetJetDropsChannelInspect ¶
func (m *TransformerMock) MinimockGetJetDropsChannelInspect()
MinimockGetJetDropsChannelInspect logs each unmet expectation
func (*TransformerMock) MinimockStartDone ¶
func (m *TransformerMock) MinimockStartDone() bool
MinimockStartDone returns true if the count of the Start invocations corresponds the number of defined expectations
func (*TransformerMock) MinimockStartInspect ¶
func (m *TransformerMock) MinimockStartInspect()
MinimockStartInspect logs each unmet expectation
func (*TransformerMock) MinimockStopDone ¶
func (m *TransformerMock) MinimockStopDone() bool
MinimockStopDone returns true if the count of the Stop invocations corresponds the number of defined expectations
func (*TransformerMock) MinimockStopInspect ¶
func (m *TransformerMock) MinimockStopInspect()
MinimockStopInspect logs each unmet expectation
func (*TransformerMock) MinimockWait ¶
func (m *TransformerMock) MinimockWait(timeout mm_time.Duration)
MinimockWait waits for all mocked methods to be called the expected number of times
func (*TransformerMock) Start ¶
func (mmStart *TransformerMock) Start(ctx context.Context) (err error)
Start implements interfaces.Transformer
func (*TransformerMock) StartAfterCounter ¶
func (mmStart *TransformerMock) StartAfterCounter() uint64
StartAfterCounter returns a count of finished TransformerMock.Start invocations
func (*TransformerMock) StartBeforeCounter ¶
func (mmStart *TransformerMock) StartBeforeCounter() uint64
StartBeforeCounter returns a count of TransformerMock.Start invocations
func (*TransformerMock) Stop ¶
func (mmStop *TransformerMock) Stop(ctx context.Context) (err error)
Stop implements interfaces.Transformer
func (*TransformerMock) StopAfterCounter ¶
func (mmStop *TransformerMock) StopAfterCounter() uint64
StopAfterCounter returns a count of finished TransformerMock.Stop invocations
func (*TransformerMock) StopBeforeCounter ¶
func (mmStop *TransformerMock) StopBeforeCounter() uint64
StopBeforeCounter returns a count of TransformerMock.Stop invocations
type TransformerMockGetJetDropsChannelExpectation ¶
type TransformerMockGetJetDropsChannelExpectation struct { Counter uint64 // contains filtered or unexported fields }
TransformerMockGetJetDropsChannelExpectation specifies expectation struct of the Transformer.GetJetDropsChannel
type TransformerMockGetJetDropsChannelResults ¶
type TransformerMockGetJetDropsChannelResults struct {
// contains filtered or unexported fields
}
TransformerMockGetJetDropsChannelResults contains results of the Transformer.GetJetDropsChannel
type TransformerMockStartExpectation ¶
type TransformerMockStartExpectation struct { Counter uint64 // contains filtered or unexported fields }
TransformerMockStartExpectation specifies expectation struct of the Transformer.Start
func (*TransformerMockStartExpectation) Then ¶
func (e *TransformerMockStartExpectation) Then(err error) *TransformerMock
Then sets up Transformer.Start return parameters for the expectation previously defined by the When method
type TransformerMockStartParams ¶
type TransformerMockStartParams struct {
// contains filtered or unexported fields
}
TransformerMockStartParams contains parameters of the Transformer.Start
type TransformerMockStartResults ¶
type TransformerMockStartResults struct {
// contains filtered or unexported fields
}
TransformerMockStartResults contains results of the Transformer.Start
type TransformerMockStopExpectation ¶
type TransformerMockStopExpectation struct { Counter uint64 // contains filtered or unexported fields }
TransformerMockStopExpectation specifies expectation struct of the Transformer.Stop
func (*TransformerMockStopExpectation) Then ¶
func (e *TransformerMockStopExpectation) Then(err error) *TransformerMock
Then sets up Transformer.Stop return parameters for the expectation previously defined by the When method
type TransformerMockStopParams ¶
type TransformerMockStopParams struct {
// contains filtered or unexported fields
}
TransformerMockStopParams contains parameters of the Transformer.Stop
type TransformerMockStopResults ¶
type TransformerMockStopResults struct {
// contains filtered or unexported fields
}
TransformerMockStopResults contains results of the Transformer.Stop