mesosutil

Documentation

Index

• Constants
• func AddResourceReservation(resource *mesos.Resource, principal string, role string) *mesos.Resource
• func AddResourceRevocable(resource *mesos.Resource) *mesos.Resource
• func FilterOffersResources(offers []*mesos.Offer, filter func(*mesos.Resource) bool) (result []*mesos.Resource)
• func FilterResources(resources []*mesos.Resource, filter func(*mesos.Resource) bool) (result []*mesos.Resource)
• func GetHostname(hostnameOverride string) string
• func NewCommandInfo(command string) *mesos.CommandInfo
• func NewCreateOperation(volumes []*mesos.Resource) *mesos.Offer_Operation
• func NewDestroyOperation(volumes []*mesos.Resource) *mesos.Offer_Operation
• func NewExecutorID(id string) *mesos.ExecutorID
• func NewExecutorInfo(execId *mesos.ExecutorID, command *mesos.CommandInfo) *mesos.ExecutorInfo
• func NewFrameworkID(id string) *mesos.FrameworkID
• func NewFrameworkInfo(user, name string, frameworkId *mesos.FrameworkID) *mesos.FrameworkInfo
• func NewLaunchOperation(tasks []*mesos.TaskInfo) *mesos.Offer_Operation
• func NewMasterInfo(id string, ip, port uint32) *mesos.MasterInfo
• func NewOffer(offerId *mesos.OfferID, frameworkId *mesos.FrameworkID, slaveId *mesos.SlaveID, ...) *mesos.Offer
• func NewOfferID(id string) *mesos.OfferID
• func NewRangesResource(name string, ranges []*mesos.Value_Range) *mesos.Resource
• func NewRangesResourceWithReservation(name string, ranges []*mesos.Value_Range, principal string, role string) *mesos.Resource
• func NewReserveOperation(resources []*mesos.Resource) *mesos.Offer_Operation
• func NewScalarResource(name string, val float64) *mesos.Resource
• func NewScalarResourceWithReservation(name string, value float64, principal string, role string) *mesos.Resource
• func NewScalarResourceWithRevocable(name string, value float64) *mesos.Resource
• func NewSetResource(name string, items []string) *mesos.Resource
• func NewSetResourceWithReservation(name string, items []string, principal string, role string) *mesos.Resource
• func NewSlaveID(id string) *mesos.SlaveID
• func NewStatusUpdate(frameworkId *mesos.FrameworkID, taskStatus *mesos.TaskStatus, ...) *mesos.StatusUpdate
• func NewTaskID(id string) *mesos.TaskID
• func NewTaskInfo(name string, taskId *mesos.TaskID, slaveId *mesos.SlaveID, ...) *mesos.TaskInfo
• func NewTaskStatus(taskId *mesos.TaskID, state mesos.TaskState) *mesos.TaskStatus
• func NewUnreserveOperation(resources []*mesos.Resource) *mesos.Offer_Operation
• func NewValueRange(begin, end uint64) *mesos.Value_Range
• func NewVolumeResource(val float64, containerPath string, persistenceId string, ...) *mesos.Resource
• func NewVolumeResourceWithReservation(val float64, containerPath string, persistenceId string, ...) *mesos.Resource

Constants

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

Functions

func AddResourceReservation

func AddResourceReservation(resource *mesos.Resource, principal string, role string) *mesos.Resource

func AddResourceRevocable

func AddResourceRevocable(resource *mesos.Resource) *mesos.Resource

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 NewCreateOperation

func NewCreateOperation(volumes []*mesos.Resource) *mesos.Offer_Operation

func NewDestroyOperation

func NewDestroyOperation(volumes []*mesos.Resource) *mesos.Offer_Operation

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 NewLaunchOperation

func NewLaunchOperation(tasks []*mesos.TaskInfo) *mesos.Offer_Operation

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 NewRangesResourceWithReservation

func NewRangesResourceWithReservation(name string, ranges []*mesos.Value_Range, principal string, role string) *mesos.Resource

func NewReserveOperation

func NewReserveOperation(resources []*mesos.Resource) *mesos.Offer_Operation

func NewScalarResource

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

func NewScalarResourceWithReservation

func NewScalarResourceWithReservation(name string, value float64, principal string, role string) *mesos.Resource

func NewScalarResourceWithRevocable

func NewScalarResourceWithRevocable(name string, value float64) *mesos.Resource

func NewSetResource

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

func NewSetResourceWithReservation

func NewSetResourceWithReservation(name string, items []string, principal string, role 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 NewUnreserveOperation

func NewUnreserveOperation(resources []*mesos.Resource) *mesos.Offer_Operation

func NewValueRange

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

func NewVolumeResource

func NewVolumeResource(val float64, containerPath string, persistenceId string, mode *mesos.Volume_Mode) *mesos.Resource

func NewVolumeResourceWithReservation

func NewVolumeResourceWithReservation(val float64, containerPath string, persistenceId string, mode *mesos.Volume_Mode, principal string, role string) *mesos.Resource