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
  • func (d *DialQueue) Wait(ctx context.Context) bool
• 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 the implementation for task popping from the min-heap

func (*DialQueue) Wait

func (d *DialQueue) Wait(ctx context.Context) bool

Wait waits for closing or updating event or end of context. Returns true for closing event or end of the context [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