scheduler

Documentation

Index

• type ConsulScheduler
  • func (c *ConsulScheduler) Create(name, image, driverName string, attrs driver.MachineAttributes) (string, error)
  • func (c *ConsulScheduler) Delete(name, driverName, nodeID string) error
  • func (c *ConsulScheduler) Session(name, driverName, nodeID string, stdin io.ReadCloser, stdout io.WriteCloser, ...) error
• type LocalScheduler
  • func (c *LocalScheduler) Create(name, image, driverName string, attrs driver.MachineAttributes) (string, error)
  • func (c *LocalScheduler) Delete(name, driverName, node string) error
  • func (c *LocalScheduler) Session(name, driverName, node string, stdin io.ReadCloser, stdout io.WriteCloser, ...) error
• type MockScheduler
  • func (s *MockScheduler) Create(name, image, driverName string, attrs driver.MachineAttributes) (string, error)
  • func (s *MockScheduler) Delete(name, driverName, node string) error
  • func (s *MockScheduler) Session(name, driverName, node string, stdin io.ReadCloser, stdout io.WriteCloser, ...) error
• type Scheduler
  • func NewConsulScheduler(options *config.DriverOptions) (Scheduler, error)
  • func NewLocalScheduler(options *config.DriverOptions) (Scheduler, error)
  • func NewMockScheduler(options *config.DriverOptions) (Scheduler, error)
  • func NewScheduler(name string, options *config.DriverOptions) (Scheduler, error)

Types

type ConsulScheduler

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

ConsulScheduler distributes machines among a Consul cluster

func (*ConsulScheduler) Create

func (c *ConsulScheduler) Create(name, image, driverName string, attrs driver.MachineAttributes) (string, error)

Create creates a new machine

func (*ConsulScheduler) Delete

func (c *ConsulScheduler) Delete(name, driverName, nodeID string) error

Delete deletes a machine

func (*ConsulScheduler) Session

func (c *ConsulScheduler) Session(name, driverName, nodeID string, stdin io.ReadCloser, stdout io.WriteCloser, control chan driver.ControlMessage, width, height int) error

Session creates an new exec session

type LocalScheduler

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

LocalScheduler runs all machine on localhost

func (*LocalScheduler) Create

func (c *LocalScheduler) Create(name, image, driverName string, attrs driver.MachineAttributes) (string, error)

Create creates a new machine

func (*LocalScheduler) Delete

func (c *LocalScheduler) Delete(name, driverName, node string) error

Delete deletes a machine

func (*LocalScheduler) Session

func (c *LocalScheduler) Session(name, driverName, node string, stdin io.ReadCloser, stdout io.WriteCloser, control chan driver.ControlMessage, width, height int) error

Session creates an new exec session

type MockScheduler

type MockScheduler struct {
	Machines map[string]string
}

MockScheduler stores machines in memory and does not call a driver

func (*MockScheduler) Create

func (s *MockScheduler) Create(name, image, driverName string, attrs driver.MachineAttributes) (string, error)

Create creates a new machine

func (*MockScheduler) Delete

func (s *MockScheduler) Delete(name, driverName, node string) error

Delete deletes a machine

func (*MockScheduler) Session

func (s *MockScheduler) Session(name, driverName, node string, stdin io.ReadCloser, stdout io.WriteCloser, control chan driver.ControlMessage, width, height int) error

Session creates an new exec session

type Scheduler

type Scheduler interface {
	Create(name, image, driverName string, attrs driver.MachineAttributes) (string, error)
	Delete(name, driverName, node string) error
	Session(name, driverName, node string, stdin io.ReadCloser, stdout io.WriteCloser, control chan driver.ControlMessage, width, height int) error
}

Scheduler is what distirbutes Driver requests

func NewConsulScheduler

func NewConsulScheduler(options *config.DriverOptions) (Scheduler, error)

NewConsulScheduler creates a new ConsulScheduler

func NewLocalScheduler

func NewLocalScheduler(options *config.DriverOptions) (Scheduler, error)

NewLocalScheduler creates a new LocalScheduler

func NewMockScheduler

func NewMockScheduler(options *config.DriverOptions) (Scheduler, error)

NewMockScheduler creates a new MockScheduler

func NewScheduler

func NewScheduler(name string, options *config.DriverOptions) (Scheduler, error)

NewScheduler creates a new Scheduler