pkg

Dec 21, 2024

Changes in this version

+ const WorkloadPriorityHighLabel

+ const WorkloadPriorityLowLabel

Dec 20, 2024

Changes in this version

+ const AnnotationInstanceType

+ const AnnotationStorageSizeGb

+ const AnnotationWorkloadPriority

+ const DefaultWorkloadPriority

+ const WeightKeyCpuAvailable

+ const WeightKeyCpuLimit

+ const WeightKeyCpuRequested

+ const WeightKeyCpuTotal

+ const WeightKeyCpuUsage

+ const WeightKeyInterruptionRate

+ const WeightKeyLatencyRate

+ const WeightKeyMemoryAvailable

+ const WeightKeyMemoryLimit

+ const WeightKeyMemoryRequested

+ const WeightKeyMemoryTotal

+ const WeightKeyMemoryUsage

+ const WeightKeyPrice

+ const WeightKeyPriceMedian

+ const WeightKeyStorageAvailable

+ const WeightKeyStorageRequested

+ const WeightKeyStorageTotal

+ const WeightKeyStorageUsage

+ const WorkloadPriorityHigh

+ const WorkloadPriorityLow

type ComputeConfiguration

+ DataCenter *string

+ Identifier *string

+ Location *string

+ Provider *string

type WeightedInteruptionRate

+ Weight float64

type WeightedLatencyRate

+ Weight float64

type WeightedNode

+ Annotations map[string]string

+ Weights map[string]float64

type WeightedPod

+ Annotations map[string]string

+ Weights map[string]float64

+ type WorkloadPriorityEnum bool

+ func (p WorkloadPriorityEnum) String() string

Oct 14, 2024

Changes in this version

+ const MetricKeyCpuTotal

+ const MetricKeyCpuUsage

+ const MetricKeyMemoryTotal

+ const MetricKeyMemoryUsage

Oct 14, 2024

Changes in this version

+ const BlockTypeCertificate

+ const BlockTypeRsaPrivateKey

+ const CacheKeyDurableComputeConfigurationLatencyRates

+ const CacheKeyDurableComputeConfigurations

+ const CacheKeyEphemeralComputeConfigurationInteruptionRates

+ const CacheKeyEphemeralComputeConfigurations

+ func ParseCsvIpAddressString(csv string) []net.IP

Oct 14, 2024

Changes in this version

type RealKubernetesClient

+ func (r *RealKubernetesClient) ListPods(ctx context.Context, namespace string, opts metav1.ListOptions) (*corev1.PodList, error)

Oct 11, 2024

Changes in this version

+ type KubernetesClientWrapper struct

+ ClientSet *kubernetes.Clientset

+ func (k *KubernetesClientWrapper) CoreV1() v1.CoreV1Interface

+ type MetricsClientWrapper struct

+ ClientSet *metricsclient.Clientset

+ func (m *MetricsClientWrapper) MetricsV1beta1() metricsv1beta1.MetricsV1beta1Interface

+ type MetricsContainer struct

+ Name string

+ Usage corev1.ResourceList

+ type MetricsNode struct

+ Name string

+ Usage corev1.ResourceList

+ type MetricsNodeList struct

+ Items []MetricsNode

+ type MetricsPod struct

+ Containers []MetricsContainer

+ Name string

+ Namespace string

+ type MetricsPodList struct

+ Items []MetricsPod

+ type RealKubernetesClient struct

+ ClientSet *kubernetes.Clientset

+ func (r *RealKubernetesClient) ListNamespaces(ctx context.Context, opts metav1.ListOptions) (*corev1.NamespaceList, error)

+ func (r *RealKubernetesClient) ListNodes(ctx context.Context, opts metav1.ListOptions) (*corev1.NodeList, error)

+ type RealMetricsClient struct

+ ClientSet *metricsclient.Clientset

+ func (r *RealMetricsClient) ListNodeMetrics(ctx context.Context, opts metav1.ListOptions) (*MetricsNodeList, error)

+ func (r *RealMetricsClient) ListPodMetrics(ctx context.Context, namespace string, opts metav1.ListOptions) (*MetricsPodList, error)

