routing

package

v0.0.0-...-eea8d2e Latest Latest Go to latest Published: May 17, 2022 License: GPL-3.0 Imports: 11 Imported by: 1

Details

This section is empty.

View Source

var (
	MaxRedundancy = math.Max(pie.MetaDataRedundancy, pie.FileDataRedundancy)
)

This section is empty.

type Addr []string

func (a *Addr) Scan(value any) error

func (a Addr) Value() (driver.Value, error)

type Table struct {
	Protocol string
	// contains filtered or unexported fields
}

func (r *Table) AddAndConnectTracker(ctx context.Context, tracker *Tracker)

func (r *Table) AddTracker(tracker *Tracker)

func (r *Table) FindTracker(ctx context.Context, id *big.Int, numRequest int, recvTimeout time.Duration)

func (r *Table) FindTrackerOnce(ctx context.Context, id []byte, candidates []*Tracker, recvTimeout time.Duration)

func (r *Table) GetNeighbors(targetIDInt *big.Int, num int, excludeID ...*big.Int) []*Tracker

func (r *Table) GetTracker(id []byte) *Tracker

func (r *Table) Init(ctx context.Context, trackers []*Tracker)

func (r *Table) RemoveTracker(id *big.Int)

type Tracker struct {
	ID   *big.Int
	Addr Addr

	LiveFlag int32
	// contains filtered or unexported fields
}

func (t *Tracker) Connect(ctx context.Context, protocol string, cert ...*tls.Certificate) error

func (t *Tracker) GetAddrStr() string

func (t *Tracker) Session() *pie.Session

func (t *Tracker) SetAddrStr(addr string) error

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