mocks

package
v0.0.19 Latest Latest
Warning

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

 Go to latest Published: Sep 3, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FakeBatchBringer 

type FakeBatchBringer struct {
	GetBatchStub func(types.BatchID) (types.Batch, error)

	ReplicateStub func(types.ShardID) <-chan types.Batch

	StopStub func()
	// contains filtered or unexported fields
}

func (*FakeBatchBringer) GetBatch 

func (fake *FakeBatchBringer) GetBatch(arg1 types.BatchID) (types.Batch, error)

func (*FakeBatchBringer) GetBatchArgsForCall 

func (fake *FakeBatchBringer) GetBatchArgsForCall(i int) types.BatchID

func (*FakeBatchBringer) GetBatchCallCount 

func (fake *FakeBatchBringer) GetBatchCallCount() int

func (*FakeBatchBringer) GetBatchCalls 

func (fake *FakeBatchBringer) GetBatchCalls(stub func(types.BatchID) (types.Batch, error))

func (*FakeBatchBringer) GetBatchReturns 

func (fake *FakeBatchBringer) GetBatchReturns(result1 types.Batch, result2 error)

func (*FakeBatchBringer) GetBatchReturnsOnCall 

func (fake *FakeBatchBringer) GetBatchReturnsOnCall(i int, result1 types.Batch, result2 error)

func (*FakeBatchBringer) Invocations 

func (fake *FakeBatchBringer) Invocations() map[string][][]interface{}

func (*FakeBatchBringer) Replicate 

func (fake *FakeBatchBringer) Replicate(arg1 types.ShardID) <-chan types.Batch

func (*FakeBatchBringer) ReplicateArgsForCall 

func (fake *FakeBatchBringer) ReplicateArgsForCall(i int) types.ShardID

func (*FakeBatchBringer) ReplicateCallCount 

func (fake *FakeBatchBringer) ReplicateCallCount() int

func (*FakeBatchBringer) ReplicateCalls 

func (fake *FakeBatchBringer) ReplicateCalls(stub func(types.ShardID) <-chan types.Batch)

func (*FakeBatchBringer) ReplicateReturns 

func (fake *FakeBatchBringer) ReplicateReturns(result1 <-chan types.Batch)

func (*FakeBatchBringer) ReplicateReturnsOnCall 

func (fake *FakeBatchBringer) ReplicateReturnsOnCall(i int, result1 <-chan types.Batch)

func (*FakeBatchBringer) Stop 

func (fake *FakeBatchBringer) Stop()

func (*FakeBatchBringer) StopCallCount 

func (fake *FakeBatchBringer) StopCallCount() int

func (*FakeBatchBringer) StopCalls 

func (fake *FakeBatchBringer) StopCalls(stub func())

type FakeBatchBringerFactory 

type FakeBatchBringerFactory struct {
	CreateStub func(map[types.ShardID]map[types.PartyID]types.BatchSequence, *config.AssemblerNodeConfig, types.Logger) assembler.BatchBringer
	// contains filtered or unexported fields
}

func (*FakeBatchBringerFactory) Create 

func (fake *FakeBatchBringerFactory) Create(arg1 map[types.ShardID]map[types.PartyID]types.BatchSequence, arg2 *config.AssemblerNodeConfig, arg3 types.Logger) assembler.BatchBringer

func (*FakeBatchBringerFactory) CreateArgsForCall 

func (fake *FakeBatchBringerFactory) CreateArgsForCall(i int) (map[types.ShardID]map[types.PartyID]types.BatchSequence, *config.AssemblerNodeConfig, types.Logger)

func (*FakeBatchBringerFactory) CreateCallCount 

func (fake *FakeBatchBringerFactory) CreateCallCount() int

func (*FakeBatchBringerFactory) CreateCalls 

func (fake *FakeBatchBringerFactory) CreateCalls(stub func(map[types.ShardID]map[types.PartyID]types.BatchSequence, *config.AssemblerNodeConfig, types.Logger) assembler.BatchBringer)

func (*FakeBatchBringerFactory) CreateReturns 

