linkerd_prometheus_syncer.go

package linkerd

import (
	"github.com/solo-io/supergloo/pkg/stats/common"
	"k8s.io/client-go/kubernetes"

	"github.com/prometheus/prometheus/config"
	"github.com/solo-io/go-utils/errors"
	prometheusv1 "github.com/solo-io/supergloo/pkg/api/external/prometheus/v1"

	v1 "github.com/solo-io/supergloo/pkg/api/v1"
)

// registration-level syncer

func NewLinkerdPrometheusSyncer(client prometheusv1.PrometheusConfigClient, kube kubernetes.Interface) v1.RegistrationSyncer {
	return common.NewPrometheusSyncer("linkerd", client, kube, chooseMesh, getScrapeConfigs)
}

func chooseMesh(mesh *v1.Mesh) bool {
	return mesh.GetLinkerd() != nil
}

func getScrapeConfigs(mesh *v1.Mesh) ([]*config.ScrapeConfig, error) {
	linkerd := mesh.GetLinkerd()
	if linkerd == nil {
		return nil, errors.Errorf("internal error: mesh %v was expected to be type linkerd", mesh.Metadata.Ref())
	}
	return PrometheusScrapeConfigs(linkerd.InstallationNamespace)
}