mock

package
v1.0.10-0...-7349ede Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 20, 2023 License: MIT Imports: 10 Imported by: 0

Documentation

Index

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

func (mmGetJetDrops *StorageMock) GetJetDrops(pulse models.Pulse) (ja1 []models.JetDrop, err error)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL