ingest

Documentation

Index

• type BlockEvent
• type Connector
• type Engine
  • func NewEngine(web3Socket string, syncMode string, syncThreadPool int, syncThreadSize int, ...) *Engine
  • func (engine *Engine) Client() *ethclient.Client
  • func (engine *Engine) Connect() *ethclient.Client
  • func (engine *Engine) Init()
  • func (engine *Engine) Latest() (*big.Int, error)
  • func (engine *Engine) Listen()
  • func (engine *Engine) SetConnector(connector Connector)
  • func (engine *Engine) SetEnd(val string)
  • func (engine *Engine) SetProcessor(processor Processor)
  • func (engine *Engine) SetStart(val string, plusOne bool)
  • func (engine *Engine) Status() map[string]interface{}
• type ForkWatcher
  • func NewForkWatcher(engine *Engine, maxForkSize int) *ForkWatcher
• type Processor

Types

type BlockEvent

type BlockEvent interface {
	Number() *big.Int
	ParentHash() string
	Hash() string
	SetFork(bool)
}

type Connector

type Connector interface {
	Apply(BlockEvent)
	Revert(BlockEvent)
}

type Engine

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

func NewEngine

func NewEngine(web3Socket string, syncMode string, syncThreadPool int, syncThreadSize int, maxForkSize int) *Engine

func (*Engine) Client

func (engine *Engine) Client() *ethclient.Client

func (*Engine) Connect

func (engine *Engine) Connect() *ethclient.Client

func (*Engine) Init

func (engine *Engine) Init()

func (*Engine) Latest

func (engine *Engine) Latest() (*big.Int, error)

func (*Engine) Listen

func (engine *Engine) Listen()

func (*Engine) SetConnector

func (engine *Engine) SetConnector(connector Connector)

func (*Engine) SetEnd

func (engine *Engine) SetEnd(val string)

func (*Engine) SetProcessor

func (engine *Engine) SetProcessor(processor Processor)

func (*Engine) SetStart

func (engine *Engine) SetStart(val string, plusOne bool)

func (*Engine) Status

func (engine *Engine) Status() map[string]interface{}

type ForkWatcher

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

func NewForkWatcher

func NewForkWatcher(engine *Engine, maxForkSize int) *ForkWatcher

type Processor

type Processor interface {
	NewBlockEvent(*big.Int, string, string) BlockEvent
	Process(*types.Block, BlockEvent)
}