scheduler

Documentation

Index

• Constants
• type App
• type BeethovenInstance
• type Scheduler
  • func NewScheduler(cfg *config.Config, tracker *tracker.Tracker) Scheduler
• type Services
  • func (s Services) Len() int
  • func (s Services) Less(i, j int) bool
  • func (s Services) Swap(i, j int)
• type ShutdownChan
• type Task

Constants

const (
	// SwarmWatchTime is the default interval when pulling for changes
	SwarmWatchTimeSec = 10
)

Types

type App

type App struct {
	AppId  string
	Tasks  []Task
	Labels map[string]string
	Env    map[string]string
}

type BeethovenInstance

type BeethovenInstance struct {
	Host string
	Port int
}

type Scheduler

type Scheduler interface {
	// Watch for changes using streams and make callbacks to the specified
	// handler when apps have been added, removed or health changes.
	Watch(reload chan bool)
	// Shutdown the current stream watching
	Shutdown()
	// FetchApps will find all applications/services from the scheduler source
	FetchApps() (map[string]*App, error)

	// FetchBeethovenInstances will find all beethoven running instances
	FetchBeethovenInstances() ([]*BeethovenInstance, error)
}

func NewScheduler

func NewScheduler(cfg *config.Config, tracker *tracker.Tracker) Scheduler

type Services

type Services []serviceData

func (Services) Len

func (s Services) Len() int

func (Services) Less

func (s Services) Less(i, j int) bool

func (Services) Swap

func (s Services) Swap(i, j int)

type ShutdownChan

type ShutdownChan chan bool

type Task

type Task struct {
	Host         string
	Ports        []int
	ServicePorts []int
	StagedAt     string
	StartedAt    string
	Version      string
}