executor

Documentation

Index

• type Deps
• type Executor
  • func New(ctx context.Context, deps Deps) (Executor, error)

Types

type Deps

type Deps struct {
	NumRegions            int
	RegionUrlTemplate     string
	Db                    db.DB
	Port                  int
	WorkerServerManager   service_manager.WorkerServiceManager
	DefaultWorkerReplicas int32
}

type Executor

type Executor interface {
	ShortestPath(req api.ShortestPathRequest) (resp api.ShortestPathResponse, code int, err error)
	AddEdges(req api.AddEdgesRequest) (resp api.AddEdgesRequest, code int, err error)
	AddVertices(req api.AddVerticesRequest) (resp api.AddVerticesResponse, code int, err error)
	RecalculateDS() (resp api.RecalculateDsResponse, code int, err error)

	GetGeneration() (resp api.GetGenerationResponse, code int, err error)

	Healthz() (resp api.HealthzResponse, code int, err error)
}

func New

func New(ctx context.Context, deps Deps) (Executor, error)