func (fake *FakeBatchBringerFactory) CreateReturns(result1 assembler.BatchBringer)

func (*FakeBatchBringerFactory) CreateReturnsOnCall 

func (fake *FakeBatchBringerFactory) CreateReturnsOnCall(i int, result1 assembler.BatchBringer)

func (*FakeBatchBringerFactory) Invocations 

func (fake *FakeBatchBringerFactory) Invocations() map[string][][]interface{}

type FakeBatchCacheFactory 

type FakeBatchCacheFactory struct {
	CreateStub func(assembler.ShardPrimary) *assembler.BatchCache

	CreateWithTagStub func(assembler.ShardPrimary, string) *assembler.BatchCache
	// contains filtered or unexported fields
}

func (*FakeBatchCacheFactory) Create 

func (fake *FakeBatchCacheFactory) Create(arg1 assembler.ShardPrimary) *assembler.BatchCache

func (*FakeBatchCacheFactory) CreateArgsForCall 

func (fake *FakeBatchCacheFactory) CreateArgsForCall(i int) assembler.ShardPrimary

func (*FakeBatchCacheFactory) CreateCallCount 

func (fake *FakeBatchCacheFactory) CreateCallCount() int

func (*FakeBatchCacheFactory) CreateCalls 

func (fake *FakeBatchCacheFactory) CreateCalls(stub func(assembler.ShardPrimary) *assembler.BatchCache)

func (*FakeBatchCacheFactory) CreateReturns 

func (fake *FakeBatchCacheFactory) CreateReturns(result1 *assembler.BatchCache)

func (*FakeBatchCacheFactory) CreateReturnsOnCall 

func (fake *FakeBatchCacheFactory) CreateReturnsOnCall(i int, result1 *assembler.BatchCache)

func (*FakeBatchCacheFactory) CreateWithTag 

func (fake *FakeBatchCacheFactory) CreateWithTag(arg1 assembler.ShardPrimary, arg2 string) *assembler.BatchCache

func (*FakeBatchCacheFactory) CreateWithTagArgsForCall 

func (fake *FakeBatchCacheFactory) CreateWithTagArgsForCall(i int) (assembler.ShardPrimary, string)

func (*FakeBatchCacheFactory) CreateWithTagCallCount 

func (fake *FakeBatchCacheFactory) CreateWithTagCallCount() int

func (*FakeBatchCacheFactory) CreateWithTagCalls 

func (fake *FakeBatchCacheFactory) CreateWithTagCalls(stub func(assembler.ShardPrimary, string) *assembler.BatchCache)

func (*FakeBatchCacheFactory) CreateWithTagReturns 

func (fake *FakeBatchCacheFactory) CreateWithTagReturns(result1 *assembler.BatchCache)

func (*FakeBatchCacheFactory) CreateWithTagReturnsOnCall 

func (fake *FakeBatchCacheFactory) CreateWithTagReturnsOnCall(i int, result1 *assembler.BatchCache)

func (*FakeBatchCacheFactory) Invocations 

func (fake *FakeBatchCacheFactory) Invocations() map[string][][]interface{}

type FakePartitionPrefetchIndexer 

type FakePartitionPrefetchIndexer struct {
	PopOrWaitStub func(types.BatchID) (types.Batch, error)

	PutStub func(types.Batch) error

	PutForceStub func(types.Batch) error

	StopStub func()
	// contains filtered or unexported fields
}

func (*FakePartitionPrefetchIndexer) Invocations 

func (fake *FakePartitionPrefetchIndexer) Invocations() map[string][][]interface{}

func (*FakePartitionPrefetchIndexer) PopOrWait 

func (fake *FakePartitionPrefetchIndexer) PopOrWait(arg1 types.BatchID) (types.Batch, error)

func (*FakePartitionPrefetchIndexer) PopOrWaitArgsForCall 

func (fake *FakePartitionPrefetchIndexer) PopOrWaitArgsForCall(i int) types.BatchID

func (*FakePartitionPrefetchIndexer) PopOrWaitCallCount 

