sync

package
v0.0.13 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 10, 2021 License: GPL-3.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type HistorySync

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

HistorySync is responsible for syncing and iBFT instance when needed by fetching decided messages from the network

func NewHistorySync

func NewHistorySync(logger *zap.Logger, publicKey []byte, identifier []byte, network network.Network, ibftStorage collections.Iibft, validateDecidedMsgF func(msg *proto.SignedMessage) error) *HistorySync

NewHistorySync returns a new instance of HistorySync

func (*HistorySync) Start

func (s *HistorySync) Start() error

Start the sync

type ReqHandler

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

ReqHandler is responsible for syncing and iBFT instance when needed by fetching decided messages from the network

func NewReqHandler

func NewReqHandler(logger *zap.Logger, identifier []byte, network network.Network, storage collections.Iibft) *ReqHandler

NewReqHandler returns a new instance of ReqHandler

func (*ReqHandler) Process

func (s *ReqHandler) Process(msg *network.SyncChanObj)

Process takes a req and processes it

Jump to

Keyboard shortcuts

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