Documentation ¶
Index ¶
- Variables
- type MockConverter
- type MockEventTransformer
- func (t *MockEventTransformer) Execute(logs []core.EventLog) error
- func (t *MockEventTransformer) FakeTransformerInitializer(db *postgres.DB) event.ITransformer
- func (t *MockEventTransformer) GetConfig() event.TransformerConfig
- func (t *MockEventTransformer) SetTransformerConfig(config event.TransformerConfig)
- type MockLogDelegator
- type MockLogExtractor
- type MockLogFetcher
- type MockStorageDiffRepository
- func (repository *MockStorageDiffRepository) CreateBackFilledStorageValue(rawDiff types.RawDiff) error
- func (repository *MockStorageDiffRepository) CreateStorageDiff(rawDiff types.RawDiff) (int64, error)
- func (repository *MockStorageDiffRepository) GetFirstDiffIDForBlockHeight(blockHeight int64) (int64, error)
- func (repository *MockStorageDiffRepository) GetNewDiffs(minID, limit int) ([]types.PersistedDiff, error)
- func (repository *MockStorageDiffRepository) GetPendingDiffs(minID, limit int) ([]types.PersistedDiff, error)
- func (repository *MockStorageDiffRepository) GetUnrecognizedDiffs(minID, limit int) ([]types.PersistedDiff, error)
- func (repository *MockStorageDiffRepository) MarkNoncanonical(id int64) error
- func (repository *MockStorageDiffRepository) MarkNoncanonicalDiffsAsNew(blockNumber int64) error
- func (repository *MockStorageDiffRepository) MarkPending(id int64) error
- func (repository *MockStorageDiffRepository) MarkTransformed(id int64) error
- func (repository *MockStorageDiffRepository) MarkUnrecognized(id int64) error
- func (repository *MockStorageDiffRepository) MarkUnwatched(id int64) error
- type MockStorageFetcher
- type MockStorageKeysLoader
- type MockStorageKeysLookup
- type MockStorageRepository
- type MockStorageTransformer
- func (transformer *MockStorageTransformer) Execute(diff types.PersistedDiff) error
- func (transformer *MockStorageTransformer) FakeTransformerInitializer(db *postgres.DB) storage.ITransformer
- func (transformer *MockStorageTransformer) GetContractAddress() common.Address
- func (transformer *MockStorageTransformer) GetStorageKeysLookup() storage.KeysLookup
- type MockStoragediffStreamer
- type MockThrottler
Constants ¶
This section is empty.
Variables ¶
View Source
var FakeTransformerConfig = event.TransformerConfig{ TransformerName: "FakeTransformer", ContractAddresses: []string{fakes.FakeAddress.Hex()}, Topic: fakes.FakeHash.Hex(), }
Functions ¶
This section is empty.
Types ¶
type MockConverter ¶
type MockEventTransformer ¶ added in v0.0.10
type MockEventTransformer struct { ExecuteWasCalled bool ExecuteError error PassedLogs []core.EventLog // contains filtered or unexported fields }
func (*MockEventTransformer) Execute ¶ added in v0.0.10
func (t *MockEventTransformer) Execute(logs []core.EventLog) error
func (*MockEventTransformer) FakeTransformerInitializer ¶ added in v0.0.10
func (t *MockEventTransformer) FakeTransformerInitializer(db *postgres.DB) event.ITransformer
func (*MockEventTransformer) GetConfig ¶ added in v0.0.10
func (t *MockEventTransformer) GetConfig() event.TransformerConfig
func (*MockEventTransformer) SetTransformerConfig ¶ added in v0.0.10
func (t *MockEventTransformer) SetTransformerConfig(config event.TransformerConfig)
type MockLogDelegator ¶ added in v0.0.10
type MockLogDelegator struct { AddedTransformers []event.ITransformer DelegateCallCount int DelegateErrors []error DelegatePassedLimit int }
func (*MockLogDelegator) AddTransformer ¶ added in v0.0.10
func (delegator *MockLogDelegator) AddTransformer(t event.ITransformer)
func (*MockLogDelegator) DelegateLogs ¶ added in v0.0.10
func (delegator *MockLogDelegator) DelegateLogs(limit int) error
type MockLogExtractor ¶ added in v0.0.10
type MockLogExtractor struct { AddedConfigs []event.TransformerConfig AddTransformerConfigError error ExtractLogsCount int ExtractLogsErrors []error }
func (*MockLogExtractor) AddTransformerConfig ¶ added in v0.0.10
func (extractor *MockLogExtractor) AddTransformerConfig(config event.TransformerConfig) error
func (*MockLogExtractor) BackFillLogs ¶ added in v0.1.0
func (extractor *MockLogExtractor) BackFillLogs(endingBlock int64) error
func (*MockLogExtractor) ExtractLogs ¶ added in v0.0.10
func (extractor *MockLogExtractor) ExtractLogs(recheckHeaders constants.TransformerExecution) error
type MockLogFetcher ¶ added in v0.0.10
type MockStorageDiffRepository ¶ added in v0.1.0
type MockStorageDiffRepository struct { CreateBackFilledStorageValuePassedRawDiffs []types.RawDiff CreateBackFilledStorageValueReturnError error CreatePassedRawDiffs []types.RawDiff GetNewDiffsToReturn []types.PersistedDiff GetNewDiffsErrors []error GetNewDiffsPassedMinIDs []int GetNewDiffsPassedLimits []int GetPendingDiffsToReturn []types.PersistedDiff GetPendingDiffsErrors []error GetPendingDiffsPassedMinIDs []int GetPendingDiffsPassedLimits []int GetUnrecognizedDiffsToReturn []types.PersistedDiff GetUnrecognizedDiffsErrors []error GetUnrecognizedDiffsPassedMinIDs []int GetUnrecognizedDiffsPassedLimits []int MarkTransformedPassedID int64 MarkUnrecognizedPassedID int64 MarkNoncanonicalPassedID int64 MarkPendingPassedID int64 MarkUnwatchedPassedID int64 GetFirstDiffIDToReturn int64 GetFirstDiffIDErr error GetFirstDiffBlockHeightPassed int64 }
func (*MockStorageDiffRepository) CreateBackFilledStorageValue ¶ added in v0.1.0
func (repository *MockStorageDiffRepository) CreateBackFilledStorageValue(rawDiff types.RawDiff) error
func (*MockStorageDiffRepository) CreateStorageDiff ¶ added in v0.1.0
func (repository *MockStorageDiffRepository) CreateStorageDiff(rawDiff types.RawDiff) (int64, error)
func (*MockStorageDiffRepository) GetFirstDiffIDForBlockHeight ¶ added in v0.1.0
func (repository *MockStorageDiffRepository) GetFirstDiffIDForBlockHeight(blockHeight int64) (int64, error)
func (*MockStorageDiffRepository) GetNewDiffs ¶ added in v0.1.0
func (repository *MockStorageDiffRepository) GetNewDiffs(minID, limit int) ([]types.PersistedDiff, error)
func (*MockStorageDiffRepository) GetPendingDiffs ¶ added in v0.1.1
func (repository *MockStorageDiffRepository) GetPendingDiffs(minID, limit int) ([]types.PersistedDiff, error)
func (*MockStorageDiffRepository) GetUnrecognizedDiffs ¶ added in v0.1.0
func (repository *MockStorageDiffRepository) GetUnrecognizedDiffs(minID, limit int) ([]types.PersistedDiff, error)
func (*MockStorageDiffRepository) MarkNoncanonical ¶ added in v0.1.0
func (repository *MockStorageDiffRepository) MarkNoncanonical(id int64) error
func (*MockStorageDiffRepository) MarkNoncanonicalDiffsAsNew ¶ added in v0.1.1
func (repository *MockStorageDiffRepository) MarkNoncanonicalDiffsAsNew(blockNumber int64) error
func (*MockStorageDiffRepository) MarkPending ¶ added in v0.1.1
func (repository *MockStorageDiffRepository) MarkPending(id int64) error
func (*MockStorageDiffRepository) MarkTransformed ¶ added in v0.1.0
func (repository *MockStorageDiffRepository) MarkTransformed(id int64) error
func (*MockStorageDiffRepository) MarkUnrecognized ¶ added in v0.1.0
func (repository *MockStorageDiffRepository) MarkUnrecognized(id int64) error
func (*MockStorageDiffRepository) MarkUnwatched ¶ added in v0.1.0
func (repository *MockStorageDiffRepository) MarkUnwatched(id int64) error
type MockStorageFetcher ¶ added in v0.0.2
type MockStorageFetcher struct { DiffsToReturn []types.RawDiff ErrsToReturn []error FetchStorageDiffsCalled bool }
func NewMockStorageFetcher ¶ added in v0.0.2
func NewMockStorageFetcher() *MockStorageFetcher
func (*MockStorageFetcher) FetchStorageDiffs ¶ added in v0.0.2
func (fetcher *MockStorageFetcher) FetchStorageDiffs(out chan<- types.RawDiff, errs chan<- error)
type MockStorageKeysLoader ¶ added in v0.0.10
type MockStorageKeysLoader struct { LoadMappingsCallCount int LoadMappingsError error SetDBCalled bool StorageKeyMappings map[common.Hash]types.ValueMetadata }
func (*MockStorageKeysLoader) LoadMappings ¶ added in v0.0.10
func (loader *MockStorageKeysLoader) LoadMappings() (map[common.Hash]types.ValueMetadata, error)
func (*MockStorageKeysLoader) SetDB ¶ added in v0.0.10
func (loader *MockStorageKeysLoader) SetDB(db *postgres.DB)
type MockStorageKeysLookup ¶ added in v0.0.10
type MockStorageKeysLookup struct { Metadata types.ValueMetadata LookupCalled bool LookupErr error KeysToReturn []common.Hash GetKeysCalled bool GetKeysError error // contains filtered or unexported fields }
func (*MockStorageKeysLookup) GetKeys ¶ added in v0.1.0
func (lookup *MockStorageKeysLookup) GetKeys() ([]common.Hash, error)
func (*MockStorageKeysLookup) Lookup ¶ added in v0.0.10
func (lookup *MockStorageKeysLookup) Lookup(key common.Hash) (types.ValueMetadata, error)
func (*MockStorageKeysLookup) SetDB ¶ added in v0.0.10
func (lookup *MockStorageKeysLookup) SetDB(db *postgres.DB)
type MockStorageRepository ¶
type MockStorageRepository struct { CreateErr error PassedHeaderID int64 PassedDiffID int64 PassedMetadata types.ValueMetadata PassedValue interface{} // contains filtered or unexported fields }
func (*MockStorageRepository) Create ¶
func (repository *MockStorageRepository) Create(diffID, headerID int64, metadata types.ValueMetadata, value interface{}) error
func (*MockStorageRepository) SetDB ¶
func (repository *MockStorageRepository) SetDB(db *postgres.DB)
type MockStorageTransformer ¶
type MockStorageTransformer struct { Address common.Address StorageKeysLookup storage.KeysLookup ExecuteErr error PassedDiff types.PersistedDiff }
func (*MockStorageTransformer) Execute ¶
func (transformer *MockStorageTransformer) Execute(diff types.PersistedDiff) error
func (*MockStorageTransformer) FakeTransformerInitializer ¶
func (transformer *MockStorageTransformer) FakeTransformerInitializer(db *postgres.DB) storage.ITransformer
func (*MockStorageTransformer) GetContractAddress ¶ added in v0.1.0
func (transformer *MockStorageTransformer) GetContractAddress() common.Address
func (*MockStorageTransformer) GetStorageKeysLookup ¶ added in v0.1.0
func (transformer *MockStorageTransformer) GetStorageKeysLookup() storage.KeysLookup
type MockStoragediffStreamer ¶ added in v0.1.0
type MockStoragediffStreamer struct { ClientSubscription *fakes.MockSubscription PassedPayloadChan chan filters.Payload // contains filtered or unexported fields }
func (*MockStoragediffStreamer) SetPayloads ¶ added in v0.1.0
func (streamer *MockStoragediffStreamer) SetPayloads(payloads []filters.Payload)
func (*MockStoragediffStreamer) SetSubscribeError ¶ added in v0.1.0
func (streamer *MockStoragediffStreamer) SetSubscribeError(err error)
func (*MockStoragediffStreamer) Stream ¶ added in v0.1.0
func (streamer *MockStoragediffStreamer) Stream(statediffPayloadChan chan filters.Payload) (core.Subscription, error)
Click to show internal directories.
Click to hide internal directories.