libp2p

Oct 29, 2023

Changes in this version

+ func NewConnFromStream(stream network.Stream) net.Conn — darwin/amd64, linux/amd64, windows/amd64

+ func NewDiscoveryJoinRoundTripper(ctx context.Context, opts RoundTripOptions) (transport.JoinRoundTripper, error) — darwin/amd64, linux/amd64, windows/amd64

+ func NewDiscoveryRoundTripper(ctx context.Context, opts RoundTripOptions) (transport.RoundTripper[REQ, RESP], error) — darwin/amd64, linux/amd64, windows/amd64

+ func NewDiscoveryTransport(ctx context.Context, opts TransportOptions) (transport.RPCTransport, error) — darwin/amd64, linux/amd64, windows/amd64

+ func NewTransport(host Host, credentials ...grpc.DialOption) transport.RPCTransport — darwin/amd64, linux/amd64, windows/amd64

+ func NewUncertifiedPeerstore() (peerstore.Peerstore, error)

+ func ToMultiaddrs(addrs []string) []multiaddr.Multiaddr — darwin/amd64, linux/amd64, windows/amd64

type DiscoveryHost — darwin/amd64, linux/amd64, windows/amd64

+ Announce func(ctx context.Context, rendezvous string, ttl time.Duration)

+ type Host interface — darwin/amd64, linux/amd64, windows/amd64

+ AddAddrs func(addrs []multiaddr.Multiaddr, id peer.ID, ttl time.Duration) error

+ Close func() error

+ ConsumePeerRecord func(rec *record.Envelope, ttl time.Duration) error

+ Host func() host.Host

+ ID func() string

+ RPCListener func() net.Listener

+ SignAddrs func(seq uint64) (*record.Envelope, error)

type HostOptions — darwin/amd64, linux/amd64, windows/amd64

+ Key crypto.PrivateKey

+ NoFallbackDefaults bool

+ UncertifiedPeerstore bool

type RoundTripOptions — darwin/amd64, linux/amd64, windows/amd64

+ Credentials []grpc.DialOption

+ Multiaddrs []multiaddr.Multiaddr

+ type TransportOptions struct — darwin/amd64, linux/amd64, windows/amd64

+ Credentials []grpc.DialOption

+ Host Host

+ HostOptions HostOptions

+ Rendezvous string

+ type UncertifiedPeerstore struct

+ func (ps *UncertifiedPeerstore) ConsumePeerRecord(s *record.Envelope, ttl time.Duration) (accepted bool, err error)

+ func (ps *UncertifiedPeerstore) GetPeerRecord(p peer.ID) *record.Envelope

Oct 6, 2023

Changes in this version

type AnnounceOptions — darwin/amd64, linux/amd64, windows/amd64

+ func (opts AnnounceOptions) MarshalJSON() ([]byte, error)

type HostOptions — darwin/amd64, linux/amd64, windows/amd64

+ func (o HostOptions) MarshalJSON() ([]byte, error)

Sep 26, 2023

Changes in this version

+ const BootstrapProtocol — darwin/amd64, linux/amd64, windows/amd64

+ const LineFeed — darwin/amd64, linux/amd64, windows/amd64

+ const MaxBuffer — darwin/amd64, linux/amd64, windows/amd64

+ const RPCProtocol — darwin/amd64, linux/amd64, windows/amd64

+ const RaftProtocol — darwin/amd64, linux/amd64, windows/amd64

+ const UDPRelayProtocol — darwin/amd64, linux/amd64, windows/amd64

+ func NewAnnouncer(ctx context.Context, opts AnnounceOptions, rt transport.UnaryServer[REQ, RESP]) (io.Closer, error) — darwin/amd64, linux/amd64, windows/amd64

+ func NewDHT(ctx context.Context, host host.Host, bootstrapPeers []multiaddr.Multiaddr, ...) (*dht.IpfsDHT, error) — darwin/amd64, linux/amd64, windows/amd64

+ func NewHost(ctx context.Context, opts HostOptions) (host.Host, error) — darwin/amd64, linux/amd64, windows/amd64

+ func NewJoinAnnouncer(ctx context.Context, opts AnnounceOptions, join transport.JoinServer) (io.Closer, error) — darwin/amd64, linux/amd64, windows/amd64