func (fake *FakePartitionPrefetchIndexer) PopOrWaitCallCount() int

func (*FakePartitionPrefetchIndexer) PopOrWaitCalls 

func (fake *FakePartitionPrefetchIndexer) PopOrWaitCalls(stub func(types.BatchID) (types.Batch, error))

func (*FakePartitionPrefetchIndexer) PopOrWaitReturns 

func (fake *FakePartitionPrefetchIndexer) PopOrWaitReturns(result1 types.Batch, result2 error)

func (*FakePartitionPrefetchIndexer) PopOrWaitReturnsOnCall 

func (fake *FakePartitionPrefetchIndexer) PopOrWaitReturnsOnCall(i int, result1 types.Batch, result2 error)

func (*FakePartitionPrefetchIndexer) Put 

func (fake *FakePartitionPrefetchIndexer) Put(arg1 types.Batch) error

func (*FakePartitionPrefetchIndexer) PutArgsForCall 

func (fake *FakePartitionPrefetchIndexer) PutArgsForCall(i int) types.Batch

func (*FakePartitionPrefetchIndexer) PutCallCount 

func (fake *FakePartitionPrefetchIndexer) PutCallCount() int

func (*FakePartitionPrefetchIndexer) PutCalls 

func (fake *FakePartitionPrefetchIndexer) PutCalls(stub func(types.Batch) error)

func (*FakePartitionPrefetchIndexer) PutForce 

func (fake *FakePartitionPrefetchIndexer) PutForce(arg1 types.Batch) error

func (*FakePartitionPrefetchIndexer) PutForceArgsForCall 

func (fake *FakePartitionPrefetchIndexer) PutForceArgsForCall(i int) types.Batch

func (*FakePartitionPrefetchIndexer) PutForceCallCount 

func (fake *FakePartitionPrefetchIndexer) PutForceCallCount() int

func (*FakePartitionPrefetchIndexer) PutForceCalls 

func (fake *FakePartitionPrefetchIndexer) PutForceCalls(stub func(types.Batch) error)

func (*FakePartitionPrefetchIndexer) PutForceReturns 

func (fake *FakePartitionPrefetchIndexer) PutForceReturns(result1 error)

func (*FakePartitionPrefetchIndexer) PutForceReturnsOnCall 

func (fake *FakePartitionPrefetchIndexer) PutForceReturnsOnCall(i int, result1 error)

func (*FakePartitionPrefetchIndexer) PutReturns 

func (fake *FakePartitionPrefetchIndexer) PutReturns(result1 error)

func (*FakePartitionPrefetchIndexer) PutReturnsOnCall 

func (fake *FakePartitionPrefetchIndexer) PutReturnsOnCall(i int, result1 error)

func (*FakePartitionPrefetchIndexer) Stop 

func (fake *FakePartitionPrefetchIndexer) Stop()

func (*FakePartitionPrefetchIndexer) StopCallCount 

func (fake *FakePartitionPrefetchIndexer) StopCallCount() int

func (*FakePartitionPrefetchIndexer) StopCalls 

func (fake *FakePartitionPrefetchIndexer) StopCalls(stub func())

type FakePartitionPrefetchIndexerFactory 

type FakePartitionPrefetchIndexerFactory struct {
	CreateStub func(assembler.ShardPrimary, types.Logger, time.Duration, int, assembler.TimerFactory, assembler.BatchCacheFactory, chan types.BatchID, time.Duration) assembler.PartitionPrefetchIndexer
	// contains filtered or unexported fields
}

func (*FakePartitionPrefetchIndexerFactory) Create 

func (fake *FakePartitionPrefetchIndexerFactory) Create(arg1 assembler.ShardPrimary, arg2 types.Logger, arg3 time.Duration, arg4 int, arg5 assembler.TimerFactory, arg6 assembler.BatchCacheFactory, arg7 chan types.BatchID, arg8 time.Duration) assembler.PartitionPrefetchIndexer

func (*FakePartitionPrefetchIndexerFactory) CreateArgsForCall 

