Documentation
¶
Index ¶
Constants ¶
View Source
const TptAddrDelimiter = '|'
TptAddrDelimiter is the delimiter for tpt addr sections.
Variables ¶
View Source
var ErrInvalidTptAddr = errors.New("invalid transport address: expected transport-type-id|addr")
ErrInvalidTptAddr is returned if the tptaddr was invalid.
Functions ¶
func ParseTptAddr ¶
ParseTptAddr parses a transport address string.
Types ¶
type DialTptAddr ¶
type DialTptAddr interface {
// Directive indicates DialTptAddr is a directive.
directive.Directive
// DialTptAddrSourcePeerId returns the source peer ID.
// Can be empty to allow any.
DialTptAddrSourcePeerId() peer.ID
// DialTptAddrTargetPeerId returns the target peer ID.
// Cannot be empty.
DialTptAddrTargetPeerId() peer.ID
// DialTptAddrDialerOpts are options for the dialer.
// Address: usually {transport-type-id}|{addr}
// Addr cannot be empty.
DialTptAddrDialerOpts() *dialer.DialerOpts
}
DialTptAddr is a directive to establish a link with a peer via a transport address.
Value: Link
func NewDialTptAddr ¶
func NewDialTptAddr(dialerOpts *dialer.DialerOpts, srcPeer, destPeer peer.ID) DialTptAddr
NewDialTptAddr constructs a new DialTptAddr directive.
type DialTptAddrValue ¶
DialTptAddrValue is the type emitted when resolving DialTptAddr.
type LookupTptAddr ¶
type LookupTptAddr interface {
// Directive indicates LookupTptAddr is a directive.
directive.Directive
// LookupTptAddrTargetPeerId returns the target peer ID.
// Cannot be empty.
LookupTptAddrTargetPeerId() peer.ID
}
LookupTptAddr is a directive to look up transport addresses for a peer id.
Value: string in transport address format.
func NewLookupTptAddr ¶
func NewLookupTptAddr(destPeer peer.ID) LookupTptAddr
NewLookupTptAddr constructs a new LookupTptAddr directive.
type LookupTptAddrValue ¶
type LookupTptAddrValue = string
LookupTptAddrValue is the type emitted when resolving LookupTptAddr.
func ExLookupTptAddr ¶
func ExLookupTptAddr(ctx context.Context, b bus.Bus, destPeerID peer.ID, waitOne bool) ([]LookupTptAddrValue, directive.Instance, directive.Reference, error)
ExLookupTptAddr executes collecting transport addresses for a peer.
Note: waits to return until all resolvers become idle.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.