artin/sourcegraph
1
0
Fork 0
mirror of https://github.com/sourcegraph/sourcegraph.git synced 2026-02-06 20:31:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

observation: AddEvent sends honeycomb span-event (#43557)

Browse Source
This commit is contained in:
Noah S-C 2022-10-27 16:07:23 +01:00 committed by GitHub
parent c65f36f184
commit 3a178e4015
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 20 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
internal/observation/observation.go
View File

@ -175,9 +175,10 @@ func TestTraceLogger(logger log.Logger) TraceLogger {
}
type traceLogger struct {
opName string
event honey.Event
trace *trace.Trace
opName string
event honey.Event
trace *trace.Trace
context *Context
log.Logger
}
@ -196,10 +197,19 @@ func (t *traceLogger) initWithTags(fields ...otlog.Field) {
}
func (t *traceLogger) AddEvent(name string, attributes ...attribute.KeyValue) {
if honey.Enabled() {
if honey.Enabled() && t.context.HoneyDataset != nil {
event := t.context.HoneyDataset.EventWithFields(map[string]any{
"operation": toSnakeCase(name),
"meta.annotation_type": "span_event",
"trace.trace_id": t.event.Fields()["trace.trace_id"],
"trace.parent_id": t.event.Fields()["trace.span_id"],
})
for _, attr := range attributes {
t.event.AddField(t.opName+"."+toSnakeCase(string(attr.Key)), attr.Value)
event.AddField(t.opName+"."+toSnakeCase(string(attr.Key)), attr.Value.AsInterface())
}
// if sample rate > 1 for this dataset, then theres a possibility that this event
// won't be sent but the "parent" may be sent.
event.Send()
}
if t.trace != nil {
t.trace.AddEvent(name, attributes...)
@ -356,10 +366,11 @@ func (op *Operation) With(ctx context.Context, err *error, args Args) (context.C
}
trLogger := &traceLogger{
opName: snakecaseOpName,
event: event,
trace: tr,
Logger: logger,
context: op.context,
opName: snakecaseOpName,
event: event,
trace: tr,
Logger: logger,
}
if mergedFields := mergeLogFields(op.logFields, args.LogFields); len(mergedFields) > 0 {