p2putils

Documentation

Index

• func ConnectednessToString(connectedness network.Connectedness) (string, bool)
• func CountStream(host host.Host, targetID peer.ID, opts ...FilterOption) int
• func DirectionToString(direction network.Direction) (string, bool)
• func FilterStream(host host.Host, targetID peer.ID, options ...FilterOption) []network.Stream
• func FlowStream(conn network.Conn) network.Stream
• func IPPortFromMultiAddress(addrs ...multiaddr.Multiaddr) (string, string, error)
• func NetworkingInfo(identity flow.Identity) (string, string, crypto.PubKey, error)
• func StreamLogger(log zerolog.Logger, stream network.Stream) zerolog.Logger
• type FilterOption
  • func All() FilterOption
  • func Direction(dir network.Direction) FilterOption
  • func Protocol(protocol protocol.ID) FilterOption
• type FilterOptions

Functions

func ConnectednessToString

func ConnectednessToString(connectedness network.Connectedness) (string, bool)

ConnectednessToString reverse translates libp2p network connectedness to string

func CountStream

func CountStream(host host.Host, targetID peer.ID, opts ...FilterOption) int

CountStream finds total number of outbound stream to the target id

func DirectionToString

func DirectionToString(direction network.Direction) (string, bool)

DirectionToString reverse translates libp2p network direction to string

func FilterStream

func FilterStream(host host.Host, targetID peer.ID, options ...FilterOption) []network.Stream

FilterStream filters the streams to a target peer based on the provided options. The default behavior is to consider all directions and protocols, and return just the first matching stream. This behavior can be customized by providing FilterOption values.

Usage:

• To find all outbound streams to a target peer with a specific protocol ID: streams := FilterStream(host, targetID, Direction(network.DirOutbound), Protocol(myProtocolID), All(true))

• To find the first inbound stream to a target peer, regardless of protocol ID: stream := FilterStream(host, targetID, Direction(network.DirInbound))

host is the host from which to filter streams. targetID is the ID of the target peer. options is a variadic parameter that allows zero or more FilterOption values to be provided.

It returns a slice of network.Stream values that match the filtering criteria.

func FlowStream

func FlowStream(conn network.Conn) network.Stream

FlowStream returns the Flow protocol Stream in the connection if one exist, else it returns nil

func IPPortFromMultiAddress

func IPPortFromMultiAddress(addrs ...multiaddr.Multiaddr) (string, string, error)

IPPortFromMultiAddress returns the IP/hostname and the port for the given multi-addresses associated with a libp2p host

func NetworkingInfo

func NetworkingInfo(identity flow.Identity) (string, string, crypto.PubKey, error)

NetworkingInfo returns ip, port, libp2p public key of the identity.

func StreamLogger

func StreamLogger(log zerolog.Logger, stream network.Stream) zerolog.Logger

StreamLogger creates a logger for libp2p stream which logs the remote and local peer IDs and addresses

Types

type FilterOption

type FilterOption func(*FilterOptions)

FilterOption defines a function type that modifies FilterOptions.

func All

func All() FilterOption

All is a FilterOption for setting whether to return all matching streams or just the first matching stream.

func Direction

func Direction(dir network.Direction) FilterOption

Direction is a FilterOption for setting the direction of the streams to be filtered.

func Protocol

func Protocol(protocol protocol.ID) FilterOption

Protocol is a FilterOption for setting the protocol ID of the streams to be filtered.

type FilterOptions

type FilterOptions struct {
	// contains filtered or unexported fields
}

FilterOptions holds the filtering options used in FilterStream.