mesos

Documentation

Overview

Package mesos is copied from mesos-uns-bridge/mesos/detector.go with modifications : 1) refer to forked mesos-go dependencies

Index

• Constants
• func GetAuthHeader(config *Config, secretPath string) (http.Header, error)
• func InitManager(d *yarpc.Dispatcher, mesosConfig *Config, store storage.FrameworkInfoStore)
• type Config
• type FrameworkConfig
• type FrameworkInfoProvider
• type MasterDetector
  • func NewZKDetector(zkPath string) (MasterDetector, error)
• type SchedulerDriver
  • func GetSchedulerDriver() SchedulerDriver
  • func InitSchedulerDriver(cfg *Config, store storage.FrameworkInfoStore, defaultHeaders http.Header) SchedulerDriver

Constants

const (
	// ServiceName for mesos scheduler
	ServiceName = "Scheduler"
)

Functions

func GetAuthHeader

func GetAuthHeader(config *Config, secretPath string) (http.Header, error)

GetAuthHeader returns necessary auth header used for HTTP request.

func InitManager

func InitManager(
	d *yarpc.Dispatcher,
	mesosConfig *Config,
	store storage.FrameworkInfoStore)

InitManager initializes the mesosManager

Types

type Config

type Config struct {
	Framework *FrameworkConfig `yaml:"framework"`
	ZkPath    string           `yaml:"zk_path"`
	Encoding  string           `yaml:"encoding"`
}

Config for Mesos specific configuration

type FrameworkConfig

type FrameworkConfig struct {
	User                        string  `yaml:"user"`
	Name                        string  `yaml:"name"`
	Role                        string  `yaml:"role"`
	Principal                   string  `yaml:"principal"`
	FailoverTimeout             float64 `yaml:"failover_timeout"`
	GPUSupported                bool    `yaml:"gpu_supported"`
	TaskKillingStateSupported   bool    `yaml:"task_killing_state"`
	PartitionAwareSupported     bool    `yaml:"partition_aware"`
	RevocableResourcesSupported bool    `yaml:"revocable_resources"`
	MaxConnectionsToMesosMaster int     `yaml:"max_connections_to_mesos_master"`
}

FrameworkConfig for framework specific configuration

type FrameworkInfoProvider

type FrameworkInfoProvider interface {
	GetMesosStreamID(ctx context.Context) string
	GetFrameworkID(ctx context.Context) *mesos.FrameworkID
}

FrameworkInfoProvider can be used to retrieve mesosStreamID and frameworkID.

type MasterDetector

type MasterDetector interface {
	mhttp.LeaderDetector
}

MasterDetector is the interface for finding where is an active Mesos master.

func NewZKDetector

func NewZKDetector(zkPath string) (MasterDetector, error)

NewZKDetector creates a new MasterDetector which caches last detected leader.

type SchedulerDriver

type SchedulerDriver interface {
	mhttp.MesosDriver
	FrameworkInfoProvider
}

SchedulerDriver extends the Mesos HTTP Driver API.

func GetSchedulerDriver

func GetSchedulerDriver() SchedulerDriver

GetSchedulerDriver return the interface to SchedulerDriver.

func InitSchedulerDriver

func InitSchedulerDriver(
	cfg *Config,
	store storage.FrameworkInfoStore,
	defaultHeaders http.Header) SchedulerDriver

InitSchedulerDriver initialize Mesos scheduler driver for Mesos scheduler HTTP API.