sync

package

v0.0.0-...-477d63b Latest Latest Go to latest Published: Apr 11, 2024 License: MIT Imports: 18 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

gitlab.com/thorchain/midgard

Documentation ¶

Index ¶

Variables
func InitBlockFetch(ctx context.Context) (<-chan chain.Block, jobs.NamedFunction)
func InitGlobalSync(ctx context.Context)
func SetFirstBlock(height int64, timestmap db.Nano, hash string)
type Iterator
- func NewIterator(s *Sync, startHeight, finalHeight int64) Iterator
- func (i *Iterator) FetchingFrom() string
- func (i *Iterator) Next() (*chain.Block, error)
type Sync

Constants ¶

This section is empty.

Variables ¶

View Source

var CheckBlockStoreBlocks = false

View Source

var CursorHeight = metrics.Must1LabelInteger("midgard_chain_cursor_height", "node")

CursorHeight is the Tendermint chain position [sequence identifier].

View Source

var NodeHeight = metrics.Must1LabelRealSample("midgard_chain_height", "node")

NodeHeight is the latest Tendermint chain position [sequence identifier] reported by the node.

Functions ¶

func InitBlockFetch ¶

func InitBlockFetch(ctx context.Context) (<-chan chain.Block, jobs.NamedFunction)

func InitGlobalSync ¶

func InitGlobalSync(ctx context.Context)

func SetFirstBlock ¶

func SetFirstBlock(height int64, timestmap db.Nano, hash string)

Types ¶

type Iterator ¶

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

func NewIterator ¶

func NewIterator(s *Sync, startHeight, finalHeight int64) Iterator

func (*Iterator) FetchingFrom ¶

func (i *Iterator) FetchingFrom() string

func (*Iterator) Next ¶

func (i *Iterator) Next() (*chain.Block, error)

type Sync ¶

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

var GlobalSync *Sync

func (*Sync) BlockStoreHeight ¶

func (s *Sync) BlockStoreHeight() int64

func (*Sync) CatchUp ¶

func (s *Sync) CatchUp(out chan<- chain.Block, startHeight int64) (
	height int64, inSync bool, err error)

CatchUp reads the latest block height from Status then it fetches all blocks from offset to that height. The error return is never nil. See ErrQuit and ErrNoData for normal exit.

func (*Sync) CheckGenesisStatus ¶

func (s *Sync) CheckGenesisStatus()

func (*Sync) FetchSingle ¶

func (s *Sync) FetchSingle(height int64) (*coretypes.ResultBlockResults, error)

func (*Sync) KeepInSync ¶

func (s *Sync) KeepInSync(ctx context.Context, out chan chain.Block)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
blockstore
chain Package chain provides a blockchain client.	Package chain provides a blockchain client.

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