Versions in this module Expand all Collapse all v0 v0.1.1 Feb 25, 2019 Changes in this version + const BanTime + var ErrIntOverflowNode = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthNode = fmt.Errorf("proto: negative length found during unmarshaling") + func CheckAddTx(ctx context.Context, s *setting.Setting, tr *tx.Transaction, typ tx.Type) error + func CheckAddTxs(ctx context.Context, s *setting.Setting, trs []*imesh.TxWithType) error + func ConnSize() int + func GetBanned() map[string][]time.Time + func GetPeerlist() []msg.Addr + func RegisterTxNotifier(n chan []tx.Hash) + func RunMiner(ctx context.Context, s *setting.Setting) + func Start(ctx context.Context, setting *setting.Setting, debug bool) (net.Listener, error) + func WriteAll(s *setting.Setting, m proto.Marshaler, cmd msg.Command) + type Broadcaster struct + Setting *setting.Setting + func NewBroadcaster(s *setting.Setting) *Broadcaster + func (bc *Broadcaster) GetTx(h tx.Hash) + func (bc *Broadcaster) Send(p *akconsensus.Message) + type NodesDB struct + Addrs []*msg.Addr + func NewPopulatedNodesDB(r randyNode, easy bool) *NodesDB + func (*NodesDB) Descriptor() ([]byte, []int) + func (*NodesDB) ProtoMessage() + func (dst *NodesDB) XXX_Merge(src proto.Message) + func (m *NodesDB) Marshal() (dAtA []byte, err error) + func (m *NodesDB) MarshalTo(dAtA []byte) (int, error) + func (m *NodesDB) Reset() + func (m *NodesDB) Size() (n int) + func (m *NodesDB) String() string + func (m *NodesDB) Unmarshal(dAtA []byte) error + func (m *NodesDB) XXX_DiscardUnknown() + func (m *NodesDB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NodesDB) XXX_Size() int + func (m *NodesDB) XXX_Unmarshal(b []byte) error + func (this *NodesDB) Equal(that interface{}) bool