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.