diff --git a/.example/net/gtrace/1.http/client/main.go b/.example/net/gtrace/1.http/client/main.go
deleted file mode 100644
index e22e606d1..000000000
--- a/.example/net/gtrace/1.http/client/main.go
+++ /dev/null
@@ -1,51 +0,0 @@
-package main
-
-import (
-	"context"
-	"github.com/gogf/gf/frame/g"
-	"github.com/gogf/gf/net/ghttp"
-	"github.com/gogf/gf/net/gtrace"
-	"go.opentelemetry.io/otel/baggage"
-	"go.opentelemetry.io/otel/exporters/trace/jaeger"
-	"go.opentelemetry.io/otel/label"
-	sdkTrace "go.opentelemetry.io/otel/sdk/trace"
-)
-
-const (
-	JaegerEndpoint = "http://localhost:14268/api/traces"
-	ServiceName    = "tracing-http-client"
-)
-
-// initTracer creates a new trace provider instance and registers it as global trace provider.
-func initTracer() func() {
-	// Create and install Jaeger export pipeline.
-	flush, err := jaeger.InstallNewPipeline(
-		jaeger.WithCollectorEndpoint(JaegerEndpoint),
-		jaeger.WithProcess(jaeger.Process{
-			ServiceName: ServiceName,
-		}),
-		jaeger.WithSDK(&sdkTrace.Config{DefaultSampler: sdkTrace.AlwaysSample()}),
-	)
-	if err != nil {
-		g.Log().Fatal(err)
-	}
-	return flush
-}
-
-func StartRequests() {
-	ctx, span := gtrace.Tracer().Start(context.Background(), "StartRequests")
-	defer span.End()
-
-	ctx = baggage.ContextWithValues(ctx, label.String("name", "john"))
-	client := g.Client().Use(ghttp.MiddlewareClientTracing)
-
-	content := client.Ctx(ctx).GetContent("http://127.0.0.1:8199/hello")
-	g.Log().Ctx(ctx).Print(content)
-}
-
-func main() {
-	flush := initTracer()
-	defer flush()
-
-	StartRequests()
-}
diff --git a/.example/net/gtrace/1.http/server/main.go b/.example/net/gtrace/1.http/server/main.go
deleted file mode 100644
index 7c6a2687c..000000000
--- a/.example/net/gtrace/1.http/server/main.go
+++ /dev/null
@@ -1,52 +0,0 @@
-package main
-
-import (
-	"github.com/gogf/gf/frame/g"
-	"github.com/gogf/gf/net/ghttp"
-	"github.com/gogf/gf/net/gtrace"
-	"go.opentelemetry.io/otel/baggage"
-	"go.opentelemetry.io/otel/exporters/trace/jaeger"
-	sdkTrace "go.opentelemetry.io/otel/sdk/trace"
-)
-
-const (
-	JaegerEndpoint = "http://localhost:14268/api/traces"
-	ServiceName    = "tracing-http-server"
-)
-
-// initTracer creates a new trace provider instance and registers it as global trace provider.
-func initTracer() func() {
-	// Create and install Jaeger export pipeline.
-	flush, err := jaeger.InstallNewPipeline(
-		jaeger.WithCollectorEndpoint(JaegerEndpoint),
-		jaeger.WithProcess(jaeger.Process{
-			ServiceName: ServiceName,
-		}),
-		jaeger.WithSDK(&sdkTrace.Config{DefaultSampler: sdkTrace.AlwaysSample()}),
-	)
-	if err != nil {
-		g.Log().Fatal(err)
-	}
-	return flush
-}
-
-func main() {
-	flush := initTracer()
-	defer flush()
-
-	s := g.Server()
-	s.Group("/", func(group *ghttp.RouterGroup) {
-		group.Middleware(ghttp.MiddlewareServerTracing)
-		group.GET("/hello", helloHandler)
-	})
-	s.SetPort(8199)
-	s.Run()
-}
-
-func helloHandler(r *ghttp.Request) {
-	ctx, span := gtrace.Tracer().Start(r.Context(), "helloHandler")
-	defer span.End()
-
-	value := baggage.Value(ctx, "name")
-	r.Response.Write("hello:", value.AsString())
-}
diff --git a/.example/net/gtrace/2.http+db/config.toml b/.example/net/gtrace/2.http+db/config.toml
deleted file mode 100644
index 643cb6089..000000000
--- a/.example/net/gtrace/2.http+db/config.toml
+++ /dev/null
@@ -1,19 +0,0 @@
-
-# MySQL.
-[database]
-    [database.logger]
-        level   = "all"
-        stdout  = true
-    [database.default]
-        link   = "mysql:root:12345678@tcp(127.0.0.1:3306)/test"
-        debug  = true
-
-# Redis.
-[redis]
-    default = "127.0.0.1:6379,0"
-    cache   = "127.0.0.1:6379,1"
-
-
-
-
-
diff --git a/.example/net/gtrace/2.http+db/main.go b/.example/net/gtrace/2.http+db/main.go
deleted file mode 100644
index c85061135..000000000
--- a/.example/net/gtrace/2.http+db/main.go
+++ /dev/null
@@ -1,64 +0,0 @@
-package main
-
-import (
-	"github.com/gogf/gf/errors/gerror"
-	"github.com/gogf/gf/frame/g"
-	"github.com/gogf/gf/net/ghttp"
-	"go.opentelemetry.io/otel/exporters/trace/jaeger"
-	sdkTrace "go.opentelemetry.io/otel/sdk/trace"
-)
-
-type tracingApi struct{}
-
-const (
-	JaegerEndpoint = "http://localhost:14268/api/traces"
-	ServiceName    = "tracing-demo-db"
-)
-
-// initTracer creates a new trace provider instance and registers it as global trace provider.
-func initTracer() func() {
-	// Create and install Jaeger export pipeline.
-	flush, err := jaeger.InstallNewPipeline(
-		jaeger.WithCollectorEndpoint(JaegerEndpoint),
-		jaeger.WithProcess(jaeger.Process{
-			ServiceName: ServiceName,
-		}),
-		jaeger.WithSDK(&sdkTrace.Config{DefaultSampler: sdkTrace.AlwaysSample()}),
-	)
-	if err != nil {
-		g.Log().Fatal(err)
-	}
-	return flush
-}
-
-func (api *tracingApi) Insert(r *ghttp.Request) {
-	result, err := g.Table("user").Ctx(r.Context()).Insert(g.Map{
-		"name": r.GetString("name"),
-	})
-	if err != nil {
-		r.Response.WriteExit(gerror.Current(err))
-	}
-	id, _ := result.LastInsertId()
-	r.Response.Write("id:", id)
-}
-
-func (api *tracingApi) Query(r *ghttp.Request) {
-	one, err := g.Table("user").Ctx(r.Context()).FindOne(r.GetInt("id"))
-	if err != nil {
-		r.Response.WriteExit(gerror.Current(err))
-	}
-	r.Response.Write("user:", one)
-}
-
-func main() {
-	flush := initTracer()
-	defer flush()
-
-	s := g.Server()
-	s.Group("/", func(group *ghttp.RouterGroup) {
-		group.Middleware(ghttp.MiddlewareServerTracing)
-		group.ALL("/user", new(tracingApi))
-	})
-	s.SetPort(8199)
-	s.Run()
-}
diff --git a/.example/net/gtrace/3.http+redis/config.toml b/.example/net/gtrace/3.http+redis/config.toml
deleted file mode 100644
index a1e7b2d69..000000000
--- a/.example/net/gtrace/3.http+redis/config.toml
+++ /dev/null
@@ -1,10 +0,0 @@
-
-# Redis.
-[redis]
-    default = "127.0.0.1:6379,0"
-    cache   = "127.0.0.1:6379,1"
-
-
-
-
-
diff --git a/.example/net/gtrace/3.http+redis/main.go b/.example/net/gtrace/3.http+redis/main.go
deleted file mode 100644
index 35788087f..000000000
--- a/.example/net/gtrace/3.http+redis/main.go
+++ /dev/null
@@ -1,63 +0,0 @@
-package main
-
-import (
-	"github.com/gogf/gf/errors/gerror"
-	"github.com/gogf/gf/frame/g"
-	"github.com/gogf/gf/net/ghttp"
-	"go.opentelemetry.io/otel/exporters/trace/jaeger"
-	sdkTrace "go.opentelemetry.io/otel/sdk/trace"
-)
-
-type tracingApi struct{}
-
-const (
-	JaegerEndpoint = "http://localhost:14268/api/traces"
-	ServiceName    = "tracing-demo-redis"
-)
-
-func (api *tracingApi) Set(r *ghttp.Request) {
-	_, err := g.Redis().Ctx(r.Context()).Do("SET", r.GetString("key"), r.GetString("value"))
-	if err != nil {
-		r.Response.WriteExit(gerror.Current(err))
-	}
-	r.Response.Write("ok")
-}
-
-func (api *tracingApi) Get(r *ghttp.Request) {
-	value, err := g.Redis().Ctx(r.Context()).DoVar(
-		"GET", r.GetString("key"),
-	)
-	if err != nil {
-		r.Response.WriteExit(gerror.Current(err))
-	}
-	r.Response.Write(value.String())
-}
-
-// initTracer creates a new trace provider instance and registers it as global trace provider.
-func initTracer() func() {
-	// Create and install Jaeger export pipeline.
-	flush, err := jaeger.InstallNewPipeline(
-		jaeger.WithCollectorEndpoint(JaegerEndpoint),
-		jaeger.WithProcess(jaeger.Process{
-			ServiceName: ServiceName,
-		}),
-		jaeger.WithSDK(&sdkTrace.Config{DefaultSampler: sdkTrace.AlwaysSample()}),
-	)
-	if err != nil {
-		g.Log().Fatal(err)
-	}
-	return flush
-}
-
-func main() {
-	flush := initTracer()
-	defer flush()
-
-	s := g.Server()
-	s.Group("/", func(group *ghttp.RouterGroup) {
-		group.Middleware(ghttp.MiddlewareServerTracing)
-		group.ALL("/redis", new(tracingApi))
-	})
-	s.SetPort(8199)
-	s.Run()
-}
diff --git a/.example/net/gtrace/4.http+db+redis+log/client/main.go b/.example/net/gtrace/4.http+db+redis+log/client/main.go
deleted file mode 100644
index 353a58bcf..000000000
--- a/.example/net/gtrace/4.http+db+redis+log/client/main.go
+++ /dev/null
@@ -1,74 +0,0 @@
-package main
-
-import (
-	"context"
-	"github.com/gogf/gf/frame/g"
-	"github.com/gogf/gf/net/ghttp"
-	"github.com/gogf/gf/net/gtrace"
-	"go.opentelemetry.io/otel/exporters/trace/jaeger"
-	sdkTrace "go.opentelemetry.io/otel/sdk/trace"
-)
-
-const (
-	JaegerEndpoint = "http://localhost:14268/api/traces"
-	ServiceName    = "tracing-http-client"
-)
-
-// initTracer creates a new trace provider instance and registers it as global trace provider.
-func initTracer() func() {
-	// Create and install Jaeger export pipeline.
-	flush, err := jaeger.InstallNewPipeline(
-		jaeger.WithCollectorEndpoint(JaegerEndpoint),
-		jaeger.WithProcess(jaeger.Process{
-			ServiceName: ServiceName,
-		}),
-		jaeger.WithSDK(&sdkTrace.Config{DefaultSampler: sdkTrace.AlwaysSample()}),
-	)
-	if err != nil {
-		g.Log().Fatal(err)
-	}
-	return flush
-}
-
-func StartRequests() {
-	ctx, span := gtrace.Tracer().Start(context.Background(), "StartRequests")
-	defer span.End()
-
-	client := g.Client().Use(ghttp.MiddlewareClientTracing)
-	// Add user info.
-	idStr := client.Ctx(ctx).PostContent(
-		"http://127.0.0.1:8199/user/insert",
-		g.Map{
-			"name": "john",
-		},
-	)
-	if idStr == "" {
-		g.Log().Ctx(ctx).Fatal("retrieve empty id string")
-	}
-	g.Log().Ctx(ctx).Print("insert:", idStr)
-
-	// Query user info.
-	userJson := client.Ctx(ctx).GetContent(
-		"http://127.0.0.1:8199/user/query",
-		g.Map{
-			"id": idStr,
-		},
-	)
-	g.Log().Ctx(ctx).Print("query:", idStr, userJson)
-
-	// Delete user info.
-	deleteResult := client.Ctx(ctx).PostContent(
-		"http://127.0.0.1:8199/user/delete",
-		g.Map{
-			"id": idStr,
-		},
-	)
-	g.Log().Ctx(ctx).Print("delete:", idStr, deleteResult)
-}
-
-func main() {
-	flush := initTracer()
-	defer flush()
-
-	StartRequests()
-}
diff --git a/.example/net/gtrace/4.http+db+redis+log/server/config.toml b/.example/net/gtrace/4.http+db+redis+log/server/config.toml
deleted file mode 100644
index 451299306..000000000
--- a/.example/net/gtrace/4.http+db+redis+log/server/config.toml
+++ /dev/null
@@ -1,19 +0,0 @@
-
-# MySQL.
-[database]
-    [database.logger]
-        level   = "all"
-        stdout  = true
-    [database.default]
-        link    = "mysql:root:12345678@tcp(127.0.0.1:3306)/test"
-        debug   = true
-
-# Redis.
-[redis]
-    default = "127.0.0.1:6379,0"
-    cache   = "127.0.0.1:6379,1"
-
-
-
-
-
diff --git a/.example/net/gtrace/4.http+db+redis+log/server/main.go b/.example/net/gtrace/4.http+db+redis+log/server/main.go
deleted file mode 100644
index 4b244fb4c..000000000
--- a/.example/net/gtrace/4.http+db+redis+log/server/main.go
+++ /dev/null
@@ -1,122 +0,0 @@
-package main
-
-import (
-	"fmt"
-	"github.com/gogf/gcache-adapter/adapter"
-	"github.com/gogf/gf/errors/gerror"
-	"github.com/gogf/gf/frame/g"
-	"github.com/gogf/gf/net/ghttp"
-	"go.opentelemetry.io/otel/exporters/trace/jaeger"
-	sdkTrace "go.opentelemetry.io/otel/sdk/trace"
-	"time"
-)
-
-type tracingApi struct{}
-
-const (
-	JaegerEndpoint = "http://localhost:14268/api/traces"
-	ServiceName    = "tracing-http-server"
-)
-
-// initTracer creates a new trace provider instance and registers it as global trace provider.
-func initTracer() func() {
-	// Create and install Jaeger export pipeline.
-	flush, err := jaeger.InstallNewPipeline(
-		jaeger.WithCollectorEndpoint(JaegerEndpoint),
-		jaeger.WithProcess(jaeger.Process{
-			ServiceName: ServiceName,
-		}),
-		jaeger.WithSDK(&sdkTrace.Config{DefaultSampler: sdkTrace.AlwaysSample()}),
-	)
-	if err != nil {
-		g.Log().Fatal(err)
-	}
-	return flush
-}
-
-type userApiInsert struct {
-	Name string `v:"required#Please input user name."`
-}
-
-// Insert is a route handler for inserting user info into dtabase.
-func (api *tracingApi) Insert(r *ghttp.Request) {
-	var (
-		dataReq *userApiInsert
-	)
-	if err := r.Parse(&dataReq); err != nil {
-		r.Response.WriteExit(gerror.Current(err))
-	}
-	result, err := g.Table("user").Ctx(r.Context()).Insert(g.Map{
-		"name": dataReq.Name,
-	})
-	if err != nil {
-		r.Response.WriteExit(gerror.Current(err))
-	}
-	id, _ := result.LastInsertId()
-	r.Response.Write(id)
-}
-
-type userApiQuery struct {
-	Id int `v:"min:1#User id is required for querying."`
-}
-
-// Query is a route handler for querying user info. It firstly retrieves the info from redis,
-// if there's nothing in the redis, it then does db select.
-func (api *tracingApi) Query(r *ghttp.Request) {
-	var (
-		dataReq *userApiQuery
-	)
-	if err := r.Parse(&dataReq); err != nil {
-		r.Response.WriteExit(gerror.Current(err))
-	}
-	one, err := g.Table("user").
-		Ctx(r.Context()).
-		Cache(5*time.Second, api.userCacheKey(dataReq.Id)).
-		FindOne(dataReq.Id)
-	if err != nil {
-		r.Response.WriteExit(gerror.Current(err))
-	}
-	r.Response.WriteJson(one)
-}
-
-type userApiDelete struct {
-	Id int `v:"min:1#User id is required for deleting."`
-}
-
-// Delete is a route handler for deleting specified user info.
-func (api *tracingApi) Delete(r *ghttp.Request) {
-	var (
-		dataReq *userApiDelete
-	)
-	if err := r.Parse(&dataReq); err != nil {
-		r.Response.WriteExit(gerror.Current(err))
-	}
-	_, err := g.Table("user").
-		Ctx(r.Context()).
-		Cache(-1, api.userCacheKey(dataReq.Id)).
-		WherePri(dataReq.Id).
-		Delete()
-	if err != nil {
-		r.Response.WriteExit(gerror.Current(err))
-	}
-	r.Response.Write("ok")
-}
-
-func (api *tracingApi) userCacheKey(id int) string {
-	return fmt.Sprintf(`userInfo:%d`, id)
-}
-
-func main() {
-	flush := initTracer()
-	defer flush()
-
-	g.DB().GetCache().SetAdapter(adapter.NewRedis(g.Redis()))
-
-	s := g.Server()
-	s.Group("/", func(group *ghttp.RouterGroup) {
-		group.Middleware(ghttp.MiddlewareServerTracing)
-		group.ALL("/user", new(tracingApi))
-	})
-	s.SetPort(8199)
-	s.Run()
-}
diff --git a/.example/net/gtrace/5.grpc+db+redis+log/client/main.go b/.example/net/gtrace/5.grpc+db+redis+log/client/main.go
deleted file mode 100644
index 3da3dc5f5..000000000
--- a/.example/net/gtrace/5.grpc+db+redis+log/client/main.go
+++ /dev/null
@@ -1,80 +0,0 @@
-package main
-
-import (
-	"context"
-	"github.com/gogf/gf/.example/net/gtrace/5.grpc+db+redis+log/protobuf/user"
-	"github.com/gogf/gf/frame/g"
-	"github.com/gogf/gf/net/gtrace"
-	"go.opentelemetry.io/otel/exporters/trace/jaeger"
-	sdkTrace "go.opentelemetry.io/otel/sdk/trace"
-	"google.golang.org/grpc"
-)
-
-const (
-	JaegerEndpoint = "http://localhost:14268/api/traces"
-	ServiceName    = "tracing-grpc-client"
-)
-
-// initTracer creates a new trace provider instance and registers it as global trace provider.
-func initTracer() func() {
-	// Create and install Jaeger export pipeline.
-	flush, err := jaeger.InstallNewPipeline(
-		jaeger.WithCollectorEndpoint(JaegerEndpoint),
-		jaeger.WithProcess(jaeger.Process{
-			ServiceName: ServiceName,
-		}),
-		jaeger.WithSDK(&sdkTrace.Config{DefaultSampler: sdkTrace.AlwaysSample()}),
-	)
-	if err != nil {
-		g.Log().Fatal(err)
-	}
-	return flush
-}
-
-func StartRequests() {
-	ctx, span := gtrace.Tracer().Start(context.Background(), "StartRequests")
-	defer span.End()
-
-	conn, err := grpc.Dial(":8000", grpc.WithInsecure(), grpc.WithBlock())
-	if err != nil {
-		g.Log().Fatalf("did not connect: %v", err)
-	}
-	defer conn.Close()
-
-	client := user.NewUserClient(conn)
-
-	// Insert.
-	insertRes, err := client.Insert(ctx, &user.InsertReq{
-		Name: "john",
-	})
-	if err != nil {
-		g.Log().Ctx(ctx).Fatalf(`%+v`, err)
-	}
-	g.Log().Ctx(ctx).Println("insert:", insertRes.Id)
-
-	// Query.
-	queryRes, err := client.Query(ctx, &user.QueryReq{
-		Id: insertRes.Id,
-	})
-	if err != nil {
-		g.Log().Ctx(ctx).Fatalf(`%+v`, err)
-	}
-	g.Log().Ctx(ctx).Println("query:", queryRes)
-
-	// Delete.
-	_, err = client.Delete(ctx, &user.DeleteReq{
-		Id: insertRes.Id,
-	})
-	if err != nil {
-		g.Log().Ctx(ctx).Fatalf(`%+v`, err)
-	}
-	g.Log().Ctx(ctx).Println("delete:", "ok")
-
-}
-
-func main() {
-	flush := initTracer()
-	defer flush()
-
-	StartRequests()
-}
diff --git a/.example/net/gtrace/5.grpc+db+redis+log/protobuf/user/user.pb.go b/.example/net/gtrace/5.grpc+db+redis+log/protobuf/user/user.pb.go
deleted file mode 100644
index 89fcfd05d..000000000
--- a/.example/net/gtrace/5.grpc+db+redis+log/protobuf/user/user.pb.go
+++ /dev/null
@@ -1,1336 +0,0 @@
-// Code generated by protoc-gen-gogo. DO NOT EDIT.
-// source: protocol/user.proto
-
-package user
-
-import (
-	context "context"
-	fmt "fmt"
-	_ "github.com/gogo/protobuf/gogoproto"
-	proto "github.com/golang/protobuf/proto"
-	grpc "google.golang.org/grpc"
-	codes "google.golang.org/grpc/codes"
-	status "google.golang.org/grpc/status"
-	io "io"
-	math "math"
-	math_bits "math/bits"
-)
-
-// Reference imports to suppress errors if they are not otherwise used.
-var _ = proto.Marshal
-var _ = fmt.Errorf
-var _ = math.Inf
-
-// This is a compile-time assertion to ensure that this generated file
-// is compatible with the proto package it is being compiled against.
-// A compilation error at this line likely means your copy of the
-// proto package needs to be updated.
-const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
-
-type InsertReq struct {
-	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty" v:"required#Please input user name."`
-	XXX_NoUnkeyedLiteral struct{} `json:"-"`
-	XXX_unrecognized     []byte   `json:"-"`
-	XXX_sizecache        int32    `json:"-"`
-}
-
-func (m *InsertReq) Reset()         { *m = InsertReq{} }
-func (m *InsertReq) String() string { return proto.CompactTextString(m) }
-func (*InsertReq) ProtoMessage()    {}
-func (*InsertReq) Descriptor() ([]byte, []int) {
-	return fileDescriptor_fe658c3c35e8c4bc, []int{0}
-}
-func (m *InsertReq) XXX_Unmarshal(b []byte) error {
-	return m.Unmarshal(b)
-}
-func (m *InsertReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
-	if deterministic {
-		return xxx_messageInfo_InsertReq.Marshal(b, m, deterministic)
-	} else {
-		b = b[:cap(b)]
-		n, err := m.MarshalToSizedBuffer(b)
-		if err != nil {
-			return nil, err
-		}
-		return b[:n], nil
-	}
-}
-func (m *InsertReq) XXX_Merge(src proto.Message) {
-	xxx_messageInfo_InsertReq.Merge(m, src)
-}
-func (m *InsertReq) XXX_Size() int {
-	return m.Size()
-}
-func (m *InsertReq) XXX_DiscardUnknown() {
-	xxx_messageInfo_InsertReq.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_InsertReq proto.InternalMessageInfo
-
-func (m *InsertReq) GetName() string {
-	if m != nil {
-		return m.Name
-	}
-	return ""
-}
-
-type InsertRes struct {
-	Id                   int32    `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"`
-	XXX_NoUnkeyedLiteral struct{} `json:"-"`
-	XXX_unrecognized     []byte   `json:"-"`
-	XXX_sizecache        int32    `json:"-"`
-}
-
-func (m *InsertRes) Reset()         { *m = InsertRes{} }
-func (m *InsertRes) String() string { return proto.CompactTextString(m) }
-func (*InsertRes) ProtoMessage()    {}
-func (*InsertRes) Descriptor() ([]byte, []int) {
-	return fileDescriptor_fe658c3c35e8c4bc, []int{1}
-}
-func (m *InsertRes) XXX_Unmarshal(b []byte) error {
-	return m.Unmarshal(b)
-}
-func (m *InsertRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
-	if deterministic {
-		return xxx_messageInfo_InsertRes.Marshal(b, m, deterministic)
-	} else {
-		b = b[:cap(b)]
-		n, err := m.MarshalToSizedBuffer(b)
-		if err != nil {
-			return nil, err
-		}
-		return b[:n], nil
-	}
-}
-func (m *InsertRes) XXX_Merge(src proto.Message) {
-	xxx_messageInfo_InsertRes.Merge(m, src)
-}
-func (m *InsertRes) XXX_Size() int {
-	return m.Size()
-}
-func (m *InsertRes) XXX_DiscardUnknown() {
-	xxx_messageInfo_InsertRes.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_InsertRes proto.InternalMessageInfo
-
-func (m *InsertRes) GetId() int32 {
-	if m != nil {
-		return m.Id
-	}
-	return 0
-}
-
-type QueryReq struct {
-	Id                   int32    `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty" v:"min:1#User id is required for querying."`
-	XXX_NoUnkeyedLiteral struct{} `json:"-"`
-	XXX_unrecognized     []byte   `json:"-"`
-	XXX_sizecache        int32    `json:"-"`
-}
-
-func (m *QueryReq) Reset()         { *m = QueryReq{} }
-func (m *QueryReq) String() string { return proto.CompactTextString(m) }
-func (*QueryReq) ProtoMessage()    {}
-func (*QueryReq) Descriptor() ([]byte, []int) {
-	return fileDescriptor_fe658c3c35e8c4bc, []int{2}
-}
-func (m *QueryReq) XXX_Unmarshal(b []byte) error {
-	return m.Unmarshal(b)
-}
-func (m *QueryReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
-	if deterministic {
-		return xxx_messageInfo_QueryReq.Marshal(b, m, deterministic)
-	} else {
-		b = b[:cap(b)]
-		n, err := m.MarshalToSizedBuffer(b)
-		if err != nil {
-			return nil, err
-		}
-		return b[:n], nil
-	}
-}
-func (m *QueryReq) XXX_Merge(src proto.Message) {
-	xxx_messageInfo_QueryReq.Merge(m, src)
-}
-func (m *QueryReq) XXX_Size() int {
-	return m.Size()
-}
-func (m *QueryReq) XXX_DiscardUnknown() {
-	xxx_messageInfo_QueryReq.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_QueryReq proto.InternalMessageInfo
-
-func (m *QueryReq) GetId() int32 {
-	if m != nil {
-		return m.Id
-	}
-	return 0
-}
-
-type QueryRes struct {
-	Id                   int32    `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"`
-	Name                 string   `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
-	XXX_NoUnkeyedLiteral struct{} `json:"-"`
-	XXX_unrecognized     []byte   `json:"-"`
-	XXX_sizecache        int32    `json:"-"`
-}
-
-func (m *QueryRes) Reset()         { *m = QueryRes{} }
-func (m *QueryRes) String() string { return proto.CompactTextString(m) }
-func (*QueryRes) ProtoMessage()    {}
-func (*QueryRes) Descriptor() ([]byte, []int) {
-	return fileDescriptor_fe658c3c35e8c4bc, []int{3}
-}
-func (m *QueryRes) XXX_Unmarshal(b []byte) error {
-	return m.Unmarshal(b)
-}
-func (m *QueryRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
-	if deterministic {
-		return xxx_messageInfo_QueryRes.Marshal(b, m, deterministic)
-	} else {
-		b = b[:cap(b)]
-		n, err := m.MarshalToSizedBuffer(b)
-		if err != nil {
-			return nil, err
-		}
-		return b[:n], nil
-	}
-}
-func (m *QueryRes) XXX_Merge(src proto.Message) {
-	xxx_messageInfo_QueryRes.Merge(m, src)
-}
-func (m *QueryRes) XXX_Size() int {
-	return m.Size()
-}
-func (m *QueryRes) XXX_DiscardUnknown() {
-	xxx_messageInfo_QueryRes.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_QueryRes proto.InternalMessageInfo
-
-func (m *QueryRes) GetId() int32 {
-	if m != nil {
-		return m.Id
-	}
-	return 0
-}
-
-func (m *QueryRes) GetName() string {
-	if m != nil {
-		return m.Name
-	}
-	return ""
-}
-
-type DeleteReq struct {
-	Id                   int32    `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty" v:"required#User id is required for deleting."`
-	XXX_NoUnkeyedLiteral struct{} `json:"-"`
-	XXX_unrecognized     []byte   `json:"-"`
-	XXX_sizecache        int32    `json:"-"`
-}
-
-func (m *DeleteReq) Reset()         { *m = DeleteReq{} }
-func (m *DeleteReq) String() string { return proto.CompactTextString(m) }
-func (*DeleteReq) ProtoMessage()    {}
-func (*DeleteReq) Descriptor() ([]byte, []int) {
-	return fileDescriptor_fe658c3c35e8c4bc, []int{4}
-}
-func (m *DeleteReq) XXX_Unmarshal(b []byte) error {
-	return m.Unmarshal(b)
-}
-func (m *DeleteReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
-	if deterministic {
-		return xxx_messageInfo_DeleteReq.Marshal(b, m, deterministic)
-	} else {
-		b = b[:cap(b)]
-		n, err := m.MarshalToSizedBuffer(b)
-		if err != nil {
-			return nil, err
-		}
-		return b[:n], nil
-	}
-}
-func (m *DeleteReq) XXX_Merge(src proto.Message) {
-	xxx_messageInfo_DeleteReq.Merge(m, src)
-}
-func (m *DeleteReq) XXX_Size() int {
-	return m.Size()
-}
-func (m *DeleteReq) XXX_DiscardUnknown() {
-	xxx_messageInfo_DeleteReq.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_DeleteReq proto.InternalMessageInfo
-
-func (m *DeleteReq) GetId() int32 {
-	if m != nil {
-		return m.Id
-	}
-	return 0
-}
-
-type DeleteRes struct {
-	XXX_NoUnkeyedLiteral struct{} `json:"-"`
-	XXX_unrecognized     []byte   `json:"-"`
-	XXX_sizecache        int32    `json:"-"`
-}
-
-func (m *DeleteRes) Reset()         { *m = DeleteRes{} }
-func (m *DeleteRes) String() string { return proto.CompactTextString(m) }
-func (*DeleteRes) ProtoMessage()    {}
-func (*DeleteRes) Descriptor() ([]byte, []int) {
-	return fileDescriptor_fe658c3c35e8c4bc, []int{5}
-}
-func (m *DeleteRes) XXX_Unmarshal(b []byte) error {
-	return m.Unmarshal(b)
-}
-func (m *DeleteRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
-	if deterministic {
-		return xxx_messageInfo_DeleteRes.Marshal(b, m, deterministic)
-	} else {
-		b = b[:cap(b)]
-		n, err := m.MarshalToSizedBuffer(b)
-		if err != nil {
-			return nil, err
-		}
-		return b[:n], nil
-	}
-}
-func (m *DeleteRes) XXX_Merge(src proto.Message) {
-	xxx_messageInfo_DeleteRes.Merge(m, src)
-}
-func (m *DeleteRes) XXX_Size() int {
-	return m.Size()
-}
-func (m *DeleteRes) XXX_DiscardUnknown() {
-	xxx_messageInfo_DeleteRes.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_DeleteRes proto.InternalMessageInfo
-
-func init() {
-	proto.RegisterType((*InsertReq)(nil), "demos.InsertReq")
-	proto.RegisterType((*InsertRes)(nil), "demos.InsertRes")
-	proto.RegisterType((*QueryReq)(nil), "demos.QueryReq")
-	proto.RegisterType((*QueryRes)(nil), "demos.QueryRes")
-	proto.RegisterType((*DeleteReq)(nil), "demos.DeleteReq")
-	proto.RegisterType((*DeleteRes)(nil), "demos.DeleteRes")
-}
-
-func init() { proto.RegisterFile("protocol/user.proto", fileDescriptor_fe658c3c35e8c4bc) }
-
-var fileDescriptor_fe658c3c35e8c4bc = []byte{
-	// 358 bytes of a gzipped FileDescriptorProto
-	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x74, 0x52, 0xcb, 0x4a, 0xc3, 0x40,
-	0x14, 0x6d, 0x4a, 0x5b, 0xec, 0x88, 0x0f, 0xc6, 0x8d, 0x44, 0x48, 0x86, 0xa9, 0x8b, 0x42, 0x71,
-	0x82, 0x75, 0x57, 0x04, 0x21, 0xb8, 0x09, 0x82, 0x8f, 0x82, 0x1b, 0x77, 0x6d, 0x73, 0x1b, 0x07,
-	0x9a, 0x4c, 0x3b, 0x93, 0x14, 0xfc, 0x0e, 0x37, 0x7e, 0x92, 0x4b, 0xbf, 0xa0, 0x48, 0xfd, 0x83,
-	0x7e, 0x81, 0xcc, 0xb4, 0x4d, 0x4a, 0xc4, 0x5d, 0xce, 0xbd, 0x39, 0xe7, 0xdc, 0x73, 0xef, 0xa0,
-	0x93, 0xa9, 0x14, 0xa9, 0x18, 0x89, 0x89, 0x97, 0x29, 0x90, 0xcc, 0x20, 0x5c, 0x0f, 0x21, 0x16,
-	0xca, 0xbe, 0x88, 0x78, 0xfa, 0x9a, 0x0d, 0xd9, 0x48, 0xc4, 0x5e, 0x24, 0x22, 0xe1, 0x99, 0xee,
-	0x30, 0x1b, 0x1b, 0x64, 0x80, 0xf9, 0x5a, 0xb3, 0x68, 0x80, 0x9a, 0x41, 0xa2, 0x40, 0xa6, 0x7d,
-	0x98, 0xe1, 0x6b, 0x54, 0xbb, 0x1f, 0xc4, 0x70, 0x6a, 0x11, 0xab, 0xdd, 0xf4, 0xdb, 0xab, 0x85,
-	0x7b, 0x3e, 0xef, 0x51, 0x09, 0xb3, 0x8c, 0x4b, 0x08, 0x5b, 0x8f, 0x13, 0x18, 0x28, 0x20, 0x3c,
-	0x99, 0x66, 0x29, 0xd1, 0xce, 0x24, 0x19, 0xc4, 0xc0, 0x68, 0xdf, 0xb0, 0xe8, 0x59, 0x21, 0xa5,
-	0xf0, 0x21, 0xaa, 0x06, 0xa1, 0x11, 0xaa, 0xf7, 0xab, 0x41, 0x48, 0xef, 0xd0, 0xde, 0x53, 0x06,
-	0xf2, 0x4d, 0xdb, 0xdc, 0x14, 0x3d, 0xdf, 0x5b, 0x2d, 0xdc, 0xce, 0xbc, 0x47, 0x63, 0x9e, 0xf4,
-	0x2e, 0x5b, 0xcf, 0x5a, 0x94, 0x87, 0x84, 0x2b, 0xb2, 0x75, 0x25, 0x63, 0x21, 0xc9, 0x4c, 0x53,
-	0x79, 0x12, 0x31, 0x6a, 0xc4, 0x58, 0x2e, 0xf6, 0xc7, 0x08, 0xe3, 0x4d, 0x86, 0xaa, 0xce, 0xb0,
-	0x99, 0xec, 0x01, 0x35, 0x6f, 0x61, 0x02, 0x29, 0x68, 0x77, 0x7f, 0xc7, 0xbd, 0xbb, 0x5a, 0xb8,
-	0x6c, 0x37, 0xe2, 0x7f, 0x03, 0x84, 0x9a, 0x5e, 0x0c, 0xb0, 0x5f, 0x08, 0xaa, 0xee, 0xbb, 0x85,
-	0x6a, 0x9a, 0x87, 0x19, 0x6a, 0xac, 0x17, 0x80, 0x8f, 0x99, 0x39, 0x06, 0xcb, 0x57, 0x6b, 0x97,
-	0x2b, 0x8a, 0x56, 0x70, 0x07, 0xd5, 0x4d, 0x0c, 0x7c, 0xb4, 0x69, 0x6e, 0x37, 0x64, 0x97, 0x0a,
-	0xfa, 0x67, 0x86, 0x1a, 0x6b, 0xcb, 0x5c, 0x3c, 0x8f, 0x64, 0x97, 0x2b, 0x8a, 0x56, 0x7c, 0xf7,
-	0x73, 0xe9, 0x58, 0x5f, 0x4b, 0xc7, 0xfa, 0x5e, 0x3a, 0xd6, 0xc7, 0x8f, 0x53, 0x79, 0x39, 0xc8,
-	0x5f, 0x82, 0xbe, 0xdd, 0xb0, 0x61, 0xe0, 0xd5, 0x6f, 0x00, 0x00, 0x00, 0xff, 0xff, 0xec, 0x23,
-	0x28, 0xf9, 0x4d, 0x02, 0x00, 0x00,
-}
-
-// Reference imports to suppress errors if they are not otherwise used.
-var _ context.Context
-var _ grpc.ClientConn
-
-// This is a compile-time assertion to ensure that this generated file
-// is compatible with the grpc package it is being compiled against.
-const _ = grpc.SupportPackageIsVersion4
-
-// UserClient is the client API for User service.
-//
-// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
-type UserClient interface {
-	Insert(ctx context.Context, in *InsertReq, opts ...grpc.CallOption) (*InsertRes, error)
-	Query(ctx context.Context, in *QueryReq, opts ...grpc.CallOption) (*QueryRes, error)
-	Delete(ctx context.Context, in *DeleteReq, opts ...grpc.CallOption) (*DeleteRes, error)
-}
-
-type userClient struct {
-	cc *grpc.ClientConn
-}
-
-func NewUserClient(cc *grpc.ClientConn) UserClient {
-	return &userClient{cc}
-}
-
-func (c *userClient) Insert(ctx context.Context, in *InsertReq, opts ...grpc.CallOption) (*InsertRes, error) {
-	out := new(InsertRes)
-	err := c.cc.Invoke(ctx, "/demos.User/Insert", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *userClient) Query(ctx context.Context, in *QueryReq, opts ...grpc.CallOption) (*QueryRes, error) {
-	out := new(QueryRes)
-	err := c.cc.Invoke(ctx, "/demos.User/Query", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *userClient) Delete(ctx context.Context, in *DeleteReq, opts ...grpc.CallOption) (*DeleteRes, error) {
-	out := new(DeleteRes)
-	err := c.cc.Invoke(ctx, "/demos.User/Delete", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-// UserServer is the server API for User service.
-type UserServer interface {
-	Insert(context.Context, *InsertReq) (*InsertRes, error)
-	Query(context.Context, *QueryReq) (*QueryRes, error)
-	Delete(context.Context, *DeleteReq) (*DeleteRes, error)
-}
-
-// UnimplementedUserServer can be embedded to have forward compatible implementations.
-type UnimplementedUserServer struct {
-}
-
-func (*UnimplementedUserServer) Insert(ctx context.Context, req *InsertReq) (*InsertRes, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method Insert not implemented")
-}
-func (*UnimplementedUserServer) Query(ctx context.Context, req *QueryReq) (*QueryRes, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method Query not implemented")
-}
-func (*UnimplementedUserServer) Delete(ctx context.Context, req *DeleteReq) (*DeleteRes, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method Delete not implemented")
-}
-
-func RegisterUserServer(s *grpc.Server, srv UserServer) {
-	s.RegisterService(&_User_serviceDesc, srv)
-}
-
-func _User_Insert_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(InsertReq)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(UserServer).Insert(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/demos.User/Insert",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(UserServer).Insert(ctx, req.(*InsertReq))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _User_Query_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(QueryReq)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(UserServer).Query(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/demos.User/Query",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(UserServer).Query(ctx, req.(*QueryReq))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _User_Delete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(DeleteReq)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(UserServer).Delete(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/demos.User/Delete",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(UserServer).Delete(ctx, req.(*DeleteReq))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-var _User_serviceDesc = grpc.ServiceDesc{
-	ServiceName: "demos.User",
-	HandlerType: (*UserServer)(nil),
-	Methods: []grpc.MethodDesc{
-		{
-			MethodName: "Insert",
-			Handler:    _User_Insert_Handler,
-		},
-		{
-			MethodName: "Query",
-			Handler:    _User_Query_Handler,
-		},
-		{
-			MethodName: "Delete",
-			Handler:    _User_Delete_Handler,
-		},
-	},
-	Streams:  []grpc.StreamDesc{},
-	Metadata: "protocol/user.proto",
-}
-
-func (m *InsertReq) Marshal() (dAtA []byte, err error) {
-	size := m.Size()
-	dAtA = make([]byte, size)
-	n, err := m.MarshalToSizedBuffer(dAtA[:size])
-	if err != nil {
-		return nil, err
-	}
-	return dAtA[:n], nil
-}
-
-func (m *InsertReq) MarshalTo(dAtA []byte) (int, error) {
-	size := m.Size()
-	return m.MarshalToSizedBuffer(dAtA[:size])
-}
-
-func (m *InsertReq) MarshalToSizedBuffer(dAtA []byte) (int, error) {
-	i := len(dAtA)
-	_ = i
-	var l int
-	_ = l
-	if m.XXX_unrecognized != nil {
-		i -= len(m.XXX_unrecognized)
-		copy(dAtA[i:], m.XXX_unrecognized)
-	}
-	if len(m.Name) > 0 {
-		i -= len(m.Name)
-		copy(dAtA[i:], m.Name)
-		i = encodeVarintUser(dAtA, i, uint64(len(m.Name)))
-		i--
-		dAtA[i] = 0xa
-	}
-	return len(dAtA) - i, nil
-}
-
-func (m *InsertRes) Marshal() (dAtA []byte, err error) {
-	size := m.Size()
-	dAtA = make([]byte, size)
-	n, err := m.MarshalToSizedBuffer(dAtA[:size])
-	if err != nil {
-		return nil, err
-	}
-	return dAtA[:n], nil
-}
-
-func (m *InsertRes) MarshalTo(dAtA []byte) (int, error) {
-	size := m.Size()
-	return m.MarshalToSizedBuffer(dAtA[:size])
-}
-
-func (m *InsertRes) MarshalToSizedBuffer(dAtA []byte) (int, error) {
-	i := len(dAtA)
-	_ = i
-	var l int
-	_ = l
-	if m.XXX_unrecognized != nil {
-		i -= len(m.XXX_unrecognized)
-		copy(dAtA[i:], m.XXX_unrecognized)
-	}
-	if m.Id != 0 {
-		i = encodeVarintUser(dAtA, i, uint64(m.Id))
-		i--
-		dAtA[i] = 0x8
-	}
-	return len(dAtA) - i, nil
-}
-
-func (m *QueryReq) Marshal() (dAtA []byte, err error) {
-	size := m.Size()
-	dAtA = make([]byte, size)
-	n, err := m.MarshalToSizedBuffer(dAtA[:size])
-	if err != nil {
-		return nil, err
-	}
-	return dAtA[:n], nil
-}
-
-func (m *QueryReq) MarshalTo(dAtA []byte) (int, error) {
-	size := m.Size()
-	return m.MarshalToSizedBuffer(dAtA[:size])
-}
-
-func (m *QueryReq) MarshalToSizedBuffer(dAtA []byte) (int, error) {
-	i := len(dAtA)
-	_ = i
-	var l int
-	_ = l
-	if m.XXX_unrecognized != nil {
-		i -= len(m.XXX_unrecognized)
-		copy(dAtA[i:], m.XXX_unrecognized)
-	}
-	if m.Id != 0 {
-		i = encodeVarintUser(dAtA, i, uint64(m.Id))
-		i--
-		dAtA[i] = 0x8
-	}
-	return len(dAtA) - i, nil
-}
-
-func (m *QueryRes) Marshal() (dAtA []byte, err error) {
-	size := m.Size()
-	dAtA = make([]byte, size)
-	n, err := m.MarshalToSizedBuffer(dAtA[:size])
-	if err != nil {
-		return nil, err
-	}
-	return dAtA[:n], nil
-}
-
-func (m *QueryRes) MarshalTo(dAtA []byte) (int, error) {
-	size := m.Size()
-	return m.MarshalToSizedBuffer(dAtA[:size])
-}
-
-func (m *QueryRes) MarshalToSizedBuffer(dAtA []byte) (int, error) {
-	i := len(dAtA)
-	_ = i
-	var l int
-	_ = l
-	if m.XXX_unrecognized != nil {
-		i -= len(m.XXX_unrecognized)
-		copy(dAtA[i:], m.XXX_unrecognized)
-	}
-	if len(m.Name) > 0 {
-		i -= len(m.Name)
-		copy(dAtA[i:], m.Name)
-		i = encodeVarintUser(dAtA, i, uint64(len(m.Name)))
-		i--
-		dAtA[i] = 0x12
-	}
-	if m.Id != 0 {
-		i = encodeVarintUser(dAtA, i, uint64(m.Id))
-		i--
-		dAtA[i] = 0x8
-	}
-	return len(dAtA) - i, nil
-}
-
-func (m *DeleteReq) Marshal() (dAtA []byte, err error) {
-	size := m.Size()
-	dAtA = make([]byte, size)
-	n, err := m.MarshalToSizedBuffer(dAtA[:size])
-	if err != nil {
-		return nil, err
-	}
-	return dAtA[:n], nil
-}
-
-func (m *DeleteReq) MarshalTo(dAtA []byte) (int, error) {
-	size := m.Size()
-	return m.MarshalToSizedBuffer(dAtA[:size])
-}
-
-func (m *DeleteReq) MarshalToSizedBuffer(dAtA []byte) (int, error) {
-	i := len(dAtA)
-	_ = i
-	var l int
-	_ = l
-	if m.XXX_unrecognized != nil {
-		i -= len(m.XXX_unrecognized)
-		copy(dAtA[i:], m.XXX_unrecognized)
-	}
-	if m.Id != 0 {
-		i = encodeVarintUser(dAtA, i, uint64(m.Id))
-		i--
-		dAtA[i] = 0x8
-	}
-	return len(dAtA) - i, nil
-}
-
-func (m *DeleteRes) Marshal() (dAtA []byte, err error) {
-	size := m.Size()
-	dAtA = make([]byte, size)
-	n, err := m.MarshalToSizedBuffer(dAtA[:size])
-	if err != nil {
-		return nil, err
-	}
-	return dAtA[:n], nil
-}
-
-func (m *DeleteRes) MarshalTo(dAtA []byte) (int, error) {
-	size := m.Size()
-	return m.MarshalToSizedBuffer(dAtA[:size])
-}
-
-func (m *DeleteRes) MarshalToSizedBuffer(dAtA []byte) (int, error) {
-	i := len(dAtA)
-	_ = i
-	var l int
-	_ = l
-	if m.XXX_unrecognized != nil {
-		i -= len(m.XXX_unrecognized)
-		copy(dAtA[i:], m.XXX_unrecognized)
-	}
-	return len(dAtA) - i, nil
-}
-
-func encodeVarintUser(dAtA []byte, offset int, v uint64) int {
-	offset -= sovUser(v)
-	base := offset
-	for v >= 1<<7 {
-		dAtA[offset] = uint8(v&0x7f | 0x80)
-		v >>= 7
-		offset++
-	}
-	dAtA[offset] = uint8(v)
-	return base
-}
-func (m *InsertReq) Size() (n int) {
-	if m == nil {
-		return 0
-	}
-	var l int
-	_ = l
-	l = len(m.Name)
-	if l > 0 {
-		n += 1 + l + sovUser(uint64(l))
-	}
-	if m.XXX_unrecognized != nil {
-		n += len(m.XXX_unrecognized)
-	}
-	return n
-}
-
-func (m *InsertRes) Size() (n int) {
-	if m == nil {
-		return 0
-	}
-	var l int
-	_ = l
-	if m.Id != 0 {
-		n += 1 + sovUser(uint64(m.Id))
-	}
-	if m.XXX_unrecognized != nil {
-		n += len(m.XXX_unrecognized)
-	}
-	return n
-}
-
-func (m *QueryReq) Size() (n int) {
-	if m == nil {
-		return 0
-	}
-	var l int
-	_ = l
-	if m.Id != 0 {
-		n += 1 + sovUser(uint64(m.Id))
-	}
-	if m.XXX_unrecognized != nil {
-		n += len(m.XXX_unrecognized)
-	}
-	return n
-}
-
-func (m *QueryRes) Size() (n int) {
-	if m == nil {
-		return 0
-	}
-	var l int
-	_ = l
-	if m.Id != 0 {
-		n += 1 + sovUser(uint64(m.Id))
-	}
-	l = len(m.Name)
-	if l > 0 {
-		n += 1 + l + sovUser(uint64(l))
-	}
-	if m.XXX_unrecognized != nil {
-		n += len(m.XXX_unrecognized)
-	}
-	return n
-}
-
-func (m *DeleteReq) Size() (n int) {
-	if m == nil {
-		return 0
-	}
-	var l int
-	_ = l
-	if m.Id != 0 {
-		n += 1 + sovUser(uint64(m.Id))
-	}
-	if m.XXX_unrecognized != nil {
-		n += len(m.XXX_unrecognized)
-	}
-	return n
-}
-
-func (m *DeleteRes) Size() (n int) {
-	if m == nil {
-		return 0
-	}
-	var l int
-	_ = l
-	if m.XXX_unrecognized != nil {
-		n += len(m.XXX_unrecognized)
-	}
-	return n
-}
-
-func sovUser(x uint64) (n int) {
-	return (math_bits.Len64(x|1) + 6) / 7
-}
-func sozUser(x uint64) (n int) {
-	return sovUser(uint64((x << 1) ^ uint64((int64(x) >> 63))))
-}
-func (m *InsertReq) Unmarshal(dAtA []byte) error {
-	l := len(dAtA)
-	iNdEx := 0
-	for iNdEx < l {
-		preIndex := iNdEx
-		var wire uint64
-		for shift := uint(0); ; shift += 7 {
-			if shift >= 64 {
-				return ErrIntOverflowUser
-			}
-			if iNdEx >= l {
-				return io.ErrUnexpectedEOF
-			}
-			b := dAtA[iNdEx]
-			iNdEx++
-			wire |= uint64(b&0x7F) << shift
-			if b < 0x80 {
-				break
-			}
-		}
-		fieldNum := int32(wire >> 3)
-		wireType := int(wire & 0x7)
-		if wireType == 4 {
-			return fmt.Errorf("proto: InsertReq: wiretype end group for non-group")
-		}
-		if fieldNum <= 0 {
-			return fmt.Errorf("proto: InsertReq: illegal tag %d (wire type %d)", fieldNum, wire)
-		}
-		switch fieldNum {
-		case 1:
-			if wireType != 2 {
-				return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType)
-			}
-			var stringLen uint64
-			for shift := uint(0); ; shift += 7 {
-				if shift >= 64 {
-					return ErrIntOverflowUser
-				}
-				if iNdEx >= l {
-					return io.ErrUnexpectedEOF
-				}
-				b := dAtA[iNdEx]
-				iNdEx++
-				stringLen |= uint64(b&0x7F) << shift
-				if b < 0x80 {
-					break
-				}
-			}
-			intStringLen := int(stringLen)
-			if intStringLen < 0 {
-				return ErrInvalidLengthUser
-			}
-			postIndex := iNdEx + intStringLen
-			if postIndex < 0 {
-				return ErrInvalidLengthUser
-			}
-			if postIndex > l {
-				return io.ErrUnexpectedEOF
-			}
-			m.Name = string(dAtA[iNdEx:postIndex])
-			iNdEx = postIndex
-		default:
-			iNdEx = preIndex
-			skippy, err := skipUser(dAtA[iNdEx:])
-			if err != nil {
-				return err
-			}
-			if (skippy < 0) || (iNdEx+skippy) < 0 {
-				return ErrInvalidLengthUser
-			}
-			if (iNdEx + skippy) > l {
-				return io.ErrUnexpectedEOF
-			}
-			m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
-			iNdEx += skippy
-		}
-	}
-
-	if iNdEx > l {
-		return io.ErrUnexpectedEOF
-	}
-	return nil
-}
-func (m *InsertRes) Unmarshal(dAtA []byte) error {
-	l := len(dAtA)
-	iNdEx := 0
-	for iNdEx < l {
-		preIndex := iNdEx
-		var wire uint64
-		for shift := uint(0); ; shift += 7 {
-			if shift >= 64 {
-				return ErrIntOverflowUser
-			}
-			if iNdEx >= l {
-				return io.ErrUnexpectedEOF
-			}
-			b := dAtA[iNdEx]
-			iNdEx++
-			wire |= uint64(b&0x7F) << shift
-			if b < 0x80 {
-				break
-			}
-		}
-		fieldNum := int32(wire >> 3)
-		wireType := int(wire & 0x7)
-		if wireType == 4 {
-			return fmt.Errorf("proto: InsertRes: wiretype end group for non-group")
-		}
-		if fieldNum <= 0 {
-			return fmt.Errorf("proto: InsertRes: illegal tag %d (wire type %d)", fieldNum, wire)
-		}
-		switch fieldNum {
-		case 1:
-			if wireType != 0 {
-				return fmt.Errorf("proto: wrong wireType = %d for field Id", wireType)
-			}
-			m.Id = 0
-			for shift := uint(0); ; shift += 7 {
-				if shift >= 64 {
-					return ErrIntOverflowUser
-				}
-				if iNdEx >= l {
-					return io.ErrUnexpectedEOF
-				}
-				b := dAtA[iNdEx]
-				iNdEx++
-				m.Id |= int32(b&0x7F) << shift
-				if b < 0x80 {
-					break
-				}
-			}
-		default:
-			iNdEx = preIndex
-			skippy, err := skipUser(dAtA[iNdEx:])
-			if err != nil {
-				return err
-			}
-			if (skippy < 0) || (iNdEx+skippy) < 0 {
-				return ErrInvalidLengthUser
-			}
-			if (iNdEx + skippy) > l {
-				return io.ErrUnexpectedEOF
-			}
-			m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
-			iNdEx += skippy
-		}
-	}
-
-	if iNdEx > l {
-		return io.ErrUnexpectedEOF
-	}
-	return nil
-}
-func (m *QueryReq) Unmarshal(dAtA []byte) error {
-	l := len(dAtA)
-	iNdEx := 0
-	for iNdEx < l {
-		preIndex := iNdEx
-		var wire uint64
-		for shift := uint(0); ; shift += 7 {
-			if shift >= 64 {
-				return ErrIntOverflowUser
-			}
-			if iNdEx >= l {
-				return io.ErrUnexpectedEOF
-			}
-			b := dAtA[iNdEx]
-			iNdEx++
-			wire |= uint64(b&0x7F) << shift
-			if b < 0x80 {
-				break
-			}
-		}
-		fieldNum := int32(wire >> 3)
-		wireType := int(wire & 0x7)
-		if wireType == 4 {
-			return fmt.Errorf("proto: QueryReq: wiretype end group for non-group")
-		}
-		if fieldNum <= 0 {
-			return fmt.Errorf("proto: QueryReq: illegal tag %d (wire type %d)", fieldNum, wire)
-		}
-		switch fieldNum {
-		case 1:
-			if wireType != 0 {
-				return fmt.Errorf("proto: wrong wireType = %d for field Id", wireType)
-			}
-			m.Id = 0
-			for shift := uint(0); ; shift += 7 {
-				if shift >= 64 {
-					return ErrIntOverflowUser
-				}
-				if iNdEx >= l {
-					return io.ErrUnexpectedEOF
-				}
-				b := dAtA[iNdEx]
-				iNdEx++
-				m.Id |= int32(b&0x7F) << shift
-				if b < 0x80 {
-					break
-				}
-			}
-		default:
-			iNdEx = preIndex
-			skippy, err := skipUser(dAtA[iNdEx:])
-			if err != nil {
-				return err
-			}
-			if (skippy < 0) || (iNdEx+skippy) < 0 {
-				return ErrInvalidLengthUser
-			}
-			if (iNdEx + skippy) > l {
-				return io.ErrUnexpectedEOF
-			}
-			m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
-			iNdEx += skippy
-		}
-	}
-
-	if iNdEx > l {
-		return io.ErrUnexpectedEOF
-	}
-	return nil
-}
-func (m *QueryRes) Unmarshal(dAtA []byte) error {
-	l := len(dAtA)
-	iNdEx := 0
-	for iNdEx < l {
-		preIndex := iNdEx
-		var wire uint64
-		for shift := uint(0); ; shift += 7 {
-			if shift >= 64 {
-				return ErrIntOverflowUser
-			}
-			if iNdEx >= l {
-				return io.ErrUnexpectedEOF
-			}
-			b := dAtA[iNdEx]
-			iNdEx++
-			wire |= uint64(b&0x7F) << shift
-			if b < 0x80 {
-				break
-			}
-		}
-		fieldNum := int32(wire >> 3)
-		wireType := int(wire & 0x7)
-		if wireType == 4 {
-			return fmt.Errorf("proto: QueryRes: wiretype end group for non-group")
-		}
-		if fieldNum <= 0 {
-			return fmt.Errorf("proto: QueryRes: illegal tag %d (wire type %d)", fieldNum, wire)
-		}
-		switch fieldNum {
-		case 1:
-			if wireType != 0 {
-				return fmt.Errorf("proto: wrong wireType = %d for field Id", wireType)
-			}
-			m.Id = 0
-			for shift := uint(0); ; shift += 7 {
-				if shift >= 64 {
-					return ErrIntOverflowUser
-				}
-				if iNdEx >= l {
-					return io.ErrUnexpectedEOF
-				}
-				b := dAtA[iNdEx]
-				iNdEx++
-				m.Id |= int32(b&0x7F) << shift
-				if b < 0x80 {
-					break
-				}
-			}
-		case 2:
-			if wireType != 2 {
-				return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType)
-			}
-			var stringLen uint64
-			for shift := uint(0); ; shift += 7 {
-				if shift >= 64 {
-					return ErrIntOverflowUser
-				}
-				if iNdEx >= l {
-					return io.ErrUnexpectedEOF
-				}
-				b := dAtA[iNdEx]
-				iNdEx++
-				stringLen |= uint64(b&0x7F) << shift
-				if b < 0x80 {
-					break
-				}
-			}
-			intStringLen := int(stringLen)
-			if intStringLen < 0 {
-				return ErrInvalidLengthUser
-			}
-			postIndex := iNdEx + intStringLen
-			if postIndex < 0 {
-				return ErrInvalidLengthUser
-			}
-			if postIndex > l {
-				return io.ErrUnexpectedEOF
-			}
-			m.Name = string(dAtA[iNdEx:postIndex])
-			iNdEx = postIndex
-		default:
-			iNdEx = preIndex
-			skippy, err := skipUser(dAtA[iNdEx:])
-			if err != nil {
-				return err
-			}
-			if (skippy < 0) || (iNdEx+skippy) < 0 {
-				return ErrInvalidLengthUser
-			}
-			if (iNdEx + skippy) > l {
-				return io.ErrUnexpectedEOF
-			}
-			m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
-			iNdEx += skippy
-		}
-	}
-
-	if iNdEx > l {
-		return io.ErrUnexpectedEOF
-	}
-	return nil
-}
-func (m *DeleteReq) Unmarshal(dAtA []byte) error {
-	l := len(dAtA)
-	iNdEx := 0
-	for iNdEx < l {
-		preIndex := iNdEx
-		var wire uint64
-		for shift := uint(0); ; shift += 7 {
-			if shift >= 64 {
-				return ErrIntOverflowUser
-			}
-			if iNdEx >= l {
-				return io.ErrUnexpectedEOF
-			}
-			b := dAtA[iNdEx]
-			iNdEx++
-			wire |= uint64(b&0x7F) << shift
-			if b < 0x80 {
-				break
-			}
-		}
-		fieldNum := int32(wire >> 3)
-		wireType := int(wire & 0x7)
-		if wireType == 4 {
-			return fmt.Errorf("proto: DeleteReq: wiretype end group for non-group")
-		}
-		if fieldNum <= 0 {
-			return fmt.Errorf("proto: DeleteReq: illegal tag %d (wire type %d)", fieldNum, wire)
-		}
-		switch fieldNum {
-		case 1:
-			if wireType != 0 {
-				return fmt.Errorf("proto: wrong wireType = %d for field Id", wireType)
-			}
-			m.Id = 0
-			for shift := uint(0); ; shift += 7 {
-				if shift >= 64 {
-					return ErrIntOverflowUser
-				}
-				if iNdEx >= l {
-					return io.ErrUnexpectedEOF
-				}
-				b := dAtA[iNdEx]
-				iNdEx++
-				m.Id |= int32(b&0x7F) << shift
-				if b < 0x80 {
-					break
-				}
-			}
-		default:
-			iNdEx = preIndex
-			skippy, err := skipUser(dAtA[iNdEx:])
-			if err != nil {
-				return err
-			}
-			if (skippy < 0) || (iNdEx+skippy) < 0 {
-				return ErrInvalidLengthUser
-			}
-			if (iNdEx + skippy) > l {
-				return io.ErrUnexpectedEOF
-			}
-			m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
-			iNdEx += skippy
-		}
-	}
-
-	if iNdEx > l {
-		return io.ErrUnexpectedEOF
-	}
-	return nil
-}
-func (m *DeleteRes) Unmarshal(dAtA []byte) error {
-	l := len(dAtA)
-	iNdEx := 0
-	for iNdEx < l {
-		preIndex := iNdEx
-		var wire uint64
-		for shift := uint(0); ; shift += 7 {
-			if shift >= 64 {
-				return ErrIntOverflowUser
-			}
-			if iNdEx >= l {
-				return io.ErrUnexpectedEOF
-			}
-			b := dAtA[iNdEx]
-			iNdEx++
-			wire |= uint64(b&0x7F) << shift
-			if b < 0x80 {
-				break
-			}
-		}
-		fieldNum := int32(wire >> 3)
-		wireType := int(wire & 0x7)
-		if wireType == 4 {
-			return fmt.Errorf("proto: DeleteRes: wiretype end group for non-group")
-		}
-		if fieldNum <= 0 {
-			return fmt.Errorf("proto: DeleteRes: illegal tag %d (wire type %d)", fieldNum, wire)
-		}
-		switch fieldNum {
-		default:
-			iNdEx = preIndex
-			skippy, err := skipUser(dAtA[iNdEx:])
-			if err != nil {
-				return err
-			}
-			if (skippy < 0) || (iNdEx+skippy) < 0 {
-				return ErrInvalidLengthUser
-			}
-			if (iNdEx + skippy) > l {
-				return io.ErrUnexpectedEOF
-			}
-			m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
-			iNdEx += skippy
-		}
-	}
-
-	if iNdEx > l {
-		return io.ErrUnexpectedEOF
-	}
-	return nil
-}
-func skipUser(dAtA []byte) (n int, err error) {
-	l := len(dAtA)
-	iNdEx := 0
-	depth := 0
-	for iNdEx < l {
-		var wire uint64
-		for shift := uint(0); ; shift += 7 {
-			if shift >= 64 {
-				return 0, ErrIntOverflowUser
-			}
-			if iNdEx >= l {
-				return 0, io.ErrUnexpectedEOF
-			}
-			b := dAtA[iNdEx]
-			iNdEx++
-			wire |= (uint64(b) & 0x7F) << shift
-			if b < 0x80 {
-				break
-			}
-		}
-		wireType := int(wire & 0x7)
-		switch wireType {
-		case 0:
-			for shift := uint(0); ; shift += 7 {
-				if shift >= 64 {
-					return 0, ErrIntOverflowUser
-				}
-				if iNdEx >= l {
-					return 0, io.ErrUnexpectedEOF
-				}
-				iNdEx++
-				if dAtA[iNdEx-1] < 0x80 {
-					break
-				}
-			}
-		case 1:
-			iNdEx += 8
-		case 2:
-			var length int
-			for shift := uint(0); ; shift += 7 {
-				if shift >= 64 {
-					return 0, ErrIntOverflowUser
-				}
-				if iNdEx >= l {
-					return 0, io.ErrUnexpectedEOF
-				}
-				b := dAtA[iNdEx]
-				iNdEx++
-				length |= (int(b) & 0x7F) << shift
-				if b < 0x80 {
-					break
-				}
-			}
-			if length < 0 {
-				return 0, ErrInvalidLengthUser
-			}
-			iNdEx += length
-		case 3:
-			depth++
-		case 4:
-			if depth == 0 {
-				return 0, ErrUnexpectedEndOfGroupUser
-			}
-			depth--
-		case 5:
-			iNdEx += 4
-		default:
-			return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
-		}
-		if iNdEx < 0 {
-			return 0, ErrInvalidLengthUser
-		}
-		if depth == 0 {
-			return iNdEx, nil
-		}
-	}
-	return 0, io.ErrUnexpectedEOF
-}
-
-var (
-	ErrInvalidLengthUser        = fmt.Errorf("proto: negative length found during unmarshaling")
-	ErrIntOverflowUser          = fmt.Errorf("proto: integer overflow")
-	ErrUnexpectedEndOfGroupUser = fmt.Errorf("proto: unexpected end of group")
-)
diff --git a/.example/net/gtrace/5.grpc+db+redis+log/protocol/user/user.proto b/.example/net/gtrace/5.grpc+db+redis+log/protocol/user/user.proto
deleted file mode 100644
index dc7bd7afc..000000000
--- a/.example/net/gtrace/5.grpc+db+redis+log/protocol/user/user.proto
+++ /dev/null
@@ -1,39 +0,0 @@
-// protoc --gofast_out=plugins=grpc:. protocol/*.proto -I/Users/john/Workspace/Go/GOPATH/src
-
-syntax = "proto3";
-
-package demos;
-
-option go_package = "protobuf/user";
-
-import "github.com/gogo/protobuf/gogoproto/gogo.proto";
-
-// User service for tracing demo.
-service User {
-  rpc Insert(InsertReq) returns (InsertRes) {}
-  rpc Query(QueryReq) returns (QueryRes) {}
-  rpc Delete(DeleteReq) returns (DeleteRes) {}
-}
-
-message InsertReq {
-  string Name = 1 [(gogoproto.moretags) = 'v:"required#Please input user name."'];
-}
-
-message InsertRes {
-  int32 Id = 1;
-}
-
-message QueryReq {
-  int32 Id = 1 [(gogoproto.moretags) = 'v:"min:1#User id is required for querying."'];
-}
-
-message QueryRes {
-  int32  Id = 1;
-  string Name = 2;
-}
-
-message DeleteReq {
-  int32 Id = 1 [(gogoproto.moretags) = 'v:"required#User id is required for deleting."'];
-}
-
-message DeleteRes {}
\ No newline at end of file
diff --git a/.example/net/gtrace/5.grpc+db+redis+log/server/config.toml b/.example/net/gtrace/5.grpc+db+redis+log/server/config.toml
deleted file mode 100644
index 451299306..000000000
--- a/.example/net/gtrace/5.grpc+db+redis+log/server/config.toml
+++ /dev/null
@@ -1,19 +0,0 @@
-
-# MySQL.
-[database]
-    [database.logger]
-        level   = "all"
-        stdout  = true
-    [database.default]
-        link    = "mysql:root:12345678@tcp(127.0.0.1:3306)/test"
-        debug   = true
-
-# Redis.
-[redis]
-    default = "127.0.0.1:6379,0"
-    cache   = "127.0.0.1:6379,1"
-
-
-
-
-
diff --git a/.example/net/gtrace/5.grpc+db+redis+log/server/main.go b/.example/net/gtrace/5.grpc+db+redis+log/server/main.go
deleted file mode 100644
index b2e254b11..000000000
--- a/.example/net/gtrace/5.grpc+db+redis+log/server/main.go
+++ /dev/null
@@ -1,118 +0,0 @@
-package main
-
-import (
-	"context"
-	"fmt"
-	"github.com/gogf/gcache-adapter/adapter"
-	"github.com/gogf/gf/.example/net/gtrace/5.grpc+db+redis+log/protobuf/user"
-	"github.com/gogf/gf/errors/gerror"
-	"github.com/gogf/gf/frame/g"
-	"github.com/gogf/gf/util/gvalid"
-	"go.opentelemetry.io/otel/exporters/trace/jaeger"
-	sdkTrace "go.opentelemetry.io/otel/sdk/trace"
-	"google.golang.org/grpc"
-	"google.golang.org/grpc/codes"
-	"net"
-	"time"
-)
-
-type server struct{}
-
-const (
-	JaegerEndpoint = "http://localhost:14268/s/traces"
-	ServiceName    = "tracing-grpc-server"
-)
-
-// initTracer creates a new trace provider instance and registers it as global trace provider.
-func initTracer() func() {
-	// Create and install Jaeger export pipeline.
-	flush, err := jaeger.InstallNewPipeline(
-		jaeger.WithCollectorEndpoint(JaegerEndpoint),
-		jaeger.WithProcess(jaeger.Process{
-			ServiceName: ServiceName,
-		}),
-		jaeger.WithSDK(&sdkTrace.Config{DefaultSampler: sdkTrace.AlwaysSample()}),
-	)
-	if err != nil {
-		g.Log().Fatal(err)
-	}
-	return flush
-}
-
-// Common validation unary interpreter.
-func UnaryValidate(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {
-	// It does nothing if there's no validation tag in the struct definition.
-	if err := gvalid.CheckStruct(req, nil); err != nil {
-		return nil, gerror.NewCode(
-			int(codes.InvalidArgument),
-			gerror.Current(err).Error(),
-		)
-	}
-	return handler(ctx, req)
-}
-
-// Insert is a route handler for inserting user info into dtabase.
-func (s *server) Insert(ctx context.Context, req *user.InsertReq) (*user.InsertRes, error) {
-	res := user.InsertRes{}
-	result, err := g.Table("user").Ctx(ctx).Insert(g.Map{
-		"name": req.Name,
-	})
-	if err != nil {
-		return nil, err
-	}
-	id, _ := result.LastInsertId()
-	res.Id = int32(id)
-	return &res, nil
-}
-
-// Query is a route handler for querying user info. It firstly retrieves the info from redis,
-// if there's nothing in the redis, it then does db select.
-func (s *server) Query(ctx context.Context, req *user.QueryReq) (*user.QueryRes, error) {
-	res := user.QueryRes{}
-	err := g.Table("user").
-		Ctx(ctx).
-		Cache(5*time.Second, s.userCacheKey(req.Id)).
-		WherePri(req.Id).
-		Scan(&res)
-	if err != nil {
-		return nil, err
-	}
-	return &res, nil
-}
-
-// Delete is a route handler for deleting specified user info.
-func (s *server) Delete(ctx context.Context, req *user.DeleteReq) (*user.DeleteRes, error) {
-	res := user.DeleteRes{}
-	_, err := g.Table("user").
-		Ctx(ctx).
-		Cache(-1, s.userCacheKey(req.Id)).
-		WherePri(req.Id).
-		Delete()
-	if err != nil {
-		return nil, err
-	}
-	return &res, nil
-}
-
-func (s *server) userCacheKey(id int32) string {
-	return fmt.Sprintf(`userInfo:%d`, id)
-}
-
-func main() {
-	flush := initTracer()
-	defer flush()
-
-	g.DB().GetCache().SetAdapter(adapter.NewRedis(g.Redis()))
-
-	listen, err := net.Listen("tcp", ":8000")
-	if err != nil {
-		g.Log().Fatalf("failed to listen: %v", err)
-	}
-	s := grpc.NewServer(
-		grpc.ChainUnaryInterceptor(UnaryValidate),
-	)
-	user.RegisterUserServer(s, &server{})
-	if err := s.Serve(listen); err != nil {
-		g.Log().Fatalf("failed to serve: %v", err)
-	}
-}