mesos

Documentation

Index

• func NewCluster(scheduler *scheduler.Scheduler, store *state.Store, TLSConfig *tls.Config, ...) (cluster.Cluster, error)
• type Cluster
  • func (c *Cluster) Container(IDOrName string) *cluster.Container
  • func (c *Cluster) Containers() cluster.Containers
  • func (c *Cluster) CreateContainer(config *cluster.ContainerConfig, name string) (*cluster.Container, error)
  • func (c *Cluster) Disconnected(mesosscheduler.SchedulerDriver)
  • func (c *Cluster) Error(d mesosscheduler.SchedulerDriver, msg string)
  • func (c *Cluster) ExecutorLost(mesosscheduler.SchedulerDriver, *mesosproto.ExecutorID, *mesosproto.SlaveID, ...)
  • func (c *Cluster) FrameworkMessage(mesosscheduler.SchedulerDriver, *mesosproto.ExecutorID, *mesosproto.SlaveID, ...)
  • func (c *Cluster) Image(IDOrName string) *cluster.Image
  • func (c *Cluster) Images() []*cluster.Image
  • func (c *Cluster) Import(source string, repository string, tag string, imageReader io.Reader, ...)
  • func (c *Cluster) Info() [][2]string
  • func (c *Cluster) Load(imageReader io.Reader, callback func(what, status string))
  • func (c *Cluster) OfferRescinded(mesosscheduler.SchedulerDriver, *mesosproto.OfferID)
  • func (c *Cluster) Pull(name string, authConfig *dockerclient.AuthConfig, ...)
  • func (c *Cluster) RANDOMENGINE() (*cluster.Engine, error)
  • func (c *Cluster) RegisterEventHandler(h cluster.EventHandler) error
  • func (c *Cluster) Registered(driver mesosscheduler.SchedulerDriver, fwID *mesosproto.FrameworkID, ...)
  • func (c *Cluster) RemoveContainer(container *cluster.Container, force bool) error
  • func (c *Cluster) RemoveImage(image *cluster.Image) ([]*dockerclient.ImageDelete, error)
  • func (c *Cluster) RemoveImages(name string) ([]*dockerclient.ImageDelete, error)
  • func (c *Cluster) RenameContainer(container *cluster.Container, newName string) error
  • func (c *Cluster) Reregistered(mesosscheduler.SchedulerDriver, *mesosproto.MasterInfo)
  • func (c *Cluster) ResourceOffers(_ mesosscheduler.SchedulerDriver, offers []*mesosproto.Offer)
  • func (c *Cluster) SlaveLost(mesosscheduler.SchedulerDriver, *mesosproto.SlaveID)
  • func (c *Cluster) StatusUpdate(_ mesosscheduler.SchedulerDriver, taskStatus *mesosproto.TaskStatus)

Functions

func NewCluster

func NewCluster(scheduler *scheduler.Scheduler, store *state.Store, TLSConfig *tls.Config, master string, options cluster.DriverOpts) (cluster.Cluster, error)

NewCluster for mesos Cluster creation

Types

type Cluster

type Cluster struct {
	sync.RWMutex

	TLSConfig *tls.Config
	// contains filtered or unexported fields
}

Cluster struct for mesos

func (*Cluster) Container

func (c *Cluster) Container(IDOrName string) *cluster.Container

Container returns the container with IdOrName in the cluster

func (*Cluster) Containers

func (c *Cluster) Containers() cluster.Containers

Containers returns all the containers in the cluster.

func (*Cluster) CreateContainer

func (c *Cluster) CreateContainer(config *cluster.ContainerConfig, name string) (*cluster.Container, error)

CreateContainer for container creation in Mesos task

func (*Cluster) Disconnected

func (c *Cluster) Disconnected(mesosscheduler.SchedulerDriver)

Disconnected method

func (*Cluster) Error

func (c *Cluster) Error(d mesosscheduler.SchedulerDriver, msg string)

Error method

func (*Cluster) ExecutorLost

func (c *Cluster) ExecutorLost(mesosscheduler.SchedulerDriver, *mesosproto.ExecutorID, *mesosproto.SlaveID, int)

ExecutorLost method

func (*Cluster) FrameworkMessage

func (c *Cluster) FrameworkMessage(mesosscheduler.SchedulerDriver, *mesosproto.ExecutorID, *mesosproto.SlaveID, string)

FrameworkMessage method

func (*Cluster) Image

func (c *Cluster) Image(IDOrName string) *cluster.Image

Image returns an image with IdOrName in the cluster

func (*Cluster) Images

func (c *Cluster) Images() []*cluster.Image

Images returns all the images in the cluster.

func (*Cluster) Import

func (c *Cluster) Import(source string, repository string, tag string, imageReader io.Reader, callback func(what, status string))

Import image

func (*Cluster) Info

func (c *Cluster) Info() [][2]string

Info gives minimal information about containers and resources on the mesos cluster

func (*Cluster) Load

func (c *Cluster) Load(imageReader io.Reader, callback func(what, status string))

Load images

func (*Cluster) OfferRescinded

func (c *Cluster) OfferRescinded(mesosscheduler.SchedulerDriver, *mesosproto.OfferID)

OfferRescinded method

func (*Cluster) Pull

func (c *Cluster) Pull(name string, authConfig *dockerclient.AuthConfig, callback func(what, status string))

Pull will pull images on the cluster nodes

func (*Cluster) RANDOMENGINE

func (c *Cluster) RANDOMENGINE() (*cluster.Engine, error)

RANDOMENGINE returns a random engine.

func (*Cluster) RegisterEventHandler

func (c *Cluster) RegisterEventHandler(h cluster.EventHandler) error

RegisterEventHandler registers an event handler.

func (*Cluster) Registered

func (c *Cluster) Registered(driver mesosscheduler.SchedulerDriver, fwID *mesosproto.FrameworkID, masterInfo *mesosproto.MasterInfo)

Registered method for registered mesos framework

func (*Cluster) RemoveContainer

func (c *Cluster) RemoveContainer(container *cluster.Container, force bool) error

RemoveContainer to remove containers on mesos cluster

func (*Cluster) RemoveImage

func (c *Cluster) RemoveImage(image *cluster.Image) ([]*dockerclient.ImageDelete, error)

RemoveImage removes an image from the cluster

func (*Cluster) RemoveImages

func (c *Cluster) RemoveImages(name string) ([]*dockerclient.ImageDelete, error)

RemoveImages removes images from the cluster

func (*Cluster) RenameContainer

func (c *Cluster) RenameContainer(container *cluster.Container, newName string) error

RenameContainer Rename a container

func (*Cluster) Reregistered

func (c *Cluster) Reregistered(mesosscheduler.SchedulerDriver, *mesosproto.MasterInfo)

Reregistered method for registered mesos framework

func (*Cluster) ResourceOffers

func (c *Cluster) ResourceOffers(_ mesosscheduler.SchedulerDriver, offers []*mesosproto.Offer)

ResourceOffers method

func (*Cluster) SlaveLost

func (c *Cluster) SlaveLost(mesosscheduler.SchedulerDriver, *mesosproto.SlaveID)

SlaveLost method

func (*Cluster) StatusUpdate

func (c *Cluster) StatusUpdate(_ mesosscheduler.SchedulerDriver, taskStatus *mesosproto.TaskStatus)

StatusUpdate method