Documentation
¶
Overview ¶
Package builtin contains built-in injection configurations for supported instrumentations.
Index ¶
Constants ¶
View Source
const Checksum = "sha512:pXFHjupxWE+tdgFLK/03Q7H+ireSfSHPXx8ETxc5ZuHABZLZc1DPOpFxCcZmOP2tCoSAc+K6iWr3iwKmJE3/qQ=="
Checksum is a checksum of the built-in configuration which can be used to invalidate caches.
Variables ¶
View Source
var Aspects = [...]aspect.Aspect{ { JoinPoint: join.StructLiteral(join.MustTypeName("github.com/hashicorp/vault/api.Config"), join.StructLiteralMatchAny), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "{{- .AST.Type -}}{\n {{- $hasField := false -}}\n {{ range .AST.Elts }}\n {{- if eq .Key.Name \"HttpClient\" }}\n {{- $hasField = true -}}\n HttpClient: vaulttrace.WrapHTTPClient({{ .Value }}),\n {{- else -}}\n {{ . }},\n {{ end -}}\n {{ end }}\n {{- if not $hasField -}}\n HttpClient: vaulttrace.NewHTTPClient(),\n {{- end }}\n}", map[string]string{ "vaulttrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/hashicorp/vault", }, )), }, }, { JoinPoint: join.StructLiteral(join.MustTypeName("github.com/aws/aws-sdk-go-v2/aws.Config"), join.StructLiteralMatchValueOnly), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "func(cfg aws.Config) (aws.Config) {\n awstrace.AppendMiddleware(&cfg)\n return cfg\n}({{ . }})", map[string]string{ "aws": "github.com/aws/aws-sdk-go-v2/aws", "awstrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/aws/aws-sdk-go-v2/aws", }, )), }, }, { JoinPoint: join.OneOf( join.StructLiteral(join.MustTypeName("github.com/aws/aws-sdk-go-v2/aws.Config"), join.StructLiteralMatchPointerOnly), join.FunctionCall("github.com/aws/aws-sdk-go-v2/aws.NewConfig"), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "func(cfg *aws.Config) (*aws.Config) {\n awstrace.AppendMiddleware(cfg)\n return cfg\n}({{ . }})", map[string]string{ "aws": "github.com/aws/aws-sdk-go-v2/aws", "awstrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/aws/aws-sdk-go-v2/aws", }, )), }, }, { JoinPoint: join.FunctionCall("github.com/aws/aws-sdk-go/aws/session.NewSession"), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "func(sess *session.Session, err error) (*session.Session, error) {\n if sess != nil {\n sess = awstrace.WrapSession(sess)\n }\n return sess, err\n}({{ . }})", map[string]string{ "awstrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/aws/aws-sdk-go/aws", "session": "github.com/aws/aws-sdk-go/aws/session", }, )), }, }, { JoinPoint: join.OneOf( join.FunctionCall("github.com/go-redis/redis.NewClient"), join.FunctionCall("github.com/go-redis/redis.NewFailoverClient"), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "func() (client *redis.Client) {\n client = {{ . }}\n trace.WrapClient(client)\n return\n}()", map[string]string{ "redis": "github.com/go-redis/redis", "trace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/go-redis/redis", }, )), }, }, { JoinPoint: join.OneOf( join.FunctionCall("github.com/go-redis/redis/v7.NewClient"), join.FunctionCall("github.com/go-redis/redis/v7.NewFailoverClient"), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "func() (client *redis.Client) {\n client = {{ . }}\n trace.WrapClient(client)\n return\n}()", map[string]string{ "redis": "github.com/go-redis/redis/v7", "trace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/go-redis/redis.v7", }, )), }, }, { JoinPoint: join.OneOf( join.FunctionCall("github.com/go-redis/redis/v8.NewClient"), join.FunctionCall("github.com/go-redis/redis/v8.NewFailoverClient"), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "func() (client *redis.Client) {\n client = {{ . }}\n trace.WrapClient(client)\n return\n}()", map[string]string{ "redis": "github.com/go-redis/redis/v8", "trace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/go-redis/redis.v8", }, )), }, }, { JoinPoint: join.OneOf( join.FunctionCall("github.com/redis/go-redis/v9.NewClient"), join.FunctionCall("github.com/redis/go-redis/v9.NewFailoverClient"), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "func() (client *redis.Client) {\n client = {{ . }}\n trace.WrapClient(client)\n return\n}()", map[string]string{ "redis": "github.com/redis/go-redis/v9", "trace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/redis/go-redis.v9", }, )), }, }, { JoinPoint: join.AllOf( join.OneOf( join.StructLiteral(join.MustTypeName("github.com/gocql/gocql.ClusterConfig"), join.StructLiteralMatchPointerOnly), join.FunctionCall("github.com/gocql/gocql.NewCluster"), ), join.Not(join.ImportPath("github.com/gocql/gocql")), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "func(cluster *gocql.ClusterConfig) *gocql.ClusterConfig {\n obs := gocqltrace.NewObserver(cluster) \n cluster.QueryObserver = obs\n cluster.BatchObserver = obs\n cluster.ConnectObserver = obs\n return cluster\n}({{ . }})", map[string]string{ "gocql": "github.com/gocql/gocql", "gocqltrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/gocql/gocql", }, )), }, }, { JoinPoint: join.AllOf( join.StructLiteral(join.MustTypeName("github.com/gocql/gocql.ClusterConfig"), join.StructLiteralMatchValueOnly), join.Not(join.ImportPath("github.com/gocql/gocql")), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "func(cluster gocql.ClusterConfig) gocql.ClusterConfig {\n obs := gocqltrace.NewObserver(&cluster) \n cluster.QueryObserver = obs\n cluster.BatchObserver = obs\n cluster.ConnectObserver = obs\n return cluster\n}({{ . }})", map[string]string{ "gocql": "github.com/gocql/gocql", "gocqltrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/gocql/gocql", }, )), }, }, { JoinPoint: join.FunctionCall("gorm.io/gorm.Open"), Advice: []advice.Advice{ advice.ReplaceFunction("gopkg.in/DataDog/dd-trace-go.v1/contrib/gorm.io/gorm.v1", "Open"), }, }, { JoinPoint: join.FunctionCall("github.com/jinzhu/gorm.Open"), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "func() (*gorm.DB, error) {\n db, err := {{ . }}\n if err != nil {\n return nil, err\n }\n return gormtrace.WithCallbacks(db), err\n}()", map[string]string{ "gorm": "github.com/jinzhu/gorm", "gormtrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/jinzhu/gorm", }, )), }, }, { JoinPoint: join.FunctionCall("go.mongodb.org/mongo-driver/mongo/options.Client"), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "{{ . }}.SetMonitor(mongotrace.NewMonitor())", map[string]string{ "mongotrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/go.mongodb.org/mongo-driver/mongo", "options": "go.mongodb.org/mongo-driver/mongo/options", }, )), }, }, { JoinPoint: join.FunctionCall("github.com/gomodule/redigo/redis.Dial"), Advice: []advice.Advice{ advice.ReplaceFunction("gopkg.in/DataDog/dd-trace-go.v1/contrib/gomodule/redigo", "Dial"), }, }, { JoinPoint: join.FunctionCall("github.com/gomodule/redigo/redis.DialContext"), Advice: []advice.Advice{ advice.ReplaceFunction("gopkg.in/DataDog/dd-trace-go.v1/contrib/gomodule/redigo", "DialContext"), }, }, { JoinPoint: join.FunctionCall("github.com/gomodule/redigo/redis.DialURL"), Advice: []advice.Advice{ advice.ReplaceFunction("gopkg.in/DataDog/dd-trace-go.v1/contrib/gomodule/redigo", "DialURL"), }, }, { JoinPoint: join.FunctionBody(join.Function( join.Receiver(join.MustTypeName("*cloud.google.com/go/pubsub.Subscription")), join.Name("Receive"), )), Advice: []advice.Advice{ advice.PrependStmts(code.MustTemplate( "{{- $subscription := .Function.Receiver -}}\n{{- $handler := .Function.Argument 1 -}}\n__dd_traceFn := tracing.TraceReceiveFunc({{ $subscription }})\n__dd_wrapHandler := func(h func(ctx context.Context, msg *Message)) func(ctx context.Context, msg *Message) {\n return func(ctx context.Context, msg *Message) {\n __dd_traceMsg := &tracing.Message{\n ID: msg.ID,\n Data: msg.Data,\n OrderingKey: msg.OrderingKey,\n Attributes: msg.Attributes,\n DeliveryAttempt: msg.DeliveryAttempt,\n PublishTime: msg.PublishTime,\n }\n ctx, closeSpan := __dd_traceFn(ctx, __dd_traceMsg)\n defer closeSpan()\n h(ctx, msg)\n }\n}\n{{ $handler }} = __dd_wrapHandler({{ $handler }})", map[string]string{ "tracing": "gopkg.in/DataDog/dd-trace-go.v1/contrib/cloud.google.com/go/pubsub.v1/internal/tracing", }, )), }, }, { JoinPoint: join.StructDefinition(join.MustTypeName("cloud.google.com/go/internal/pubsub.PublishResult")), Advice: []advice.Advice{ advice.InjectDeclarations(code.MustTemplate( "type DDCloseSpanFunc = func(serverID string, err error)", map[string]string{}, ), []string{}), advice.AddStructField("DDCloseSpan", join.MustTypeName("DDCloseSpanFunc")), }, }, { JoinPoint: join.FunctionBody(join.Function( join.Receiver(join.MustTypeName("*cloud.google.com/go/pubsub.Topic")), join.Name("Publish"), )), Advice: []advice.Advice{ advice.PrependStmts(code.MustTemplate( "{{- $topic := .Function.Receiver -}}\n{{- $ctx := .Function.Argument 0 -}}\n{{- $msg := .Function.Argument 1 -}}\n{{- $publishResult := .Function.Result 0 -}}\n__dd_traceMsg := &tracing.Message{\n ID: {{ $msg }}.ID,\n Data: {{ $msg }}.Data,\n OrderingKey: {{ $msg }}.OrderingKey,\n Attributes: {{ $msg }}.Attributes,\n DeliveryAttempt: {{ $msg }}.DeliveryAttempt,\n PublishTime: {{ $msg }}.PublishTime,\n}\n__dd_ctx, __dd_closeSpan := tracing.TracePublish({{ $ctx }}, {{ $topic }}, __dd_traceMsg)\n{{ $ctx }} = __dd_ctx\n{{ $msg }}.Attributes = __dd_traceMsg.Attributes\n\ndefer func() {\n {{ $publishResult }}.DDCloseSpan = __dd_closeSpan\n}()", map[string]string{ "tracing": "gopkg.in/DataDog/dd-trace-go.v1/contrib/cloud.google.com/go/pubsub.v1/internal/tracing", }, )), }, }, { JoinPoint: join.FunctionBody(join.Function( join.Receiver(join.MustTypeName("*cloud.google.com/go/internal/pubsub.PublishResult")), join.Name("Get"), )), Advice: []advice.Advice{ advice.PrependStmts(code.MustTemplate( "{{- $publishResult := .Function.Receiver -}}\n{{- $serverID := .Function.Result 0 -}}\n{{- $err := .Function.Result 1 -}}\ndefer func() {\n if {{ $publishResult }}.DDCloseSpan != nil {\n {{ $publishResult }}.DDCloseSpan({{ $serverID }}, {{ $err }})\n }\n}()", map[string]string{}, )), }, }, { JoinPoint: join.OneOf( join.FunctionCall("github.com/IBM/sarama.NewConsumer"), join.FunctionCall("github.com/IBM/sarama.NewConsumerClient"), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "func(c sarama.Consumer, err error) (sarama.Consumer, error) {\n if c != nil {\n c = saramatrace.WrapConsumer(c)\n }\n return c, err\n}({{ . }})", map[string]string{ "sarama": "github.com/IBM/sarama", "saramatrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/IBM/sarama.v1", }, )), }, }, { JoinPoint: join.OneOf( join.FunctionCall("github.com/IBM/sarama.NewSyncProducer"), join.FunctionCall("github.com/IBM/sarama.NewSyncProducerFromClient"), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "{{- $cfg := .Function.ArgumentOfType \"sarama.Config\" -}}\nfunc(p sarama.SyncProducer, err error) (sarama.SyncProducer, error) {\n if p != nil {\n p = saramatrace.WrapSyncProducer(\n {{- if $cfg -}}\n {{ $cfg }},\n {{- else -}}\n nil,\n {{- end -}}\n p,\n )\n }\n return p, err\n}({{ . }})", map[string]string{ "sarama": "github.com/IBM/sarama", "saramatrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/IBM/sarama.v1", }, )), }, }, { JoinPoint: join.OneOf( join.FunctionCall("github.com/IBM/sarama.NewAsyncProducer"), join.FunctionCall("github.com/IBM/sarama.NewAsyncProducerFromClient"), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "{{- $cfg := .Function.ArgumentOfType \"sarama.Config\" -}}\nfunc(p sarama.AsyncProducer, err error) (sarama.AsyncProducer, error) {\n if p != nil {\n p = saramatrace.WrapAsyncProducer(\n {{- if $cfg -}}\n {{ $cfg }},\n {{- else -}}\n nil,\n {{- end -}}\n p,\n )\n }\n return p, err\n}({{ . }})", map[string]string{ "sarama": "github.com/IBM/sarama", "saramatrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/IBM/sarama.v1", }, )), }, }, { JoinPoint: join.OneOf( join.FunctionCall("github.com/Shopify/sarama.NewConsumer"), join.FunctionCall("github.com/Shopify/sarama.NewConsumerClient"), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "func(c sarama.Consumer, err error) (sarama.Consumer, error) {\n if c != nil {\n c = saramatrace.WrapConsumer(c)\n }\n return c, err\n}({{ . }})", map[string]string{ "sarama": "github.com/Shopify/sarama", "saramatrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/Shopify/sarama", }, )), }, }, { JoinPoint: join.OneOf( join.FunctionCall("github.com/Shopify/sarama.NewSyncProducer"), join.FunctionCall("github.com/Shopify/sarama.NewSyncProducerFromClient"), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "{{- $cfg := .Function.ArgumentOfType \"sarama.Config\" -}}\nfunc(p sarama.SyncProducer, err error) (sarama.SyncProducer, error) {\n if p != nil {\n p = saramatrace.WrapSyncProducer(\n {{- if $cfg -}}\n {{ $cfg }},\n {{- else -}}\n nil,\n {{- end -}}\n p,\n )\n }\n return p, err\n}({{ . }})", map[string]string{ "sarama": "github.com/Shopify/sarama", "saramatrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/Shopify/sarama", }, )), }, }, { JoinPoint: join.OneOf( join.FunctionCall("github.com/Shopify/sarama.NewAsyncProducer"), join.FunctionCall("github.com/Shopify/sarama.NewAsyncProducerFromClient"), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "{{- $cfg := .Function.ArgumentOfType \"sarama.Config\" -}}\nfunc(p sarama.AsyncProducer, err error) (sarama.AsyncProducer, error) {\n if p != nil {\n p = saramatrace.WrapAsyncProducer(\n {{- if $cfg -}}\n {{ $cfg }},\n {{- else -}}\n nil,\n {{- end -}}\n p,\n )\n }\n return p, err\n}({{ . }})", map[string]string{ "sarama": "github.com/Shopify/sarama", "saramatrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/Shopify/sarama", }, )), }, }, { JoinPoint: join.FunctionBody(join.Directive("dd:span")), Advice: []advice.Advice{ advice.PrependStmts(code.MustTemplate( "{{- $ctx := .Function.ArgumentOfType \"context.Context\" -}}\n{{- $req := .Function.ArgumentOfType \"*net/http.Request\" -}}\n{{- if (eq $ctx \"\") -}}\n {{- $ctx = \"ctx\" -}}\n ctx := {{- with $req -}}\n {{ $req }}.Context()\n {{- else -}}\n context.TODO()\n {{- end }}\n{{ end -}}\n\n{{ $functionName := .Function.Name -}}\n{{- $opName := $functionName -}}\n{{- range .DirectiveArgs \"dd:span\" -}}\n {{- if eq $opName \"\" -}}\n {{ $opName = .Value }}\n {{- end -}}\n {{- if eq .Key \"span.name\" -}}\n {{- $opName = .Value -}}\n {{- break -}}\n {{- end -}}\n{{- end -}}\n\nvar span tracer.Span\nspan, {{ $ctx }} = tracer.StartSpanFromContext({{ $ctx }}, {{ printf \"%q\" $opName }},\n {{- with $functionName }}\n tracer.Tag(\"function-name\", {{ printf \"%q\" $functionName }}),\n {{ end -}}\n {{- range .DirectiveArgs \"dd:span\" }}\n {{ if eq .Key \"span.name\" -}}{{- continue -}}{{- end -}}\n tracer.Tag({{ printf \"%q\" .Key }}, {{ printf \"%q\" .Value }}),\n {{- end }}\n)\n{{- with $req }}\n {{ $req }} = {{ $req }}.WithContext({{ $ctx }})\n{{- end }}\n\n{{ with .Function.ResultOfType \"error\" -}}\n defer func(){\n span.Finish(tracer.WithError({{ . }}))\n }()\n{{ else -}}\n defer span.Finish()\n{{- end -}}", map[string]string{ "context": "context", "tracer": "gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer", }, )), }, }, { JoinPoint: join.AllOf( join.Directive("dd:orchestrion-enabled"), join.ValueDeclaration(join.MustTypeName("bool")), ), Advice: []advice.Advice{ advice.AssignValue(code.MustTemplate( "true", map[string]string{}, )), }, TracerInternal: true, }, { JoinPoint: join.AllOf( join.PackageName("main"), join.FunctionBody(join.Function( join.Name("main"), join.Signature( nil, nil, ), )), ), Advice: []advice.Advice{ advice.InjectDeclarations(code.MustTemplate( "func init() {\n tracer.Start(tracer.WithOrchestrion(map[string]string{\"version\": {{printf \"%q\" Version}}}))\n}", map[string]string{ "tracer": "gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer", }, ), []string{}), advice.InjectDeclarations(code.MustTemplate( "func init() {\n switch os.Getenv(\"DD_PROFILING_ENABLED\") {\n case \"1\", \"true\", \"auto\":\n // The \"auto\" value can be set if profiling is enabled via the\n // Datadog Admission Controller. We always turn on the profiler in\n // the \"auto\" case since we only send profiles after at least a\n // minute, and we assume anything running that long is worth\n // profiling.\n err := profiler.Start(\n profiler.WithProfileTypes(\n profiler.CPUProfile,\n profiler.HeapProfile,\n // Non-default profiles which are highly likely to be useful:\n profiler.GoroutineProfile,\n profiler.MutexProfile,\n ),\n profiler.WithTags(\"orchestrion:true\"),\n )\n if err != nil {\n // TODO: is there a better reporting mechanism?\n // The tracer and profiler already use the stdlib logger, so\n // we're not adding anything new. But users might be using a\n // different logger.\n log.Printf(\"failed to start profiling: %s\", err)\n }\n }\n}", map[string]string{ "log": "log", "os": "os", "profiler": "gopkg.in/DataDog/dd-trace-go.v1/profiler", }, ), []string{}), advice.PrependStmts(code.MustTemplate( "defer tracer.Stop()\ndefer profiler.Stop()", map[string]string{ "profiler": "gopkg.in/DataDog/dd-trace-go.v1/profiler", "tracer": "gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer", }, )), }, }, { JoinPoint: join.OneOf( join.FunctionCall("github.com/99designs/gqlgen/graphql/handler.New"), join.FunctionCall("github.com/99designs/gqlgen/graphql/handler.NewDefaultServer"), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "func(s *handler.Server) *handler.Server {\n s.Use(gqlgentrace.NewTracer())\n return s\n}({{ . }})", map[string]string{ "gqlgentrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/99designs/gqlgen", "handler": "github.com/99designs/gqlgen/graphql/handler", }, )), }, }, { JoinPoint: join.OneOf( join.FunctionCall("github.com/graph-gophers/graphql-go.MustParseSchema"), join.FunctionCall("github.com/graph-gophers/graphql-go.ParseSchema"), ), Advice: []advice.Advice{ advice.AppendArgs( join.MustTypeName("any"), code.MustTemplate( "graphql.Tracer(graphqltrace.NewTracer())", map[string]string{ "graphql": "github.com/graph-gophers/graphql-go", "graphqltrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/graph-gophers/graphql-go", }, ), ), }, }, { JoinPoint: join.FunctionCall("github.com/graphql-go/graphql.NewSchema"), Advice: []advice.Advice{ advice.ReplaceFunction("gopkg.in/DataDog/dd-trace-go.v1/contrib/graphql-go/graphql", "NewSchema"), }, }, { JoinPoint: join.OneOf( join.FunctionCall("google.golang.org/grpc.Dial"), join.FunctionCall("google.golang.org/grpc.DialContext"), join.FunctionCall("google.golang.org/grpc.NewClient"), ), Advice: []advice.Advice{ advice.AppendArgs( join.MustTypeName("google.golang.org/grpc.DialOption"), code.MustTemplate( "grpc.WithStreamInterceptor(grpctrace.StreamClientInterceptor())", map[string]string{ "grpc": "google.golang.org/grpc", "grpctrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/google.golang.org/grpc", }, ), code.MustTemplate( "grpc.WithUnaryInterceptor(grpctrace.UnaryClientInterceptor())", map[string]string{ "grpc": "google.golang.org/grpc", "grpctrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/google.golang.org/grpc", }, ), ), }, }, { JoinPoint: join.FunctionCall("google.golang.org/grpc.NewServer"), Advice: []advice.Advice{ advice.AppendArgs( join.MustTypeName("google.golang.org/grpc.ServerOption"), code.MustTemplate( "grpc.StreamInterceptor(grpctrace.StreamServerInterceptor())", map[string]string{ "grpc": "google.golang.org/grpc", "grpctrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/google.golang.org/grpc", }, ), code.MustTemplate( "grpc.UnaryInterceptor(grpctrace.UnaryServerInterceptor())", map[string]string{ "grpc": "google.golang.org/grpc", "grpctrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/google.golang.org/grpc", }, ), ), }, }, { JoinPoint: join.AllOf( join.OneOf( join.FunctionCall("github.com/go-chi/chi.NewMux"), join.FunctionCall("github.com/go-chi/chi.NewRouter"), ), join.Not(join.OneOf( join.ImportPath("github.com/go-chi/chi"), join.ImportPath("github.com/go-chi/chi/middleware"), )), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "func() *chi.Mux {\n mux := {{ . }}\n mux.Use(chitrace.Middleware())\n return mux\n}()", map[string]string{ "chi": "github.com/go-chi/chi", "chitrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/go-chi/chi", }, )), }, }, { JoinPoint: join.AllOf( join.OneOf( join.FunctionCall("github.com/go-chi/chi/v5.NewMux"), join.FunctionCall("github.com/go-chi/chi/v5.NewRouter"), ), join.Not(join.OneOf( join.ImportPath("github.com/go-chi/chi/v5"), join.ImportPath("github.com/go-chi/chi/v5/middleware"), )), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "func() *chi.Mux {\n mux := {{ . }}\n mux.Use(chitrace.Middleware())\n return mux\n}()", map[string]string{ "chi": "github.com/go-chi/chi/v5", "chitrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/go-chi/chi.v5", }, )), }, }, { JoinPoint: join.FunctionCall("github.com/labstack/echo/v4.New"), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "func() *echo.Echo {\n e := {{ . }}\n e.Use(echotrace.Middleware())\n return e\n}()", map[string]string{ "echo": "github.com/labstack/echo/v4", "echotrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/labstack/echo.v4", }, )), }, }, { JoinPoint: join.FunctionCall("github.com/gofiber/fiber/v2.New"), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "func() *fiber.App {\n app := {{ . }}\n app.Use(fibertrace.Middleware())\n return app\n}()", map[string]string{ "fiber": "github.com/gofiber/fiber/v2", "fibertrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/gofiber/fiber.v2", }, )), }, }, { JoinPoint: join.OneOf( join.FunctionCall("github.com/gin-gonic/gin.Default"), join.FunctionCall("github.com/gin-gonic/gin.New"), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "func() *gin.Engine {\n e := {{ . }}\n e.Use(gintrace.Middleware(\"\"))\n return e\n}()", map[string]string{ "gin": "github.com/gin-gonic/gin", "gintrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/gin-gonic/gin", }, )), }, }, { JoinPoint: join.StructDefinition(join.MustTypeName("github.com/gorilla/mux.Router")), Advice: []advice.Advice{ advice.InjectDeclarations(code.MustTemplate( "type ddRouterConfig struct {\n ignoreRequest func(*http.Request) bool\n headerTags *internal.LockMap\n resourceNamer func(*Router, *http.Request) string\n serviceName string\n spanOpts []ddtrace.StartSpanOption\n}\n\nfunc ddDefaultResourceNamer(router *Router, req *http.Request) string {\n var (\n match RouteMatch\n route = \"unknown\"\n )\n if router.Match(req, &match) && match.Route != nil {\n if r, err := match.Route.GetPathTemplate(); err == nil {\n route = r\n }\n }\n return fmt.Sprintf(\"%s %s\", req.Method, route)\n}\n\nfunc init() {\n telemetry.LoadIntegration(\"gorilla/mux\")\n tracer.MarkIntegrationImported(\"github.com/gorilla/mux\")\n}", map[string]string{ "ddtrace": "gopkg.in/DataDog/dd-trace-go.v1/ddtrace", "http": "net/http", "internal": "gopkg.in/DataDog/dd-trace-go.v1/internal", "telemetry": "gopkg.in/DataDog/dd-trace-go.v1/internal/telemetry", "tracer": "gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer", }, ), []string{}), advice.AddStructField("__dd_config", join.MustTypeName("ddRouterConfig")), }, }, { JoinPoint: join.AllOf( join.ImportPath("github.com/gorilla/mux"), join.FunctionBody(join.Function( join.Name("NewRouter"), )), ), Advice: []advice.Advice{ advice.PrependStmts(code.MustTemplate( "{{- $res := .Function.Result 0 -}}\ndefer func() {\n var analyticsRate float64\n if internal.BoolEnv(\"DD_TRACE_MUX_ANALYTICS_ENABLED\", false) {\n analyticsRate = 1.0\n } else {\n analyticsRate = globalconfig.AnalyticsRate()\n }\n\n {{ $res }}.__dd_config.headerTags = globalconfig.HeaderTagMap()\n {{ $res }}.__dd_config.ignoreRequest = func(*http.Request) bool { return false }\n {{ $res }}.__dd_config.resourceNamer = ddDefaultResourceNamer\n {{ $res }}.__dd_config.serviceName = namingschema.ServiceName(\"mux.router\")\n {{ $res }}.__dd_config.spanOpts = []ddtrace.StartSpanOption{\n tracer.Tag(ext.Component, \"gorilla/mux\"),\n tracer.Tag(ext.SpanKind, ext.SpanKindServer),\n }\n if !math.IsNaN(analyticsRate) {\n {{ $res }}.__dd_config.spanOpts = append(\n {{ $res }}.__dd_config.spanOpts,\n tracer.Tag(ext.EventSampleRate, analyticsRate),\n )\n }\n}()", map[string]string{ "ddtrace": "gopkg.in/DataDog/dd-trace-go.v1/ddtrace", "ext": "gopkg.in/DataDog/dd-trace-go.v1/ddtrace/ext", "globalconfig": "gopkg.in/DataDog/dd-trace-go.v1/internal/globalconfig", "http": "net/http", "internal": "gopkg.in/DataDog/dd-trace-go.v1/internal", "math": "math", "namingschema": "gopkg.in/DataDog/dd-trace-go.v1/internal/namingschema", "tracer": "gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer", }, )), }, }, { JoinPoint: join.FunctionBody(join.Function( join.Receiver(join.MustTypeName("*github.com/gorilla/mux.Router")), join.Name("ServeHTTP"), )), Advice: []advice.Advice{ advice.PrependStmts(code.MustTemplate( "{{- $r := .Function.Receiver -}}\n{{- $w := .Function.Argument 0 -}}\n{{- $req := .Function.Argument 1 -}}\nif !{{ $r }}.__dd_config.ignoreRequest({{ $req }}) {\n var (\n match RouteMatch\n route string\n spanOpts = options.Copy({{ $r }}.__dd_config.spanOpts...)\n )\n if {{ $r }}.Match({{ $req }}, &match) && match.Route != nil {\n if h, err := match.Route.GetHostTemplate(); err == nil {\n spanOpts = append(spanOpts, tracer.Tag(\"mux.host\", h))\n }\n route, _ = match.Route.GetPathTemplate()\n }\n spanOpts = append(spanOpts, httptraceinternal.HeaderTagsFromRequest({{ $req }}, {{ $r }}.__dd_config.headerTags))\n resource := {{ $r }}.__dd_config.resourceNamer({{ $r }}, {{ $req }})\n\n // This is a temporary workaround/hack to prevent endless recursion via httptrace.TraceAndServe, which\n // basically implies passing a shallow copy of this router that ignores all requests down to\n // httptrace.TraceAndServe.\n var rCopy Router\n rCopy = *{{ $r }}\n rCopy.__dd_config.ignoreRequest = func(*http.Request) bool { return true }\n\n httptrace.TraceAndServe(&rCopy, {{ $w }}, {{ $req }}, &httptrace.ServeConfig{\n Service: {{ $r }}.__dd_config.serviceName,\n Resource: resource,\n SpanOpts: spanOpts,\n RouteParams: match.Vars,\n Route: route,\n })\n return\n}", map[string]string{ "http": "net/http", "httptrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/net/http", "httptraceinternal": "gopkg.in/DataDog/dd-trace-go.v1/contrib/internal/httptrace", "options": "gopkg.in/DataDog/dd-trace-go.v1/contrib/internal/options", "tracer": "gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer", }, )), }, }, { JoinPoint: join.StructLiteral(join.MustTypeName("k8s.io/client-go/rest.Config"), join.StructLiteralMatchAny), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "{{- .AST.Type -}}{\n {{- $hasField := false -}}\n {{ range .AST.Elts }}\n {{- if eq .Key.Name \"WrapTransport\" }}\n {{- $hasField = true -}}\n WrapTransport: kubernetestransport.Wrappers({{ .Value }}, kubernetestrace.WrapRoundTripper),\n {{- else -}}\n {{ . }},\n {{ end -}}\n {{ end }}\n {{- if not $hasField -}}\n WrapTransport: kubernetestransport.Wrappers(nil, kubernetestrace.WrapRoundTripper),\n {{- end }}\n}", map[string]string{ "kubernetestrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/k8s.io/client-go/kubernetes", "kubernetestransport": "k8s.io/client-go/transport", }, )), }, }, { JoinPoint: join.FunctionCall("database/sql.Register"), Advice: []advice.Advice{ advice.ReplaceFunction("gopkg.in/DataDog/dd-trace-go.v1/contrib/database/sql", "Register"), }, }, { JoinPoint: join.FunctionCall("database/sql.Open"), Advice: []advice.Advice{ advice.ReplaceFunction("gopkg.in/DataDog/dd-trace-go.v1/contrib/database/sql", "Open"), }, }, { JoinPoint: join.FunctionCall("database/sql.OpenDB"), Advice: []advice.Advice{ advice.ReplaceFunction("gopkg.in/DataDog/dd-trace-go.v1/contrib/database/sql", "OpenDB"), }, }, { JoinPoint: join.StructDefinition(join.MustTypeName("net/http.Transport")), Advice: []advice.Advice{ advice.AddStructField("DD__tracer_internal", join.MustTypeName("bool")), }, }, { JoinPoint: join.AllOf( join.StructLiteral(join.MustTypeName("net/http.Transport"), join.StructLiteralMatchAny), join.OneOf( join.ImportPath("gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer"), join.ImportPath("gopkg.in/DataDog/dd-trace-go.v1/internal/hostname/httputils"), join.ImportPath("gopkg.in/DataDog/dd-trace-go.v1/internal/remoteconfig"), join.ImportPath("gopkg.in/DataDog/dd-trace-go.v1/internal/telemetry"), join.ImportPath("gopkg.in/DataDog/dd-trace-go.v1/profiler"), ), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "{{- .AST.Type -}}{\n DD__tracer_internal: true,\n {{ range .AST.Elts }}{{ . }},\n {{ end }}\n}", map[string]string{}, )), }, TracerInternal: true, }, { JoinPoint: join.FunctionBody(join.Function( join.Name("RoundTrip"), join.Receiver(join.MustTypeName("*net/http.Transport")), )), Advice: []advice.Advice{ advice.InjectDeclarations(code.MustTemplate( "//go:linkname __dd_appsec_RASPEnabled gopkg.in/DataDog/dd-trace-go.v1/internal/appsec.RASPEnabled\nfunc __dd_appsec_RASPEnabled() bool\n\n//go:linkname __dd_httpsec_ProtectRoundTrip gopkg.in/DataDog/dd-trace-go.v1/internal/appsec/emitter/httpsec.ProtectRoundTrip\nfunc __dd_httpsec_ProtectRoundTrip(context.Context, string) error\n\n//go:linkname __dd_tracer_SpanType gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer.SpanType\nfunc __dd_tracer_SpanType(string) ddtrace.StartSpanOption\n\n//go:linkname __dd_tracer_ResourceName gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer.ResourceName\nfunc __dd_tracer_ResourceName(string) ddtrace.StartSpanOption\n\n//go:linkname __dd_tracer_Tag gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer.Tag\nfunc __dd_tracer_Tag(string, any) ddtrace.StartSpanOption\n\n//go:linkname __dd_tracer_StartSpanFromContext gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer.StartSpanFromContext\nfunc __dd_tracer_StartSpanFromContext(context.Context, string, ...ddtrace.StartSpanOption) (ddtrace.Span, context.Context)\n\n//go:linkname __dd_tracer_WithError gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer.WithError\nfunc __dd_tracer_WithError(error) ddtrace.FinishOption\n\n//go:linkname __dd_tracer_Inject gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer.Inject\nfunc __dd_tracer_Inject(ddtrace.SpanContext, any) error\n\ntype __dd_tracer_HTTPHeadersCarrier Header\nfunc (c __dd_tracer_HTTPHeadersCarrier) Set(key, val string) {\n Header(c).Set(key, val)\n}", map[string]string{ "context": "context", "ddtrace": "gopkg.in/DataDog/dd-trace-go.v1/ddtrace", }, ), []string{ "gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer", "gopkg.in/DataDog/dd-trace-go.v1/internal/appsec", "gopkg.in/DataDog/dd-trace-go.v1/internal/appsec/emitter/httpsec", }), advice.PrependStmts(code.MustTemplate( "{{- /* Largely copied from https://github.com/DataDog/dd-trace-go/blob/v1.65.0-rc.2/contrib/net/http/roundtripper.go#L28-L104 */ -}}\n{{- $t := .Function.Receiver -}}\n{{- $req := .Function.Argument 0 -}}\n{{- $res := .Function.Result 0 -}}\n{{- $err := .Function.Result 1 -}}\nif !{{ $t }}.DD__tracer_internal {\n resourceName := fmt.Sprintf(\"%s %s\", {{ $req }}.Method, {{ $req }}.URL.Path)\n spanName := namingschema.OpName(namingschema.HTTPClient)\n // Copy the URL so we don't modify the outgoing request\n url := *{{ $req }}.URL\n url.User = nil // Don't include userinfo in the http.url tag\n opts := []ddtrace.StartSpanOption{\n __dd_tracer_SpanType(ext.SpanTypeHTTP),\n __dd_tracer_ResourceName(resourceName),\n __dd_tracer_Tag(ext.HTTPMethod, {{ $req }}.Method),\n __dd_tracer_Tag(ext.HTTPURL, url.String()),\n __dd_tracer_Tag(ext.Component, \"net/http\"),\n __dd_tracer_Tag(ext.SpanKind, ext.SpanKindClient),\n __dd_tracer_Tag(ext.NetworkDestinationName, url.Hostname()),\n }\n if analyticsRate := globalconfig.AnalyticsRate(); !math.IsNaN(analyticsRate) {\n opts = append(opts, __dd_tracer_Tag(ext.EventSampleRate, analyticsRate))\n }\n if port, err := strconv.Atoi(url.Port()); err == nil {\n opts = append(opts, __dd_tracer_Tag(ext.NetworkDestinationPort, port))\n }\n span, ctx := __dd_tracer_StartSpanFromContext({{ $req }}.Context(), spanName, opts...)\n {{ $req }} = {{ $req }}.Clone(ctx)\n defer func() {\n if !events.IsSecurityError({{ $err }}) {\n span.Finish(__dd_tracer_WithError({{ $err }}))\n } else {\n span.Finish()\n }\n }()\n\n if {{ $err }} = __dd_tracer_Inject(span.Context(), __dd_tracer_HTTPHeadersCarrier({{ $req }}.Header)); {{ $err }} != nil {\n fmt.Fprintf(os.Stderr, \"contrib/net/http.Roundtrip: failed to inject http headers: %v\\n\", {{ $err }})\n }\n\n if __dd_appsec_RASPEnabled() {\n if err := __dd_httpsec_ProtectRoundTrip(ctx, {{ $req }}.URL.String()); err != nil {\n return nil, err\n }\n }\n\n defer func() {\n if {{ $err }} != nil {\n span.SetTag(\"http.errors\", {{ $err }}.Error())\n span.SetTag(ext.Error, {{ $err }})\n } else {\n span.SetTag(ext.HTTPCode, strconv.Itoa({{ $res }}.StatusCode))\n if {{ $res }}.StatusCode >= 500 && {{ $res}}.StatusCode < 600 {\n // Treat HTTP 5XX as errors\n span.SetTag(\"http.errors\", {{ $res }}.Status)\n span.SetTag(ext.Error, fmt.Errorf(\"%d: %s\", {{ $res }}.StatusCode, StatusText({{ $res }}.StatusCode)))\n }\n }\n }()\n}", map[string]string{ "ddtrace": "gopkg.in/DataDog/dd-trace-go.v1/ddtrace", "events": "gopkg.in/DataDog/dd-trace-go.v1/appsec/events", "ext": "gopkg.in/DataDog/dd-trace-go.v1/ddtrace/ext", "fmt": "fmt", "globalconfig": "gopkg.in/DataDog/dd-trace-go.v1/internal/globalconfig", "math": "math", "namingschema": "gopkg.in/DataDog/dd-trace-go.v1/internal/namingschema", "os": "os", "strconv": "strconv", }, )), }, }, { JoinPoint: join.AllOf( join.Not(join.ImportPath("net/http")), join.OneOf( join.FunctionCall("net/http.Get"), join.FunctionCall("net/http.Head"), join.FunctionCall("net/http.Post"), join.FunctionCall("net/http.PostForm"), ), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "{{- $ctx := .Function.ArgumentOfType \"context.Context\" -}}\n{{- $req := .Function.ArgumentOfType \"*net/http.Request\" }}\n{{- if $ctx -}}\n instrument.{{ .AST.Fun.Name }}(\n {{ $ctx }},\n {{ range .AST.Args }}{{ . }},\n {{ end }}\n )\n{{- else if $req -}}\n instrument.{{ .AST.Fun.Name }}(\n {{ $req }}.Context(),\n {{ range .AST.Args }}{{ . }},\n {{ end }}\n )\n{{- else -}}\n {{ . }}\n{{- end -}}", map[string]string{ "instrument": "github.com/DataDog/orchestrion/instrument/net/http", }, )), }, }, { JoinPoint: join.AllOf( join.Configuration(map[string]string{ "httpmode": "wrap", }), join.StructLiteralField(join.MustTypeName("net/http.Server"), "Handler"), join.Not(join.OneOf( join.ImportPath("github.com/go-chi/chi/v5"), join.ImportPath("github.com/go-chi/chi/v5/middleware"), join.ImportPath("golang.org/x/net/http2"), )), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "//dd:startwrap\ninstrument.WrapHandler({{.}})\n//dd:endwrap", map[string]string{ "instrument": "github.com/DataDog/orchestrion/instrument", }, )), }, }, { JoinPoint: join.AllOf( join.Configuration(map[string]string{ "httpmode": "wrap", }), join.Function( join.Name(""), join.Signature( []join.TypeName{join.MustTypeName("net/http.ResponseWriter"), join.MustTypeName("*net/http.Request")}, nil, ), ), join.Not(join.OneOf( join.ImportPath("github.com/go-chi/chi/v5"), join.ImportPath("github.com/go-chi/chi/v5/middleware"), join.ImportPath("golang.org/x/net/http2"), )), ), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "instrument.WrapHandlerFunc({{.}})", map[string]string{ "instrument": "github.com/DataDog/orchestrion/instrument", }, )), }, }, { JoinPoint: join.AllOf( join.Configuration(map[string]string{ "httpmode": "report", }), join.FunctionBody(join.Function( join.Signature( []join.TypeName{join.MustTypeName("net/http.ResponseWriter"), join.MustTypeName("*net/http.Request")}, nil, ), )), join.Not(join.OneOf( join.ImportPath("github.com/go-chi/chi/v5"), join.ImportPath("github.com/go-chi/chi/v5/middleware"), join.ImportPath("golang.org/x/net/http2"), )), ), Advice: []advice.Advice{ advice.PrependStmts(code.MustTemplate( "{{- $arg := .Function.Argument 1 -}}\n{{- $name := .Function.Name -}}\n{{$arg}} = {{$arg}}.WithContext(instrument.Report(\n {{$arg}}.Context(),\n event.EventStart,\n {{with $name}}\"function-name\", {{printf \"%q\" .}},{{end}}\n \"span.kind\", \"server\",\n \"http.method\", {{$arg}}.Method,\n \"http.url\", {{$arg}}.URL,\n \"http.useragent\", {{$arg}}.Header.Get(\"User-Agent\"),\n {{ range .DirectiveArgs \"dd:span\" -}}{{printf \"%q, %q,\\n\" .Key .Value}}{{ end }}\n))\ndefer instrument.Report(\n {{$arg}}.Context(),\n event.EventEnd,\n {{with $name}}\"function-name\", {{printf \"%q\" .}},{{end}}\n \"span.kind\", \"server\",\n \"http.method\", {{$arg}}.Method,\n \"http.url\", {{$arg}}.URL,\n \"http.useragent\", {{$arg}}.Header.Get(\"User-Agent\"),\n {{ range .DirectiveArgs \"dd:span\" -}}{{printf \"%q, %q,\" .Key .Value}}{{- end }}\n)", map[string]string{ "event": "github.com/DataDog/orchestrion/instrument/event", "instrument": "github.com/DataDog/orchestrion/instrument", }, )), }, }, { JoinPoint: join.AllOf( join.ImportPath("os"), join.FunctionBody(join.Function( join.Name("OpenFile"), )), ), Advice: []advice.Advice{ advice.PrependStmts(code.MustTemplate( "__dd_parent_op, _ := dyngo.FromContext(nil)\nif __dd_parent_op != nil {\n __dd_op := &ossec.OpenOperation{\n Operation: dyngo.NewOperation(__dd_parent_op),\n }\n\n var __dd_block bool\n dyngo.OnData(__dd_op, func(_ *events.BlockingSecurityEvent) {\n __dd_block = true\n })\n\n dyngo.StartOperation(__dd_op, ossec.OpenOperationArgs{\n Path: {{ .Function.Argument 0 }},\n Flags: {{ .Function.Argument 1 }},\n Perms: {{ .Function.Argument 2 }},\n })\n\n defer dyngo.FinishOperation(__dd_op, ossec.OpenOperationRes[*File]{\n File: &{{ .Function.Result 0 }},\n Err: &{{ .Function.Result 1 }},\n })\n\n if __dd_block {\n return\n }\n}", map[string]string{ "dyngo": "gopkg.in/DataDog/dd-trace-go.v1/internal/appsec/dyngo", "events": "gopkg.in/DataDog/dd-trace-go.v1/appsec/events", "ossec": "gopkg.in/DataDog/dd-trace-go.v1/internal/appsec/emitter/ossec", }, )), }, }, { JoinPoint: join.StructDefinition(join.MustTypeName("runtime.g")), Advice: []advice.Advice{ advice.AddStructField("__dd_gls", join.MustTypeName("any")), advice.AddBlankImport("unsafe"), advice.InjectDeclarations(code.MustTemplate( "//go:linkname __dd_orchestrion_gls_get __dd_orchestrion_gls_get\nvar __dd_orchestrion_gls_get = func() any {\n return getg().m.curg.__dd_gls\n}\n\n//go:linkname __dd_orchestrion_gls_set __dd_orchestrion_gls_set\nvar __dd_orchestrion_gls_set = func(val any) {\n getg().m.curg.__dd_gls = val\n}", map[string]string{}, ), []string{}), }, }, { JoinPoint: join.AllOf( join.ImportPath("runtime"), join.FunctionBody(join.Function( join.Name("goexit1"), )), ), Advice: []advice.Advice{ advice.PrependStmts(code.MustTemplate( "getg().__dd_gls = nil", map[string]string{}, )), }, }, { JoinPoint: join.FunctionCall("log/slog.New"), Advice: []advice.Advice{ advice.WrapExpression(code.MustTemplate( "{{ .AST.Fun }}(slogtrace.WrapHandler({{ index .AST.Args 0 }}))", map[string]string{ "slogtrace": "gopkg.in/DataDog/dd-trace-go.v1/contrib/log/slog", }, )), }, }, }
Aspects is the list of built-in aspects.
View Source
var InjectedPaths = [...]string{
"context",
"fmt",
"github.com/DataDog/orchestrion/instrument",
"github.com/DataDog/orchestrion/instrument/event",
"github.com/DataDog/orchestrion/instrument/net/http",
"gopkg.in/DataDog/dd-trace-go.v1/appsec/events",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/99designs/gqlgen",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/IBM/sarama.v1",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/Shopify/sarama",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/aws/aws-sdk-go-v2/aws",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/aws/aws-sdk-go/aws",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/cloud.google.com/go/pubsub.v1/internal/tracing",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/database/sql",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/gin-gonic/gin",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/go-chi/chi",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/go-chi/chi.v5",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/go-redis/redis",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/go-redis/redis.v7",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/go-redis/redis.v8",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/go.mongodb.org/mongo-driver/mongo",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/gocql/gocql",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/gofiber/fiber.v2",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/gomodule/redigo",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/google.golang.org/grpc",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/gorm.io/gorm.v1",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/graph-gophers/graphql-go",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/graphql-go/graphql",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/hashicorp/vault",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/internal/httptrace",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/internal/options",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/jinzhu/gorm",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/k8s.io/client-go/kubernetes",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/labstack/echo.v4",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/log/slog",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/net/http",
"gopkg.in/DataDog/dd-trace-go.v1/contrib/redis/go-redis.v9",
"gopkg.in/DataDog/dd-trace-go.v1/ddtrace",
"gopkg.in/DataDog/dd-trace-go.v1/ddtrace/ext",
"gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer",
"gopkg.in/DataDog/dd-trace-go.v1/internal",
"gopkg.in/DataDog/dd-trace-go.v1/internal/appsec",
"gopkg.in/DataDog/dd-trace-go.v1/internal/appsec/dyngo",
"gopkg.in/DataDog/dd-trace-go.v1/internal/appsec/emitter/httpsec",
"gopkg.in/DataDog/dd-trace-go.v1/internal/appsec/emitter/ossec",
"gopkg.in/DataDog/dd-trace-go.v1/internal/globalconfig",
"gopkg.in/DataDog/dd-trace-go.v1/internal/namingschema",
"gopkg.in/DataDog/dd-trace-go.v1/internal/telemetry",
"gopkg.in/DataDog/dd-trace-go.v1/profiler",
"k8s.io/client-go/transport",
"log",
"math",
"net/http",
"os",
"strconv",
}
InjectedPaths is a set of import paths that may be injected by built-in aspects. This list is used to ensure proper invalidation of cached artifacts when injected dependencies change.
Functions ¶
This section is empty.
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.