services

Oct 14, 2024

Changes in this version

type ICoreClient

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

type IKubernetesService

+ GetPods func(ctx context.Context, options metav1.ListOptions) ([]corev1.Pod, error)

type KubernetesService

+ func (ks *KubernetesService) GetPods(ctx context.Context, options metav1.ListOptions) ([]corev1.Pod, error)

Oct 11, 2024

Changes in this version

+ type ICoreClient interface

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

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

+ type IMetricsClient interface

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

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

type KubernetesService

+ K8sClient ICoreClient

+ MetricsClient IMetricsClient

Oct 11, 2024

Changes in this version

type KubernetesService

+ func NewKubernetesService(kubernetesMasterUrl string, kubernetesConfigPath string) (*KubernetesService, error)

Oct 11, 2024

Changes in this version

+ type IKubernetesService interface

+ GetNodeMetrics func() (map[string]map[string]string, error)

+ GetNodes func() ([]corev1.Node, error)

+ GetPodMetrics func() (map[string]map[string]string, error)

+ type KubernetesService struct

+ func NewKubernetesClient(kubernetesMasterUrl string, kubernetesConfigPath string) (*KubernetesService, error)

+ func (k *KubernetesService) GetNodeMetrics() (map[string]map[string]string, error)

+ func (k *KubernetesService) GetPodMetrics() (map[string]map[string]string, error)

+ func (kc *KubernetesService) GetNodes() ([]corev1.Node, error)

Oct 9, 2024

retracted

Changes in this version

type CacheService

+ func NewCacheService(innerCache *cache.Cache, redisClient *redis.Client) *CacheService

type CertificateService

+ func NewCertificateService() *CertificateService

type ComputeService

+ func NewComputeService(algorithm *algorithm.IAlgorithm, cacheService *ICacheService, ...) *ComputeService

+ func (cs *ComputeService) GetInteruptionRateForWeightedNode(wNode ultron.WeightedNode) (match *ultron.WeightedInteruptionRate, err error)

+ func (cs *ComputeService) GetLatencyRateForWeightedNode(wNode ultron.WeightedNode) (match *ultron.WeightedLatencyRate, err error)

type IComputeService

+ GetInteruptionRateForWeightedNode func(wNode ultron.WeightedNode) (*ultron.WeightedInteruptionRate, error)

+ GetLatencyRateForWeightedNode func(wNode ultron.WeightedNode) (*ultron.WeightedLatencyRate, error)

Oct 8, 2024

retracted

Changes in this version

+ const BlockTypeCertificate

+ const BlockTypeRsaPrivateKey

+ type CertificateService interface

+ ExportCACert func(caCert []byte, filePath string) error

+ GenerateSelfSignedCert func(organization string, commonName string, dnsNames []string, ...) (tls.Certificate, error)

+ type ICertificateService struct

+ func NewICertificateService() *ICertificateService

+ func (cs ICertificateService) ExportCACert(caCert []byte, filePath string) error

+ func (cs ICertificateService) GenerateSelfSignedCert(organization string, commonName string, dnsNames []string, ...) (tls.Certificate, error)

Oct 8, 2024

retracted

Changes in this version

+ type CacheService interface

+ AddCacheItem func(key string, value interface{}, d time.Duration) error

+ GetAllComputeConfigurations func() ([]ultron.ComputeConfiguration, error)

+ GetCacheItem func(key string) (interface{}, error)

+ GetDurableComputeConfigurations func() ([]ultron.ComputeConfiguration, error)

+ GetEphemeralComputeConfigurations func() ([]ultron.ComputeConfiguration, error)

+ GetWeightedInteruptionRates func() ([]ultron.WeightedInteruptionRate, error)

+ GetWeightedLatencyRates func() ([]ultron.WeightedLatencyRate, error)

+ GetWeightedNodes func() ([]ultron.WeightedNode, error)

+ type ComputeService interface

+ CalculateWeightedNodeMedianPrice func(wNode ultron.WeightedNode) (float64, error)

+ ComputeConfigurationMatchesWeightedNodeRequirements func(computeConfiguration ultron.ComputeConfiguration, wNode ultron.WeightedNode) bool

+ ComputeConfigurationMatchesWeightedPodRequirements func(computeConfiguration ultron.ComputeConfiguration, wPod ultron.WeightedPod) bool

+ ComputeInteruptionRateForWeightedNode func(wNode ultron.WeightedNode) (*ultron.WeightedInteruptionRate, error)

+ ComputeLatencyRateForWeightedNode func(wNode ultron.WeightedNode) (*ultron.WeightedLatencyRate, error)

+ MatchPodSpec func(pod *corev1.Pod) (*ultron.WeightedNode, error)

+ MatchWeightedNodeToComputeConfiguration func(wNode ultron.WeightedNode) (*ultron.ComputeConfiguration, error)

+ MatchWeightedPodToComputeConfiguration func(wPod ultron.WeightedPod) (*ultron.ComputeConfiguration, error)

+ MatchWeightedPodToWeightedNode func(wPod ultron.WeightedPod) (*ultron.WeightedNode, error)

+ type ICacheService struct

+ func NewICacheService(innerCache *cache.Cache, redisClient *redis.Client) *ICacheService

+ func (c *ICacheService) AddCacheItem(key string, value interface{}, d time.Duration) error

+ func (c *ICacheService) GetAllComputeConfigurations() ([]ultron.ComputeConfiguration, error)

+ func (c *ICacheService) GetCacheItem(key string) (interface{}, error)

+ func (c *ICacheService) GetDurableComputeConfigurations() ([]ultron.ComputeConfiguration, error)

+ func (c *ICacheService) GetEphemeralComputeConfigurations() ([]ultron.ComputeConfiguration, error)

+ func (c *ICacheService) GetWeightedInteruptionRates() ([]ultron.WeightedInteruptionRate, error)

+ func (c *ICacheService) GetWeightedLatencyRates() ([]ultron.WeightedLatencyRate, error)

+ func (c *ICacheService) GetWeightedNodes() ([]ultron.WeightedNode, error)

+ type IComputeService struct

+ func NewIComputeService(algorithm algorithm.Algorithm, cacheService CacheService, mapper mapper.Mapper) *IComputeService

+ func (cs IComputeService) CalculateWeightedNodeMedianPrice(wNode ultron.WeightedNode) (float64, error)

+ func (cs IComputeService) ComputeConfigurationMatchesWeightedNodeRequirements(computeConfiguration ultron.ComputeConfiguration, wNode ultron.WeightedNode) bool

+ func (cs IComputeService) ComputeConfigurationMatchesWeightedPodRequirements(computeConfiguration ultron.ComputeConfiguration, wPod ultron.WeightedPod) bool

+ func (cs IComputeService) ComputeInteruptionRateForWeightedNode(wNode ultron.WeightedNode) (match *ultron.WeightedInteruptionRate, err error)

+ func (cs IComputeService) ComputeLatencyRateForWeightedNode(wNode ultron.WeightedNode) (match *ultron.WeightedLatencyRate, err error)

+ func (cs IComputeService) MatchPodSpec(pod *corev1.Pod) (*ultron.WeightedNode, error)

+ func (cs IComputeService) MatchWeightedNodeToComputeConfiguration(wNode ultron.WeightedNode) (*ultron.ComputeConfiguration, error)

+ func (cs IComputeService) MatchWeightedPodToComputeConfiguration(wPod ultron.WeightedPod) (*ultron.ComputeConfiguration, error)

+ func (cs IComputeService) MatchWeightedPodToWeightedNode(pod ultron.WeightedPod) (*ultron.WeightedNode, error)