bba

Documentation

Index

• Variables
• func IsErrNoResult(err error) bool
• type AuxRequest
  • func (r AuxRequest) Recv()
• type BBA
  • func New(n, f int, epoch cleisthenes.Epoch, owner cleisthenes.Member, ...) *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
  • func (r BvalRequest) Recv()

Variables

var ErrInvalidType = errors.New("request type is invalid")

var ErrNoResult = errors.New("no result with id")

var ErrUndefinedRequestType = errors.New("unexpected request type")

Functions

func IsErrNoResult

func IsErrNoResult(err error) bool

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) Close

func (bba *BBA) Close()

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.

func (*BBA) Idle

func (bba *BBA) Idle() bool

func (*BBA) Result

func (bba *BBA) Result() (cleisthenes.Binary, bool)

func (*BBA) Round

func (bba *BBA) Round() uint64

func (*BBA) Trace

func (bba *BBA) Trace()

type BvalRequest

type BvalRequest struct {
	Value cleisthenes.Binary
}

func (BvalRequest) Recv

func (r BvalRequest) Recv()