diff --git a/pkg/plug/server.go b/pkg/plug/server.go index f338446..11df7a2 100644 --- a/pkg/plug/server.go +++ b/pkg/plug/server.go @@ -132,33 +132,17 @@ func (p *Plug) Listen(ctx context.Context) error { } func (p *Plug) GetSource() models.Source { - _, span := tracer.Start(p.ctx, "GetSource") - defer span.End() - - span.SetAttributes(attribute.String("source_domain", string(p.source.Domain))) return p.source } func (p *Plug) TaskExecutionFunction(function TaskExecution) { - _, span := tracer.Start(p.ctx, "TaskExecutionFunction") - defer span.End() - p.taskExecutionFunction = function - span.AddEvent("Task execution function set") } func (p *Plug) SendMessageExecution(function SendMessageExecution) { - _, span := tracer.Start(p.ctx, "SendMessageExecution") - defer span.End() - p.sendMessageExecution = function - span.AddEvent("Send message execution function set") } func (p *Plug) GetMessageExecution(function GetMessageExecution) { - _, span := tracer.Start(p.ctx, "GetMessageExecution") - defer span.End() - p.getMessageExecution = function - span.AddEvent("Get message execution function set") }