dial

Documentation

Index

• type DialQueue
  • func NewDialQueue() *DialQueue
  • func (d *DialQueue) AddTask(addrInfo *peer.AddrInfo, priority common.DialPriority)
  • func (d *DialQueue) Close()
  • func (d *DialQueue) DeleteTask(peer peer.ID)
  • func (d *DialQueue) PopTask() *DialTask
• type DialTask
  • func (dt *DialTask) GetAddrInfo() *peer.AddrInfo

Types

type DialQueue

type DialQueue struct {
	sync.Mutex
	// contains filtered or unexported fields
}

DialQueue is a queue that holds dials tasks for potential peers, implemented as a min-heap

func NewDialQueue

func NewDialQueue() *DialQueue

NewDialQueue creates a new DialQueue instance

func (*DialQueue) AddTask

func (d *DialQueue) AddTask(
	addrInfo *peer.AddrInfo,
	priority common.DialPriority,
)

AddTask adds a new task to the dial queue

func (*DialQueue) Close

func (d *DialQueue) Close()

Close closes the running DialQueue

func (*DialQueue) DeleteTask

func (d *DialQueue) DeleteTask(peer peer.ID)

DeleteTask deletes a task from the dial queue for the specified peer

func (*DialQueue) PopTask

func (d *DialQueue) PopTask() *DialTask

PopTask is a loop that handles update and close events [BLOCKING]

type DialTask

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

func (*DialTask) GetAddrInfo

func (dt *DialTask) GetAddrInfo() *peer.AddrInfo

GetAddrInfo returns the peer information associated with the dial