worker

type Deps ¶

type Deps struct {
	Db         db.DB
	Discoverer discoverer.Discoverer
	RegionID   db.RegionId
	Context    context.Context
	LinkPort   int
}

type Item ¶

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

An Item is something we manage in a distance queue.

type PriorityQueue ¶

type PriorityQueue []*Item

A PriorityQueue implements heap.Interface and holds Items.

func (pq PriorityQueue) Len() int

func (pq PriorityQueue) Less(i, j int) bool

func (pq *PriorityQueue) Pop() any

func (pq *PriorityQueue) Push(x any)

func (pq PriorityQueue) Swap(i, j int)

type Worker ¶

type Worker interface {
	service.Worker
	link_server.Worker

	LoadRegionData(ctx context.Context) error
}

Worker All methods from link service and worker service should end up calling this interface.

func New(deps Deps) (Worker, error)