mailservers

Nov 18, 2019

Changes in this version

+ var ErrNoConnected = errors.New("no connected mail servers")

+ func EnsureUsedRecordsAddedFirst(ps *PeerStore, conn NodesNotifee) error

+ func GetFirstConnected(provider PeersProvider, store *PeerStore) (*enode.Node, error)

+ type Cache struct

+ func NewCache(db *leveldb.DB) *Cache

+ func (c *Cache) LoadAll() (rst []PeerRecord, err error)

+ func (c *Cache) Replace(nodes []*enode.Node) error

+ func (c *Cache) UpdateRecord(record PeerRecord) error

+ type ConnectionManager struct

+ func NewConnectionManager(server p2pServer, whisper EnvelopeEventSubscriber, target, maxFailures int, ...) *ConnectionManager

+ func (ps *ConnectionManager) Notify(nodes []*enode.Node)

+ func (ps *ConnectionManager) Start()

+ func (ps *ConnectionManager) Stop()

+ type EnvelopeEventSubscriber interface

+ SubscribeEnvelopeEvents func(chan<- whispertypes.EnvelopeEvent) whispertypes.Subscription

+ type LastUsedConnectionMonitor struct

+ func NewLastUsedConnectionMonitor(ps *PeerStore, cache *Cache, whisper EnvelopeEventSubscriber) *LastUsedConnectionMonitor

+ func (mon *LastUsedConnectionMonitor) Start()

+ func (mon *LastUsedConnectionMonitor) Stop()

+ type NodesNotifee interface

+ Notify func([]*enode.Node)

+ type PeerAdderRemover interface

+ AddPeer func(node *enode.Node)

+ RemovePeer func(node *enode.Node)

+ type PeerEventsSubscriber interface

+ SubscribeEvents func(chan *p2p.PeerEvent) event.Subscription

+ type PeerRecord struct

+ LastUsed time.Time

+ func NewPeerRecord(node *enode.Node) PeerRecord

+ func (r PeerRecord) Encode() ([]byte, error)

+ func (r PeerRecord) EncodeKey() ([]byte, error)

+ func (r PeerRecord) ID() enode.ID

+ func (r PeerRecord) Node() *enode.Node

+ type PeerStore struct

+ func NewPeerStore(cache *Cache) *PeerStore

+ func (ps *PeerStore) Exist(nodeID whispertypes.EnodeID) bool

+ func (ps *PeerStore) Get(nodeID whispertypes.EnodeID) *enode.Node

+ func (ps *PeerStore) Update(nodes []*enode.Node) error

+ type PeersProvider interface

+ Peers func() []*p2p.Peer