Oct 11, 2024

Changes in this version

+ func InitializeRedisClientFromConfig(ctx context.Context, config *Config, sugar *zap.SugaredLogger) *redis.Client

Oct 11, 2024

Changes in this version

+ func InitializeRedisClient(address string, password string, db int) *redis.Client

+ type Config struct

+ CertificateCommonName string

+ CertificateDnsNamesCSV string

+ CertificateExportPath string

+ CertificateIpAddressesCSV string

+ CertificateOrganization string

+ RedisServerAddress string

+ RedisServerDatabase int

+ RedisServerPassword string

+ ServerAddress string

+ func LoadConfig() (*Config, error)

Oct 11, 2024

Changes in this version

+ const EnvKubernetesConfig

+ const EnvKubernetesServiceHost

+ const EnvKubernetesServicePort

Oct 10, 2024

retracted

Changes in this version

+ const AnnotationManaged

Oct 9, 2024

retracted

Changes in this version

+ const TopicNodeObserve

+ const TopicPodObserve

Oct 9, 2024

retracted

Changes in this version

+ const LabelManaged

Oct 8, 2024

retracted

Changes in this version

type ComputeConfiguration

+ CloudNetworkTypes []string

+ Cost *ComputeCost

+ DataCenterId *string

+ DataCenterName *string

+ Id *int32

+ LocationId *int32

+ LocationName *string

+ OsId *int32

+ OsType *string

+ OsVersion *string

+ ProviderId *int32

+ ProviderName *string

+ RamGb *int32

+ VCpu *int32

+ VCpuType *string

+ VolumeGb *int32

+ VolumeType *string

+ type ComputeCost struct

+ Currency *string

+ PricePerUnit *float32

+ Unit *string

Oct 8, 2024

retracted

Changes in this version

+ const EnvRedisServerAddress

+ const EnvRedisServerDatabase

+ const EnvRedisServerPassword

+ const EnvServerAddress

+ const EnvServerCertificateCommonName

+ const EnvServerCertificateDnsNames

+ const EnvServerCertificateExportPath

+ const EnvServerCertificateIpAddresses

+ const EnvServerCertificateOrganization

Oct 8, 2024

retracted

Changes in this version

+ const AnnotationDiskType

+ const AnnotationNetworkType

+ const AnnotationPriority

+ const AnnotationStorageSize

+ const CacheKeyDurableVmConfigurationLatencyRates

+ const CacheKeyDurableVmConfigurations

+ const CacheKeySpotVmConfigurationInteruptionRates

+ const CacheKeySpotVmConfigurations

+ const CacheKeyWeightedNodes

+ const ComputeTypeDurable

+ const ComputeTypeEphemeral

+ const DefaultDiskType

+ const DefaultDurableInstanceType

+ const DefaultEphemeralInstanceType

+ const DefaultNetworkType

+ const DefaultPriority

+ const DefaultStorageSizeGB

+ const LabelHostName

+ const LabelInstanceType

+ const MetadataName

+ const PriorityHigh

+ const PriorityLow

+ type ComputeConfiguration struct

+ ComputeType ComputeType

+ type ComputeType string

+ type PriorityEnum bool

+ func (p PriorityEnum) String() string

+ type WeightedInteruptionRate struct

+ Selector map[string]string

+ Value float64

+ type WeightedLatencyRate struct

+ Selector map[string]string

+ Value float64

+ type WeightedNode struct

+ AvailableCPU float64

+ AvailableMemory float64

+ AvailableStorage float64

+ DiskType string

+ InstanceType string

+ InterruptionRate WeightedInteruptionRate

+ LatencyRate WeightedLatencyRate

+ MedianPrice float64

+ NetworkType string

+ Price float64

+ Selector map[string]string

+ TotalCPU float64

+ TotalMemory float64

+ TotalStorage float64

+ type WeightedPod struct

+ LimitCPU float64

+ LimitMemory float64

+ Priority PriorityEnum

+ RequestedCPU float64

+ RequestedDiskType string

+ RequestedMemory float64

+ RequestedNetworkType string

+ RequestedStorage float64

+ Selector map[string]string