nodegroup

package

Go to main page

Versions in this module

v0

v0.4.1

Jan 13, 2026

v0.4.0

Jan 12, 2026

Changes in this version

+ type ASGClient interface

+ DescribeAutoScalingGroups func(ctx context.Context, params *autoscaling.DescribeAutoScalingGroupsInput, ...) (*autoscaling.DescribeAutoScalingGroupsOutput, error)

type CostAnalyzer

+ func (c *CostAnalyzer) CalculateSpotSavings(ctx context.Context, instanceType string) (savingsPercent float64, ok bool)

+ func (c *CostAnalyzer) CompareCosts(ctx context.Context, instanceType string, nodeCount int) (*CostComparison, error)

+ func (c *CostAnalyzer) EstimateSpotUSD(ctx context.Context, instanceType string) (perHour float64, perMonth float64, ok bool)

+ func (c *CostAnalyzer) GetFallbackPrice(instanceType string) (perHour float64, perMonth float64, ok bool)

+ func (c *CostAnalyzer) GetSpotPricesByAZ(ctx context.Context, instanceType string) ([]SpotPriceResult, error)

+ func (c *CostAnalyzer) SetEC2Client(ec2Client *ec2.Client)

+ type CostComparison struct

+ EstimatedRisk string

+ InstanceType string

+ OnDemandHourly float64

+ OnDemandMonthly float64

+ RecommendedCapacity string

+ SavingsPercent float64

+ SpotHourly float64

+ SpotMonthly float64

+ type NodegroupAnalysisData struct

+ CPUUtil UtilizationData

+ CapacityType string

+ DesiredSize int32

+ HasCPUData bool

+ HasCostData bool

+ HourlyCost float64

+ InstanceType string

+ Instances []InstanceDetails

+ MaxSize int32

+ MinSize int32

+ MonthlyCost float64

+ Name string

+ type RecommendationsAnalyzer struct

+ func NewRecommendationsAnalyzer(eksClient EKSAPI, ec2Client *ec2.Client, asgClient ASGClient, ...) *RecommendationsAnalyzer

+ func (a *RecommendationsAnalyzer) AnalyzeNodegroups(ctx context.Context, clusterName string, options RecommendationOptions) ([]Recommendation, error)

+ type SpotPriceResult struct

+ AvailabilityZone string

+ InstanceType string

+ SpotPrice float64

+ Timestamp time.Time

type UtilizationCollector

+ func (u *UtilizationCollector) CollectAllMetrics(ctx context.Context, instanceIDs []string, window string) UtilizationMetrics

+ func (u *UtilizationCollector) CollectDiskForInstances(ctx context.Context, instanceIDs []string, window string) (UtilizationData, bool)

+ func (u *UtilizationCollector) CollectMemoryForInstances(ctx context.Context, instanceIDs []string, window string) (UtilizationData, bool)

+ func (u *UtilizationCollector) CollectNetworkForInstances(ctx context.Context, instanceIDs []string, window string) (UtilizationData, bool)

v0.3.0

Jan 12, 2026

v0.2.2

Dec 3, 2025

Changes in this version

type EKSAPI

+ DescribeCluster func(ctx context.Context, params *eks.DescribeClusterInput, ...) (*eks.DescribeClusterOutput, error)

type NodegroupDetails

+ AMIStatus types.AMIStatus

+ CurrentAMI string

+ LatestAMI string

type NodegroupSummary

+ AMIStatus types.AMIStatus

+ CurrentAMI string

v0.2.1

Aug 8, 2025

Changes in this version

+ type Cache struct

+ func NewCache() *Cache

+ func (c *Cache) Get(key string) (any, bool)

+ func (c *Cache) Set(key string, value any, ttl time.Duration)

+ type CostAnalysis struct

+ CostBreakdown CostBreakdown

+ CostPerNode float64

+ CurrentMonthlyCost float64

+ OptimizationPotential float64

+ ProjectedMonthlyCost float64

+ type CostAnalyzer struct

+ func NewCostAnalyzer(p *pricing.Client, logger *slog.Logger, cache *Cache, region string) *CostAnalyzer

+ func (c *CostAnalyzer) EstimateOnDemandUSD(ctx context.Context, instanceType string) (perHour float64, perMonth float64, ok bool)

+ type CostBreakdown struct

+ type DescribeOptions struct

+ ShowCosts bool

+ ShowInstances bool

