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.
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 ¶
- type FakeBAFCreator
- func (fake *FakeBAFCreator) CreateBAF(arg1 types.BatchSequence, arg2 types.PartyID, arg3 types.ShardID, arg4 []byte) types.BatchAttestationFragment
- func (fake *FakeBAFCreator) CreateBAFArgsForCall(i int) (types.BatchSequence, types.PartyID, types.ShardID, []byte)
- func (fake *FakeBAFCreator) CreateBAFCallCount() int
- func (fake *FakeBAFCreator) CreateBAFCalls(...)
- func (fake *FakeBAFCreator) CreateBAFReturns(result1 types.BatchAttestationFragment)
- func (fake *FakeBAFCreator) CreateBAFReturnsOnCall(i int, result1 types.BatchAttestationFragment)
- func (fake *FakeBAFCreator) Invocations() map[string][][]interface{}
- type FakeBAFSender
- func (fake *FakeBAFSender) Invocations() map[string][][]interface{}
- func (fake *FakeBAFSender) SendBAF(arg1 types.BatchAttestationFragment)
- func (fake *FakeBAFSender) SendBAFArgsForCall(i int) types.BatchAttestationFragment
- func (fake *FakeBAFSender) SendBAFCallCount() int
- func (fake *FakeBAFSender) SendBAFCalls(stub func(types.BatchAttestationFragment))
- type FakeBatchAcker
- func (fake *FakeBatchAcker) Ack(arg1 types.BatchSequence, arg2 types.PartyID)
- func (fake *FakeBatchAcker) AckArgsForCall(i int) (types.BatchSequence, types.PartyID)
- func (fake *FakeBatchAcker) AckCallCount() int
- func (fake *FakeBatchAcker) AckCalls(stub func(types.BatchSequence, types.PartyID))
- func (fake *FakeBatchAcker) Invocations() map[string][][]interface{}
- type FakeBatchLedger
- func (fake *FakeBatchLedger) Append(arg1 types.PartyID, arg2 types.BatchSequence, arg3 types.BatchedRequests)
- func (fake *FakeBatchLedger) AppendArgsForCall(i int) (types.PartyID, types.BatchSequence, types.BatchedRequests)
- func (fake *FakeBatchLedger) AppendCallCount() int
- func (fake *FakeBatchLedger) AppendCalls(stub func(types.PartyID, types.BatchSequence, types.BatchedRequests))
- func (fake *FakeBatchLedger) Height(arg1 types.PartyID) uint64
- func (fake *FakeBatchLedger) HeightArgsForCall(i int) types.PartyID
- func (fake *FakeBatchLedger) HeightCallCount() int
- func (fake *FakeBatchLedger) HeightCalls(stub func(types.PartyID) uint64)
- func (fake *FakeBatchLedger) HeightReturns(result1 uint64)
- func (fake *FakeBatchLedger) HeightReturnsOnCall(i int, result1 uint64)
- func (fake *FakeBatchLedger) Invocations() map[string][][]interface{}
- func (fake *FakeBatchLedger) RetrieveBatchByNumber(arg1 types.PartyID, arg2 uint64) types.Batch
- func (fake *FakeBatchLedger) RetrieveBatchByNumberArgsForCall(i int) (types.PartyID, uint64)
- func (fake *FakeBatchLedger) RetrieveBatchByNumberCallCount() int
- func (fake *FakeBatchLedger) RetrieveBatchByNumberCalls(stub func(types.PartyID, uint64) types.Batch)
- func (fake *FakeBatchLedger) RetrieveBatchByNumberReturns(result1 types.Batch)
- func (fake *FakeBatchLedger) RetrieveBatchByNumberReturnsOnCall(i int, result1 types.Batch)
- type FakeBatchedRequestsVerifier
- func (fake *FakeBatchedRequestsVerifier) Invocations() map[string][][]interface{}
- func (fake *FakeBatchedRequestsVerifier) VerifyBatchedRequests(arg1 types.BatchedRequests) error
- func (fake *FakeBatchedRequestsVerifier) VerifyBatchedRequestsArgsForCall(i int) types.BatchedRequests
- func (fake *FakeBatchedRequestsVerifier) VerifyBatchedRequestsCallCount() int
- func (fake *FakeBatchedRequestsVerifier) VerifyBatchedRequestsCalls(stub func(types.BatchedRequests) error)
- func (fake *FakeBatchedRequestsVerifier) VerifyBatchedRequestsReturns(result1 error)
- func (fake *FakeBatchedRequestsVerifier) VerifyBatchedRequestsReturnsOnCall(i int, result1 error)
- type FakeBatchesPuller
- func (fake *FakeBatchesPuller) Invocations() map[string][][]interface{}
- func (fake *FakeBatchesPuller) PullBatches(arg1 types.PartyID) <-chan types.Batch
- func (fake *FakeBatchesPuller) PullBatchesArgsForCall(i int) types.PartyID
- func (fake *FakeBatchesPuller) PullBatchesCallCount() int
- func (fake *FakeBatchesPuller) PullBatchesCalls(stub func(types.PartyID) <-chan types.Batch)
- func (fake *FakeBatchesPuller) PullBatchesReturns(result1 <-chan types.Batch)
- func (fake *FakeBatchesPuller) PullBatchesReturnsOnCall(i int, result1 <-chan types.Batch)
- func (fake *FakeBatchesPuller) Stop()
- func (fake *FakeBatchesPuller) StopCallCount() int
- func (fake *FakeBatchesPuller) StopCalls(stub func())
- type FakeComplainer
- type FakeConsensusStateReplicatorCreator
- func (fake *FakeConsensusStateReplicatorCreator) CreateStateConsensusReplicator(arg1 *config.BatcherNodeConfig, arg2 types.Logger) batcher.StateReplicator
- func (fake *FakeConsensusStateReplicatorCreator) CreateStateConsensusReplicatorArgsForCall(i int) (*config.BatcherNodeConfig, types.Logger)
- func (fake *FakeConsensusStateReplicatorCreator) CreateStateConsensusReplicatorCallCount() int
- func (fake *FakeConsensusStateReplicatorCreator) CreateStateConsensusReplicatorCalls(stub func(*config.BatcherNodeConfig, types.Logger) batcher.StateReplicator)
- func (fake *FakeConsensusStateReplicatorCreator) CreateStateConsensusReplicatorReturns(result1 batcher.StateReplicator)
- func (fake *FakeConsensusStateReplicatorCreator) CreateStateConsensusReplicatorReturnsOnCall(i int, result1 batcher.StateReplicator)
- func (fake *FakeConsensusStateReplicatorCreator) Invocations() map[string][][]interface{}
- type FakeConsenterControlEventSender
- func (fake *FakeConsenterControlEventSender) Invocations() map[string][][]interface{}
- func (fake *FakeConsenterControlEventSender) SendControlEvent(arg1 state.ControlEvent) error
- func (fake *FakeConsenterControlEventSender) SendControlEventArgsForCall(i int) state.ControlEvent
- func (fake *FakeConsenterControlEventSender) SendControlEventCallCount() int
- func (fake *FakeConsenterControlEventSender) SendControlEventCalls(stub func(state.ControlEvent) error)
- func (fake *FakeConsenterControlEventSender) SendControlEventReturns(result1 error)
- func (fake *FakeConsenterControlEventSender) SendControlEventReturnsOnCall(i int, result1 error)
- type FakeConsenterControlEventSenderCreator
- func (fake *FakeConsenterControlEventSenderCreator) CreateConsenterControlEventSender(arg1 config.RawBytes, arg2 config.RawBytes, arg3 config.ConsenterInfo) batcher.ConsenterControlEventSender
- func (fake *FakeConsenterControlEventSenderCreator) CreateConsenterControlEventSenderArgsForCall(i int) (config.RawBytes, config.RawBytes, config.ConsenterInfo)
- func (fake *FakeConsenterControlEventSenderCreator) CreateConsenterControlEventSenderCallCount() int
- func (fake *FakeConsenterControlEventSenderCreator) CreateConsenterControlEventSenderCalls(...)
- func (fake *FakeConsenterControlEventSenderCreator) CreateConsenterControlEventSenderReturns(result1 batcher.ConsenterControlEventSender)
- func (fake *FakeConsenterControlEventSenderCreator) CreateConsenterControlEventSenderReturnsOnCall(i int, result1 batcher.ConsenterControlEventSender)
- func (fake *FakeConsenterControlEventSenderCreator) Invocations() map[string][][]interface{}
- type FakeMemPool
- func (fake *FakeMemPool) Close()
- func (fake *FakeMemPool) CloseCallCount() int
- func (fake *FakeMemPool) CloseCalls(stub func())
- func (fake *FakeMemPool) Invocations() map[string][][]interface{}
- func (fake *FakeMemPool) NextRequests(arg1 context.Context) [][]byte
- func (fake *FakeMemPool) NextRequestsArgsForCall(i int) context.Context
- func (fake *FakeMemPool) NextRequestsCallCount() int
- func (fake *FakeMemPool) NextRequestsCalls(stub func(context.Context) [][]byte)
- func (fake *FakeMemPool) NextRequestsReturns(result1 [][]byte)
- func (fake *FakeMemPool) NextRequestsReturnsOnCall(i int, result1 [][]byte)
- func (fake *FakeMemPool) RemoveRequests(arg1 ...string)
- func (fake *FakeMemPool) RemoveRequestsArgsForCall(i int) []string
- func (fake *FakeMemPool) RemoveRequestsCallCount() int
- func (fake *FakeMemPool) RemoveRequestsCalls(stub func(...string))
- func (fake *FakeMemPool) Restart(arg1 bool)
- func (fake *FakeMemPool) RestartArgsForCall(i int) bool
- func (fake *FakeMemPool) RestartCallCount() int
- func (fake *FakeMemPool) RestartCalls(stub func(bool))
- func (fake *FakeMemPool) Submit(arg1 []byte) error
- func (fake *FakeMemPool) SubmitArgsForCall(i int) []byte
- func (fake *FakeMemPool) SubmitCallCount() int
- func (fake *FakeMemPool) SubmitCalls(stub func([]byte) error)
- func (fake *FakeMemPool) SubmitReturns(result1 error)
- func (fake *FakeMemPool) SubmitReturnsOnCall(i int, result1 error)
- type FakeRequestInspector
- func (fake *FakeRequestInspector) Invocations() map[string][][]interface{}
- func (fake *FakeRequestInspector) RequestID(arg1 []byte) string
- func (fake *FakeRequestInspector) RequestIDArgsForCall(i int) []byte
- func (fake *FakeRequestInspector) RequestIDCallCount() int
- func (fake *FakeRequestInspector) RequestIDCalls(stub func([]byte) string)
- func (fake *FakeRequestInspector) RequestIDReturns(result1 string)
- func (fake *FakeRequestInspector) RequestIDReturnsOnCall(i int, result1 string)
- type FakeRequestVerifier
- func (fake *FakeRequestVerifier) Invocations() map[string][][]interface{}
- func (fake *FakeRequestVerifier) VerifyRequest(arg1 []byte) error
- func (fake *FakeRequestVerifier) VerifyRequestArgsForCall(i int) []byte
- func (fake *FakeRequestVerifier) VerifyRequestCallCount() int
- func (fake *FakeRequestVerifier) VerifyRequestCalls(stub func([]byte) error)
- func (fake *FakeRequestVerifier) VerifyRequestReturns(result1 error)
- func (fake *FakeRequestVerifier) VerifyRequestReturnsOnCall(i int, result1 error)
- type FakeStateProvider
- func (fake *FakeStateProvider) GetLatestStateChan() <-chan *state.State
- func (fake *FakeStateProvider) GetLatestStateChanCallCount() int
- func (fake *FakeStateProvider) GetLatestStateChanCalls(stub func() <-chan *state.State)
- func (fake *FakeStateProvider) GetLatestStateChanReturns(result1 <-chan *state.State)
- func (fake *FakeStateProvider) GetLatestStateChanReturnsOnCall(i int, result1 <-chan *state.State)
- func (fake *FakeStateProvider) Invocations() map[string][][]interface{}
- type FakeStateReplicator
- func (fake *FakeStateReplicator) Invocations() map[string][][]interface{}
- func (fake *FakeStateReplicator) ReplicateState() <-chan *state.State
- func (fake *FakeStateReplicator) ReplicateStateCallCount() int
- func (fake *FakeStateReplicator) ReplicateStateCalls(stub func() <-chan *state.State)
- func (fake *FakeStateReplicator) ReplicateStateReturns(result1 <-chan *state.State)
- func (fake *FakeStateReplicator) ReplicateStateReturnsOnCall(i int, result1 <-chan *state.State)
- func (fake *FakeStateReplicator) Stop()
- func (fake *FakeStateReplicator) StopCallCount() int
- func (fake *FakeStateReplicator) StopCalls(stub func())
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FakeBAFCreator ¶ added in v0.0.19
type FakeBAFCreator struct {
CreateBAFStub func(types.BatchSequence, types.PartyID, types.ShardID, []byte) types.BatchAttestationFragment
// contains filtered or unexported fields
}
func (*FakeBAFCreator) CreateBAF ¶ added in v0.0.19
func (fake *FakeBAFCreator) CreateBAF(arg1 types.BatchSequence, arg2 types.PartyID, arg3 types.ShardID, arg4 []byte) types.BatchAttestationFragment
func (*FakeBAFCreator) CreateBAFArgsForCall ¶ added in v0.0.19
func (fake *FakeBAFCreator) CreateBAFArgsForCall(i int) (types.BatchSequence, types.PartyID, types.ShardID, []byte)
func (*FakeBAFCreator) CreateBAFCallCount ¶ added in v0.0.19
func (fake *FakeBAFCreator) CreateBAFCallCount() int
func (*FakeBAFCreator) CreateBAFCalls ¶ added in v0.0.19
func (fake *FakeBAFCreator) CreateBAFCalls(stub func(types.BatchSequence, types.PartyID, types.ShardID, []byte) types.BatchAttestationFragment)
func (*FakeBAFCreator) CreateBAFReturns ¶ added in v0.0.19
func (fake *FakeBAFCreator) CreateBAFReturns(result1 types.BatchAttestationFragment)
func (*FakeBAFCreator) CreateBAFReturnsOnCall ¶ added in v0.0.19
func (fake *FakeBAFCreator) CreateBAFReturnsOnCall(i int, result1 types.BatchAttestationFragment)
func (*FakeBAFCreator) Invocations ¶ added in v0.0.19
func (fake *FakeBAFCreator) Invocations() map[string][][]interface{}
type FakeBAFSender ¶ added in v0.0.19
type FakeBAFSender struct {
SendBAFStub func(types.BatchAttestationFragment)
// contains filtered or unexported fields
}
func (*FakeBAFSender) Invocations ¶ added in v0.0.19
func (fake *FakeBAFSender) Invocations() map[string][][]interface{}
func (*FakeBAFSender) SendBAF ¶ added in v0.0.19
func (fake *FakeBAFSender) SendBAF(arg1 types.BatchAttestationFragment)
func (*FakeBAFSender) SendBAFArgsForCall ¶ added in v0.0.19
func (fake *FakeBAFSender) SendBAFArgsForCall(i int) types.BatchAttestationFragment
func (*FakeBAFSender) SendBAFCallCount ¶ added in v0.0.19
func (fake *FakeBAFSender) SendBAFCallCount() int
func (*FakeBAFSender) SendBAFCalls ¶ added in v0.0.19
func (fake *FakeBAFSender) SendBAFCalls(stub func(types.BatchAttestationFragment))
type FakeBatchAcker ¶ added in v0.0.19
type FakeBatchAcker struct {
AckStub func(types.BatchSequence, types.PartyID)
// contains filtered or unexported fields
}
func (*FakeBatchAcker) Ack ¶ added in v0.0.19
func (fake *FakeBatchAcker) Ack(arg1 types.BatchSequence, arg2 types.PartyID)
func (*FakeBatchAcker) AckArgsForCall ¶ added in v0.0.19
func (fake *FakeBatchAcker) AckArgsForCall(i int) (types.BatchSequence, types.PartyID)
func (*FakeBatchAcker) AckCallCount ¶ added in v0.0.19
func (fake *FakeBatchAcker) AckCallCount() int
func (*FakeBatchAcker) AckCalls ¶ added in v0.0.19
func (fake *FakeBatchAcker) AckCalls(stub func(types.BatchSequence, types.PartyID))
func (*FakeBatchAcker) Invocations ¶ added in v0.0.19
func (fake *FakeBatchAcker) Invocations() map[string][][]interface{}
type FakeBatchLedger ¶ added in v0.0.19
type FakeBatchLedger struct {
AppendStub func(types.PartyID, types.BatchSequence, types.BatchedRequests)
HeightStub func(types.PartyID) uint64
RetrieveBatchByNumberStub func(types.PartyID, uint64) types.Batch
// contains filtered or unexported fields
}
func (*FakeBatchLedger) Append ¶ added in v0.0.19
func (fake *FakeBatchLedger) Append(arg1 types.PartyID, arg2 types.BatchSequence, arg3 types.BatchedRequests)
func (*FakeBatchLedger) AppendArgsForCall ¶ added in v0.0.19
func (fake *FakeBatchLedger) AppendArgsForCall(i int) (types.PartyID, types.BatchSequence, types.BatchedRequests)
func (*FakeBatchLedger) AppendCallCount ¶ added in v0.0.19
func (fake *FakeBatchLedger) AppendCallCount() int
func (*FakeBatchLedger) AppendCalls ¶ added in v0.0.19
func (fake *FakeBatchLedger) AppendCalls(stub func(types.PartyID, types.BatchSequence, types.BatchedRequests))
func (*FakeBatchLedger) Height ¶ added in v0.0.19
func (fake *FakeBatchLedger) Height(arg1 types.PartyID) uint64
func (*FakeBatchLedger) HeightArgsForCall ¶ added in v0.0.19
func (fake *FakeBatchLedger) HeightArgsForCall(i int) types.PartyID
func (*FakeBatchLedger) HeightCallCount ¶ added in v0.0.19
func (fake *FakeBatchLedger) HeightCallCount() int
func (*FakeBatchLedger) HeightCalls ¶ added in v0.0.19
func (fake *FakeBatchLedger) HeightCalls(stub func(types.PartyID) uint64)
func (*FakeBatchLedger) HeightReturns ¶ added in v0.0.19
func (fake *FakeBatchLedger) HeightReturns(result1 uint64)
func (*FakeBatchLedger) HeightReturnsOnCall ¶ added in v0.0.19
func (fake *FakeBatchLedger) HeightReturnsOnCall(i int, result1 uint64)
func (*FakeBatchLedger) Invocations ¶ added in v0.0.19
func (fake *FakeBatchLedger) Invocations() map[string][][]interface{}
func (*FakeBatchLedger) RetrieveBatchByNumber ¶ added in v0.0.19
func (*FakeBatchLedger) RetrieveBatchByNumberArgsForCall ¶ added in v0.0.19
func (fake *FakeBatchLedger) RetrieveBatchByNumberArgsForCall(i int) (types.PartyID, uint64)
func (*FakeBatchLedger) RetrieveBatchByNumberCallCount ¶ added in v0.0.19
func (fake *FakeBatchLedger) RetrieveBatchByNumberCallCount() int
func (*FakeBatchLedger) RetrieveBatchByNumberCalls ¶ added in v0.0.19
func (*FakeBatchLedger) RetrieveBatchByNumberReturns ¶ added in v0.0.19
func (fake *FakeBatchLedger) RetrieveBatchByNumberReturns(result1 types.Batch)
func (*FakeBatchLedger) RetrieveBatchByNumberReturnsOnCall ¶ added in v0.0.19
func (fake *FakeBatchLedger) RetrieveBatchByNumberReturnsOnCall(i int, result1 types.Batch)
type FakeBatchedRequestsVerifier ¶ added in v0.0.19
type FakeBatchedRequestsVerifier struct {
VerifyBatchedRequestsStub func(types.BatchedRequests) error
// contains filtered or unexported fields
}
func (*FakeBatchedRequestsVerifier) Invocations ¶ added in v0.0.19
func (fake *FakeBatchedRequestsVerifier) Invocations() map[string][][]interface{}
func (*FakeBatchedRequestsVerifier) VerifyBatchedRequests ¶ added in v0.0.19
func (fake *FakeBatchedRequestsVerifier) VerifyBatchedRequests(arg1 types.BatchedRequests) error
func (*FakeBatchedRequestsVerifier) VerifyBatchedRequestsArgsForCall ¶ added in v0.0.19
func (fake *FakeBatchedRequestsVerifier) VerifyBatchedRequestsArgsForCall(i int) types.BatchedRequests
func (*FakeBatchedRequestsVerifier) VerifyBatchedRequestsCallCount ¶ added in v0.0.19
func (fake *FakeBatchedRequestsVerifier) VerifyBatchedRequestsCallCount() int
func (*FakeBatchedRequestsVerifier) VerifyBatchedRequestsCalls ¶ added in v0.0.19
func (fake *FakeBatchedRequestsVerifier) VerifyBatchedRequestsCalls(stub func(types.BatchedRequests) error)
func (*FakeBatchedRequestsVerifier) VerifyBatchedRequestsReturns ¶ added in v0.0.19
func (fake *FakeBatchedRequestsVerifier) VerifyBatchedRequestsReturns(result1 error)
func (*FakeBatchedRequestsVerifier) VerifyBatchedRequestsReturnsOnCall ¶ added in v0.0.19
func (fake *FakeBatchedRequestsVerifier) VerifyBatchedRequestsReturnsOnCall(i int, result1 error)
type FakeBatchesPuller ¶ added in v0.0.19
type FakeBatchesPuller struct {
PullBatchesStub func(types.PartyID) <-chan types.Batch
StopStub func()
// contains filtered or unexported fields
}
func (*FakeBatchesPuller) Invocations ¶ added in v0.0.19
func (fake *FakeBatchesPuller) Invocations() map[string][][]interface{}
func (*FakeBatchesPuller) PullBatches ¶ added in v0.0.19
func (fake *FakeBatchesPuller) PullBatches(arg1 types.PartyID) <-chan types.Batch
func (*FakeBatchesPuller) PullBatchesArgsForCall ¶ added in v0.0.19
func (fake *FakeBatchesPuller) PullBatchesArgsForCall(i int) types.PartyID
func (*FakeBatchesPuller) PullBatchesCallCount ¶ added in v0.0.19
func (fake *FakeBatchesPuller) PullBatchesCallCount() int
func (*FakeBatchesPuller) PullBatchesCalls ¶ added in v0.0.19
func (fake *FakeBatchesPuller) PullBatchesCalls(stub func(types.PartyID) <-chan types.Batch)
func (*FakeBatchesPuller) PullBatchesReturns ¶ added in v0.0.19
func (fake *FakeBatchesPuller) PullBatchesReturns(result1 <-chan types.Batch)
func (*FakeBatchesPuller) PullBatchesReturnsOnCall ¶ added in v0.0.19
func (fake *FakeBatchesPuller) PullBatchesReturnsOnCall(i int, result1 <-chan types.Batch)
func (*FakeBatchesPuller) Stop ¶ added in v0.0.19
func (fake *FakeBatchesPuller) Stop()
func (*FakeBatchesPuller) StopCallCount ¶ added in v0.0.19
func (fake *FakeBatchesPuller) StopCallCount() int
func (*FakeBatchesPuller) StopCalls ¶ added in v0.0.19
func (fake *FakeBatchesPuller) StopCalls(stub func())
type FakeComplainer ¶ added in v0.0.19
type FakeComplainer struct {
ComplainStub func(string)
// contains filtered or unexported fields
}
func (*FakeComplainer) Complain ¶ added in v0.0.19
func (fake *FakeComplainer) Complain(arg1 string)
func (*FakeComplainer) ComplainArgsForCall ¶ added in v0.0.19
func (fake *FakeComplainer) ComplainArgsForCall(i int) string
func (*FakeComplainer) ComplainCallCount ¶ added in v0.0.19
func (fake *FakeComplainer) ComplainCallCount() int
func (*FakeComplainer) ComplainCalls ¶ added in v0.0.19
func (fake *FakeComplainer) ComplainCalls(stub func(string))
func (*FakeComplainer) Invocations ¶ added in v0.0.19
func (fake *FakeComplainer) Invocations() map[string][][]interface{}
type FakeConsensusStateReplicatorCreator ¶
type FakeConsensusStateReplicatorCreator struct {
CreateStateConsensusReplicatorStub func(*config.BatcherNodeConfig, types.Logger) batcher.StateReplicator
// contains filtered or unexported fields
}
func (*FakeConsensusStateReplicatorCreator) CreateStateConsensusReplicator ¶
func (fake *FakeConsensusStateReplicatorCreator) CreateStateConsensusReplicator(arg1 *config.BatcherNodeConfig, arg2 types.Logger) batcher.StateReplicator
func (*FakeConsensusStateReplicatorCreator) CreateStateConsensusReplicatorArgsForCall ¶
func (fake *FakeConsensusStateReplicatorCreator) CreateStateConsensusReplicatorArgsForCall(i int) (*config.BatcherNodeConfig, types.Logger)
func (*FakeConsensusStateReplicatorCreator) CreateStateConsensusReplicatorCallCount ¶
func (fake *FakeConsensusStateReplicatorCreator) CreateStateConsensusReplicatorCallCount() int
func (*FakeConsensusStateReplicatorCreator) CreateStateConsensusReplicatorCalls ¶
func (fake *FakeConsensusStateReplicatorCreator) CreateStateConsensusReplicatorCalls(stub func(*config.BatcherNodeConfig, types.Logger) batcher.StateReplicator)
func (*FakeConsensusStateReplicatorCreator) CreateStateConsensusReplicatorReturns ¶
func (fake *FakeConsensusStateReplicatorCreator) CreateStateConsensusReplicatorReturns(result1 batcher.StateReplicator)
func (*FakeConsensusStateReplicatorCreator) CreateStateConsensusReplicatorReturnsOnCall ¶
func (fake *FakeConsensusStateReplicatorCreator) CreateStateConsensusReplicatorReturnsOnCall(i int, result1 batcher.StateReplicator)
func (*FakeConsensusStateReplicatorCreator) Invocations ¶
func (fake *FakeConsensusStateReplicatorCreator) Invocations() map[string][][]interface{}
type FakeConsenterControlEventSender ¶
type FakeConsenterControlEventSender struct {
SendControlEventStub func(state.ControlEvent) error
// contains filtered or unexported fields
}
func (*FakeConsenterControlEventSender) Invocations ¶
func (fake *FakeConsenterControlEventSender) Invocations() map[string][][]interface{}
func (*FakeConsenterControlEventSender) SendControlEvent ¶
func (fake *FakeConsenterControlEventSender) SendControlEvent(arg1 state.ControlEvent) error
func (*FakeConsenterControlEventSender) SendControlEventArgsForCall ¶
func (fake *FakeConsenterControlEventSender) SendControlEventArgsForCall(i int) state.ControlEvent
func (*FakeConsenterControlEventSender) SendControlEventCallCount ¶
func (fake *FakeConsenterControlEventSender) SendControlEventCallCount() int
func (*FakeConsenterControlEventSender) SendControlEventCalls ¶
func (fake *FakeConsenterControlEventSender) SendControlEventCalls(stub func(state.ControlEvent) error)
func (*FakeConsenterControlEventSender) SendControlEventReturns ¶
func (fake *FakeConsenterControlEventSender) SendControlEventReturns(result1 error)
func (*FakeConsenterControlEventSender) SendControlEventReturnsOnCall ¶
func (fake *FakeConsenterControlEventSender) SendControlEventReturnsOnCall(i int, result1 error)
type FakeConsenterControlEventSenderCreator ¶
type FakeConsenterControlEventSenderCreator struct {
CreateConsenterControlEventSenderStub func(config.RawBytes, config.RawBytes, config.ConsenterInfo) batcher.ConsenterControlEventSender
// contains filtered or unexported fields
}
func (*FakeConsenterControlEventSenderCreator) CreateConsenterControlEventSender ¶
func (fake *FakeConsenterControlEventSenderCreator) CreateConsenterControlEventSender(arg1 config.RawBytes, arg2 config.RawBytes, arg3 config.ConsenterInfo) batcher.ConsenterControlEventSender
func (*FakeConsenterControlEventSenderCreator) CreateConsenterControlEventSenderArgsForCall ¶
func (fake *FakeConsenterControlEventSenderCreator) CreateConsenterControlEventSenderArgsForCall(i int) (config.RawBytes, config.RawBytes, config.ConsenterInfo)
func (*FakeConsenterControlEventSenderCreator) CreateConsenterControlEventSenderCallCount ¶
func (fake *FakeConsenterControlEventSenderCreator) CreateConsenterControlEventSenderCallCount() int
func (*FakeConsenterControlEventSenderCreator) CreateConsenterControlEventSenderCalls ¶
func (fake *FakeConsenterControlEventSenderCreator) CreateConsenterControlEventSenderCalls(stub func(config.RawBytes, config.RawBytes, config.ConsenterInfo) batcher.ConsenterControlEventSender)
func (*FakeConsenterControlEventSenderCreator) CreateConsenterControlEventSenderReturns ¶
func (fake *FakeConsenterControlEventSenderCreator) CreateConsenterControlEventSenderReturns(result1 batcher.ConsenterControlEventSender)
func (*FakeConsenterControlEventSenderCreator) CreateConsenterControlEventSenderReturnsOnCall ¶
func (fake *FakeConsenterControlEventSenderCreator) CreateConsenterControlEventSenderReturnsOnCall(i int, result1 batcher.ConsenterControlEventSender)
func (*FakeConsenterControlEventSenderCreator) Invocations ¶
func (fake *FakeConsenterControlEventSenderCreator) Invocations() map[string][][]interface{}
type FakeMemPool ¶ added in v0.0.19
type FakeMemPool struct {
CloseStub func()
NextRequestsStub func(context.Context) [][]byte
RemoveRequestsStub func(...string)
RestartStub func(bool)
SubmitStub func([]byte) error
// contains filtered or unexported fields
}
func (*FakeMemPool) Close ¶ added in v0.0.19
func (fake *FakeMemPool) Close()
func (*FakeMemPool) CloseCallCount ¶ added in v0.0.19
func (fake *FakeMemPool) CloseCallCount() int
func (*FakeMemPool) CloseCalls ¶ added in v0.0.19
func (fake *FakeMemPool) CloseCalls(stub func())
func (*FakeMemPool) Invocations ¶ added in v0.0.19
func (fake *FakeMemPool) Invocations() map[string][][]interface{}
func (*FakeMemPool) NextRequests ¶ added in v0.0.19
func (fake *FakeMemPool) NextRequests(arg1 context.Context) [][]byte
func (*FakeMemPool) NextRequestsArgsForCall ¶ added in v0.0.19
func (fake *FakeMemPool) NextRequestsArgsForCall(i int) context.Context
func (*FakeMemPool) NextRequestsCallCount ¶ added in v0.0.19
func (fake *FakeMemPool) NextRequestsCallCount() int
func (*FakeMemPool) NextRequestsCalls ¶ added in v0.0.19
func (fake *FakeMemPool) NextRequestsCalls(stub func(context.Context) [][]byte)
func (*FakeMemPool) NextRequestsReturns ¶ added in v0.0.19
func (fake *FakeMemPool) NextRequestsReturns(result1 [][]byte)
func (*FakeMemPool) NextRequestsReturnsOnCall ¶ added in v0.0.19
func (fake *FakeMemPool) NextRequestsReturnsOnCall(i int, result1 [][]byte)
func (*FakeMemPool) RemoveRequests ¶ added in v0.0.19
func (fake *FakeMemPool) RemoveRequests(arg1 ...string)
func (*FakeMemPool) RemoveRequestsArgsForCall ¶ added in v0.0.19
func (fake *FakeMemPool) RemoveRequestsArgsForCall(i int) []string
func (*FakeMemPool) RemoveRequestsCallCount ¶ added in v0.0.19
func (fake *FakeMemPool) RemoveRequestsCallCount() int
func (*FakeMemPool) RemoveRequestsCalls ¶ added in v0.0.19
func (fake *FakeMemPool) RemoveRequestsCalls(stub func(...string))
func (*FakeMemPool) Restart ¶ added in v0.0.19
func (fake *FakeMemPool) Restart(arg1 bool)
func (*FakeMemPool) RestartArgsForCall ¶ added in v0.0.19
func (fake *FakeMemPool) RestartArgsForCall(i int) bool
func (*FakeMemPool) RestartCallCount ¶ added in v0.0.19
func (fake *FakeMemPool) RestartCallCount() int
func (*FakeMemPool) RestartCalls ¶ added in v0.0.19
func (fake *FakeMemPool) RestartCalls(stub func(bool))
func (*FakeMemPool) Submit ¶ added in v0.0.19
func (fake *FakeMemPool) Submit(arg1 []byte) error
func (*FakeMemPool) SubmitArgsForCall ¶ added in v0.0.19
func (fake *FakeMemPool) SubmitArgsForCall(i int) []byte
func (*FakeMemPool) SubmitCallCount ¶ added in v0.0.19
func (fake *FakeMemPool) SubmitCallCount() int
func (*FakeMemPool) SubmitCalls ¶ added in v0.0.19
func (fake *FakeMemPool) SubmitCalls(stub func([]byte) error)
func (*FakeMemPool) SubmitReturns ¶ added in v0.0.19
func (fake *FakeMemPool) SubmitReturns(result1 error)
func (*FakeMemPool) SubmitReturnsOnCall ¶ added in v0.0.19
func (fake *FakeMemPool) SubmitReturnsOnCall(i int, result1 error)
type FakeRequestInspector ¶ added in v0.0.19
type FakeRequestInspector struct {
RequestIDStub func([]byte) string
// contains filtered or unexported fields
}
func (*FakeRequestInspector) Invocations ¶ added in v0.0.19
func (fake *FakeRequestInspector) Invocations() map[string][][]interface{}
func (*FakeRequestInspector) RequestID ¶ added in v0.0.19
func (fake *FakeRequestInspector) RequestID(arg1 []byte) string
func (*FakeRequestInspector) RequestIDArgsForCall ¶ added in v0.0.19
func (fake *FakeRequestInspector) RequestIDArgsForCall(i int) []byte
func (*FakeRequestInspector) RequestIDCallCount ¶ added in v0.0.19
func (fake *FakeRequestInspector) RequestIDCallCount() int
func (*FakeRequestInspector) RequestIDCalls ¶ added in v0.0.19
func (fake *FakeRequestInspector) RequestIDCalls(stub func([]byte) string)
func (*FakeRequestInspector) RequestIDReturns ¶ added in v0.0.19
func (fake *FakeRequestInspector) RequestIDReturns(result1 string)
func (*FakeRequestInspector) RequestIDReturnsOnCall ¶ added in v0.0.19
func (fake *FakeRequestInspector) RequestIDReturnsOnCall(i int, result1 string)
type FakeRequestVerifier ¶
type FakeRequestVerifier struct {
VerifyRequestStub func([]byte) error
// contains filtered or unexported fields
}
func (*FakeRequestVerifier) Invocations ¶
func (fake *FakeRequestVerifier) Invocations() map[string][][]interface{}
func (*FakeRequestVerifier) VerifyRequest ¶
func (fake *FakeRequestVerifier) VerifyRequest(arg1 []byte) error
func (*FakeRequestVerifier) VerifyRequestArgsForCall ¶
func (fake *FakeRequestVerifier) VerifyRequestArgsForCall(i int) []byte
func (*FakeRequestVerifier) VerifyRequestCallCount ¶
func (fake *FakeRequestVerifier) VerifyRequestCallCount() int
func (*FakeRequestVerifier) VerifyRequestCalls ¶
func (fake *FakeRequestVerifier) VerifyRequestCalls(stub func([]byte) error)
func (*FakeRequestVerifier) VerifyRequestReturns ¶
func (fake *FakeRequestVerifier) VerifyRequestReturns(result1 error)
func (*FakeRequestVerifier) VerifyRequestReturnsOnCall ¶
func (fake *FakeRequestVerifier) VerifyRequestReturnsOnCall(i int, result1 error)
type FakeStateProvider ¶ added in v0.0.19
type FakeStateProvider struct {
GetLatestStateChanStub func() <-chan *state.State
// contains filtered or unexported fields
}
func (*FakeStateProvider) GetLatestStateChan ¶ added in v0.0.19
func (fake *FakeStateProvider) GetLatestStateChan() <-chan *state.State
func (*FakeStateProvider) GetLatestStateChanCallCount ¶ added in v0.0.19
func (fake *FakeStateProvider) GetLatestStateChanCallCount() int
func (*FakeStateProvider) GetLatestStateChanCalls ¶ added in v0.0.19
func (fake *FakeStateProvider) GetLatestStateChanCalls(stub func() <-chan *state.State)
func (*FakeStateProvider) GetLatestStateChanReturns ¶ added in v0.0.19
func (fake *FakeStateProvider) GetLatestStateChanReturns(result1 <-chan *state.State)
func (*FakeStateProvider) GetLatestStateChanReturnsOnCall ¶ added in v0.0.19
func (fake *FakeStateProvider) GetLatestStateChanReturnsOnCall(i int, result1 <-chan *state.State)
func (*FakeStateProvider) Invocations ¶ added in v0.0.19
func (fake *FakeStateProvider) Invocations() map[string][][]interface{}
type FakeStateReplicator ¶
type FakeStateReplicator struct {
ReplicateStateStub func() <-chan *state.State
StopStub func()
// contains filtered or unexported fields
}
func (*FakeStateReplicator) Invocations ¶
func (fake *FakeStateReplicator) Invocations() map[string][][]interface{}
func (*FakeStateReplicator) ReplicateState ¶
func (fake *FakeStateReplicator) ReplicateState() <-chan *state.State
func (*FakeStateReplicator) ReplicateStateCallCount ¶
func (fake *FakeStateReplicator) ReplicateStateCallCount() int
func (*FakeStateReplicator) ReplicateStateCalls ¶
func (fake *FakeStateReplicator) ReplicateStateCalls(stub func() <-chan *state.State)
func (*FakeStateReplicator) ReplicateStateReturns ¶
func (fake *FakeStateReplicator) ReplicateStateReturns(result1 <-chan *state.State)
func (*FakeStateReplicator) ReplicateStateReturnsOnCall ¶
func (fake *FakeStateReplicator) ReplicateStateReturnsOnCall(i int, result1 <-chan *state.State)
func (*FakeStateReplicator) Stop ¶
func (fake *FakeStateReplicator) Stop()
func (*FakeStateReplicator) StopCallCount ¶
func (fake *FakeStateReplicator) StopCallCount() int
func (*FakeStateReplicator) StopCalls ¶
func (fake *FakeStateReplicator) StopCalls(stub func())
Source Files
¶
- baf_creator.go
- baf_sender.go
- batch_acker.go
- batch_ledger.go
- batched_requests_verifier.go
- batches_puller.go
- complainer.go
- consensus_state_replicator_creator.go
- consenter_control_event_sender.go
- consenter_control_event_sender_creator.go
- mem_pool.go
- request_inspector.go
- request_verifier.go
- state_provider.go
- state_replicator.go