api

type Config struct {
	Listen   string
	LogLevel string
}

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 func(w http.ResponseWriter, r *http.Request)

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

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