traversal

Documentation

Index

• type Operation
  • func Start(input OperationInput) *Operation
  • func (op *Operation) AddNodes(nodes []types.AddrMaybeId) (added int)
  • func (op *Operation) Closest() *k_nearest_nodes.Type
  • func (op *Operation) Stalled() events.Active
  • func (op *Operation) Stats() *Stats
  • func (op *Operation) Stop()
  • func (op *Operation) Stopped() events.Done
• type OperationInput
• type QueryResult
• type Stats

Types

type Operation

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

func Start

func Start(input OperationInput) *Operation

func (*Operation) AddNodes

func (op *Operation) AddNodes(nodes []types.AddrMaybeId) (added int)

func (*Operation) Closest

func (op *Operation) Closest() *k_nearest_nodes.Type

func (*Operation) Stalled

func (op *Operation) Stalled() events.Active

func (*Operation) Stats

func (op *Operation) Stats() *Stats

func (*Operation) Stop

func (op *Operation) Stop()

func (*Operation) Stopped

func (op *Operation) Stopped() events.Done

type OperationInput

type OperationInput struct {
	Target     krpc.ID
	Alpha      int
	K          int
	DoQuery    func(context.Context, krpc.NodeAddr) QueryResult
	NodeFilter func(types.AddrMaybeId) bool
}

type QueryResult

type QueryResult struct {
	// A node that should be considered for a closest entry.
	ResponseFrom *krpc.NodeInfo
	// Data associated with a closest node.
	ClosestData interface{}
	Nodes       []krpc.NodeInfo
	Nodes6      []krpc.NodeInfo
}

type Stats

type Stats struct {
	// Count of (probably) distinct addresses we've sent traversal queries to. Accessed with atomic.
	NumAddrsTried uint32
	// Number of responses we received to queries related to this traversal. Accessed with atomic.
	NumResponses uint32
}