mesos

Documentation

Index

• Constants
• type Config
• type ConfigWrapper
• type Duration
  • func (d *Duration) UnmarshalText(data []byte) error
• type MesosCloud
  • func (c *MesosCloud) Clusters() (cloudprovider.Clusters, bool)
  • func (c *MesosCloud) ExternalID(instance string) (string, error)
  • func (c *MesosCloud) GetNodeResources(name string) (*api.NodeResources, error)
  • func (c *MesosCloud) Instances() (cloudprovider.Instances, bool)
  • func (c *MesosCloud) List(filter string) ([]string, error)
  • func (c *MesosCloud) ListClusters() ([]string, error)
  • func (c *MesosCloud) Master(clusterName string) (string, error)
  • func (c *MesosCloud) MasterURI() string
  • func (c *MesosCloud) NodeAddresses(name string) ([]api.NodeAddress, error)
  • func (c *MesosCloud) TCPLoadBalancer() (cloudprovider.TCPLoadBalancer, bool)
  • func (c *MesosCloud) Zones() (cloudprovider.Zones, bool)

Constants

const (
	DefaultMesosMaster       = "localhost:5050"
	DefaultHttpClientTimeout = time.Duration(10) * time.Second
	DefaultStateCacheTTL     = time.Duration(5) * time.Second
)

Types

type Config

type Config struct {
	MesosMaster            string   `gcfg:"mesos-master"`
	MesosHttpClientTimeout Duration `gcfg:"http-client-timeout"`
	StateCacheTTL          Duration `gcfg:"state-cache-ttl"`
}

type ConfigWrapper

type ConfigWrapper struct {
	Mesos_Cloud Config
}

type Duration

type Duration struct {
	Duration time.Duration `gcfg:"duration"`
}

func (*Duration) UnmarshalText

func (d *Duration) UnmarshalText(data []byte) error

type MesosCloud

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

var (
	PluginName    = "mesos"
	CloudProvider *MesosCloud
)

func (*MesosCloud) Clusters

func (c *MesosCloud) Clusters() (cloudprovider.Clusters, bool)

Mesos does not provide support for multiple clusters.

func (*MesosCloud) ExternalID

func (c *MesosCloud) ExternalID(instance string) (string, error)

ExternalID returns the cloud provider ID of the specified instance.

func (*MesosCloud) GetNodeResources

func (c *MesosCloud) GetNodeResources(name string) (*api.NodeResources, error)

GetNodeResources gets the resources for a particular node

func (*MesosCloud) Instances

func (c *MesosCloud) Instances() (cloudprovider.Instances, bool)

Mesos natively provides minimal cloud-type resources. More robust cloud support requires a combination of Mesos and cloud-specific knowledge.

func (*MesosCloud) List

func (c *MesosCloud) List(filter string) ([]string, error)

List lists instances that match 'filter' which is a regular expression which must match the entire instance name (fqdn).

func (*MesosCloud) ListClusters

func (c *MesosCloud) ListClusters() ([]string, error)

List lists the names of the available clusters.

func (*MesosCloud) Master

func (c *MesosCloud) Master(clusterName string) (string, error)

Master gets back the address (either DNS name or IP address) of the master node for the cluster.

func (*MesosCloud) MasterURI

func (c *MesosCloud) MasterURI() string

func (*MesosCloud) NodeAddresses

func (c *MesosCloud) NodeAddresses(name string) ([]api.NodeAddress, error)

NodeAddresses returns the addresses of the specified instance.

func (*MesosCloud) TCPLoadBalancer

func (c *MesosCloud) TCPLoadBalancer() (cloudprovider.TCPLoadBalancer, bool)

Mesos does not provide any type of native load balancing by default, so this implementation always returns (nil, false).

func (*MesosCloud) Zones

func (c *MesosCloud) Zones() (cloudprovider.Zones, bool)

Mesos does not provide any type of native region or zone awareness, so this implementation always returns (nil, false).