uploadselection

Documentation

Overview

Package uploadselection implements node selection logic for uploads.

Index

• Variables
• func ContainsID(ids []storj.NodeID, id storj.NodeID) bool
• type Criteria
  • func (c *Criteria) MatchInclude(node *Node) bool
• type Node
  • func (node *Node) Clone() *Node
• type Request
• type SelectByID
  • func (nodes SelectByID) Count() int
  • func (nodes SelectByID) Select(n int, criteria Criteria) []*Node
• type SelectBySubnet
  • func SelectBySubnetFromNodes(nodes []*Node) SelectBySubnet
  • func (subnets SelectBySubnet) Count() int
  • func (subnets SelectBySubnet) Select(n int, criteria Criteria) []*Node
• type Selector
• type State
  • func NewState(reputableNodes, newNodes []*Node) *State
  • func (state *State) Select(ctx context.Context, request Request) (_ []*Node, err error)
  • func (state *State) Stats() Stats
• type Stats
• type Subnet

Variables

var ErrNotEnoughNodes = errs.Class("not enough nodes")

ErrNotEnoughNodes is when selecting nodes failed with the given parameters.

var (

	// Error represents an uploadselection error.
	Error = errs.Class("uploadselection")
)

Functions

func ContainsID

func ContainsID(ids []storj.NodeID, id storj.NodeID) bool

ContainsID returns whether ids contain id.

Types

type Criteria

type Criteria struct {
	ExcludeNodeIDs     []storj.NodeID
	AutoExcludeSubnets map[string]struct{} // initialize it with empty map to keep only one node per subnet.
}

Criteria to filter nodes.

func (*Criteria) MatchInclude

func (c *Criteria) MatchInclude(node *Node) bool

MatchInclude returns with true if node is selected.

type Node

type Node struct {
	storj.NodeURL
	LastNet    string
	LastIPPort string
}

Node defines necessary information for node-selection.

func (*Node) Clone

func (node *Node) Clone() *Node

Clone returns a deep clone of the selected node.

type Request

type Request struct {
	Count       int
	NewFraction float64
	Distinct    bool
	ExcludedIDs []storj.NodeID
}

Request contains arguments for State.Request.

type SelectByID

type SelectByID []*Node

SelectByID implements selection from nodes with every node having equal probability.

func (SelectByID) Count

func (nodes SelectByID) Count() int

Count returns the number of maximum number of nodes that it can return.

func (SelectByID) Select

func (nodes SelectByID) Select(n int, criteria Criteria) []*Node

Select selects upto n nodes.

type SelectBySubnet

type SelectBySubnet []Subnet

SelectBySubnet implements selection from nodes with every subnet having equal probability.

func SelectBySubnetFromNodes

func SelectBySubnetFromNodes(nodes []*Node) SelectBySubnet

SelectBySubnetFromNodes creates SelectBySubnet selector from nodes.

func (SelectBySubnet) Count

func (subnets SelectBySubnet) Count() int

Count returns the number of maximum number of nodes that it can return.

func (SelectBySubnet) Select

func (subnets SelectBySubnet) Select(n int, criteria Criteria) []*Node

Select selects upto n nodes.

type Selector

type Selector interface {
	// Count returns the number of maximum number of nodes that it can return.
	Count() int
	// Select selects up-to n nodes which are included by the criteria.
	// empty criteria includes all the nodes
	Select(n int, criteria Criteria) []*Node
}

Selector defines interface for selecting nodes.

type State

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

State defines a node selector state that allows for selection.

func NewState

func NewState(reputableNodes, newNodes []*Node) *State

NewState returns a state based on the input.

func (*State) Select

func (state *State) Select(ctx context.Context, request Request) (_ []*Node, err error)

Select selects requestedCount nodes where there will be newFraction nodes.

func (*State) Stats

func (state *State) Stats() Stats

Stats returns state information.

type Stats

type Stats struct {
	New       int
	Reputable int

	NewDistinct       int
	ReputableDistinct int
}

Stats contains state information.

type Subnet

type Subnet struct {
	Net   string
	Nodes []*Node
}

Subnet groups together nodes with the same subnet.