feat : Integrated Configuration Center, Registry Component

go.mod

@@ -0,0 +1,72 @@
+module github.com/kitex-contrib/obs-opentelemetry
+
+go 1.21
+
+require (
+	github.com/apache/thrift v0.16.0 // indirect
+	github.com/bytedance/gopkg v0.0.0-20230728082804-614d0af6619b
+	github.com/cloudwego/kitex v0.9.1
+	github.com/stretchr/testify v1.8.4
+	go.opentelemetry.io/contrib/instrumentation/runtime v0.45.0
+	go.opentelemetry.io/contrib/propagators/b3 v1.20.0
+	go.opentelemetry.io/contrib/propagators/ot v1.20.0
+	go.opentelemetry.io/otel v1.19.0
+	go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetricgrpc v0.42.0
+	go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.19.0
+	go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.19.0
+	go.opentelemetry.io/otel/metric v1.19.0
+	go.opentelemetry.io/otel/sdk v1.19.0
+	go.opentelemetry.io/otel/sdk/metric v1.19.0
+	go.opentelemetry.io/otel/trace v1.19.0
+)
+
+require (
+	github.com/bytedance/sonic v1.11.2 // indirect
+	github.com/cenkalti/backoff/v4 v4.2.1 // indirect
+	github.com/chenzhuoyu/base64x v0.0.0-20230717121745-296ad89f973d // indirect
+	github.com/chenzhuoyu/iasm v0.9.1 // indirect
+	github.com/choleraehyq/pid v0.0.18 // indirect
+	github.com/cloudwego/configmanager v0.2.0 // indirect
+	github.com/cloudwego/dynamicgo v0.2.0 // indirect
+	github.com/cloudwego/fastpb v0.0.4 // indirect
+	github.com/cloudwego/frugal v0.1.14 // indirect
+	github.com/cloudwego/localsession v0.0.2 // indirect
+	github.com/cloudwego/netpoll v0.6.0 // indirect
+	github.com/cloudwego/thriftgo v0.3.6 // indirect
+	github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect
+	github.com/fatih/structtag v1.2.0 // indirect
+	github.com/go-logr/logr v1.3.0 // indirect
+	github.com/go-logr/stdr v1.2.2 // indirect
+	github.com/golang/protobuf v1.5.3 // indirect
+	github.com/google/pprof v0.0.0-20230509042627-b1315fad0c5a // indirect
+	github.com/grpc-ecosystem/grpc-gateway/v2 v2.18.0 // indirect
+	github.com/iancoleman/strcase v0.2.0 // indirect
+	github.com/jhump/protoreflect v1.8.2 // indirect
+	github.com/json-iterator/go v1.1.12 // indirect
+	github.com/klauspost/cpuid/v2 v2.2.4 // indirect
+	github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421 // indirect
+	github.com/modern-go/gls v0.0.0-20220109145502-612d0167dce5 // indirect
+	github.com/modern-go/reflect2 v1.0.2 // indirect
+	github.com/oleiade/lane v1.0.1 // indirect
+	github.com/pmezard/go-difflib v1.0.0 // indirect
+	github.com/tidwall/gjson v1.9.3 // indirect
+	github.com/tidwall/match v1.1.1 // indirect
+	github.com/tidwall/pretty v1.2.0 // indirect
+	github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
+	go.opentelemetry.io/otel/exporters/otlp/otlpmetric v0.42.0 // indirect
+	go.opentelemetry.io/proto/otlp v1.0.0 // indirect
+	go.uber.org/multierr v1.11.0 // indirect
+	golang.org/x/arch v0.2.0 // indirect
+	golang.org/x/net v0.17.0 // indirect
+	golang.org/x/sync v0.3.0 // indirect
+	golang.org/x/sys v0.13.0 // indirect
+	golang.org/x/text v0.13.0 // indirect
+	google.golang.org/genproto v0.0.0-20231012201019-e917dd12ba7a // indirect
+	google.golang.org/genproto/googleapis/api v0.0.0-20231016165738-49dd2c1f3d0b // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20231016165738-49dd2c1f3d0b // indirect
+	google.golang.org/grpc v1.59.0 // indirect
+	google.golang.org/protobuf v1.31.0 // indirect
+	gopkg.in/yaml.v3 v3.0.1 // indirect
+)
+
+replace github.com/apache/thrift => github.com/apache/thrift v0.13.0

go.work

