lead

Documentation

Index

• func ExecWithRetry(f func() error) error
• type Client
• type Node
  • func NewNode() *Node
  • func (n *Node) GetBlock(heightBack int64) (*chainhash.Hash, error)
  • func (n *Node) SaveBlock(dbi.BlockInfo) error
  • func (n *Node) SaveTxs(ctx context.Context, b *dbi.Block) error
  • func (n *Node) Start(memPool, syncDone bool)
  • func (n *Node) Stop()
• type Processor
  • func NewProcessor(verbose bool) *Processor
  • func (p *Processor) ProcessBlock(block *dbi.Block, loc string) bool
  • func (p *Processor) Run() error
  • func (p *Processor) SaveBlockShards(height int64, seen time.Time, shardBlocks map[uint32]*cluster_pb.Block) bool
• type ShardError

Functions

func ExecWithRetry

func ExecWithRetry(f func() error) error

Types

type Client

type Client struct {
	Config    config.Shard
	Client    cluster_pb.ClusterClient
	Connected bool
}

type Node

type Node struct {
	Off      bool
	Peer     *peer.Peer
	NewBlock chan *dbi.Block
	SyncDone chan struct{}
	Verbose  bool
}

func NewNode

func NewNode() *Node

func (*Node) GetBlock

func (n *Node) GetBlock(heightBack int64) (*chainhash.Hash, error)

func (*Node) SaveBlock

func (n *Node) SaveBlock(dbi.BlockInfo) error

func (*Node) SaveTxs

func (n *Node) SaveTxs(ctx context.Context, b *dbi.Block) error

func (*Node) Start

func (n *Node) Start(memPool, syncDone bool)

func (*Node) Stop

func (n *Node) Stop()

type Processor

type Processor struct {
	Clients     map[int]*Client
	ErrorChan   chan error
	BlockNode   *Node
	MemPoolNode *Node
	Verbose     bool
	Synced      bool
}

func NewProcessor

func NewProcessor(verbose bool) *Processor

func (*Processor) ProcessBlock

func (p *Processor) ProcessBlock(block *dbi.Block, loc string) bool

func (*Processor) Run

func (p *Processor) Run() error

func (*Processor) SaveBlockShards

func (p *Processor) SaveBlockShards(height int64, seen time.Time, shardBlocks map[uint32]*cluster_pb.Block) bool

type ShardError

type ShardError struct {
	Shard int
	Error error
}