istio

Documentation

Index

• Constants
• func GetObjectsReference(labels model.Metric) (source, destination *v1.ObjectReference, err error)
• func GetType(labels fmt.Stringer) (string, error)
• func ObjectReferenceFromPodLabel(value model.LabelValue) (*v1.ObjectReference, error)
• type Config
• type Istio
  • func NewIstioProvider(config Config) (*Istio, error)
  • func (l *Istio) GetEdgeMetrics(ctx context.Context, query mesh.Query, interval *metrics.Interval, ...) (*metrics.TrafficMetricsList, error)
  • func (l *Istio) GetResourceMetrics(ctx context.Context, query mesh.Query, interval *metrics.Interval) (*metrics.TrafficMetricsList, error)
  • func (l *Istio) GetSupportedResources(ctx context.Context) (*metav1.APIResourceList, error)

Constants

const (
	Pod       string = "Pod"
	Workload  string = "Workload"
	Namespace string = "Namespace"
)

Functions

func GetObjectsReference

func GetObjectsReference(labels model.Metric) (source, destination *v1.ObjectReference, err error)

Return (src, dst) from the result labels

func GetType

func GetType(labels fmt.Stringer) (string, error)

func ObjectReferenceFromPodLabel

func ObjectReferenceFromPodLabel(value model.LabelValue) (*v1.ObjectReference, error)

Types

type Config

type Config struct {
	PrometheusURL    string             `yaml:"prometheusUrl"`
	NamespaceQueries prometheus.Queries `yaml:"namespaceQueries"`
	PodQueries       prometheus.Queries `yaml:"podQueries"`
	WorkloadQueries  prometheus.Queries `yaml:"workloadQueries"`
}

type Istio

type Istio struct {
	// contains filtered or unexported fields
}

func NewIstioProvider

func NewIstioProvider(config Config) (*Istio, error)

func (*Istio) GetEdgeMetrics

func (l *Istio) GetEdgeMetrics(ctx context.Context,
	query mesh.Query,
	interval *metrics.Interval,
	details *mesh.ResourceDetails) (*metrics.TrafficMetricsList, error)

func (*Istio) GetResourceMetrics

func (l *Istio) GetResourceMetrics(ctx context.Context,
	query mesh.Query,
	interval *metrics.Interval) (*metrics.TrafficMetricsList, error)

func (*Istio) GetSupportedResources

func (l *Istio) GetSupportedResources(ctx context.Context) (*metav1.APIResourceList, error)