storage

func (*CBORStorage) AddOrUpdateKnown ¶

func (bs *CBORStorage) AddOrUpdateKnown(known []KnownPeer, now time.Time) error

AddOrUpdateKnown adds known peers with now timestamp into peers storage with strong error guarantees.

func (*CBORStorage) AddSuspended ¶

func (bs *CBORStorage) AddSuspended(suspended []SuspendedPeer) error

AddSuspended adds suspended peers into peers storage with strong error guarantees.

func (*CBORStorage) AddToBlackList ¶

func (bs *CBORStorage) AddToBlackList(blackListed []BlackListedPeer) error

AddToBlackList adds suspended peers into peers storage with strong error guarantees.

func (*CBORStorage) BlackList ¶

func (bs *CBORStorage) BlackList(now time.Time) []BlackListedPeer

func (*CBORStorage) DeleteBlackListedByIP ¶

func (bs *CBORStorage) DeleteBlackListedByIP(restricted []BlackListedPeer) error

func (*CBORStorage) DeleteKnown ¶

func (bs *CBORStorage) DeleteKnown(known []KnownPeer) error

DeleteKnown removes known peers from peers storage with strong error guarantees.

func (*CBORStorage) DeleteSuspendedByIP ¶

func (bs *CBORStorage) DeleteSuspendedByIP(suspended []SuspendedPeer) error

DeleteSuspendedByIP removes suspended peers from peers storage with strong error guarantees. Note, that only IP field in input parameter will be used.

func (*CBORStorage) DropBlackList ¶

func (bs *CBORStorage) DropBlackList() error

func (*CBORStorage) DropKnown ¶

func (bs *CBORStorage) DropKnown() error

DropKnown clear known in memory cache and truncates known peers storage file with strong error guarantee.

func (*CBORStorage) DropStorage ¶

func (bs *CBORStorage) DropStorage() error

DropStorage clear storage memory cache and truncates storage files. In case of error we can lose suspended peers storage file, but honestly it's almost impossible case.

func (*CBORStorage) DropSuspended ¶

func (bs *CBORStorage) DropSuspended() error

DropSuspended clear suspended in memory cache and truncates suspended peers storage file with strong error guarantee.

func (*CBORStorage) IsBlackListedIP ¶

func (bs *CBORStorage) IsBlackListedIP(ip IP, now time.Time) bool

func (*CBORStorage) IsBlackListedIPs ¶

func (bs *CBORStorage) IsBlackListedIPs(ips []IP, now time.Time) []bool

func (*CBORStorage) IsSuspendedIP ¶

func (bs *CBORStorage) IsSuspendedIP(ip IP, now time.Time) bool

func (*CBORStorage) IsSuspendedIPs ¶

func (bs *CBORStorage) IsSuspendedIPs(ips []IP, now time.Time) []bool

func (*CBORStorage) Known ¶

func (bs *CBORStorage) Known(limit int) []KnownPeer

func (*CBORStorage) RefreshBlackList ¶

func (bs *CBORStorage) RefreshBlackList(now time.Time) error

func (*CBORStorage) RefreshSuspended ¶

func (bs *CBORStorage) RefreshSuspended(now time.Time) error

RefreshSuspended removes expired peers from suspended peers storage with strong error guarantee.

func (*CBORStorage) Suspended ¶

func (bs *CBORStorage) Suspended(now time.Time) []SuspendedPeer

func (*IP) String ¶

func (i *IP) String() string

func (*KnownPeer) IP ¶

func (kp *KnownPeer) IP() IP

func (*KnownPeer) IpPort ¶

func (kp *KnownPeer) IpPort() proto.IpPort

func (*KnownPeer) String ¶

func (kp *KnownPeer) String() string