peers

Documentation

Index

• type Peers
  • func NewPeers() (*Peers, error)
  • func (p *Peers) APIs() []rpc.API
  • func (p *Peers) Add(id string, Addr string)
  • func (p *Peers) All() []*db.Peer
  • func (p *Peers) Count() int
  • func (p *Peers) FindPeerList() []*db.Peer
  • func (p *Peers) LoadPeers()
  • func (p *Peers) Start() error
  • func (p *Peers) Stop() error
  • func (p *Peers) UpdateConnectTime(id string, timestamp int64)
  • func (p *Peers) UpdateUnConnected(id string)
• type PeersApi
  • func NewPeersApi(peers *Peers) *PeersApi
  • func (api *PeersApi) GetNodeList() (interface{}, error)

Types

type Peers

type Peers struct {
	// contains filtered or unexported fields
}

func NewPeers

func NewPeers() (*Peers, error)

func (*Peers) APIs

func (p *Peers) APIs() []rpc.API

func (*Peers) Add

func (p *Peers) Add(id string, Addr string)

func (*Peers) All

func (p *Peers) All() []*db.Peer

func (*Peers) Count

func (p *Peers) Count() int

func (*Peers) FindPeerList

func (p *Peers) FindPeerList() []*db.Peer

func (*Peers) LoadPeers

func (p *Peers) LoadPeers()

func (*Peers) Start

func (p *Peers) Start() error

func (*Peers) Stop

func (p *Peers) Stop() error

func (*Peers) UpdateConnectTime

func (p *Peers) UpdateConnectTime(id string, timestamp int64)

func (*Peers) UpdateUnConnected

func (p *Peers) UpdateUnConnected(id string)

type PeersApi

type PeersApi struct {
	// contains filtered or unexported fields
}

func NewPeersApi

func NewPeersApi(peers *Peers) *PeersApi

func (*PeersApi) GetNodeList

func (api *PeersApi) GetNodeList() (interface{}, error)