node

Documentation

Index

• Constants
• Variables
• 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
  • func NewBroadcaster(s *setting.Setting) *Broadcaster
  • func (bc *Broadcaster) GetTx(h tx.Hash)
  • func (bc *Broadcaster) Send(p *akconsensus.Message)
• type NodesDB
  • func NewPopulatedNodesDB(r randyNode, easy bool) *NodesDB
  • func (*NodesDB) Descriptor() ([]byte, []int)
  • func (this *NodesDB) Equal(that interface{}) bool
  • func (m *NodesDB) Marshal() (dAtA []byte, err error)
  • func (m *NodesDB) MarshalTo(dAtA []byte) (int, error)
  • func (*NodesDB) ProtoMessage()
  • 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 (dst *NodesDB) XXX_Merge(src proto.Message)
  • func (m *NodesDB) XXX_Size() int
  • func (m *NodesDB) XXX_Unmarshal(b []byte) error

Constants

const (
	//BanTime is time to be banned
	BanTime = time.Hour
)

Variables

var (
	ErrInvalidLengthNode = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNode   = fmt.Errorf("proto: integer overflow")
)

Functions

func CheckAddTx

func CheckAddTx(ctx context.Context, s *setting.Setting, tr *tx.Transaction, typ tx.Type) error

CheckAddTx adds trs into imeash if they are already resolved. If not adds to search cron.

func CheckAddTxs

func CheckAddTxs(ctx context.Context, s *setting.Setting, trs []*imesh.TxWithType) error

CheckAddTxs adds trs into imeash if they are already resolved. If not adds to search cron.

func ConnSize

func ConnSize() int

ConnSize returns number of connection peers.

func GetBanned

func GetBanned() map[string][]time.Time

GetBanned returns a banned list.

func GetPeerlist

func GetPeerlist() []msg.Addr

GetPeerlist returns a peer list.

func RegisterTxNotifier

func RegisterTxNotifier(n chan []tx.Hash)

RegisterTxNotifier registers a notifier for resolved txs.

func RunMiner

func RunMiner(ctx context.Context, s *setting.Setting)

RunMiner runs a miner

func Start

func Start(ctx context.Context, setting *setting.Setting, debug bool) (net.Listener, error)

Start starts a node server.

func WriteAll

func WriteAll(s *setting.Setting, m proto.Marshaler, cmd msg.Command)

WriteAll writes a command to all connected peers.

Types

type Broadcaster

type Broadcaster struct {
	Setting *setting.Setting
}

Broadcaster is for consensus to communicate with peers.

func NewBroadcaster

func NewBroadcaster(s *setting.Setting) *Broadcaster

NewBroadcaster returns a ConsensusPeer object.

func (*Broadcaster) GetTx

func (bc *Broadcaster) GetTx(h tx.Hash)

GetTx tryies to get a tx.

func (*Broadcaster) Send

func (bc *Broadcaster) Send(p *akconsensus.Message)

Send broadcasts a Message..

type NodesDB

type NodesDB struct {
	Addrs []*msg.Addr `protobuf:"bytes,1,rep,name=addrs,proto3" json:"addrs,omitempty"`
}

func NewPopulatedNodesDB

func NewPopulatedNodesDB(r randyNode, easy bool) *NodesDB

func (*NodesDB) Descriptor

func (*NodesDB) Descriptor() ([]byte, []int)

func (*NodesDB) Equal

func (this *NodesDB) Equal(that interface{}) bool

func (*NodesDB) Marshal

func (m *NodesDB) Marshal() (dAtA []byte, err error)

func (*NodesDB) MarshalTo

func (m *NodesDB) MarshalTo(dAtA []byte) (int, error)

func (*NodesDB) ProtoMessage

func (*NodesDB) ProtoMessage()

func (*NodesDB) Reset

func (m *NodesDB) Reset()

func (*NodesDB) Size

func (m *NodesDB) Size() (n int)

func (*NodesDB) String

func (m *NodesDB) String() string

func (*NodesDB) Unmarshal

func (m *NodesDB) Unmarshal(dAtA []byte) error

func (*NodesDB) XXX_DiscardUnknown

func (m *NodesDB) XXX_DiscardUnknown()

func (*NodesDB) XXX_Marshal

func (m *NodesDB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodesDB) XXX_Merge

func (dst *NodesDB) XXX_Merge(src proto.Message)

func (*NodesDB) XXX_Size

func (m *NodesDB) XXX_Size() int

func (*NodesDB) XXX_Unmarshal

func (m *NodesDB) XXX_Unmarshal(b []byte) error