sync

Documentation

Index

• Constants
• Variables
• type Sync
  • func New(ctx context.Context, chn clienttypes.InterfaceChains) (*Sync, error)
  • func (s *Sync) On(event synctypes.EventEnum, cb clienttypes.EventCallback)
  • func (s *Sync) PeerRequests(pr clienttypes.InterfacePeer) (clienttypes.Requests, error)
  • func (s *Sync) ProvideBlocks(pr clienttypes.InterfacePeer, request *clienttypes.BlockRequest) error
  • func (s *Sync) QueueBlocks(pr clienttypes.InterfacePeer, response *clienttypes.BlockResponse) error
  • func (s *Sync) RequestBlocks(pr clienttypes.InterfacePeer) error

Constants

const (
	// REPORT_COUNT ...
	REPORT_COUNT int = 5
	// REQUEST_TIMEOUT ...
	// note: ms?
	REQUEST_TIMEOUT int = 60000
)

Variables

var (
	// ErrNilConfig ...
	ErrNilConfig = errors.New("nil config")
	// ErrNilChain ...
	ErrNilChain = errors.New("nil chain")
)

Types

type Sync

type Sync struct {
	BestSeen *big.Int
	Status   synctypes.StatusEnum
	// contains filtered or unexported fields
}

Sync ...

func New

func New(ctx context.Context, chn clienttypes.InterfaceChains) (*Sync, error)

New ...

func (*Sync) On

func (s *Sync) On(event synctypes.EventEnum, cb clienttypes.EventCallback)

On ...

func (*Sync) PeerRequests

func (s *Sync) PeerRequests(pr clienttypes.InterfacePeer) (clienttypes.Requests, error)

PeerRequests ...

func (*Sync) ProvideBlocks

func (s *Sync) ProvideBlocks(pr clienttypes.InterfacePeer, request *clienttypes.BlockRequest) error

ProvideBlocks ...

func (*Sync) QueueBlocks

func (s *Sync) QueueBlocks(pr clienttypes.InterfacePeer, response *clienttypes.BlockResponse) error

QueueBlocks ...

func (*Sync) RequestBlocks

func (s *Sync) RequestBlocks(pr clienttypes.InterfacePeer) error

RequestBlocks ...