link

Documentation

Index

• type Address
• type Link
  • func New(ctx context.Context, addr string) (Link, error)
• type RegionManager
  • func NewRegionDialer(port int) RegionManager

Types

type Address

type Address string

type Link

type Link interface {
	// TODO[wprzytula]: retries, consider backoff lib to unify retries in every method here
	Init(ctx context.Context, requestId api.RequestId) error
	Step(ctx context.Context, vertexId db.VertexId, distance float64, through db.VertexId, reqId api.RequestId) (db.VertexId, float64, db.VertexId, error)
	Reconstruct(ctx context.Context, vertexId db.VertexId, requestId api.RequestId) ([]db.VertexId, error)
	Finish(ctx context.Context, requestId api.RequestId) error

	io.Closer
}

func New

func New(ctx context.Context, addr string) (Link, error)

New creates new link. Currently, nodes connects even to itself via gRPC as it should be fast enough.

type RegionManager

type RegionManager interface {
	UpdateInstances(ctx context.Context, instances []discoverer.WorkerInstance) error
	GetLink() (Address, Link, error)
}

func NewRegionDialer

func NewRegionDialer(port int) RegionManager