The highest tagged major version is v4.

mesosutil

package

v1.1.6 Latest Latest Go to latest Published: Apr 5, 2016 License: Apache-2.0, Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/openshift/origin

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AddResourceReservation(resource *mesos.Resource, principal string, role string) *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 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 ¶ added in v1.1.4

func AddResourceReservation(resource *mesos.Resource, principal string, role string) *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 ¶ added in v1.1.4

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

func NewDestroyOperation ¶ added in v1.1.4

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 ¶ added in v1.1.4

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 ¶ added in v1.1.4

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

func NewReserveOperation ¶ added in v1.1.4

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

func NewScalarResource ¶

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

func NewScalarResourceWithReservation ¶ added in v1.1.4

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

func NewSetResource ¶

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

func NewSetResourceWithReservation ¶ added in v1.1.4

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 ¶ added in v1.1.4

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

func NewValueRange ¶

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

func NewVolumeResource ¶ added in v1.1.4

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

func NewVolumeResourceWithReservation ¶ added in v1.1.4

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

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