func (fake *FakePartitionPrefetchIndexerFactory) CreateArgsForCall(i int) (assembler.ShardPrimary, types.Logger, time.Duration, int, assembler.TimerFactory, assembler.BatchCacheFactory, chan types.BatchID, time.Duration)

func (*FakePartitionPrefetchIndexerFactory) CreateCallCount 

func (fake *FakePartitionPrefetchIndexerFactory) CreateCallCount() int

func (*FakePartitionPrefetchIndexerFactory) CreateCalls 

func (fake *FakePartitionPrefetchIndexerFactory) CreateCalls(stub func(assembler.ShardPrimary, types.Logger, time.Duration, int, assembler.TimerFactory, assembler.BatchCacheFactory, chan types.BatchID, time.Duration) assembler.PartitionPrefetchIndexer)

func (*FakePartitionPrefetchIndexerFactory) CreateReturns 

func (fake *FakePartitionPrefetchIndexerFactory) CreateReturns(result1 assembler.PartitionPrefetchIndexer)

func (*FakePartitionPrefetchIndexerFactory) CreateReturnsOnCall 

func (fake *FakePartitionPrefetchIndexerFactory) CreateReturnsOnCall(i int, result1 assembler.PartitionPrefetchIndexer)

func (*FakePartitionPrefetchIndexerFactory) Invocations 

func (fake *FakePartitionPrefetchIndexerFactory) Invocations() map[string][][]interface{}

type FakePrefetchIndexer 

type FakePrefetchIndexer struct {
	PopOrWaitStub func(types.BatchID) (types.Batch, error)

	PutStub func(types.Batch) error

	PutForceStub func(types.Batch) error

	RequestsStub func() <-chan types.BatchID

	StopStub func()
	// contains filtered or unexported fields
}

func (*FakePrefetchIndexer) Invocations 

func (fake *FakePrefetchIndexer) Invocations() map[string][][]interface{}

func (*FakePrefetchIndexer) PopOrWait 

func (fake *FakePrefetchIndexer) PopOrWait(arg1 types.BatchID) (types.Batch, error)

func (*FakePrefetchIndexer) PopOrWaitArgsForCall 

func (fake *FakePrefetchIndexer) PopOrWaitArgsForCall(i int) types.BatchID

func (*FakePrefetchIndexer) PopOrWaitCallCount 

func (fake *FakePrefetchIndexer) PopOrWaitCallCount() int

func (*FakePrefetchIndexer) PopOrWaitCalls 

func (fake *FakePrefetchIndexer) PopOrWaitCalls(stub func(types.BatchID) (types.Batch, error))

func (*FakePrefetchIndexer) PopOrWaitReturns 

func (fake *FakePrefetchIndexer) PopOrWaitReturns(result1 types.Batch, result2 error)

func (*FakePrefetchIndexer) PopOrWaitReturnsOnCall 

func (fake *FakePrefetchIndexer) PopOrWaitReturnsOnCall(i int, result1 types.Batch, result2 error)

func (*FakePrefetchIndexer) Put 

func (fake *FakePrefetchIndexer) Put(arg1 types.Batch) error

func (*FakePrefetchIndexer) PutArgsForCall 

func (fake *FakePrefetchIndexer) PutArgsForCall(i int) types.Batch

func (*FakePrefetchIndexer) PutCallCount 

func (fake *FakePrefetchIndexer) PutCallCount() int

func (*FakePrefetchIndexer) PutCalls 

func (fake *FakePrefetchIndexer) PutCalls(stub func(types.Batch) error)

func (*FakePrefetchIndexer) PutForce 

func (fake *FakePrefetchIndexer) PutForce(arg1 types.Batch) error

func (*FakePrefetchIndexer) PutForceArgsForCall 

func (fake *FakePrefetchIndexer) PutForceArgsForCall(i int) types.Batch

func (*FakePrefetchIndexer) PutForceCallCount 

func (fake *FakePrefetchIndexer) PutForceCallCount() int

func (*FakePrefetchIndexer) PutForceCalls 

