Versions in this module Expand all Collapse all v0 v0.1.0 Jun 22, 2023 Changes in this version + const ValidatorNamespace + var InvalidDhtKey = errors.New("invalid dht key") + func ACLQueryFilter(acl ACL, protocol protocol.ID, logger commontypes.Logger) dht.QueryFilterFunc + func ACLRoutingTableFilter(acl ACL, protocol protocol.ID, logger commontypes.Logger) dht.RouteTableFilterFunc + type ACL interface + IsACLEnforced func(protocol protocol.ID) bool + IsAllowed func(id peer.ID, protocol protocol.ID) bool + String func() string + type ACLHost interface + GetACL func() ACL + SetACL func(acl ACL) + func WrapACL(h host.Host, acl ACL, logger loghelper.LoggerWithContext) ACLHost + type AnnouncementValidator struct + func (v AnnouncementValidator) Select(_ string, values [][]byte) (int, error) + func (v AnnouncementValidator) Validate(key string, value []byte) error + type BasicACLHost struct + func (aclHost *BasicACLHost) SetACL(acl ACL) + func (aclHost BasicACLHost) Addrs() []ma.Multiaddr + func (aclHost BasicACLHost) Close() error + func (aclHost BasicACLHost) ConnManager() connmgr.ConnManager + func (aclHost BasicACLHost) Connect(ctx context.Context, pi peer.AddrInfo) error + func (aclHost BasicACLHost) EventBus() event.Bus + func (aclHost BasicACLHost) GetACL() ACL + func (aclHost BasicACLHost) ID() peer.ID + func (aclHost BasicACLHost) Mux() protocol.Switch + func (aclHost BasicACLHost) Network() p2pnetwork.Network + func (aclHost BasicACLHost) NewStream(ctx context.Context, p peer.ID, pids ...protocol.ID) (p2pnetwork.Stream, error) + func (aclHost BasicACLHost) Peerstore() peerstore.Peerstore + func (aclHost BasicACLHost) RemoveStreamHandler(pid protocol.ID) + func (aclHost BasicACLHost) SetStreamHandler(protocol protocol.ID, handler p2pnetwork.StreamHandler) + func (aclHost BasicACLHost) SetStreamHandlerMatch(id protocol.ID, f func(string) bool, handler p2pnetwork.StreamHandler) + type DHTNodeConfig struct + func BuildConfig(bootstrapNodes []peer.AddrInfo, prefix protocol.ID, ...) DHTNodeConfig + func (config *DHTNodeConfig) AddBootstrapNodes(addrs []peer.AddrInfo) + func (config DHTNodeConfig) ProtocolID() protocol.ID + func (config DHTNodeConfig) String() string + type DHTRouter struct + func (router DHTRouter) Close() error + func (router DHTRouter) FindPeer(ctx context.Context, peerId peer.ID) (addr peer.AddrInfo, error error) + func (router DHTRouter) ProtocolID() p2pprotocol.ID + func (router DHTRouter) Start() + type PeerDiscoveryRouter interface + Close func() error + ProtocolID func() p2pprotocol.ID + Start func() + func NewDHTRouter(ctx context.Context, config DHTNodeConfig, aclHost ACLHost) (PeerDiscoveryRouter, error) + type PermitListACL interface + Activate func(protocol protocol.ID, permitted ...peer.ID) + Deactivate func(protocol protocol.ID) + Permit func(protocol protocol.ID, ids ...peer.ID) error + Reject func(protocol protocol.ID, id peer.ID) error + func NewPermitListACL(logger loghelper.LoggerWithContext) PermitListACL
Go to main page