1
1
<?php
2
-
3
- declare (strict_types = 1 );
2
+ declare (strict_types=1 );
4
3
5
4
namespace CodeTool \Jaeger \MongoDb ;
6
5
7
6
use Jaeger \Log \ErrorLog ;
8
7
use Jaeger \Span \SpanInterface ;
9
- use Jaeger \Tag \BoolTag ;
10
8
use Jaeger \Tag \ComponentTag ;
11
9
use Jaeger \Tag \DbInstanceTag ;
12
10
use Jaeger \Tag \DbStatementTag ;
@@ -45,17 +43,14 @@ public function commandStarted(CommandStartedEvent $event)
45
43
{
46
44
/** @var MongoDB\Driver\Server $server */
47
45
$ server = $ event ->getServer ();
48
-
49
46
$ this ->requestIdToSpan [$ event ->getRequestId ()] = $ this ->tracer ->start (
50
47
sprintf ('mongodb.%s ' , $ event ->getCommandName ()),
51
48
[
52
49
new SpanKindClientTag (),
53
50
new ComponentTag ('php-mongodb ' ),
54
-
55
51
new DbType ('mongo ' ),
56
52
new DbInstanceTag ($ event ->getDatabaseName ()),
57
53
new DbStatementTag ($ this ->convertor ->convert ($ event ->getCommand ())),
58
-
59
54
new PeerHostnameTag ($ server ->getHost ()),
60
55
new PeerPortTag ($ server ->getPort ()),
61
56
]
@@ -68,7 +63,6 @@ private function getSpanByEvent($event): ?SpanInterface
68
63
// warning, should not happen!
69
64
return null ;
70
65
}
71
-
72
66
$ span = $ this ->requestIdToSpan [$ event ->getRequestId ()];
73
67
unset($ this ->requestIdToSpan [$ event ->getRequestId ()]);
74
68
@@ -80,19 +74,16 @@ public function commandFailed(CommandFailedEvent $event)
80
74
if (null === $ span = $ this ->getSpanByEvent ($ event )) {
81
75
return ;
82
76
}
83
-
84
77
$ span ->addTag (new ErrorTag ());
85
78
$ span ->addLog (new ErrorLog ($ event ->getError ()->getMessage (), $ event ->getError ()->getTraceAsString ()));
86
-
87
- $ this ->tracer ->finish ($ span , $ event ->getDurationMicros ());
79
+ $ span ->finish ($ event ->getDurationMicros ());
88
80
}
89
81
90
82
public function commandSucceeded (CommandSucceededEvent $ event )
91
83
{
92
84
if (null === $ span = $ this ->getSpanByEvent ($ event )) {
93
85
return ;
94
86
}
95
-
96
- $ this ->tracer ->finish ($ span , $ event ->getDurationMicros ());
87
+ $ span ->finish ($ event ->getDurationMicros ());
97
88
}
98
89
}
0 commit comments