Documentation
¶
Index ¶
- Variables
- type MockConverter
- func (converter *MockConverter) SetToEntityConverterError(err error)
- func (c *MockConverter) SetToModelConverterError(err error)
- func (converter *MockConverter) ToEntities(contractAbi string, ethLogs []types.Log) ([]interface{}, error)
- func (converter *MockConverter) ToModels(entities []interface{}) ([]interface{}, error)
- type MockLogNoteConverter
- type MockMappings
- type MockRepository
- func (repository *MockRepository) AssertMarkHeaderCheckedCalledWith(i int64)
- func (repository *MockRepository) AssertMarkHeaderCheckedNotCalled()
- func (repository *MockRepository) Create(headerID int64, models []interface{}) error
- func (repository *MockRepository) MarkHeaderChecked(headerID int64) error
- func (repository *MockRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error)
- func (repository *MockRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error)
- func (repository *MockRepository) SetAllHeaders(headers []core.Header)
- func (repository *MockRepository) SetCreateError(e error)
- func (repository *MockRepository) SetDB(db *postgres.DB)
- func (repository *MockRepository) SetMarkHeaderCheckedError(e error)
- func (repository *MockRepository) SetMissingHeaders(headers []core.Header)
- func (repository *MockRepository) SetMissingHeadersError(e error)
- type MockStorageQueue
- type MockStorageRepository
- type MockStorageTransformer
- type MockTransformer
- func (mh *MockTransformer) Execute(logs []types.Log, header core.Header, ...) error
- func (mh *MockTransformer) FakeTransformerInitializer(db *postgres.DB) shared_t.EventTransformer
- func (mh *MockTransformer) GetConfig() shared_t.EventTransformerConfig
- func (mh *MockTransformer) SetTransformerConfig(config shared_t.EventTransformerConfig)
- type MockWatcherRepository
- func (repository *MockWatcherRepository) CreateNotCheckedSQL(boolColumns []string) string
- func (repository *MockWatcherRepository) GetCheckedColumnNames(db *postgres.DB) ([]string, error)
- func (repository *MockWatcherRepository) MissingHeaders(startingBlockNumber int64, endingBlockNumber int64, db *postgres.DB, ...) ([]core.Header, error)
- func (repository *MockWatcherRepository) SetCheckedColumnNames(checkedColumnNames []string)
- func (repository *MockWatcherRepository) SetMissingHeaders(headers []core.Header)
- func (repository *MockWatcherRepository) SetNotCheckedSQL(notCheckedSql string)
Constants ¶
This section is empty.
Variables ¶
View Source
var FakeTransformerConfig = shared_t.EventTransformerConfig{ TransformerName: "FakeTransformer", ContractAddresses: []string{"FakeAddress"}, Topic: "FakeTopic", }
Functions ¶
This section is empty.
Types ¶
type MockConverter ¶
type MockConverter struct {
ToEntitiesError error
PassedContractAddresses []string
ToModelsError error
ContractAbi string
LogsToConvert []types.Log
EntitiesToConvert []interface{}
EntitiesToReturn []interface{}
ModelsToReturn []interface{}
ToEntitiesCalledCounter int
ToModelsCalledCounter int
// contains filtered or unexported fields
}
func (*MockConverter) SetToEntityConverterError ¶
func (converter *MockConverter) SetToEntityConverterError(err error)
func (*MockConverter) SetToModelConverterError ¶
func (c *MockConverter) SetToModelConverterError(err error)
func (*MockConverter) ToEntities ¶
func (converter *MockConverter) ToEntities(contractAbi string, ethLogs []types.Log) ([]interface{}, error)
func (*MockConverter) ToModels ¶
func (converter *MockConverter) ToModels(entities []interface{}) ([]interface{}, error)
type MockLogNoteConverter ¶
type MockLogNoteConverter struct {
PassedLogs []types.Log
ToModelsCalledCounter int
// contains filtered or unexported fields
}
func (*MockLogNoteConverter) SetConverterError ¶
func (converter *MockLogNoteConverter) SetConverterError(e error)
func (*MockLogNoteConverter) SetReturnModels ¶
func (converter *MockLogNoteConverter) SetReturnModels(models []interface{})
type MockMappings ¶
type MockMappings struct {
Metadata utils.StorageValueMetadata
LookupCalled bool
LookupErr error
}
func (*MockMappings) Lookup ¶
func (mappings *MockMappings) Lookup(key common.Hash) (utils.StorageValueMetadata, error)
func (*MockMappings) SetDB ¶
func (*MockMappings) SetDB(db *postgres.DB)
type MockRepository ¶
type MockRepository struct {
MarkHeaderCheckedPassedHeaderIDs []int64
CreatedHeaderIds []int64
PassedStartingBlockNumber int64
PassedEndingBlockNumber int64
PassedHeaderID int64
PassedModels []interface{}
SetDbCalled bool
CreateCalledCounter int
// contains filtered or unexported fields
}
func (*MockRepository) AssertMarkHeaderCheckedCalledWith ¶
func (repository *MockRepository) AssertMarkHeaderCheckedCalledWith(i int64)
func (*MockRepository) AssertMarkHeaderCheckedNotCalled ¶
func (repository *MockRepository) AssertMarkHeaderCheckedNotCalled()
func (*MockRepository) Create ¶
func (repository *MockRepository) Create(headerID int64, models []interface{}) error
func (*MockRepository) MarkHeaderChecked ¶
func (repository *MockRepository) MarkHeaderChecked(headerID int64) error
func (*MockRepository) MissingHeaders ¶
func (repository *MockRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error)
func (*MockRepository) RecheckHeaders ¶
func (repository *MockRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error)
func (*MockRepository) SetAllHeaders ¶
func (repository *MockRepository) SetAllHeaders(headers []core.Header)
func (*MockRepository) SetCreateError ¶
func (repository *MockRepository) SetCreateError(e error)
func (*MockRepository) SetDB ¶
func (repository *MockRepository) SetDB(db *postgres.DB)
func (*MockRepository) SetMarkHeaderCheckedError ¶
func (repository *MockRepository) SetMarkHeaderCheckedError(e error)
func (*MockRepository) SetMissingHeaders ¶
func (repository *MockRepository) SetMissingHeaders(headers []core.Header)
func (*MockRepository) SetMissingHeadersError ¶
func (repository *MockRepository) SetMissingHeadersError(e error)
type MockStorageQueue ¶
func (*MockStorageQueue) Add ¶
func (queue *MockStorageQueue) Add(row utils.StorageDiffRow) error
type MockStorageRepository ¶
type MockStorageRepository struct {
CreateErr error
PassedBlockNumber int
PassedBlockHash string
PassedMetadata utils.StorageValueMetadata
PassedValue interface{}
}
func (*MockStorageRepository) Create ¶
func (repository *MockStorageRepository) Create(blockNumber int, blockHash string, metadata utils.StorageValueMetadata, value interface{}) error
func (*MockStorageRepository) SetDB ¶
func (*MockStorageRepository) SetDB(db *postgres.DB)
type MockStorageTransformer ¶
type MockStorageTransformer struct {
Address common.Address
ExecuteErr error
PassedRow utils.StorageDiffRow
}
func (*MockStorageTransformer) ContractAddress ¶
func (transformer *MockStorageTransformer) ContractAddress() common.Address
func (*MockStorageTransformer) Execute ¶
func (transformer *MockStorageTransformer) Execute(row utils.StorageDiffRow) error
func (*MockStorageTransformer) FakeTransformerInitializer ¶
func (transformer *MockStorageTransformer) FakeTransformerInitializer(db *postgres.DB) transformer.StorageTransformer
type MockTransformer ¶
type MockTransformer struct {
ExecuteWasCalled bool
ExecuteError error
PassedLogs []types.Log
PassedHeader core.Header
// contains filtered or unexported fields
}
func (*MockTransformer) Execute ¶
func (mh *MockTransformer) Execute(logs []types.Log, header core.Header, recheckHeaders constants.TransformerExecution) error
func (*MockTransformer) FakeTransformerInitializer ¶
func (mh *MockTransformer) FakeTransformerInitializer(db *postgres.DB) shared_t.EventTransformer
func (*MockTransformer) GetConfig ¶
func (mh *MockTransformer) GetConfig() shared_t.EventTransformerConfig
func (*MockTransformer) SetTransformerConfig ¶
func (mh *MockTransformer) SetTransformerConfig(config shared_t.EventTransformerConfig)
type MockWatcherRepository ¶
type MockWatcherRepository struct {
ReturnCheckedColumnNames []string
GetCheckedColumnNamesError error
GetCheckedColumnNamesCalled bool
ReturnNotCheckedSQL string
CreateNotCheckedSQLCalled bool
ReturnMissingHeaders []core.Header
MissingHeadersError error
MissingHeadersCalled bool
}
func (*MockWatcherRepository) CreateNotCheckedSQL ¶
func (repository *MockWatcherRepository) CreateNotCheckedSQL(boolColumns []string) string
func (*MockWatcherRepository) GetCheckedColumnNames ¶
func (repository *MockWatcherRepository) GetCheckedColumnNames(db *postgres.DB) ([]string, error)
func (*MockWatcherRepository) MissingHeaders ¶
func (*MockWatcherRepository) SetCheckedColumnNames ¶
func (repository *MockWatcherRepository) SetCheckedColumnNames(checkedColumnNames []string)
func (*MockWatcherRepository) SetMissingHeaders ¶
func (repository *MockWatcherRepository) SetMissingHeaders(headers []core.Header)
func (*MockWatcherRepository) SetNotCheckedSQL ¶
func (repository *MockWatcherRepository) SetNotCheckedSQL(notCheckedSql string)
Click to show internal directories.
Click to hide internal directories.