Documentation ¶
Index ¶
- type KVStoreAPI
- func (_m *KVStoreAPI) GetEpochCommitSafetyThreshold() uint64
- func (_m *KVStoreAPI) GetEpochExtensionViewCount() uint64
- func (_m *KVStoreAPI) GetEpochStateID() flow.Identifier
- func (_m *KVStoreAPI) GetProtocolStateVersion() uint64
- func (_m *KVStoreAPI) GetVersionUpgrade() *protocol.ViewBasedActivator[uint64]
- func (_m *KVStoreAPI) ID() flow.Identifier
- func (_m *KVStoreAPI) Replicate(protocolVersion uint64) (protocol_state.KVStoreMutator, error)
- func (_m *KVStoreAPI) VersionedEncode() (uint64, []byte, error)
- type KVStoreMutator
- func (_m *KVStoreMutator) GetEpochCommitSafetyThreshold() uint64
- func (_m *KVStoreMutator) GetEpochExtensionViewCount() uint64
- func (_m *KVStoreMutator) GetEpochStateID() flow.Identifier
- func (_m *KVStoreMutator) GetProtocolStateVersion() uint64
- func (_m *KVStoreMutator) GetVersionUpgrade() *protocol.ViewBasedActivator[uint64]
- func (_m *KVStoreMutator) ID() flow.Identifier
- func (_m *KVStoreMutator) SetEpochExtensionViewCount(viewCount uint64) error
- func (_m *KVStoreMutator) SetEpochStateID(stateID flow.Identifier)
- func (_m *KVStoreMutator) SetVersionUpgrade(version *protocol.ViewBasedActivator[uint64])
- func (_m *KVStoreMutator) VersionedEncode() (uint64, []byte, error)
- type KeyValueStoreStateMachineFactory
- type OrthogonalStoreStateMachine
- func (_m *OrthogonalStoreStateMachine[P]) Build() (*transaction.DeferredBlockPersist, error)
- func (_m *OrthogonalStoreStateMachine[P]) EvolveState(sealedServiceEvents []flow.ServiceEvent) error
- func (_m *OrthogonalStoreStateMachine[P]) ParentState() P
- func (_m *OrthogonalStoreStateMachine[P]) View() uint64
- type ProtocolKVStore
- func (_m *ProtocolKVStore) ByBlockID(blockID flow.Identifier) (protocol_state.KVStoreAPI, error)
- func (_m *ProtocolKVStore) ByID(id flow.Identifier) (protocol_state.KVStoreAPI, error)
- func (_m *ProtocolKVStore) IndexTx(blockID flow.Identifier, stateID flow.Identifier) func(*transaction.Tx) error
- func (_m *ProtocolKVStore) StoreTx(stateID flow.Identifier, kvStore protocol.KVStoreReader) func(*transaction.Tx) error
- type StateMachineEventsTelemetryFactory
- type StateMachineTelemetryConsumer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KVStoreAPI ¶
KVStoreAPI is an autogenerated mock type for the KVStoreAPI type
func NewKVStoreAPI ¶
func NewKVStoreAPI(t interface { mock.TestingT Cleanup(func()) }) *KVStoreAPI
NewKVStoreAPI creates a new instance of KVStoreAPI. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*KVStoreAPI) GetEpochCommitSafetyThreshold ¶ added in v0.37.1
func (_m *KVStoreAPI) GetEpochCommitSafetyThreshold() uint64
GetEpochCommitSafetyThreshold provides a mock function with given fields:
func (*KVStoreAPI) GetEpochExtensionViewCount ¶ added in v0.37.1
func (_m *KVStoreAPI) GetEpochExtensionViewCount() uint64
GetEpochExtensionViewCount provides a mock function with given fields:
func (*KVStoreAPI) GetEpochStateID ¶
func (_m *KVStoreAPI) GetEpochStateID() flow.Identifier
GetEpochStateID provides a mock function with given fields:
func (*KVStoreAPI) GetProtocolStateVersion ¶
func (_m *KVStoreAPI) GetProtocolStateVersion() uint64
GetProtocolStateVersion provides a mock function with given fields:
func (*KVStoreAPI) GetVersionUpgrade ¶
func (_m *KVStoreAPI) GetVersionUpgrade() *protocol.ViewBasedActivator[uint64]
GetVersionUpgrade provides a mock function with given fields:
func (*KVStoreAPI) ID ¶
func (_m *KVStoreAPI) ID() flow.Identifier
ID provides a mock function with given fields:
func (*KVStoreAPI) Replicate ¶
func (_m *KVStoreAPI) Replicate(protocolVersion uint64) (protocol_state.KVStoreMutator, error)
Replicate provides a mock function with given fields: protocolVersion
func (*KVStoreAPI) VersionedEncode ¶
func (_m *KVStoreAPI) VersionedEncode() (uint64, []byte, error)
VersionedEncode provides a mock function with given fields:
type KVStoreMutator ¶
KVStoreMutator is an autogenerated mock type for the KVStoreMutator type
func NewKVStoreMutator ¶
func NewKVStoreMutator(t interface { mock.TestingT Cleanup(func()) }) *KVStoreMutator
NewKVStoreMutator creates a new instance of KVStoreMutator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*KVStoreMutator) GetEpochCommitSafetyThreshold ¶ added in v0.37.1
func (_m *KVStoreMutator) GetEpochCommitSafetyThreshold() uint64
GetEpochCommitSafetyThreshold provides a mock function with given fields:
func (*KVStoreMutator) GetEpochExtensionViewCount ¶ added in v0.37.1
func (_m *KVStoreMutator) GetEpochExtensionViewCount() uint64
GetEpochExtensionViewCount provides a mock function with given fields:
func (*KVStoreMutator) GetEpochStateID ¶
func (_m *KVStoreMutator) GetEpochStateID() flow.Identifier
GetEpochStateID provides a mock function with given fields:
func (*KVStoreMutator) GetProtocolStateVersion ¶
func (_m *KVStoreMutator) GetProtocolStateVersion() uint64
GetProtocolStateVersion provides a mock function with given fields:
func (*KVStoreMutator) GetVersionUpgrade ¶
func (_m *KVStoreMutator) GetVersionUpgrade() *protocol.ViewBasedActivator[uint64]
GetVersionUpgrade provides a mock function with given fields:
func (*KVStoreMutator) ID ¶
func (_m *KVStoreMutator) ID() flow.Identifier
ID provides a mock function with given fields:
func (*KVStoreMutator) SetEpochExtensionViewCount ¶ added in v0.37.1
func (_m *KVStoreMutator) SetEpochExtensionViewCount(viewCount uint64) error
SetEpochExtensionViewCount provides a mock function with given fields: viewCount
func (*KVStoreMutator) SetEpochStateID ¶
func (_m *KVStoreMutator) SetEpochStateID(stateID flow.Identifier)
SetEpochStateID provides a mock function with given fields: stateID
func (*KVStoreMutator) SetVersionUpgrade ¶
func (_m *KVStoreMutator) SetVersionUpgrade(version *protocol.ViewBasedActivator[uint64])
SetVersionUpgrade provides a mock function with given fields: version
func (*KVStoreMutator) VersionedEncode ¶
func (_m *KVStoreMutator) VersionedEncode() (uint64, []byte, error)
VersionedEncode provides a mock function with given fields:
type KeyValueStoreStateMachineFactory ¶
KeyValueStoreStateMachineFactory is an autogenerated mock type for the KeyValueStoreStateMachineFactory type
func NewKeyValueStoreStateMachineFactory ¶
func NewKeyValueStoreStateMachineFactory(t interface { mock.TestingT Cleanup(func()) }) *KeyValueStoreStateMachineFactory
NewKeyValueStoreStateMachineFactory creates a new instance of KeyValueStoreStateMachineFactory. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*KeyValueStoreStateMachineFactory) Create ¶
func (_m *KeyValueStoreStateMachineFactory) Create(candidateView uint64, parentID flow.Identifier, parentState protocol.KVStoreReader, mutator protocol_state.KVStoreMutator) (protocol_state.OrthogonalStoreStateMachine[protocol.KVStoreReader], error)
Create provides a mock function with given fields: candidateView, parentID, parentState, mutator
type OrthogonalStoreStateMachine ¶
OrthogonalStoreStateMachine is an autogenerated mock type for the OrthogonalStoreStateMachine type
func NewOrthogonalStoreStateMachine ¶
func NewOrthogonalStoreStateMachine[P interface{}](t interface { mock.TestingT Cleanup(func()) }) *OrthogonalStoreStateMachine[P]
NewOrthogonalStoreStateMachine creates a new instance of OrthogonalStoreStateMachine. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*OrthogonalStoreStateMachine[P]) Build ¶
func (_m *OrthogonalStoreStateMachine[P]) Build() (*transaction.DeferredBlockPersist, error)
Build provides a mock function with given fields:
func (*OrthogonalStoreStateMachine[P]) EvolveState ¶
func (_m *OrthogonalStoreStateMachine[P]) EvolveState(sealedServiceEvents []flow.ServiceEvent) error
EvolveState provides a mock function with given fields: sealedServiceEvents
func (*OrthogonalStoreStateMachine[P]) ParentState ¶
func (_m *OrthogonalStoreStateMachine[P]) ParentState() P
ParentState provides a mock function with given fields:
func (*OrthogonalStoreStateMachine[P]) View ¶
func (_m *OrthogonalStoreStateMachine[P]) View() uint64
View provides a mock function with given fields:
type ProtocolKVStore ¶
ProtocolKVStore is an autogenerated mock type for the ProtocolKVStore type
func NewProtocolKVStore ¶
func NewProtocolKVStore(t interface { mock.TestingT Cleanup(func()) }) *ProtocolKVStore
NewProtocolKVStore creates a new instance of ProtocolKVStore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ProtocolKVStore) ByBlockID ¶
func (_m *ProtocolKVStore) ByBlockID(blockID flow.Identifier) (protocol_state.KVStoreAPI, error)
ByBlockID provides a mock function with given fields: blockID
func (*ProtocolKVStore) ByID ¶
func (_m *ProtocolKVStore) ByID(id flow.Identifier) (protocol_state.KVStoreAPI, error)
ByID provides a mock function with given fields: id
func (*ProtocolKVStore) IndexTx ¶
func (_m *ProtocolKVStore) IndexTx(blockID flow.Identifier, stateID flow.Identifier) func(*transaction.Tx) error
IndexTx provides a mock function with given fields: blockID, stateID
func (*ProtocolKVStore) StoreTx ¶
func (_m *ProtocolKVStore) StoreTx(stateID flow.Identifier, kvStore protocol.KVStoreReader) func(*transaction.Tx) error
StoreTx provides a mock function with given fields: stateID, kvStore
type StateMachineEventsTelemetryFactory ¶ added in v0.37.1
StateMachineEventsTelemetryFactory is an autogenerated mock type for the StateMachineEventsTelemetryFactory type
func NewStateMachineEventsTelemetryFactory ¶ added in v0.37.1
func NewStateMachineEventsTelemetryFactory(t interface { mock.TestingT Cleanup(func()) }) *StateMachineEventsTelemetryFactory
NewStateMachineEventsTelemetryFactory creates a new instance of StateMachineEventsTelemetryFactory. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*StateMachineEventsTelemetryFactory) Execute ¶ added in v0.37.1
func (_m *StateMachineEventsTelemetryFactory) Execute(candidateView uint64) protocol_state.StateMachineTelemetryConsumer
Execute provides a mock function with given fields: candidateView
type StateMachineTelemetryConsumer ¶ added in v0.37.1
StateMachineTelemetryConsumer is an autogenerated mock type for the StateMachineTelemetryConsumer type
func NewStateMachineTelemetryConsumer ¶ added in v0.37.1
func NewStateMachineTelemetryConsumer(t interface { mock.TestingT Cleanup(func()) }) *StateMachineTelemetryConsumer
NewStateMachineTelemetryConsumer creates a new instance of StateMachineTelemetryConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*StateMachineTelemetryConsumer) OnInvalidServiceEvent ¶ added in v0.37.1
func (_m *StateMachineTelemetryConsumer) OnInvalidServiceEvent(event flow.ServiceEvent, err error)
OnInvalidServiceEvent provides a mock function with given fields: event, err
func (*StateMachineTelemetryConsumer) OnServiceEventProcessed ¶ added in v0.37.1
func (_m *StateMachineTelemetryConsumer) OnServiceEventProcessed(event flow.ServiceEvent)
OnServiceEventProcessed provides a mock function with given fields: event
func (*StateMachineTelemetryConsumer) OnServiceEventReceived ¶ added in v0.37.1
func (_m *StateMachineTelemetryConsumer) OnServiceEventReceived(event flow.ServiceEvent)
OnServiceEventReceived provides a mock function with given fields: event