mesosutil

package

v0.0.11 Latest Latest Go to latest Published: May 15, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/AVENTER-UG/mesos-go

Links

Open Source Insights

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 ¶

View Source

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

Variables ¶

This section is empty.

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

Types ¶

This section is empty.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
process

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL