incoming

Documentation

Index

• func GetDecidedInRange(identifier []byte, start, end uint64, logger *zap.Logger, ...) ([]*proto.SignedMessage, error)
• type ReqHandler
  • func New(logger *zap.Logger, identifier []byte, seqNumber int64, ...) *ReqHandler
  • func (s *ReqHandler) Process(msg *network.SyncChanObj)

Functions

func GetDecidedInRange

func GetDecidedInRange(identifier []byte, start, end uint64, logger *zap.Logger, storage collections.Iibft) ([]*proto.SignedMessage, error)

GetDecidedInRange returns decided messages of the validator (and role) for the given range

Types

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 New

func New(
	logger *zap.Logger,
	identifier []byte,
	seqNumber int64,
	network network.Network,
	storage collections.Iibft,
	lastChangeRoundMsg *proto.SignedMessage,
) *ReqHandler

New returns a new instance of ReqHandler

func (*ReqHandler) Process

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

Process takes a req and processes it