util

package
v0.0.0-...-ddc1a4a Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 9, 2022 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// ResourceEpsilon is the minimum epsilon mesos resource;
	// This is because Mesos internally uses a fixed point precision. See MESOS-4687 for details.
	ResourceEpsilon = 0.0009
)

Variables

View Source 
var UUIDLength = len(uuid.New())

UUIDLength represents the length of a 16 byte v4 UUID as a string

Functions

func ConfigHasSecretVolumes 

func ConfigHasSecretVolumes(config *task.TaskConfig) bool

ConfigHasSecretVolumes returns true if config contains secret volumes

func Contains 

func Contains(list []string, item string) bool

Contains checks whether an item contains in a list

func ContainsTaskState 

func ContainsTaskState(list []task.TaskState, item task.TaskState) bool

ContainsTaskState checks whether a TaskState contains in a list of TaskStates

func ConvertInstanceIDListToInstanceRange 

func ConvertInstanceIDListToInstanceRange(instIDs []uint32) []*pod.InstanceIDRange

ConvertInstanceIDListToInstanceRange converts list of instance ids to list of instance ranges

func ConvertLabels 

func ConvertLabels(pelotonLabels []*peloton.Label) *mesos.Labels

ConvertLabels will convert Peloton labels to Mesos labels.

func ConvertTimestampToUnixSeconds 

func ConvertTimestampToUnixSeconds(timestamp string) (int64, error)

ConvertTimestampToUnixSeconds converts timestamp string in RFC3339 format to the unix time in seconds.

func CreateHostInfo 

func CreateHostInfo(hostname string,
	agentInfo *mesos.AgentInfo) *hostsvc.HostInfo

CreateHostInfo takes the agent Info and create the hostsvc.HostInfo

func CreateLeaseIDFromHostOfferID 

func CreateLeaseIDFromHostOfferID(id *peloton.HostOfferID) *pbhostmgr.LeaseID

CreateLeaseIDFromHostOfferID creates a LeaseId from host offer ID.

func CreateMesosScalarResources 

func CreateMesosScalarResources(values map[string]float64, role string) []*mesos.Resource

CreateMesosScalarResources is a helper function to convert resource values into Mesos resources.

func CreateMesosTaskID 

func CreateMesosTaskID(jobID *peloton.JobID,
	instanceID uint32,
	runID uint64) *mesos.TaskID

CreateMesosTaskID creates mesos task id given jobID, instanceID and runID

func CreatePelotonTaskID 

func CreatePelotonTaskID(
	jobID string,
	instanceID uint32,
) string

CreatePelotonTaskID creates a PelotonTaskID given jobID and instanceID

func CreatePodIDFromMesosTaskID 

func CreatePodIDFromMesosTaskID(t *mesos.TaskID) *v1alphapeloton.PodID

CreatePodIDFromMesosTaskID creates a peloton pod ID from mesos taskID.

func CreatePortRanges 

func CreatePortRanges(portSet map[uint32]bool) *mesos.Value_Ranges

CreatePortRanges create Mesos Ranges type from given port set.

func CreatePortResources 

func CreatePortResources(portSet map[uint32]string) []*mesos.Resource

CreatePortResources create a list of Mesos resources suitable for launching from a map from port number to role name.

func CreateSecretVolume 

func CreateSecretVolume(secretPath string, secretStr string) *mesos.Volume

CreateSecretVolume builds a mesos volume of type secret from the given secret path and secret value string This volume will be added to the job's default config

func ExtractIPAndPortFromMesosAgentPID 

func ExtractIPAndPortFromMesosAgentPID(pid string) (string, string, error)

ExtractIPAndPortFromMesosAgentPID parses Mesos PID to extract IP-address and port number (if present).

func ExtractPortSet 

func ExtractPortSet(resource *mesos.Resource) map[uint32]bool

ExtractPortSet is helper function to extract available port set from a Mesos resource.

func FormatTime 

func FormatTime(timestamp float64, layout string) string

FormatTime converts a Unix timestamp to a string format of the given layout in UTC. See https://golang.org/pkg/time/ for possible time layout in golang. For example, it will return RFC3339 format string like 2017-01-02T11:00:00.123456789Z if the layout is time.RFC3339Nano

func GetDereferencedJobIDsList 

func GetDereferencedJobIDsList(jobIDs []*peloton.JobID) []peloton.JobID

GetDereferencedJobIDsList dereferences the jobIDs list

func GetOfferScalarResourceSummary 

func GetOfferScalarResourceSummary(offer *mesos.Offer) map[string]map[string]float64

GetOfferScalarResourceSummary generates a summary for all the scalar values: role -> offerName-> Value first level : role -> map(resource type-> resouce value)

func GetPortsNumFromOfferMap 

func GetPortsNumFromOfferMap(offerMap map[string]*mesos.Offer) uint32

GetPortsNumFromOfferMap is helper function to get number of available ports from given id to offer map.

func GetPortsSetFromResources 

func GetPortsSetFromResources(resources []*mesos.Resource) map[uint32]bool

GetPortsSetFromResources is helper function to extract ports resources.

func IntersectSlice 

func IntersectSlice(slice1 []uint32, slice2 []uint32) []uint32

IntersectSlice get return the result of slice1 ∩ slice2 element must be present in both slices

func IsPelotonJobStateTerminal 

func IsPelotonJobStateTerminal(state job.JobState) bool

IsPelotonJobStateTerminal returns true if job state is terminal otherwise false

