diff options
| author | jannfis <jann@mistrust.net> | 2020-12-04 16:13:20 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-12-04 16:13:20 +0100 |
| commit | 2b290e46d231aef8d0a3dbf0fc8f7c70128b52c7 (patch) | |
| tree | f7c1fa8bb16576c2438d53260f07b7b69e3561f8 /pkg/client | |
| parent | e3b13f16bfc543ffe98fac6b84b309fc8bf719ff (diff) | |
feat: Export Prometheus compatible metrics (#123)
* feat: Export Prometheus compatible metrics
Signed-off-by: jannfis <jann@mistrust.net>
* adapt spelling action configuration
Signed-off-by: jannfis <jann@mistrust.net>
* adapt spelling action configuration
Signed-off-by: jannfis <jann@mistrust.net>
Diffstat (limited to 'pkg/client')
| -rw-r--r-- | pkg/client/kubernetes.go | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/pkg/client/kubernetes.go b/pkg/client/kubernetes.go index 99e6d8b..5f4f512 100644 --- a/pkg/client/kubernetes.go +++ b/pkg/client/kubernetes.go @@ -6,6 +6,8 @@ import ( "context" "fmt" + "github.com/argoproj-labs/argocd-image-updater/pkg/metrics" + v1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/client-go/kubernetes" "k8s.io/client-go/rest" @@ -46,7 +48,9 @@ func NewKubernetesClient(kubeconfig string) (*KubernetesClient, error) { // GetSecretData returns the raw data from named K8s secret in given namespace func (client *KubernetesClient) GetSecretData(namespace string, secretName string) (map[string][]byte, error) { secret, err := client.Clientset.CoreV1().Secrets(namespace).Get(context.TODO(), secretName, v1.GetOptions{}) + metrics.Clients().IncreaseK8sClientRequest(1) if err != nil { + metrics.Clients().IncreaseK8sClientRequest(1) return nil, err } return secret.Data, nil @@ -55,7 +59,9 @@ func (client *KubernetesClient) GetSecretData(namespace string, secretName strin // GetSecretField returns the value of a field from named K8s secret in given namespace func (client *KubernetesClient) GetSecretField(namespace string, secretName string, field string) (string, error) { secret, err := client.GetSecretData(namespace, secretName) + metrics.Clients().IncreaseK8sClientRequest(1) if err != nil { + metrics.Clients().IncreaseK8sClientRequest(1) return "", err } if data, ok := secret[field]; !ok { |