func (fake *FakePrefetchIndexer) PutForceCalls(stub func(types.Batch) error)

func (*FakePrefetchIndexer) PutForceReturns 

func (fake *FakePrefetchIndexer) PutForceReturns(result1 error)

func (*FakePrefetchIndexer) PutForceReturnsOnCall 

func (fake *FakePrefetchIndexer) PutForceReturnsOnCall(i int, result1 error)

func (*FakePrefetchIndexer) PutReturns 

func (fake *FakePrefetchIndexer) PutReturns(result1 error)

func (*FakePrefetchIndexer) PutReturnsOnCall 

func (fake *FakePrefetchIndexer) PutReturnsOnCall(i int, result1 error)

func (*FakePrefetchIndexer) Requests 

func (fake *FakePrefetchIndexer) Requests() <-chan types.BatchID

func (*FakePrefetchIndexer) RequestsCallCount 

func (fake *FakePrefetchIndexer) RequestsCallCount() int

func (*FakePrefetchIndexer) RequestsCalls 

func (fake *FakePrefetchIndexer) RequestsCalls(stub func() <-chan types.BatchID)

func (*FakePrefetchIndexer) RequestsReturns 

func (fake *FakePrefetchIndexer) RequestsReturns(result1 <-chan types.BatchID)

func (*FakePrefetchIndexer) RequestsReturnsOnCall 

func (fake *FakePrefetchIndexer) RequestsReturnsOnCall(i int, result1 <-chan types.BatchID)

func (*FakePrefetchIndexer) Stop 

func (fake *FakePrefetchIndexer) Stop()

func (*FakePrefetchIndexer) StopCallCount 

func (fake *FakePrefetchIndexer) StopCallCount() int

func (*FakePrefetchIndexer) StopCalls 

func (fake *FakePrefetchIndexer) StopCalls(stub func())

type FakePrefetchIndexerFactory 

type FakePrefetchIndexerFactory struct {
	CreateStub func([]types.ShardID, []types.PartyID, types.Logger, time.Duration, int, int, assembler.TimerFactory, assembler.BatchCacheFactory, assembler.PartitionPrefetchIndexerFactory, time.Duration) assembler.PrefetchIndexer
	// contains filtered or unexported fields
}

func (*FakePrefetchIndexerFactory) Create 

func (fake *FakePrefetchIndexerFactory) Create(arg1 []types.ShardID, arg2 []types.PartyID, arg3 types.Logger, arg4 time.Duration, arg5 int, arg6 int, arg7 assembler.TimerFactory, arg8 assembler.BatchCacheFactory, arg9 assembler.PartitionPrefetchIndexerFactory, arg10 time.Duration) assembler.PrefetchIndexer

func (*FakePrefetchIndexerFactory) CreateArgsForCall 

func (fake *FakePrefetchIndexerFactory) CreateArgsForCall(i int) ([]types.ShardID, []types.PartyID, types.Logger, time.Duration, int, int, assembler.TimerFactory, assembler.BatchCacheFactory, assembler.PartitionPrefetchIndexerFactory, time.Duration)

func (*FakePrefetchIndexerFactory) CreateCallCount 

func (fake *FakePrefetchIndexerFactory) CreateCallCount() int

func (*FakePrefetchIndexerFactory) CreateCalls 

func (fake *FakePrefetchIndexerFactory) CreateCalls(stub func([]types.ShardID, []types.PartyID, types.Logger, time.Duration, int, int, assembler.TimerFactory, assembler.BatchCacheFactory, assembler.PartitionPrefetchIndexerFactory, time.Duration) assembler.PrefetchIndexer)

func (*FakePrefetchIndexerFactory) CreateReturns 

func (fake *FakePrefetchIndexerFactory) CreateReturns(result1 assembler.PrefetchIndexer)

func (*FakePrefetchIndexerFactory) CreateReturnsOnCall 

func (fake *FakePrefetchIndexerFactory) CreateReturnsOnCall(i int, result1 assembler.PrefetchIndexer)

func (*FakePrefetchIndexerFactory) Invocations 

