workerserver

Documentation

Index

• type IntMetric
  • func (i IntMetric) String() string
• type Server
  • func NewServer(logger lager.Logger, db WorkerDB, teamDBFactory db.TeamDBFactory, ...) *Server
  • func (s *Server) DeleteWorker(w http.ResponseWriter, r *http.Request)
  • func (s *Server) HeartbeatWorker(w http.ResponseWriter, r *http.Request)
  • func (s *Server) LandWorker(w http.ResponseWriter, r *http.Request)
  • func (s *Server) ListWorkers(teamDB db.TeamDB, team dbng.Team) http.Handler
  • func (s *Server) PruneWorker(w http.ResponseWriter, r *http.Request)
  • func (s *Server) RegisterWorker(w http.ResponseWriter, r *http.Request)
  • func (s *Server) RetireWorker(w http.ResponseWriter, r *http.Request)
• type WorkerDB

Types

type IntMetric

type IntMetric int

func (IntMetric) String

func (i IntMetric) String() string

type Server

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

func NewServer

func NewServer(
	logger lager.Logger,
	db WorkerDB,
	teamDBFactory db.TeamDBFactory,
	dbTeamFactory dbng.TeamFactory,
	dbWorkerFactory dbng.WorkerFactory,
) *Server

func (*Server) DeleteWorker

func (s *Server) DeleteWorker(w http.ResponseWriter, r *http.Request)

func (*Server) HeartbeatWorker

func (s *Server) HeartbeatWorker(w http.ResponseWriter, r *http.Request)

func (*Server) LandWorker

func (s *Server) LandWorker(w http.ResponseWriter, r *http.Request)

func (*Server) ListWorkers

func (s *Server) ListWorkers(teamDB db.TeamDB, team dbng.Team) http.Handler

func (*Server) PruneWorker

func (s *Server) PruneWorker(w http.ResponseWriter, r *http.Request)

func (*Server) RegisterWorker

func (s *Server) RegisterWorker(w http.ResponseWriter, r *http.Request)

func (*Server) RetireWorker

func (s *Server) RetireWorker(w http.ResponseWriter, r *http.Request)

type WorkerDB

type WorkerDB interface {
	SaveWorker(db.WorkerInfo, time.Duration) (db.SavedWorker, error)
	Workers() ([]db.SavedWorker, error)
}