Versions in this module Expand all Collapse all v0 v0.1.1 Feb 25, 2019 Changes in this version + var ErrIntOverflowAkconsensus = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthAkconsensus = fmt.Errorf("proto: negative length found during unmarshaling") + var Msgch = make(chan Message, 100) + func Init(ctx context.Context, s *setting.Setting, b broadcaster) + func IsSynced() bool + func IsValid(s *setting.Setting, tr *tx.Transaction, typ tx.Type) error + func NewProposal(ctx context.Context, s *setting.Setting, hs ...tx.Hash) error + func RegisterTxNotifier(n chan []tx.Hash) + func RetryConsensus(ctx context.Context, s *setting.Setting) error + func SetSynced(s bool) + type Message struct + Proposal []Proposal + Signature *address.Signature + Validation []Validation + Vote []Vote + func NewPopulatedMessage(r randyAkconsensus, easy bool) *Message + func ParseMessage(ctx context.Context, s *setting.Setting, buf []byte) (*Message, error) + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (dst *Message) XXX_Merge(src proto.Message) + func (m *Message) Marshal() (dAtA []byte, err error) + func (m *Message) MarshalTo(dAtA []byte) (int, error) + func (m *Message) Reset() + func (m *Message) Size() (n int) + func (m *Message) String() string + func (m *Message) Unmarshal(dAtA []byte) error + func (m *Message) XXX_DiscardUnknown() + func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Message) XXX_Size() int + func (m *Message) XXX_Unmarshal(b []byte) error + func (this *Message) Equal(that interface{}) bool + type Proposal struct + Hash github_com_AidosKuneen_aklib_tx.Hash + ValidatorsHash []byte + Value github_com_AidosKuneen_aknode_imesh.Status + func NewPopulatedProposal(r randyAkconsensus, easy bool) *Proposal + func (*Proposal) Descriptor() ([]byte, []int) + func (*Proposal) ProtoMessage() + func (dst *Proposal) XXX_Merge(src proto.Message) + func (m *Proposal) Marshal() (dAtA []byte, err error) + func (m *Proposal) MarshalTo(dAtA []byte) (int, error) + func (m *Proposal) Reset() + func (m *Proposal) Size() (n int) + func (m *Proposal) String() string + func (m *Proposal) Unmarshal(dAtA []byte) error + func (m *Proposal) XXX_DiscardUnknown() + func (m *Proposal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Proposal) XXX_Size() int + func (m *Proposal) XXX_Unmarshal(b []byte) error + func (this *Proposal) Equal(that interface{}) bool + type Validation struct + Accepted []github_com_AidosKuneen_aklib_tx.Hash + ForSync bool + Rejected []github_com_AidosKuneen_aklib_tx.Hash + func NewPopulatedValidation(r randyAkconsensus, easy bool) *Validation + func NewValidation(s *setting.Setting, accepted, rejected []tx.Hash, forSync bool) (*Validation, error) + func (*Validation) Descriptor() ([]byte, []int) + func (*Validation) ProtoMessage() + func (dst *Validation) XXX_Merge(src proto.Message) + func (m *Validation) Marshal() (dAtA []byte, err error) + func (m *Validation) MarshalTo(dAtA []byte) (int, error) + func (m *Validation) Reset() + func (m *Validation) Size() (n int) + func (m *Validation) String() string + func (m *Validation) Unmarshal(dAtA []byte) error + func (m *Validation) XXX_DiscardUnknown() + func (m *Validation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Validation) XXX_Size() int + func (m *Validation) XXX_Unmarshal(b []byte) error + func (this *Validation) Equal(that interface{}) bool + type ValidationT struct + type Vote struct + Alert bool + BBARound byte + BBAStep byte + Halted bool + Hash github_com_AidosKuneen_aklib_tx.Hash + MBARound byte + SigJ *address.Signature + ValidatorsHash []byte + func NewPopulatedVote(r randyAkconsensus, easy bool) *Vote + func (*Vote) Descriptor() ([]byte, []int) + func (*Vote) ProtoMessage() + func (dst *Vote) XXX_Merge(src proto.Message) + func (m *Vote) Marshal() (dAtA []byte, err error) + func (m *Vote) MarshalTo(dAtA []byte) (int, error) + func (m *Vote) Reset() + func (m *Vote) Size() (n int) + func (m *Vote) String() string + func (m *Vote) Unmarshal(dAtA []byte) error + func (m *Vote) XXX_DiscardUnknown() + func (m *Vote) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Vote) XXX_Size() int + func (m *Vote) XXX_Unmarshal(b []byte) error + func (this *Vote) Equal(that interface{}) bool