sync

Documentation

Index

• type HistorySync
  • func NewHistorySync(logger *zap.Logger, validatorPK []byte, network network.Network, ...) *HistorySync
  • func (s *HistorySync) Start() error
• type ReqHandler
  • func NewReqHandler(logger *zap.Logger, validatorPK []byte, network network.Network, ...) *ReqHandler
  • func (s *ReqHandler) Process(msg *network.SyncChanObj)

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,
	validatorPK []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, validatorPK []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