common

Apr 18, 2024

Changes in this version

+ func PodName(jobId string) string

Oct 3, 2023

Changes in this version

+ func ServeHttps(port uint16, mux http.Handler, certFile, keyFile string) (shutdown func())

Jan 23, 2023

Changes in this version

+ const PodNamePrefix

+ func BindCommandlineArguments()

+ func ConfigureCommandLineLogging()

+ func ConfigureLogging()

+ func ContextWithDefaultTimeout() (context.Context, context.CancelFunc)

+ func LoadConfig(config interface{}, defaultPath string, overrideConfigs []string) *viper.Viper

+ func QuantityAsFloat64(q resource.Quantity) float64

+ func ServeHttp(port uint16, mux http.Handler) (shutdown func())

+ func ServeMetrics(port uint16) (shutdown func())

+ func ServeMetricsFor(port uint16, gatherer prometheus.Gatherer) (shutdown func())

+ func UnmarshalKey(v *viper.Viper, key string, item interface{}) error

+ type ComputeResources map[string]resource.Quantity

+ func CalculateTotalResource(nodes []*v1.Node) ComputeResources

+ func CalculateTotalResourceRequest(pods []*v1.Pod) ComputeResources

+ func FromResourceList(list v1.ResourceList) ComputeResources

+ func TotalJobResourceRequest(job *api.Job) ComputeResources

+ func TotalPodResourceLimit(podSpec *v1.PodSpec) ComputeResources

+ func TotalPodResourceRequest(podSpec *v1.PodSpec) ComputeResources

+ func (a ComputeResources) Add(b ComputeResources)

+ func (a ComputeResources) AsFloat() ComputeResourcesFloat

+ func (a ComputeResources) DeepCopy() ComputeResources

+ func (a ComputeResources) Dominates(b ComputeResources) bool

+ func (a ComputeResources) Equal(b ComputeResources) bool

+ func (a ComputeResources) IsValid() bool

+ func (a ComputeResources) Max(b ComputeResources)

+ func (a ComputeResources) Mul(factor float64) ComputeResourcesFloat

+ func (a ComputeResources) MulByResource(factors map[string]float64) ComputeResourcesFloat

+ func (a ComputeResources) String() string

+ func (a ComputeResources) Sub(b ComputeResources)

+ type ComputeResourcesFloat map[string]float64

+ func (a ComputeResourcesFloat) Add(b ComputeResourcesFloat)

+ func (a ComputeResourcesFloat) DeepCopy() ComputeResourcesFloat

+ func (a ComputeResourcesFloat) IsLessThan(b ComputeResourcesFloat) bool

+ func (a ComputeResourcesFloat) IsValid() bool

+ func (a ComputeResourcesFloat) LimitToZero()

+ func (a ComputeResourcesFloat) LimitWith(limit ComputeResourcesFloat) ComputeResourcesFloat

+ func (a ComputeResourcesFloat) Max(b ComputeResourcesFloat)

+ func (a ComputeResourcesFloat) MergeWith(merged ComputeResourcesFloat) ComputeResourcesFloat

+ func (a ComputeResourcesFloat) Mul(factor float64) ComputeResourcesFloat

+ func (a ComputeResourcesFloat) Sub(b ComputeResourcesFloat)

+ type LoginCredentials struct

+ Password string

+ Username string

+ func (c *LoginCredentials) GetRequestMetadata(context.Context, ...string) (map[string]string, error)

+ func (c *LoginCredentials) RequireTransportSecurity() bool