mesosutils

Documentation

Index

• func Duration(seconds float64) time.Duration
• func FindLabel(labels []mesos.Label, key string) *mesos.Label
• func GetLabelKeysByValue(labels []mesos.Label, value string) []string
• type HTTPCheck
• type HealthCheck
• type HealthCheckType
• type TaskID
• type TaskInfo
  • func (h TaskInfo) FindEnvValue(key string) string
  • func (h TaskInfo) FindLabel(key string) *mesos.Label
  • func (h TaskInfo) GetFirstPortWithLabel(portLabel string) (*mesos.Port, error)
  • func (h TaskInfo) GetHealthCheck() (check HealthCheck)
  • func (h TaskInfo) GetLabelKeysByValue(value string) []string
  • func (h TaskInfo) GetLabelValue(key string) string
  • func (h TaskInfo) GetPorts() []mesos.Port
  • func (h TaskInfo) GetServiceID() string
  • func (h TaskInfo) GetTaskID() TaskID
  • func (h TaskInfo) GetWeight() (int, error)

Functions

func Duration

func Duration(seconds float64) time.Duration

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

func FindLabel

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

FindLabel returns a label matching given key

func GetLabelKeysByValue

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

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

Types

type HTTPCheck

type HTTPCheck struct {
	Path string
}

HTTPCheck contains details about HTTP healthcheck

type HealthCheck

type HealthCheck struct {
	// Type specify healthcheck type
	Type HealthCheckType
	// Interval specify how often healthcheck should be performed
	Interval time.Duration
	// Timeout specify duration after healtcheck should be aborted and marked as unhealthy
	Timeout time.Duration
	// HTTP contains details about heatlhcheck when HTTP Type is set
	HTTP HTTPCheck
}

HealthCheck keeps details how to check task health

type HealthCheckType

type HealthCheckType int

HealthCheckType is type of healthcheck

const (
	// NONE represents empty healthcheck
	NONE HealthCheckType = iota
	// HTTP indicates HTTP field in HealthCheck is configured
	HTTP
	// TCP indicates healthcheck is TCP
	TCP
	// COMMAND indicates healthcheck is a command
	COMMAND
)

type TaskID

type TaskID string

TaskID is framework-generated ID to distinguish a task

type TaskInfo

type TaskInfo struct {
	TaskInfo mesos.TaskInfo
}

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

func (TaskInfo) FindEnvValue

func (h TaskInfo) FindEnvValue(key string) string

FindEnvValue returns the value of an environment variable

func (TaskInfo) FindLabel

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

FindLabel returns a label matching given key

func (TaskInfo) GetFirstPortWithLabel

func (h TaskInfo) GetFirstPortWithLabel(portLabel string) (*mesos.Port, error)

GetFirstPortWithLabel returns port with specified label

func (TaskInfo) GetHealthCheck

func (h TaskInfo) GetHealthCheck() (check HealthCheck)

GetHealthCheck returns

func (TaskInfo) GetLabelKeysByValue

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

GetLabelKeysByValue returns all keys of labels that contain a given value

func (TaskInfo) GetLabelValue

func (h TaskInfo) GetLabelValue(key string) string

GetLabelValue returns value for of a label

func (TaskInfo) GetPorts

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

GetPorts returns a list of task ports

func (TaskInfo) GetServiceID

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 (TaskInfo) GetTaskID

func (h TaskInfo) GetTaskID() TaskID

GetTaskID returns id of the task

func (TaskInfo) GetWeight

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.