peerdb

Sep 30, 2024

Changes in this version

type AtomicSlice

+ func (s *AtomicSlice[PT, T]) Remove(targets ...PT)

+ func (s *AtomicSlice[PT, T]) RemoveFunc(fn func(v PT) bool)

Dec 6, 2023

Changes in this version

+ type AtomicSlice atomic.Pointer[[]PT]

+ func (s *AtomicSlice[PT, T]) Copy() *AtomicSlice[PT, T]

+ func (s *AtomicSlice[PT, T]) Equal(t *AtomicSlice[PT, T]) bool

+ func (s *AtomicSlice[PT, T]) Get(target PT) (PT, bool)

+ func (s *AtomicSlice[PT, T]) Insert(target PT) PT

+ func (s *AtomicSlice[PT, T]) Load() []PT

+ func (s *AtomicSlice[PT, T]) MarshalJSON() ([]byte, error)

+ func (s *AtomicSlice[PT, T]) Store(v []PT)

+ func (s *AtomicSlice[PT, T]) UnmarshalJSON(b []byte) error

+ type AtomicUint atomic.Uint64

+ func (v *AtomicUint) Add(delta uint64)

+ func (v *AtomicUint) Copy() *AtomicUint

+ func (v *AtomicUint) Equal(u *AtomicUint) bool

+ func (v *AtomicUint) Load() uint64

+ func (v *AtomicUint) MarshalJSON() ([]byte, error)

+ func (v *AtomicUint) Store(u uint64)

+ func (v *AtomicUint) UnmarshalJSON(b []byte) error

+ type DB struct

+ LastScan *time.Time

+ Peers *AtomicSlice[*PeerStatus, PeerStatus]

+ func LoadFile(file string) (*DB, error)

+ func New() *DB

+ func (db *DB) Load(rd io.Reader) error

+ func (db *DB) Peer(id peer.ID) *PeerStatus

+ func (db *DB) Store(wr io.Writer) error

+ func (db *DB) StoreFile(file string) error

+ func (v *DB) Copy() *DB

+ func (v *DB) CopyAsInterface() interface{}

+ func (v *DB) Equal(u *DB) bool

+ type LastStatus struct

+ Attempt *time.Time

+ Failed *AtomicUint

+ Success *time.Time

+ func (l *LastStatus) DidAttempt()

+ func (l *LastStatus) DidSucceed()

+ func (l *LastStatus) SinceAttempt() time.Duration

+ func (l *LastStatus) SinceSuccess() time.Duration

+ func (s *LastStatus) UnmarshalJSON(b []byte) error

+ func (v *LastStatus) Copy() *LastStatus

+ func (v *LastStatus) CopyAsInterface() interface{}

+ func (v *LastStatus) Equal(u *LastStatus) bool

+ type PeerAddressStatus struct

+ Address p2p.Multiaddr

+ Last LastStatus

+ func (s *PeerAddressStatus) Compare(b *PeerAddressStatus) int

+ func (v *PeerAddressStatus) Copy() *PeerAddressStatus

+ func (v *PeerAddressStatus) CopyAsInterface() interface{}

+ func (v *PeerAddressStatus) Equal(u *PeerAddressStatus) bool

+ func (v *PeerAddressStatus) MarshalJSON() ([]byte, error)

+ func (v *PeerAddressStatus) UnmarshalJSON(data []byte) error

+ type PeerNetworkStatus struct

+ Name string

+ Services *AtomicSlice[*PeerServiceStatus, PeerServiceStatus]

+ func (p *PeerNetworkStatus) Service(addr *api.ServiceAddress) *PeerServiceStatus

+ func (s *PeerNetworkStatus) Compare(b *PeerNetworkStatus) int

+ func (s *PeerNetworkStatus) UnmarshalJSON(b []byte) error

+ func (v *PeerNetworkStatus) Copy() *PeerNetworkStatus

+ func (v *PeerNetworkStatus) CopyAsInterface() interface{}

+ func (v *PeerNetworkStatus) Equal(u *PeerNetworkStatus) bool

+ type PeerServiceStatus struct

+ Address *api.ServiceAddress

+ Last LastStatus

+ func (s *PeerServiceStatus) Compare(q *PeerServiceStatus) int

+ func (v *PeerServiceStatus) Copy() *PeerServiceStatus

+ func (v *PeerServiceStatus) CopyAsInterface() interface{}

+ func (v *PeerServiceStatus) Equal(u *PeerServiceStatus) bool

+ type PeerStatus struct

+ Addresses *AtomicSlice[*PeerAddressStatus, PeerAddressStatus]

+ ID p2p.PeerID

+ Networks *AtomicSlice[*PeerNetworkStatus, PeerNetworkStatus]

+ func (p *PeerStatus) Address(addr multiaddr.Multiaddr) *PeerAddressStatus

+ func (p *PeerStatus) Network(name string) *PeerNetworkStatus

+ func (s *PeerStatus) Compare(q *PeerStatus) int

+ func (s *PeerStatus) UnmarshalJSON(b []byte) error

+ func (v *PeerStatus) Copy() *PeerStatus

+ func (v *PeerStatus) CopyAsInterface() interface{}

+ func (v *PeerStatus) Equal(u *PeerStatus) bool