infura

package
v0.1.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 25, 2023 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ModuleName   = types.ModuleName
	QuerierRoute = types.QuerierRoute
	RouterKey    = types.RouterKey
)
View Source 
const (
	FlagEnable         = "infura.enable"
	FlagRedisUrl       = "infura.redis-url"
	FlagRedisAuth      = "infura.redis-auth"
	FlagRedisDB        = "infura.redis-db"
	FlagMysqlUrl       = "infura.mysql-url"
	FlagMysqlUser      = "infura.mysql-user"
	FlagMysqlPass      = "infura.mysql-pass"
	FlagMysqlDB        = "infura.mysql-db"
	FlagCacheQueueSize = "infura.cache-queue-size"
)

Variables

View Source 
var TaskConstDesc = map[TaskConst]string{
	TaskStatusInvalid:                 "STREAM_TASK_STATUS_INVALID",
	TaskStatusSuccess:                 "STREAM_TASK_STATUS_SUCCESS",
	TaskStatusStatusFail:              "STREAM_TASK_STATUS_FAIL",
	TaskPhase1NextActionRestart:       "STREAM_TASK_PHRASE1_NEXT_ACTION_RESTART",
	TaskPhase1NextActionJumpNextBlock: "STREAM_TASK_PHRASE1_NEXT_ACTION_JUMP_NEXT_BLK",
	TaskPhase1NextActionNewTask:       "STREAM_TASK_PHRASE1_NEXT_ACTION_NEW_TASK",
	TaskPhase1NextActionReturnTask:    "STREAM_TASK_PHRASE1_NEXT_ACTION_RERUN_TASK",
	TaskPhase1NextActionUnknown:       "STREAM_TASK_PHRASE1_NEXT_ACTION_UNKNOWN",
	TaskPhase2NextActionRestart:       "STREAM_TASK_PHRASE2_NEXT_ACTION_RESTART",
	TaskPhase2NextActionJumpNextBlock: "STREAM_TASK_PHRASE2_NEXT_ACTION_JUMP_NEXT_BLK",
}

Functions

func BeginBlocker 

func BeginBlocker(ctx sdk.Context, k Keeper)

BeginBlocker runs the logic of BeginBlocker with version 0. BeginBlocker resets keeper cache.

func EndBlocker 

func EndBlocker(ctx sdk.Context, k Keeper)

Types

type AppModule 

type AppModule struct {
	AppModuleBasic
	// contains filtered or unexported fields
}

func NewAppModule 

func NewAppModule(k Keeper) AppModule

NewAppModule creates a new AppModule Object

func (AppModule) BeginBlock 

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

func (AppModule) EndBlock 

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

func (AppModule) ExportGenesis 

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

func (AppModule) InitGenesis 

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

func (AppModule) Name 

func (AppModule) Name() string

func (AppModule) NewHandler 

func (am AppModule) NewHandler() sdk.Handler

func (AppModule) NewQuerierHandler 

func (am AppModule) NewQuerierHandler() sdk.Querier

func (AppModule) QuerierRoute 

func (am AppModule) QuerierRoute() string

func (AppModule) RegisterInvariants 

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

func (AppModule) Route 

func (am AppModule) Route() string

type AppModuleBasic 

type AppModuleBasic struct{}

app module Basics object

func (AppModuleBasic) DefaultGenesis 

func (AppModuleBasic) DefaultGenesis() json.RawMessage

func (AppModuleBasic) GetQueryCmd 

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

Get the root query command of this module

func (AppModuleBasic) GetTxCmd 

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

Get the root tx command of this module

func (AppModuleBasic) Name 

func (AppModuleBasic) Name() string

func (AppModuleBasic) RegisterCodec 

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

func (AppModuleBasic) RegisterRESTRoutes 

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

Register rest routes

func (AppModuleBasic) ValidateGenesis 

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

Validation check of the Genesis

type Cache 

type Cache struct {
	// contains filtered or unexported fields
}

func NewCache 

func NewCache() *Cache

func (*Cache) AddBlock 

func (c *Cache) AddBlock(b evmtypes.Block)

func (*Cache) AddContractCode 

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

func (*Cache) AddTransaction 

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

func (*Cache) AddTransactionReceipt 

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

func (*Cache) GetBlock 

func (c *Cache) GetBlock() evmtypes.Block

func (*Cache) GetContractCodes 

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

func (*Cache) GetTransactionReceipts 

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

func (*Cache) GetTransactions 

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

func (*Cache) Reset 

func (c *Cache) Reset()

type CacheQueue 

type CacheQueue struct {
	// contains filtered or unexported fields
}

func (*CacheQueue) Enqueue 

func (cq *CacheQueue) Enqueue(sc StreamContext)

func (*CacheQueue) Start 

func (cq *CacheQueue) Start()

type EvmKeeper 

type EvmKeeper interface {
	SetObserverKeeper(keeper evm.InfuraKeeper)
}

type Keeper 

type Keeper struct {
	// contains filtered or unexported fields
}

nolint

func NewKeeper 

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

nolint

func (Keeper) OnSaveBlock 

func (k Keeper) OnSaveBlock(b evmtypes.Block)

func (Keeper) OnSaveContractCode 

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

func (Keeper) OnSaveTransaction 

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

func (Keeper) OnSaveTransactionReceipt 

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

type MySQLEngine 

type MySQLEngine struct {
	// contains filtered or unexported fields
}

func (*MySQLEngine) Write 

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

type Stream 

type Stream struct {
	// contains filtered or unexported fields
}

Stream maintains the infura engine

func NewStream 

func NewStream(logger log.Logger) *Stream

type StreamContext 

type StreamContext struct {
	// contains filtered or unexported fields
}

type Task 

type Task struct {
	Height    int64             `json:"height"`
	Done      bool              `json:"done"`
	UpdatedAt int64             `json:"updatedAt"`
	Data      types.IStreamData `json:"-"`
}

func (*Task) GetStatus 

func (t *Task) GetStatus() TaskConst

type TaskConst 

type TaskConst int
const (
	TaskStatusInvalid TaskConst = 0 + iota
	TaskStatusSuccess
	TaskStatusStatusFail
)
const (
	// Phase 1 task status
	TaskPhase1NextActionRestart TaskConst = 100 + iota
	TaskPhase1NextActionJumpNextBlock
	TaskPhase1NextActionNewTask
	TaskPhase1NextActionReturnTask
	TaskPhase1NextActionUnknown

	// Phase 2 task status
	TaskPhase2NextActionRestart TaskConst = 200 + iota
	TaskPhase2NextActionJumpNextBlock
)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.