@@ -0,0 +1,12 @@
+go 1.21
+
+use (
+	.
+	./logging/logrus
+	./logging/slog
+	./logging/zap
+	./logging/zerolog
+	tracing/hertzTracing
+)
+
+replace github.com/apache/thrift => github.com/apache/thrift v0.13.0

logging/default.go

@@ -0,0 +1,271 @@
+/*
+ * Copyright 2021 CloudWeGo Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package logging
+
+import (
+	"context"
+	"fmt"
+	"io"
+	"log"
+	"os"
+)
+
+var logger FullLogger = &defaultLogger{
+	level:  LevelInfo,
+	stdlog: log.New(os.Stderr, "", log.LstdFlags|log.Lshortfile|log.Lmicroseconds),
+}
+
+// SetOutput sets the output of default logger. By default, it is stderr.
+func SetOutput(w io.Writer) {
+	logger.SetOutput(w)
+}
+
+// SetLevel sets the level of logs below which logs will not be output.
+// The default log level is LevelTrace.
+// Note that this method is not concurrent-safe.
+func SetLevel(lv Level) {
+	logger.SetLevel(lv)
+}
+
+// DefaultLogger return the default logger for kitexTracing.
+func DefaultLogger() FullLogger {
+	return logger
+}
+
+// SetLogger sets the default logger.
+// Note that this method is not concurrent-safe and must not be called
+// after the use of DefaultLogger and global functions in this package.
+func SetLogger(v FullLogger) {
+	logger = v
+}
+
+// Fatal calls the default logger's Fatal method and then os.Exit(1).
+func Fatal(v ...interface{}) {
+	logger.Fatal(v...)
+}
+
+// Error calls the default logger's Error method.
+func Error(v ...interface{}) {
+	logger.Error(v...)
+}
+
+// Warn calls the default logger's Warn method.
+func Warn(v ...interface{}) {
+	logger.Warn(v...)
+}
+
+// Notice calls the default logger's Notice method.
+func Notice(v ...interface{}) {
+	logger.Notice(v...)
+}
+
+// Info calls the default logger's Info method.
+func Info(v ...interface{}) {
+	logger.Info(v...)
+}
+
+// Debug calls the default logger's Debug method.
+func Debug(v ...interface{}) {
+	logger.Debug(v...)
+}
+
+// Trace calls the default logger's Trace method.
+func Trace(v ...interface{}) {
+	logger.Trace(v...)
+}
+
+// Fatalf calls the default logger's Fatalf method and then os.Exit(1).
+func Fatalf(format string, v ...interface{}) {
+	logger.Fatalf(format, v...)
+}
+
+// Errorf calls the default logger's Errorf method.
+func Errorf(format string, v ...interface{}) {
+	logger.Errorf(format, v...)
+}
+
+// Warnf calls the default logger's Warnf method.
+func Warnf(format string, v ...interface{}) {
+	logger.Warnf(format, v...)
+}
+
+// Noticef calls the default logger's Noticef method.
+func Noticef(format string, v ...interface{}) {
+	logger.Noticef(format, v...)
+}
+
+// Infof calls the default logger's Infof method.
+func Infof(format string, v ...interface{}) {
+	logger.Infof(format, v...)
+}
+
+// Debugf calls the default logger's Debugf method.
+func Debugf(format string, v ...interface{}) {
+	logger.Debugf(format, v...)
+}
+
+// Tracef calls the default logger's Tracef method.
+func Tracef(format string, v ...interface{}) {
+	logger.Tracef(format, v...)
+}
+
+// CtxFatalf calls the default logger's CtxFatalf method and then os.Exit(1).
+func CtxFatalf(ctx context.Context, format string, v ...interface{}) {
+	logger.CtxFatalf(ctx, format, v...)
+}
+
+// CtxErrorf calls the default logger's CtxErrorf method.
+func CtxErrorf(ctx context.Context, format string, v ...interface{}) {
+	logger.CtxErrorf(ctx, format, v...)
+}
+
+// CtxWarnf calls the default logger's CtxWarnf method.
+func CtxWarnf(ctx context.Context, format string, v ...interface{}) {
+	logger.CtxWarnf(ctx, format, v...)
+}
+
+// CtxNoticef calls the default logger's CtxNoticef method.
+func CtxNoticef(ctx context.Context, format string, v ...interface{}) {
+	logger.CtxNoticef(ctx, format, v...)
+}
+
+// CtxInfof calls the default logger's CtxInfof method.
+func CtxInfof(ctx context.Context, format string, v ...interface{}) {
+	logger.CtxInfof(ctx, format, v...)
+}
+
+// CtxDebugf calls the default logger's CtxDebugf method.
+func CtxDebugf(ctx context.Context, format string, v ...interface{}) {
+	logger.CtxDebugf(ctx, format, v...)
+}
+
+// CtxTracef calls the default logger's CtxTracef method.
+func CtxTracef(ctx context.Context, format string, v ...interface{}) {
+	logger.CtxTracef(ctx, format, v...)
+}
+
+type defaultLogger struct {
+	stdlog *log.Logger
+	level  Level
+}
+
+func (ll *defaultLogger) SetOutput(w io.Writer) {
+	ll.stdlog.SetOutput(w)
+}
+
+func (ll *defaultLogger) SetLevel(lv Level) {
+	ll.level = lv
+}
+
+func (ll *defaultLogger) logf(lv Level, format *string, v ...interface{}) {
+	if ll.level > lv {
+		return
+	}
+	msg := lv.toString()
+	if format != nil {
+		msg += fmt.Sprintf(*format, v...)
+	} else {
+		msg += fmt.Sprint(v...)
+	}
+	ll.stdlog.Output(4, msg)
+	if lv == LevelFatal {
+		os.Exit(1)
+	}
+}
+
+func (ll *defaultLogger) Fatal(v ...interface{}) {
+	ll.logf(LevelFatal, nil, v...)
+}
+
+func (ll *defaultLogger) Error(v ...interface{}) {
+	ll.logf(LevelError, nil, v...)
+}
+
+func (ll *defaultLogger) Warn(v ...interface{}) {
+	ll.logf(LevelWarn, nil, v...)
+}
+
+func (ll *defaultLogger) Notice(v ...interface{}) {
+	ll.logf(LevelNotice, nil, v...)
+}
+
+func (ll *defaultLogger) Info(v ...interface{}) {
+	ll.logf(LevelInfo, nil, v...)
+}
+
+func (ll *defaultLogger) Debug(v ...interface{}) {
+	ll.logf(LevelDebug, nil, v...)
+}
+
+func (ll *defaultLogger) Trace(v ...interface{}) {
+	ll.logf(LevelTrace, nil, v...)
+}
+
+func (ll *defaultLogger) Fatalf(format string, v ...interface{}) {
+	ll.logf(LevelFatal, &format, v...)
+}
+
+func (ll *defaultLogger) Errorf(format string, v ...interface{}) {
+	ll.logf(LevelError, &format, v...)
+}
+
+func (ll *defaultLogger) Warnf(format string, v ...interface{}) {
+	ll.logf(LevelWarn, &format, v...)
+}
+
+func (ll *defaultLogger) Noticef(format string, v ...interface{}) {
+	ll.logf(LevelNotice, &format, v...)
+}
+
+func (ll *defaultLogger) Infof(format string, v ...interface{}) {
+	ll.logf(LevelInfo, &format, v...)
+}
+
+func (ll *defaultLogger) Debugf(format string, v ...interface{}) {
+	ll.logf(LevelDebug, &format, v...)
+}
+
+func (ll *defaultLogger) Tracef(format string, v ...interface{}) {
+	ll.logf(LevelTrace, &format, v...)
+}
+
+func (ll *defaultLogger) CtxFatalf(ctx context.Context, format string, v ...interface{}) {
+	ll.logf(LevelFatal, &format, v...)
+}
+
+func (ll *defaultLogger) CtxErrorf(ctx context.Context, format string, v ...interface{}) {
+	ll.logf(LevelError, &format, v...)
+}
+
+func (ll *defaultLogger) CtxWarnf(ctx context.Context, format string, v ...interface{}) {
+	ll.logf(LevelWarn, &format, v...)
+}
+
+func (ll *defaultLogger) CtxNoticef(ctx context.Context, format string, v ...interface{}) {
+	ll.logf(LevelNotice, &format, v...)
+}
+
+func (ll *defaultLogger) CtxInfof(ctx context.Context, format string, v ...interface{}) {
+	ll.logf(LevelInfo, &format, v...)
+}
+
+func (ll *defaultLogger) CtxDebugf(ctx context.Context, format string, v ...interface{}) {
+	ll.logf(LevelDebug, &format, v...)
+}
+
+func (ll *defaultLogger) CtxTracef(ctx context.Context, format string, v ...interface{}) {
+	ll.logf(LevelTrace, &format, v...)
+}