metrics

Apr 22, 2024

Changes in this version

+ const KindDaemonSet

+ const StateAvailable

+ const StateMisscheduled

+ const StateRunning

+ const StateScaledDown

+ const StateScheduled

+ const StateUnavailable

+ func CollectDaemonSets(daemonsets []appsv1.DaemonSet) (*MetricSet, StateSet)

Feb 2, 2024

Changes in this version

+ const KindCronJob

+ const KindDeployment

+ const KindJob

+ const KindPod

+ const KindReplicaSet

+ const KindStatefulSet

+ const StateActive

+ const StateFailed

+ const StateNotReady

+ const StateReady

+ const StateSucceeded

+ const StateSuspended

+ func CollectCronJobs(cronjobs []batchv1.CronJob) (*MetricSet, StateSet)

+ func CollectDeployments(deployments []appsv1.Deployment) (*MetricSet, StateSet)

+ func CollectJobs(jobs []batchv1.Job) (*MetricSet, StateSet)

+ func CollectPods(pods []corev1.Pod) (*MetricSet, StateSet)

+ func CollectReplicaSets(replicasets []appsv1.ReplicaSet) (*MetricSet, StateSet)

+ func CollectStatefulSets(statefulsets []appsv1.StatefulSet) (*MetricSet, StateSet)

type MetricSet

+ func CombineRecords(recordsInput *MetricSet, recordsAppend *MetricSet) *MetricSet

+ type StateSet map[string]map[string]int

+ func CombineStates(input *StateSet, og *StateSet) StateSet

Sep 9, 2021

Changes in this version

+ func ConvertToMetricData(timestamp time.Time, cluster string, phases PhaseSet) []awstypes.MetricDatum

+ type PhaseSet map[string]int

+ type Pusher struct

+ func NewPusher(cloudwatchClient types.CloudwatchInterface) *Pusher

+ func (p *Pusher) Push(ctx context.Context, namespace string, metricData []awstypes.MetricDatum) error

Sep 6, 2021

Changes in this version

+ func Log(writer io.Writer, name string, metrics *MetricSet) error

type Metric

+ Labels map[string]string

+ Name string

+ Type string

+ Value int

Sep 2, 2021

Changes in this version

+ type Logger struct

+ func NewLogger(writer io.Writer, namespace string) *Logger

+ func (l *Logger) Log(metrics *MetricSet, timestamp time.Time)

+ type Metric struct

+ Kind string

+ Namespace string

+ Phase corev1.PodPhase

+ Total int

+ type MetricSet struct

+ Items map[string]*Metric

+ func Collect(pods []corev1.Pod) *MetricSet

+ func NewMetricSet() *MetricSet

+ func (s *MetricSet) Increment(kind, namespace string, phase corev1.PodPhase)