Documentation
¶
Index ¶
- func Batch(elements []string, batchSize int) [][]string
- func CloseToDeadline(ctx context.Context) bool
- func ContainsString(list []string, val string) bool
- func DeepCopy(a map[string]string) map[string]string
- func DeepCopyListUint32(list []uint32) []uint32
- func Equal(a map[string]string, b map[string]string) bool
- func FilterKeys(a map[string]string, keys []string) map[string]string
- func GetClusterAvailableCapacity(report *api.ClusterUsageReport) common.ComputeResources
- func GetClusterCapacity(report *api.ClusterUsageReport) common.ComputeResources
- func GetOrDefault(m map[string]float64, key string, def float64) float64
- func GetQueueReports(report *api.ClusterUsageReport) []*api.QueueReport
- func MergeMaps(a map[string]string, b map[string]string) map[string]string
- func Min(a, b int) int
- func NewULID() string
- func StringListToSet(list []string) map[string]bool
- func SubtractStringList(a []string, b []string) []string
- func SumReportClusterCapacity(reports map[string]*api.ClusterUsageReport) common.ComputeResources
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CloseToDeadline ¶ added in v0.2.13
func ContainsString ¶ added in v0.1.21
func DeepCopyListUint32 ¶ added in v0.2.3
func FilterKeys ¶ added in v0.2.6
func GetClusterAvailableCapacity ¶ added in v0.2.4
func GetClusterAvailableCapacity(report *api.ClusterUsageReport) common.ComputeResources
func GetClusterCapacity ¶ added in v0.2.4
func GetClusterCapacity(report *api.ClusterUsageReport) common.ComputeResources
func GetQueueReports ¶ added in v0.2.4
func GetQueueReports(report *api.ClusterUsageReport) []*api.QueueReport
func StringListToSet ¶
func SubtractStringList ¶
func SumReportClusterCapacity ¶ added in v0.2.4
func SumReportClusterCapacity(reports map[string]*api.ClusterUsageReport) common.ComputeResources
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.