package mesosutil

import "k8s.io/kubernetes/Godeps/_workspace/src/github.com/mesos/mesos-go/mesosutil"

Index

Constants 

const (
	// MesosVersion indicates the supported mesos version.
	MesosVersion = "0.20.0"
)

Functions

func FilterOffersResources 

func FilterOffersResources(offers []*mesos.Offer, filter func(*mesos.Resource) bool) (result []*mesos.Resource)

func FilterResources 

func FilterResources(resources []*mesos.Resource, filter func(*mesos.Resource) bool) (result []*mesos.Resource)

func GetHostname 

func GetHostname(hostnameOverride string) string

TODO(jdef) copied from kubernetes/pkg/util/node.go

func NewCommandInfo 

func NewCommandInfo(command string) *mesos.CommandInfo

func NewExecutorID 

func NewExecutorID(id string) *mesos.ExecutorID

func NewExecutorInfo 

func NewExecutorInfo(execId *mesos.ExecutorID, command *mesos.CommandInfo) *mesos.ExecutorInfo

func NewFrameworkID 

func NewFrameworkID(id string) *mesos.FrameworkID

func NewFrameworkInfo 

func NewFrameworkInfo(user, name string, frameworkId *mesos.FrameworkID) *mesos.FrameworkInfo

func NewMasterInfo 

func NewMasterInfo(id string, ip, port uint32) *mesos.MasterInfo

func NewOffer 

func NewOffer(offerId *mesos.OfferID, frameworkId *mesos.FrameworkID, slaveId *mesos.SlaveID, hostname string) *mesos.Offer

func NewOfferID 

func NewOfferID(id string) *mesos.OfferID

func NewRangesResource 

func NewRangesResource(name string, ranges []*mesos.Value_Range) *mesos.Resource

func NewScalarResource 

func NewScalarResource(name string, val float64) *mesos.Resource

func NewSetResource 

func NewSetResource(name string, items []string) *mesos.Resource

func NewSlaveID 

func NewSlaveID(id string) *mesos.SlaveID

func NewStatusUpdate 

func NewStatusUpdate(frameworkId *mesos.FrameworkID, taskStatus *mesos.TaskStatus, timestamp float64, uuid []byte) *mesos.StatusUpdate

func NewTaskID 

func NewTaskID(id string) *mesos.TaskID

func NewTaskInfo 

func NewTaskInfo(
	name string,
	taskId *mesos.TaskID,
	slaveId *mesos.SlaveID,
	resources []*mesos.Resource,
) *mesos.TaskInfo

func NewTaskStatus 

func NewTaskStatus(taskId *mesos.TaskID, state mesos.TaskState) *mesos.TaskStatus

func NewValueRange 

func NewValueRange(begin, end uint64) *mesos.Value_Range

Source Files

constants.go mesosprotoutil.go node.go

Directories

PathSynopsis
Godeps/_workspace/src/github.com/mesos/mesos-go/mesosutil/process
Version
v0.19.3
Published
Jun 22, 2015
Platform
js/wasm
Imports
5 packages
Last checked
1 minute ago –

Tools for package owners.