utils

Documentation

Index

• func AllowedSubscription(role flow.Role, topic string) bool
• func MessageID(data []byte) string
• func MultiAddressStr(ip, port string) string
• func PeerAddressInfo(identity flow.Identity) (peer.AddrInfo, error)
• func PeerInfosFromIDs(ids flow.IdentityList) ([]peer.AddrInfo, map[flow.Identifier]error)

Functions

func AllowedSubscription

func AllowedSubscription(role flow.Role, topic string) bool

AllowedSubscription returns true if the given role is allowed to subscribe to the topic.

func MessageID

func MessageID(data []byte) string

MessageID returns the hash of the given data (used to generate the message ID for pubsub messages).

func MultiAddressStr

func MultiAddressStr(ip, port string) string

MultiAddressStr receives a node ip and port and returns its corresponding Libp2p MultiAddressStr in string format in current implementation IP part of the node address is either an IP or a dns4. https://docs.libp2p.io/concepts/addressing/

func PeerAddressInfo

func PeerAddressInfo(identity flow.Identity) (peer.AddrInfo, error)

PeerAddressInfo generates the libp2p peer.AddrInfo for the given Flow.Identity. A node in flow is defined by a flow.Identity while it is defined by a peer.AddrInfo in libp2p.

flow.Identity        ---> peer.AddrInfo
|-- Address          --->   |-- []multiaddr.Multiaddr
|-- NetworkPublicKey --->   |-- ID

func PeerInfosFromIDs

func PeerInfosFromIDs(ids flow.IdentityList) ([]peer.AddrInfo, map[flow.Identifier]error)

PeerInfosFromIDs converts the given flow.Identities to peer.AddrInfo. For each identity, if the conversion succeeds, the peer.AddrInfo is included in the result else it is included in the error map with the corresponding error