api

Documentation

Index

• type Config
• type Driver
• type HandlerFunc
• type Route
  • func NewPrefixRoute(method, path string, handler HandlerFunc) *Route
  • func NewRoute(method, path string, handler HandlerFunc) *Route
  • func (r *Route) Handler() HandlerFunc
  • func (r *Route) Methods() []string
  • func (r *Route) Path() string
• type Server
  • func NewServer(cfg *Config, l net.Listener, driver Driver, db store.Store) *Server
  • func (s *Server) GetLeader() string
  • func (s *Server) Reload() error
  • func (s *Server) Run() error
  • func (s *Server) Shutdown() error
  • func (s *Server) Stop() error
  • func (s *Server) UpdateLeader(leader string)

Types

type Config

type Config struct {
	Listen   string
	LogLevel string
}

type Driver

type Driver interface {
	KillTask(taskId string, agentId string, gradePeriod int64) error
	LaunchTasks([]*mesos.Task) error

	ClusterName() string

	SubscribeEvent(io.Writer, string) error
	FullTaskEventsAndRecords() []*types.CombinedEvents
	SendEvent(string, *types.Task) error

	ClusterAgents() map[string]*mole.ClusterAgent
	ClusterAgent(id string) *mole.ClusterAgent
	CloseClusterAgent(id string)

	// for debug convenience
	Dump() interface{}
	Load() map[string]interface{}
}

type HandlerFunc

type HandlerFunc func(w http.ResponseWriter, r *http.Request)

type Route

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

func NewPrefixRoute

func NewPrefixRoute(method, path string, handler HandlerFunc) *Route

func NewRoute

func NewRoute(method, path string, handler HandlerFunc) *Route

func (*Route) Handler

func (r *Route) Handler() HandlerFunc

func (*Route) Methods

func (r *Route) Methods() []string

func (*Route) Path

func (r *Route) Path() string

type Server

type Server struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewServer

func NewServer(cfg *Config, l net.Listener, driver Driver, db store.Store) *Server

func (*Server) GetLeader

func (s *Server) GetLeader() string

func (*Server) Reload

func (s *Server) Reload() error

func (*Server) Run

func (s *Server) Run() error

func (*Server) Shutdown

func (s *Server) Shutdown() error

gracefully shutdown.

func (*Server) Stop

func (s *Server) Stop() error

func (*Server) UpdateLeader

func (s *Server) UpdateLeader(leader string)