link_server

Documentation

Index

• type Deps
• type Server
  • func New(deps Deps) Server
• type Worker

Types

type Deps

type Deps struct {
	Listener net.Listener
	Worker   Worker
}

type Server

type Server interface {
	common.Runner
}

func New

func New(deps Deps) Server

type Worker

type Worker interface {
	Init(ctx context.Context, requestId api.RequestId) error
	Step(ctx context.Context, vertexId db.VertexId, distance float64, through db.VertexId, requestId 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
}