Documentation ¶
Index ¶
- Constants
- 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
- 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 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
- 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
Constants ¶
View Source
const PasswordField string = "password"
View Source
const PodNamePrefix string = "armada-"
View Source
const UsernameField string = "username"
Variables ¶
This section is empty.
Functions ¶
func BindCommandlineArguments ¶
func BindCommandlineArguments()
func ConfigureCommandLineLogging ¶
func ConfigureCommandLineLogging()
func ConfigureLogging ¶
func ConfigureLogging()
func ContextWithDefaultTimeout ¶
func ContextWithDefaultTimeout() (context.Context, context.CancelFunc)
func LoadConfig ¶
func QuantityAsFloat64 ¶
func ServeMetrics ¶
func ServeMetrics(port uint16) (shutdown func())
func ServeMetricsFor ¶ added in v0.1.29
func ServeMetricsFor(port uint16, gatherer prometheus.Gatherer) (shutdown func())
Types ¶
type ComputeResources ¶
func CalculateTotalResource ¶
func CalculateTotalResource(nodes []*v1.Node) ComputeResources
func CalculateTotalResourceRequest ¶
func CalculateTotalResourceRequest(pods []*v1.Pod) ComputeResources
func FromResourceList ¶
func FromResourceList(list v1.ResourceList) ComputeResources
func TotalJobResourceRequest ¶ added in v0.1.23
func TotalJobResourceRequest(job *api.Job) ComputeResources
func TotalPodResourceRequest ¶ added in v0.1.23
func TotalPodResourceRequest(podSpec *v1.PodSpec) ComputeResources
Resource request for a given pod is the maximum of: - sum of all containers - any individual init container This is because: - containers run in parallel (so need to sum resources) - init containers run sequentially (so only their individual resource need be considered) So pod resource usage is the max for each resource type (cpu/memory etc) that could be used at any given time
func (ComputeResources) Add ¶
func (a ComputeResources) Add(b ComputeResources)
func (ComputeResources) AsFloat ¶
func (a ComputeResources) AsFloat() ComputeResourcesFloat
func (ComputeResources) DeepCopy ¶
func (a ComputeResources) DeepCopy() ComputeResources
func (ComputeResources) Dominates ¶ added in v0.1.6
func (a ComputeResources) Dominates(b ComputeResources) bool
func (ComputeResources) Equal ¶ added in v0.1.6
func (a ComputeResources) Equal(b ComputeResources) bool
func (ComputeResources) IsValid ¶ added in v0.1.6
func (a ComputeResources) IsValid() bool
func (ComputeResources) Max ¶
func (a ComputeResources) Max(b ComputeResources)
func (ComputeResources) Mul ¶
func (a ComputeResources) Mul(factor float64) ComputeResourcesFloat
func (ComputeResources) MulByResource ¶ added in v0.1.0
func (a ComputeResources) MulByResource(factors map[string]float64) ComputeResourcesFloat
func (ComputeResources) String ¶ added in v0.1.9
func (a ComputeResources) String() string
func (ComputeResources) Sub ¶
func (a ComputeResources) Sub(b ComputeResources)
type ComputeResourcesFloat ¶
float version of compute resource, prefer calculations with quantity where possible
func (ComputeResourcesFloat) Add ¶
func (a ComputeResourcesFloat) Add(b ComputeResourcesFloat)
func (ComputeResourcesFloat) DeepCopy ¶
func (a ComputeResourcesFloat) DeepCopy() ComputeResourcesFloat
func (ComputeResourcesFloat) IsLessThan ¶
func (a ComputeResourcesFloat) IsLessThan(b ComputeResourcesFloat) bool
func (ComputeResourcesFloat) IsValid ¶
func (a ComputeResourcesFloat) IsValid() bool
func (ComputeResourcesFloat) LimitToZero ¶ added in v0.1.6
func (a ComputeResourcesFloat) LimitToZero()
func (ComputeResourcesFloat) LimitWith ¶ added in v0.0.2
func (a ComputeResourcesFloat) LimitWith(limit ComputeResourcesFloat) ComputeResourcesFloat
func (ComputeResourcesFloat) Max ¶ added in v0.1.6
func (a ComputeResourcesFloat) Max(b ComputeResourcesFloat)
func (ComputeResourcesFloat) MergeWith ¶ added in v0.1.6
func (a ComputeResourcesFloat) MergeWith(merged ComputeResourcesFloat) ComputeResourcesFloat
The merged in values take precedence and override existing values for the same key
func (ComputeResourcesFloat) Mul ¶ added in v0.0.2
func (a ComputeResourcesFloat) Mul(factor float64) ComputeResourcesFloat
func (ComputeResourcesFloat) Sub ¶
func (a ComputeResourcesFloat) Sub(b ComputeResourcesFloat)
type LoginCredentials ¶
func (*LoginCredentials) GetRequestMetadata ¶
func (*LoginCredentials) RequireTransportSecurity ¶
func (c *LoginCredentials) RequireTransportSecurity() bool
Source Files ¶
Click to show internal directories.
Click to hide internal directories.