util

Documentation

Index

• func AddQueryScope(query string) string
• func HandleClusters(lSourceCluster model.LabelValue, sourceClusterOk bool, ...) (sourceCluster, destCluster string)
• func HandleDestination(...) (string, string, string, string, string, string, string, bool)
• func HandleResponseCode(protocol, responseCode string, grpcResponseStatusOk bool, ...) string
• func IsBadDestTelemetry(cluster string, clusterOK bool, svcNs, svc, svcName, wl string) bool
• func IsBadSourceTelemetry(cluster string, clusterOK bool, ns, wl, app string) bool

Functions

func AddQueryScope

func AddQueryScope(query string) string

AddQueryScope returns the prom query unchanged if there is no configured queryScope, otherwise it returns the query with the queryScope injected after each occurrence of a leading '{'.

func HandleClusters

func HandleClusters(lSourceCluster model.LabelValue, sourceClusterOk bool, lDestCluster model.LabelValue, destClusterOk bool) (sourceCluster, destCluster string)

HandleClusters just sets source an dest cluster to unknown if it is not supplied on the telemetry TODO: Starting in Istio 1.9 source_cluster and destination_cluster are always reported. So, this function can be removed when the Kiali version can assume Istio 1.9 or later.

func HandleDestination

func HandleDestination(sourceCluster, sourceWlNs, sourceWl, destCluster, destSvcNs, destSvc, destSvcName, destWlNs, destWl, destApp, destVer string) (string, string, string, string, string, string, string, bool)

HandleDestination modifies the destination information, when necessary, for various corner cases. It should be called after source validation and before destination processing. Returns destSvcNs, destSvcName, destWlNs, destWl, destApp, destVersion, isupdated

func HandleResponseCode

func HandleResponseCode(protocol, responseCode string, grpcResponseStatusOk bool, grpcResponseStatus string) string

HandleResponseCode determines the proper response code based on how istio has set the response_code and grpc_response_status attributes. grpc_response_status was added upstream in Istio 1.5 and downstream in OSSM 1.1. We support it here in a backward compatible way. return "-" for requests that did not receive a response, regardless of protocol return HTTP response code when:

• protocol is not GRPC
• the version running does not supply the GRPC status
• the protocol is GRPC but the HTTP transport fails (i.e. an HTTP error is reported, rare).

return the GRPC status, otherwise.

func IsBadDestTelemetry

func IsBadDestTelemetry(cluster string, clusterOK bool, svcNs, svc, svcName, wl string) bool

IsBadDestTelemetry tests for known issues in generated telemetry given indicative label values.

1. During pod lifecycle changes incomplete telemetry may be generated that results in destSvc == destSvcName and no dest workload, where destSvc[Name] is in the form of an IP address.
2. destSvcNs is ok and destCluster is provided but not ok
3. no more conditions known

func IsBadSourceTelemetry

func IsBadSourceTelemetry(cluster string, clusterOK bool, ns, wl, app string) bool

IsBadSourceTelemetry tests for known issues in generated telemetry given indicative label values. 1) source namespace is ok but neither workload nor app are set 2) source namespace is ok and source_cluster is provided but not ok. 3) no more conditions known