+ ShowOptimization bool

+ ShowUtilization bool

+ ShowWorkloads bool

+ Timeframe string

+ type EKSAPI interface

+ DescribeNodegroup func(ctx context.Context, params *eks.DescribeNodegroupInput, ...) (*eks.DescribeNodegroupOutput, error)

+ ListNodegroups func(ctx context.Context, params *eks.ListNodegroupsInput, ...) (*eks.ListNodegroupsOutput, error)

+ UpdateNodegroupConfig func(ctx context.Context, params *eks.UpdateNodegroupConfigInput, ...) (*eks.UpdateNodegroupConfigOutput, error)

+ type InstanceDetails struct

+ AZ string

+ InstanceID string

+ InstanceType string

+ LaunchTime time.Time

+ Lifecycle string

+ State string

+ type ListOptions struct

+ Filters map[string]string

+ ShowCosts bool

+ ShowHealth bool

+ ShowInstances bool

+ ShowUtilization bool

+ Timeframe string

+ type NodegroupDetails struct

+ AmiType string

+ CapacityType string

+ Cost CostAnalysis

+ Health *health.HealthStatus

+ InstanceType string

+ Instances []InstanceDetails

+ Name string

+ Recommendations []Recommendation

+ Scaling ScalingConfig

+ Status string

+ Utilization UtilizationMetrics

+ Workloads WorkloadInfo

+ type NodegroupSummary struct

+ Cost SummaryCost

+ DesiredSize int32

+ InstanceType string

+ Metrics SummaryMetrics

+ Name string

+ ReadyNodes int32

+ Status string

+ type Recommendation struct

+ Description string

+ ExpectedSavings float64

+ Impact string

+ Implementation string

+ Priority string

+ RiskLevel string

+ Type string

+ type RecommendationOptions struct

+ CostOptimization bool

+ Nodegroup string

+ PerformanceOptimization bool

+ RightSizing bool

+ SpotAnalysis bool

+ Timeframe string

+ type ScaleOptions struct

+ CheckPDBs bool

+ DryRun bool

+ HealthCheck bool

+ Timeout time.Duration

+ Wait bool

+ type ScalingConfig struct

+ AutoScaling bool

+ DesiredSize int32

+ MaxSize int32

+ MinSize int32

+ type Service interface

+ Describe func(ctx context.Context, clusterName, nodegroupName string, ...) (*NodegroupDetails, error)

+ GetRecommendations func(ctx context.Context, clusterName string, options RecommendationOptions) ([]Recommendation, error)

+ List func(ctx context.Context, clusterName string, options ListOptions) ([]NodegroupSummary, error)

+ Scale func(ctx context.Context, clusterName, nodegroupName string, ...) error

+ type ServiceImpl struct

+ func NewService(awsConfig aws.Config, healthChecker *health.HealthChecker, logger *slog.Logger) *ServiceImpl

+ func (s *ServiceImpl) Describe(ctx context.Context, clusterName, nodegroupName string, ...) (*NodegroupDetails, error)

+ func (s *ServiceImpl) GetRecommendations(ctx context.Context, clusterName string, options RecommendationOptions) ([]Recommendation, error)

+ func (s *ServiceImpl) List(ctx context.Context, clusterName string, options ListOptions) ([]NodegroupSummary, error)

+ func (s *ServiceImpl) Scale(ctx context.Context, clusterName, nodegroupName string, ...) error

+ type SummaryCost struct

+ Monthly float64

+ type SummaryMetrics struct

+ CPU float64

+ type UtilizationCollector struct

+ func NewUtilizationCollector(cw *cloudwatch.Client, logger *slog.Logger, cache *Cache) *UtilizationCollector

+ func (u *UtilizationCollector) CollectBasicCPU(ctx context.Context, clusterName, nodegroupName, timeframe string) (UtilizationData, bool)

+ func (u *UtilizationCollector) CollectEC2CPUForInstances(ctx context.Context, instanceIDs []string, window string) (UtilizationData, bool)

+ type UtilizationData struct

+ Average float64

+ Current float64

+ Peak float64

+ Trend string

+ type UtilizationMetrics struct

+ CPU UtilizationData

+ Memory UtilizationData

+ Network UtilizationData

+ Storage UtilizationData

+ TimeRange string

+ type WorkloadInfo struct

+ CriticalPods int

+ PodDisruption string

+ TotalPods int

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL