enhance: Support otlp with insecure (#29115)

issue: https://github.com/milvus-io/milvus/issues/28914

Signed-off-by: Enwei Jiao <enwei.jiao@zilliz.com>

configs/milvus.yaml

@@ -703,12 +703,15 @@ quotaAndLimits:
 
 trace:
   # trace exporter type, default is stdout,
-  # optional values: ['stdout', 'jaeger']
+  # optional values: ['stdout', 'jaeger', 'otlp']
   exporter: stdout
   # fraction of traceID based sampler,
   # optional values: [0, 1]
   # Fractions >= 1 will always sample. Fractions < 0 are treated as zero.
   sampleFraction: 0
+  otlp:
+    endpoint: # "127.0.0.1:4318"
+    secure: true
   jaeger:
     url: # "http://127.0.0.1:14268/api/traces"
     # when exporter is jaeger should set the jaeger's URL

internal/core/src/common/Tracer.cpp

@@ -54,6 +54,7 @@ initTelementry(TraceConfig* config) {
     } else if (config->exporter == "otlp") {
         auto opts = otlp::OtlpGrpcExporterOptions{};
         opts.endpoint = config->otlpEndpoint;
+        opts.use_ssl_credentials = config->oltpSecure;
         exporter = otlp::OtlpGrpcExporterFactory::Create(opts);
         LOG_SEGCORE_INFO_ << "init otlp exporter, endpoint:" << opts.endpoint;
     } else {

internal/core/src/common/Tracer.h

@@ -24,6 +24,7 @@ struct TraceConfig {
     int sampleFraction;
     std::string jaegerURL;
     std::string otlpEndpoint;
+    bool oltpSecure;
 
     int nodeID;
 };

internal/core/src/common/init_c.cpp

@@ -76,6 +76,7 @@ InitTrace(CTraceConfig* config) {
                                                    config->sampleFraction,
                                                    config->jaegerURL,
                                                    config->otlpEndpoint,
+                                                   config->oltpSecure,
                                                    config->nodeID};
     std::call_once(
         traceFlag,

internal/core/src/common/type_c.h

@@ -95,6 +95,7 @@ typedef struct CTraceConfig {
     int sampleFraction;
     const char* jaegerURL;
     const char* otlpEndpoint;
+    bool oltpSecure;
 
     int nodeID;
 } CTraceConfig;

pkg/tracer/tracer.go

@@ -45,7 +45,14 @@ func Init() {
 		exp, err = jaeger.New(jaeger.WithCollectorEndpoint(
 			jaeger.WithEndpoint(params.TraceCfg.JaegerURL.GetValue())))
 	case "otlp":
-		exp, err = otlptracegrpc.New(context.Background(), otlptracegrpc.WithEndpoint(params.TraceCfg.OtlpEndpoint.GetValue()))
+		secure := params.TraceCfg.OtlpSecure.GetAsBool()
+		opts := []otlptracegrpc.Option{
+			otlptracegrpc.WithEndpoint(params.TraceCfg.OtlpEndpoint.GetValue()),
+		}
+		if !secure {
+			opts = append(opts, otlptracegrpc.WithInsecure())
+		}
+		exp, err = otlptracegrpc.New(context.Background(), opts...)
 	case "stdout":
 		exp, err = stdout.New()
 	default:

pkg/util/paramtable/component_param.go

@@ -671,6 +671,7 @@ type traceConfig struct {
 	SampleFraction ParamItem `refreshable:"false"`
 	JaegerURL      ParamItem `refreshable:"false"`
 	OtlpEndpoint   ParamItem `refreshable:"false"`
+	OtlpSecure     ParamItem `refreshable:"false"`
 }
 
 func (t *traceConfig) init(base *BaseTable) {
@@ -705,8 +706,16 @@ Fractions >= 1 will always sample. Fractions < 0 are treated as zero.`,
 	t.OtlpEndpoint = ParamItem{
 		Key:     "trace.otlp.endpoint",
 		Version: "2.3.0",
+		Doc:     "example: \"127.0.0.1:4318\"",
 	}
 	t.OtlpEndpoint.Init(base.mgr)
+
+	t.OtlpSecure = ParamItem{
+		Key:          "trace.otlp.secure",
+		Version:      "2.4.0",
+		DefaultValue: "true",
+	}
+	t.OtlpSecure.Init(base.mgr)
 }
 
 type logConfig struct {