indexservice

package

v0.5.0 Latest Latest Go to latest Published: Apr 21, 2019 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Frankonly/iotex-core

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type BlockByIndex
type IndexHistory
type Indexer
type Server
- func NewServer(cfg config.Config, bc blockchain.Blockchain) *Server

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	// ErrNotExist indicates certain item does not exist in Blockchain database
	ErrNotExist = errors.New("not exist in DB")
	// ErrAlreadyExist indicates certain item already exists in Blockchain database
	ErrAlreadyExist = errors.New("already exist in DB")
)

Functions ¶

This section is empty.

Types ¶

type BlockByIndex ¶ added in v0.5.0

type BlockByIndex struct {
	NodeAddress string
	IndexHash   []byte
	BlockHash   []byte
}

BlockByIndex defines the base schema of "index to block" table

type IndexHistory ¶ added in v0.5.0

type IndexHistory struct {
	NodeAddress string
	UserAddress string
	IndexHash   string
}

IndexHistory defines the schema of "index history" table

type Indexer ¶

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

Indexer handles the index build for blocks

func (*Indexer) BuildIndex ¶

func (idx *Indexer) BuildIndex(blk *block.Block) error

BuildIndex builds the index for a block

func (*Indexer) CreateTablesIfNotExist ¶ added in v0.4.4

func (idx *Indexer) CreateTablesIfNotExist() error

CreateTablesIfNotExist creates tables in local database

func (*Indexer) GetBlockByIndex ¶ added in v0.5.0

func (idx *Indexer) GetBlockByIndex(indexIdentifier string, indexHash hash.Hash256) (hash.Hash256, error)

GetBlockByIndex returns block hash by index hash

func (*Indexer) GetIndexHistory ¶ added in v0.5.0

func (idx *Indexer) GetIndexHistory(indexIdentifier string, userAddr string) ([]hash.Hash256, error)

GetIndexHistory gets index history

func (*Indexer) HandleBlock ¶ added in v0.4.4

func (idx *Indexer) HandleBlock(blk *block.Block) error

HandleBlock is an implementation of interface BlockCreationSubscriber

func (*Indexer) UpdateBlockByIndex ¶ added in v0.5.0

func (idx *Indexer) UpdateBlockByIndex(blk *block.Block, tx *sql.Tx, indexIdentifier string, indexHash hash.Hash256,
	blockHash hash.Hash256) error

UpdateBlockByIndex maps index hash to block hash

func (*Indexer) UpdateIndexHistory ¶ added in v0.5.0

func (idx *Indexer) UpdateIndexHistory(blk *block.Block, tx *sql.Tx, indexIdentifier string, userAddr string,
	indexHash hash.Hash256) error

UpdateIndexHistory stores index information into index history table

type Server ¶

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

Server is the container of the index service

func NewServer ¶

func NewServer(
	cfg config.Config,
	bc blockchain.Blockchain,
) *Server

NewServer instantiates an index service

func (*Server) Indexer ¶

func (s *Server) Indexer() *Indexer

Indexer return indexer interface

func (*Server) Start ¶

func (s *Server) Start(ctx context.Context) error

Start starts the explorer server

func (*Server) Stop ¶

func (s *Server) Stop(ctx context.Context) error

Stop stops the explorer server

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL