infura

Jun 17, 2022

Changes in this version

+ const FlagCacheQueueSize

+ const FlagEnable

+ const FlagMysqlDB

+ const FlagMysqlPass

+ const FlagMysqlUrl

+ const FlagMysqlUser

+ const FlagRedisAuth

+ const FlagRedisDB

+ const FlagRedisUrl

+ const ModuleName

+ const QuerierRoute

+ const RouterKey

+ var TaskConstDesc = map[TaskConst]string

+ func BeginBlocker(ctx sdk.Context, k Keeper)

+ func EndBlocker(ctx sdk.Context, k Keeper)

+ type AppModule struct

+ func NewAppModule(k Keeper) AppModule

+ func (AppModule) Name() string

+ func (am AppModule) BeginBlock(ctx sdk.Context, _ abci.RequestBeginBlock)

+ func (am AppModule) EndBlock(ctx sdk.Context, _ abci.RequestEndBlock) []abci.ValidatorUpdate

+ func (am AppModule) ExportGenesis(ctx sdk.Context) json.RawMessage

+ func (am AppModule) InitGenesis(ctx sdk.Context, data json.RawMessage) []abci.ValidatorUpdate

+ func (am AppModule) NewHandler() sdk.Handler

+ func (am AppModule) NewQuerierHandler() sdk.Querier

+ func (am AppModule) QuerierRoute() string

+ func (am AppModule) RegisterInvariants(ir sdk.InvariantRegistry)

+ func (am AppModule) Route() string

+ type AppModuleBasic struct

+ func (AppModuleBasic) DefaultGenesis() json.RawMessage

+ func (AppModuleBasic) GetQueryCmd(cdc *codec.Codec) *cobra.Command

+ func (AppModuleBasic) GetTxCmd(cdc *codec.Codec) *cobra.Command

+ func (AppModuleBasic) Name() string

+ func (AppModuleBasic) RegisterCodec(cdc *codec.Codec)

+ func (AppModuleBasic) RegisterRESTRoutes(ctx context.CLIContext, rtr *mux.Router)

+ func (AppModuleBasic) ValidateGenesis(bz json.RawMessage) error

+ type Cache struct

+ func NewCache() *Cache

+ func (c *Cache) AddBlock(b evm.Block)

+ func (c *Cache) AddContractCode(address string, code []byte)

+ func (c *Cache) AddTransaction(t evm.Transaction)

+ func (c *Cache) AddTransactionReceipt(tr evm.TransactionReceipt)

+ func (c *Cache) GetBlock() evm.Block

+ func (c *Cache) GetContractCodes() map[string][]byte

+ func (c *Cache) GetTransactionReceipts() []evm.TransactionReceipt

+ func (c *Cache) GetTransactions() []evm.Transaction

+ func (c *Cache) Reset()

+ type CacheQueue struct

+ func (cq *CacheQueue) Enqueue(sc StreamContext)

+ func (cq *CacheQueue) Start()

+ type EvmKeeper interface

+ SetObserverKeeper func(keeper evm.InfuraKeeper)

+ type Keeper struct

+ func NewKeeper(evmKeeper EvmKeeper, logger log.Logger, metrics *monitor.StreamMetrics) Keeper

+ func (k Keeper) OnSaveBlock(b evm.Block)

+ func (k Keeper) OnSaveContractCode(address string, code []byte)

+ func (k Keeper) OnSaveTransaction(t evm.Transaction)

+ func (k Keeper) OnSaveTransactionReceipt(tr evm.TransactionReceipt)

+ type MySQLEngine struct

+ func (e *MySQLEngine) Write(streamData types.IStreamData) bool

+ type Stream struct

+ func NewStream(logger log.Logger) *Stream

+ type StreamContext struct

+ type Task struct

+ Data types.IStreamData

+ Done bool

+ Height int64

+ UpdatedAt int64

+ func (t *Task) GetStatus() TaskConst

+ type TaskConst int

+ const TaskPhase1NextActionJumpNextBlock

+ const TaskPhase1NextActionNewTask

+ const TaskPhase1NextActionRestart

+ const TaskPhase1NextActionReturnTask

+ const TaskPhase1NextActionUnknown

+ const TaskPhase2NextActionJumpNextBlock

+ const TaskPhase2NextActionRestart

+ const TaskStatusInvalid

+ const TaskStatusStatusFail

+ const TaskStatusSuccess