routetab

Documentation

Index

• Variables
• type Config
• type Index
• type Path
• type PendCallResItem
• type PendingCallResArray
• type Route
• type RouteTab
• type Service
  • func New(self boson.Address, ctx context.Context, p2ps p2p.Service, kad *kademlia.Kad, ...) *Service
  • func (s *Service) Close() error
  • func (s *Service) Connect(ctx context.Context, target boson.Address) error
  • func (s *Service) DelRoute(ctx context.Context, target boson.Address) error
  • func (s *Service) FindRoute(ctx context.Context, target boson.Address, timeout ...time.Duration) (paths []*Path, err error)
  • func (s *Service) GetRoute(_ context.Context, dest boson.Address) ([]*Path, error)
  • func (s *Service) GetTargetNeighbor(ctx context.Context, target boson.Address, limit int) (addresses []boson.Address, err error)
  • func (s *Service) IsNeighbor(dest boson.Address) (has bool)
  • func (s *Service) Metrics() []prometheus.Collector
  • func (s *Service) Protocol() p2p.ProtocolSpec
  • func (s *Service) SetConfig(cfg Config)
• type Table
  • func (t *Table) Delete(path *Path)
  • func (t *Table) Gc(expire time.Duration)
  • func (t *Table) Get(dest boson.Address) ([]*Path, error)
  • func (t *Table) GetNextHop(dest boson.Address, sign []byte) (next boson.Address)
  • func (t *Table) ReqToResp(req *pb.RouteReq, paths []*Path) *pb.RouteResp
  • func (t *Table) ReqToSave(req *pb.RouteReq) error
  • func (t *Table) RespToSave(resp *pb.RouteResp) error
  • func (t *Table) RespToSaveOne(p *pb.Path) error
  • func (t *Table) ResumeRoute()
  • func (t *Table) ResumeSigned()

Variables

var (
	MaxTTL               uint8 = 10
	DefaultNeighborAlpha int32 = 2
)

var (
	ErrNotFound = errors.New("route: not found")
)

var (
	PendingTimeout = time.Second * 5
)

Types

type Config

type Config struct {
	AddressBook addressbook.Interface
	NetworkID   uint64
	LightNodes  *lightnode.Container
	Stream      p2p.Streamer
}

type Index

type Index struct {
	NextHop boson.Address
	Sign    []byte
}

type Path

type Path struct {
	CreateTime int64           `json:"createTime"`
	Sign       []byte          `json:"sign"`
	Item       []boson.Address `json:"item"`
	UsedTime   time.Time       `json:"usedTime"`
}

type PendCallResItem

type PendCallResItem struct {
	Src        boson.Address
	CreateTime time.Time
	ResCh      chan struct{}
}

type PendingCallResArray

type PendingCallResArray []*PendCallResItem

type Route

type Route struct {
	Index []Index
}

type RouteTab

type RouteTab interface {
	GetRoute(ctx context.Context, dest boson.Address) (paths []*Path, err error)
	FindRoute(ctx context.Context, dest boson.Address, timeout ...time.Duration) (paths []*Path, err error)
	DelRoute(ctx context.Context, dest boson.Address) (err error)
	Connect(ctx context.Context, dest boson.Address) error
	GetTargetNeighbor(ctx context.Context, dest boson.Address, limit int) (addresses []boson.Address, err error)
	IsNeighbor(dest boson.Address) (has bool)
}

type Service

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

func New

func New(self boson.Address, ctx context.Context, p2ps p2p.Service, kad *kademlia.Kad, store storage.StateStorer, logger logging.Logger) *Service

func (*Service) Close

func (s *Service) Close() error

Close implement for Closer Interface

func (*Service) Connect

func (s *Service) Connect(ctx context.Context, target boson.Address) error

func (*Service) DelRoute

func (s *Service) DelRoute(ctx context.Context, target boson.Address) error

func (*Service) FindRoute

func (s *Service) FindRoute(ctx context.Context, target boson.Address, timeout ...time.Duration) (paths []*Path, err error)

func (*Service) GetRoute

func (s *Service) GetRoute(_ context.Context, dest boson.Address) ([]*Path, error)

func (*Service) GetTargetNeighbor

func (s *Service) GetTargetNeighbor(ctx context.Context, target boson.Address, limit int) (addresses []boson.Address, err error)

func (*Service) IsNeighbor

func (s *Service) IsNeighbor(dest boson.Address) (has bool)

func (*Service) Metrics

func (s *Service) Metrics() []prometheus.Collector

func (*Service) Protocol

func (s *Service) Protocol() p2p.ProtocolSpec

func (*Service) SetConfig

func (s *Service) SetConfig(cfg Config)

type Table

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

func (*Table) Delete

func (t *Table) Delete(path *Path)

func (*Table) Gc

func (t *Table) Gc(expire time.Duration)

func (*Table) Get

func (t *Table) Get(dest boson.Address) ([]*Path, error)

func (*Table) GetNextHop

func (t *Table) GetNextHop(dest boson.Address, sign []byte) (next boson.Address)

func (*Table) ReqToResp

func (t *Table) ReqToResp(req *pb.RouteReq, paths []*Path) *pb.RouteResp

func (*Table) ReqToSave

func (t *Table) ReqToSave(req *pb.RouteReq) error

func (*Table) RespToSave

func (t *Table) RespToSave(resp *pb.RouteResp) error

func (*Table) RespToSaveOne

func (t *Table) RespToSaveOne(p *pb.Path) error

func (*Table) ResumeRoute

func (t *Table) ResumeRoute()

func (*Table) ResumeSigned

func (t *Table) ResumeSigned()