Documentation
¶
Index ¶
- Variables
- func IsErrNoResult(err error) bool
- type AuxRequest
- type BBA
- func (bba *BBA) Close()
- func (bba *BBA) HandleInput(round uint64, bvalRequest *BvalRequest) error
- func (bba *BBA) HandleMessage(sender cleisthenes.Member, msg *pb.Message_Bba) error
- func (bba *BBA) Idle() bool
- func (bba *BBA) Result() (cleisthenes.Binary, bool)
- func (bba *BBA) Round() uint64
- func (bba *BBA) Trace()
- type BvalRequest
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrInvalidType = errors.New("request type is invalid")
View Source
var ErrNoResult = errors.New("no result with id")
View Source
var ErrUndefinedRequestType = errors.New("unexpected request type")
Functions ¶
func IsErrNoResult ¶
Types ¶
type AuxRequest ¶
type AuxRequest struct {
Value cleisthenes.Binary
}
func (AuxRequest) Recv ¶
func (r AuxRequest) Recv()
type BBA ¶
type BBA struct {
sync.RWMutex
cleisthenes.Tracer
// contains filtered or unexported fields
}
func New ¶
func New( n, f int, epoch cleisthenes.Epoch, owner cleisthenes.Member, proposer cleisthenes.Member, broadcaster cleisthenes.Broadcaster, binInputChan cleisthenes.BinarySender, ) *BBA
func (*BBA) HandleInput ¶
func (bba *BBA) HandleInput(round uint64, bvalRequest *BvalRequest) error
HandleInput will set the given val as the initial value to be proposed in the Agreement
func (*BBA) HandleMessage ¶
func (bba *BBA) HandleMessage(sender cleisthenes.Member, msg *pb.Message_Bba) error
HandleMessage will process the given rpc message.
type BvalRequest ¶
type BvalRequest struct {
Value cleisthenes.Binary
}
func (BvalRequest) Recv ¶
func (r BvalRequest) Recv()
Source Files
Click to show internal directories.
Click to hide internal directories.