+ func NewJoinRoundTripper(ctx context.Context, opts RoundTripOptions) (transport.JoinRoundTripper, error) — darwin/amd64, linux/amd64, windows/amd64

+ func NewRaftTransport(ctx context.Context, opts RaftTransportOptions) (raft.Transport, error)

+ func NewRoundTripper(ctx context.Context, opts RoundTripOptions) (transport.RoundTripper[REQ, RESP], error) — darwin/amd64, linux/amd64, windows/amd64

+ func RPCProtocolFor(method string) protocol.ID — darwin/amd64, linux/amd64, windows/amd64

+ func SetMaxSystemBuffers() — darwin/amd64, linux/amd64, windows/amd64

+ func SetSystemBuffers(size int) — darwin/amd64, linux/amd64, windows/amd64

+ func UDPRelayProtocolFor(pubkey crypto.PublicKey) protocol.ID — darwin/amd64, linux/amd64, windows/amd64

+ type AnnounceOptions struct — darwin/amd64, linux/amd64, windows/amd64

+ AnnounceTTL time.Duration

+ Host host.Host

+ HostOptions HostOptions

+ Method string

+ Rendezvous string

+ type Announcer interface — darwin/amd64, linux/amd64, windows/amd64

+ AnnounceToDHT func(ctx context.Context, opts AnnounceOptions) error

+ LeaveDHT func(ctx context.Context, rendezvous string) error

+ type BootstrapOptions struct — darwin/amd64, linux/amd64, windows/amd64

+ ElectionTimeout time.Duration

+ Host host.Host

+ HostOptions HostOptions

+ Linger time.Duration

+ NodeID string

+ NodeIDs []string

+ Rendezvous string

+ Signer crypto.PSK

+ type BootstrapTransport interface — darwin/amd64, linux/amd64, windows/amd64

+ LeaderUUID func() uuid.UUID

+ UUID func() uuid.UUID

+ func NewBootstrapTransport(ctx context.Context, announcer Announcer, opts BootstrapOptions) (BootstrapTransport, error)

+ func NewBootstrapTransportWithHost(host DiscoveryHost, announcer Announcer, opts BootstrapOptions) (BootstrapTransport, error)

+ type DiscoveryHost interface — darwin/amd64, linux/amd64, windows/amd64

+ Close func(ctx context.Context) error

+ DHT func() *dht.IpfsDHT

+ Host func() host.Host

+ ID func() peer.ID

+ func NewDiscoveryHost(ctx context.Context, opts HostOptions) (DiscoveryHost, error)

+ func WrapHostWithDiscovery(ctx context.Context, host host.Host, bootstrapPeers []multiaddr.Multiaddr, ...) (DiscoveryHost, error)

+ type HostOptions struct — darwin/amd64, linux/amd64, windows/amd64

+ BootstrapPeers []multiaddr.Multiaddr

+ ConnectTimeout time.Duration

+ LocalAddrs []multiaddr.Multiaddr

+ Options []config.Option

+ type RaftTransportOptions struct

+ BootstrapPeers []multiaddr.Multiaddr

+ ConnectTimeout time.Duration

+ DiscoveryTTL time.Duration

+ LeaderDialer transport.LeaderDialer

+ LocalAddrs []multiaddr.Multiaddr

+ Options []config.Option

+ PSK string

+ type RoundTripOptions struct — darwin/amd64, linux/amd64, windows/amd64

+ Host host.Host

+ HostOptions HostOptions

+ Method string

+ Rendezvous string

+ type UDPRelay struct

+ func NewUDPRelay(ctx context.Context, opts UDPRelayOptions) (*UDPRelay, error)

+ func NewUDPRelayWithHost(ctx context.Context, host DiscoveryHost, opts UDPRelayOptions) (*UDPRelay, error)

+ func (u *UDPRelay) Close() error

+ func (u *UDPRelay) Closed() <-chan struct{}

+ func (u *UDPRelay) Errors() <-chan error

+ func (u *UDPRelay) LocalAddr() *net.UDPAddr

+ type UDPRelayOptions struct

+ Host HostOptions

+ PrivateKey crypto.PrivateKey

+ Relay relay.UDPOptions

+ RemotePubKey crypto.PublicKey