func IsPelotonPodStateTerminal 

func IsPelotonPodStateTerminal(state pod.PodState) bool

IsPelotonPodStateTerminal returns true if pod state is terminal otherwise false

func IsPelotonStateTerminal 

func IsPelotonStateTerminal(state task.TaskState) bool

IsPelotonStateTerminal returns true if state is terminal otherwise false

func IsSecretVolume 

func IsSecretVolume(volume *mesos.Volume) bool

IsSecretVolume returns true if the given volume is of type secret

func IsTaskHasValidVolume 

func IsTaskHasValidVolume(taskInfo *task.TaskInfo) bool

IsTaskHasValidVolume returns true if a task is stateful and has a valid volume

func IsTaskThrottled 

func IsTaskThrottled(state task.TaskState, message string) bool

IsTaskThrottled returns true if a task is currently throttled due to repeated failures

func Max 

func Max(x, y uint32) uint32

Max returns the maximum value of x, y

func MesosStateToPelotonState 

func MesosStateToPelotonState(mstate mesos.TaskState) task.TaskState

MesosStateToPelotonState translates mesos task state to peloton task state TODO: adjust in case there are additional peloton states

func Min 

func Min(x, y uint32) uint32

Min returns the minimum value of x, y

func ParseJobAndInstanceID 

func ParseJobAndInstanceID(mesosTaskID string) (string, uint32, error)

ParseJobAndInstanceID return jobID and instanceID from given mesos task id.

func ParseRunID 

func ParseRunID(mesosTaskID string) (uint64, error)

ParseRunID parse the runID from mesosTaskID

func ParseTaskID 

func ParseTaskID(taskID string) (string, uint32, error)

ParseTaskID parses the jobID and instanceID from peloton taskID

func ParseTaskIDFromMesosTaskID 

func ParseTaskIDFromMesosTaskID(mesosTaskID string) (string, error)

ParseTaskIDFromMesosTaskID parses the taskID from mesosTaskID

func PtrPrintf 

func PtrPrintf(format string, a ...interface{}) *string

PtrPrintf returns a pointer to a string format

func RemoveSecretVolumesFromConfig 

func RemoveSecretVolumesFromConfig(config *task.TaskConfig) []*mesos.Volume

RemoveSecretVolumesFromConfig removes secret volumes from the task config in place and returns the secret volumes Secret volumes are added internally at the time of creating a job with secrets by handleSecrets method. They are not supplied in the config in job create/update requests. Consequently, they should not be displayed as part of Job Get API response. This is necessary to achieve the broader goal of using the secrets proto message in Job Create/Update/Get API to describe secrets and not allow users to checkin secrets as part of config

func RemoveSecretVolumesFromJobConfig 

func RemoveSecretVolumesFromJobConfig(cfg *job.JobConfig) []*mesos.Volume

RemoveSecretVolumesFromJobConfig removes secret volumes from the default config as well as instance config in place and returns the secret volumes

func RunInParallel 

func RunInParallel(identifier string, idList []uint32, task singleTask) error

RunInParallel runs go routines which will perform action on given list of instances

func SubtractSlice 

func SubtractSlice(slice1 []uint32, slice2 []uint32) []uint32

SubtractSlice returns the result of slice1 - slice2 if an element is in slice2 but not in slice1, it would be ignored

func UnmarshalToType 

func UnmarshalToType(jsonString string, resultType reflect.Type) (interface{},
	error)

UnmarshalToType unmarshal a string to a typed interface{}

Types

type MesosResourceBuilder 

type MesosResourceBuilder struct {
	Resource mesos.Resource
}

MesosResourceBuilder is the helper to build a mesos resource

func NewMesosResourceBuilder 

func NewMesosResourceBuilder() *MesosResourceBuilder

NewMesosResourceBuilder creates a MesosResourceBuilder

func (*MesosResourceBuilder) Build 

func (o *MesosResourceBuilder) Build() *mesos.Resource

Build returns the mesos resource

func (*MesosResourceBuilder) WithDisk 

func (o *MesosResourceBuilder) WithDisk(
	diskInfo *mesos.Resource_DiskInfo) *MesosResourceBuilder

WithDisk sets disk info.

func (*MesosResourceBuilder) WithName 

func (o *MesosResourceBuilder) WithName(name string) *MesosResourceBuilder

WithName sets name

func (*MesosResourceBuilder) WithRanges 

func (o *MesosResourceBuilder) WithRanges(ranges *mesos.Value_Ranges) *MesosResourceBuilder

WithRanges sets ranges

func (*MesosResourceBuilder) WithReservation 

func (o *MesosResourceBuilder) WithReservation(
	reservation *mesos.Resource_ReservationInfo) *MesosResourceBuilder

WithReservation sets reservation info.

func (*MesosResourceBuilder) WithRevocable 

func (o *MesosResourceBuilder) WithRevocable(
	revocable *mesos.Resource_RevocableInfo) *MesosResourceBuilder

WithRevocable sets resource as revocable resource type

func (*MesosResourceBuilder) WithRole 

func (o *MesosResourceBuilder) WithRole(role string) *MesosResourceBuilder

WithRole sets role

func (*MesosResourceBuilder) WithType 

func (o *MesosResourceBuilder) WithType(t mesos.Value_Type) *MesosResourceBuilder

WithType sets type

func (*MesosResourceBuilder) WithValue 

func (o *MesosResourceBuilder) WithValue(value float64) *MesosResourceBuilder

WithValue sets value

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.