func (fake *FakePrefetchIndexerFactory) Invocations() map[string][][]interface{}

type FakePrefetcherController 

type FakePrefetcherController struct {
	StartStub func()

	StopStub func()
	// contains filtered or unexported fields
}

func (*FakePrefetcherController) Invocations 

func (fake *FakePrefetcherController) Invocations() map[string][][]interface{}

func (*FakePrefetcherController) Start 

func (fake *FakePrefetcherController) Start()

func (*FakePrefetcherController) StartCallCount 

func (fake *FakePrefetcherController) StartCallCount() int

func (*FakePrefetcherController) StartCalls 

func (fake *FakePrefetcherController) StartCalls(stub func())

func (*FakePrefetcherController) Stop 

func (fake *FakePrefetcherController) Stop()

func (*FakePrefetcherController) StopCallCount 

func (fake *FakePrefetcherController) StopCallCount() int

func (*FakePrefetcherController) StopCalls 

func (fake *FakePrefetcherController) StopCalls(stub func())

type FakePrefetcherFactory 

type FakePrefetcherFactory struct {
	CreateStub func([]types.ShardID, []types.PartyID, assembler.PrefetchIndexer, assembler.BatchBringer, types.Logger) assembler.PrefetcherController
	// contains filtered or unexported fields
}

func (*FakePrefetcherFactory) Create 

func (fake *FakePrefetcherFactory) Create(arg1 []types.ShardID, arg2 []types.PartyID, arg3 assembler.PrefetchIndexer, arg4 assembler.BatchBringer, arg5 types.Logger) assembler.PrefetcherController

func (*FakePrefetcherFactory) CreateArgsForCall 

func (fake *FakePrefetcherFactory) CreateArgsForCall(i int) ([]types.ShardID, []types.PartyID, assembler.PrefetchIndexer, assembler.BatchBringer, types.Logger)

func (*FakePrefetcherFactory) CreateCallCount 

func (fake *FakePrefetcherFactory) CreateCallCount() int

func (*FakePrefetcherFactory) CreateCalls 

func (fake *FakePrefetcherFactory) CreateCalls(stub func([]types.ShardID, []types.PartyID, assembler.PrefetchIndexer, assembler.BatchBringer, types.Logger) assembler.PrefetcherController)

func (*FakePrefetcherFactory) CreateReturns 

func (fake *FakePrefetcherFactory) CreateReturns(result1 assembler.PrefetcherController)

func (*FakePrefetcherFactory) CreateReturnsOnCall 

func (fake *FakePrefetcherFactory) CreateReturnsOnCall(i int, result1 assembler.PrefetcherController)

func (*FakePrefetcherFactory) Invocations 

func (fake *FakePrefetcherFactory) Invocations() map[string][][]interface{}

type FakeTimerFactory 

type FakeTimerFactory struct {
	CreateStub func(time.Duration, func()) assembler.StoppableTimer
	// contains filtered or unexported fields
}

func (*FakeTimerFactory) Create 

func (fake *FakeTimerFactory) Create(arg1 time.Duration, arg2 func()) assembler.StoppableTimer

func (*FakeTimerFactory) CreateArgsForCall 

func (fake *FakeTimerFactory) CreateArgsForCall(i int) (time.Duration, func())

func (*FakeTimerFactory) CreateCallCount 

func (fake *FakeTimerFactory) CreateCallCount() int

func (*FakeTimerFactory) CreateCalls 

func (fake *FakeTimerFactory) CreateCalls(stub func(time.Duration, func()) assembler.StoppableTimer)

func (*FakeTimerFactory) CreateReturns 

func (fake *FakeTimerFactory) CreateReturns(result1 assembler.StoppableTimer)

func (*FakeTimerFactory) CreateReturnsOnCall 

func (fake *FakeTimerFactory) CreateReturnsOnCall(i int, result1 assembler.StoppableTimer)

func (*FakeTimerFactory) Invocations 

func (fake *FakeTimerFactory) Invocations() map[string][][]interface{}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.