server

Feb 14, 2019

Changes in this version

+ func NewBatch(batch []crypto.Signature) (*blockBatch, error)

+ type NodeState struct

+ Addr string

+ KnownVersion proto.Version

+ LastKnownBlock crypto.Signature

+ State string

+ type Option func(*Server) error

+ func WithDeclaredAddr(addr string) Option

+ func WithGenesis(gen string) Option

+ func WithLevelDBPath(dbpath string) Option

+ func WithPeers(peers []string) Option

+ func WithRestAddr(addr string) Option

+ type Peer struct

+ func NewPeer(gen crypto.Signature, db *db.WavesDB, opts ...PeerOption) (*Peer, error)

+ func (p *Peer) State() NodeState

+ func (p *Peer) Stop()

+ type PeerOption func(*Peer) error

+ func WithAddr(addr string) PeerOption

+ func WithConn(conn net.Conn) PeerOption

+ func WithDeclAddr(addr string) PeerOption

+ func WithPeersChan(c chan proto.PeerInfo) PeerOption

Oct 30, 2018

Changes in this version

+ type Server struct

+ BootPeerAddrs []string

+ Listen string

+ func NewServer(peers []string) *Server

+ func (m *Server) Run(ctx context.Context)

+ func (m *Server) RunClients(ctx context.Context)

+ func (m *Server) Stop()