mesosutils

package

v0.8.2 Latest Latest Go to latest Published: Nov 22, 2017 License: Apache-2.0 Imports: 5 Imported by: 4

Details

This section is empty.

This section is empty.

func Duration(seconds float64) time.Duration

Duration translates float second values used by Marathon to go Duration format

func FindLabel(labels []mesos.Label, key string) *mesos.Label

FindLabel returns a label matching given key

func GetLabelKeysByValue(labels []mesos.Label, value string) []string

GetLabelKeysByValue searches provided labels for a given value and returns a list of matching keys

type TaskInfo struct {
	TaskInfo mesos.TaskInfo
}

TaskInfo is a wrapper over Mesos TaskInfo providing convenient ways to access some of its values

func (h TaskInfo) FindEnvValue(key string) string

FindEnvValue returns the value of an environment variable

func (h TaskInfo) FindLabel(key string) *mesos.Label

FindLabel returns a label matching given key

func (h TaskInfo) GetLabelKeysByValue(value string) []string

GetLabelKeysByValue returns all keys of labels that contain a given value

func (h TaskInfo) GetLabelValue(key string) string

GetLabelValue returns value for of a label

func (h TaskInfo) GetPorts() []mesos.Port

GetPorts returns a list of task ports

func (h TaskInfo) GetServiceID() string

GetServiceID extracts service ID from labels in mesos TaskInfo. If it fails to do so, it returns executor ID.

func (h TaskInfo) GetWeight() (int, error)

GetWeight return a initial weight of the task. If weight is not set or has malformed format then returned weight is 0 and error is not nil.