api: adds tls check at flags for https detection (#1005)

its possible only at best effort. https certificates must be valid.

#994

Signed-off-by: f41gh7 <[email protected]>

Author: f41gh7

api/operator/v1beta1/vmagent_types.go

@@ -695,6 +695,7 @@ func (cr VMAgent) GetNSName() string {
 	return cr.GetNamespace()
 }
 
+// AsURL - returns url for http access
 func (cr *VMAgent) AsURL() string {
 	port := cr.Spec.Port
 	if port == "" {
@@ -708,7 +709,7 @@ func (cr *VMAgent) AsURL() string {
 			}
 		}
 	}
-	return fmt.Sprintf("http://%s.%s.svc:%s", cr.PrefixedName(), cr.Namespace, port)
+	return fmt.Sprintf("%s://%s.%s.svc:%s", protoFromFlags(cr.Spec.ExtraArgs), cr.PrefixedName(), cr.Namespace, port)
 }
 
 func (cr VMAgent) STSUpdateStrategy() appsv1.StatefulSetUpdateStrategyType {

api/operator/v1beta1/vmalert_types.go

@@ -533,7 +533,7 @@ func (cr *VMAlert) AsURL() string {
 			}
 		}
 	}
-	return fmt.Sprintf("http://%s.%s.svc:%s", cr.PrefixedName(), cr.Namespace, port)
+	return fmt.Sprintf("%s://%s.%s.svc:%s", protoFromFlags(cr.Spec.ExtraArgs), cr.PrefixedName(), cr.Namespace, port)
 }
 
 // AsCRDOwner implements interface

api/operator/v1beta1/vmcluster_types.go

@@ -1083,7 +1083,7 @@ func (cr *VMCluster) VMSelectURL() string {
 			}
 		}
 	}
-	return fmt.Sprintf("http://%s.%s.svc:%s", cr.Spec.VMSelect.GetNameWithPrefix(cr.Name), cr.Namespace, port)
+	return fmt.Sprintf("%s://%s.%s.svc:%s", protoFromFlags(cr.Spec.VMSelect.ExtraArgs), cr.Spec.VMSelect.GetNameWithPrefix(cr.Name), cr.Namespace, port)
 }
 
 func (cr *VMCluster) VMInsertURL() string {
@@ -1101,7 +1101,7 @@ func (cr *VMCluster) VMInsertURL() string {
 			}
 		}
 	}
-	return fmt.Sprintf("http://%s.%s.svc:%s", cr.Spec.VMInsert.GetNameWithPrefix(cr.Name), cr.Namespace, port)
+	return fmt.Sprintf("%s://%s.%s.svc:%s", protoFromFlags(cr.Spec.VMSelect.ExtraArgs), cr.Spec.VMInsert.GetNameWithPrefix(cr.Name), cr.Namespace, port)
 }
 
 func (cr *VMCluster) VMStorageURL() string {
@@ -1119,7 +1119,7 @@ func (cr *VMCluster) VMStorageURL() string {
 			}
 		}
 	}
-	return fmt.Sprintf("http://%s.%s.svc:%s", cr.Spec.VMStorage.GetNameWithPrefix(cr.Name), cr.Namespace, port)
+	return fmt.Sprintf("%s://%s.%s.svc:%s", protoFromFlags(cr.Spec.VMSelect.ExtraArgs), cr.Spec.VMStorage.GetNameWithPrefix(cr.Name), cr.Namespace, port)
 }
 
 // AsCRDOwner implements interface

api/operator/v1beta1/vmsingle_types.go

@@ -387,7 +387,7 @@ func (cr *VMSingle) AsURL() string {
 			}
 		}
 	}
-	return fmt.Sprintf("http://%s.%s.svc:%s", cr.PrefixedName(), cr.Namespace, port)
+	return fmt.Sprintf("%s://%s.%s.svc:%s", protoFromFlags(cr.Spec.ExtraArgs), cr.PrefixedName(), cr.Namespace, port)
 }
 
 // AsCRDOwner implements interface