summaryrefslogtreecommitdiff
path: root/vendor/jonahgeorge/jaeger-client-php/tests/Jaeger/Sender
diff options
context:
space:
mode:
authorAndrew Dolgov <[email protected]>2023-10-20 17:12:29 +0300
committerAndrew Dolgov <[email protected]>2023-10-20 21:13:39 +0300
commitcdd7ad020e165fe680703b6d3319b908b682fb7a (patch)
treeb51eb09b7b4587e8fbc5624ac8d88d28cfcd0b04 /vendor/jonahgeorge/jaeger-client-php/tests/Jaeger/Sender
parent45a9ff0c88cbd33892ff16ab837e9059937d656e (diff)
jaeger-client -> opentelemetry
Diffstat (limited to 'vendor/jonahgeorge/jaeger-client-php/tests/Jaeger/Sender')
-rw-r--r--vendor/jonahgeorge/jaeger-client-php/tests/Jaeger/Sender/JaegerThriftSenderTest.php126
-rw-r--r--vendor/jonahgeorge/jaeger-client-php/tests/Jaeger/Sender/UdpSenderTest.php116
2 files changed, 0 insertions, 242 deletions
diff --git a/vendor/jonahgeorge/jaeger-client-php/tests/Jaeger/Sender/JaegerThriftSenderTest.php b/vendor/jonahgeorge/jaeger-client-php/tests/Jaeger/Sender/JaegerThriftSenderTest.php
deleted file mode 100644
index 5bd6d0a7b..000000000
--- a/vendor/jonahgeorge/jaeger-client-php/tests/Jaeger/Sender/JaegerThriftSenderTest.php
+++ /dev/null
@@ -1,126 +0,0 @@
-<?php
-
-
-namespace Jaeger\Tests\Sender;
-
-use Jaeger\Sender\JaegerSender;
-use Jaeger\Sender\UdpSender;
-use Jaeger\Span;
-use Jaeger\SpanContext;
-use Jaeger\Thrift\Agent\AgentClient;
-use Jaeger\Thrift\Batch;
-use Jaeger\Tracer;
-use PHPUnit\Framework\TestCase;
-
-class JaegerThriftSenderTest extends TestCase
-{
- /** @var Tracer|\PHPUnit\Framework\MockObject\MockObject */
- private $tracer;
-
- /** @var SpanContext|\PHPUnit\Framework\MockObject\MockObject */
- private $context;
-
- public function setUp(): void
- {
- $tracer = $this->createMock(Tracer::class);
- $tracer->method('getIpAddress')->willReturn('');
- $tracer->method('getServiceName')->willReturn('');
-
- $this->tracer = $tracer;
-
- $context = $this->createMock(SpanContext::class);
- $this->context = $context;
- }
-
- public function testFlush(): void
- {
-
- $span = $this->createMock(Span::class);
- $span->method('getOperationName')->willReturn('dummy-operation');
- $span->method('getTracer')->willReturn($this->tracer);
- $span->method('getContext')->willReturn($this->context);
-
- $client = $this->createMock(AgentClient::class);
- $sender = new JaegerSender($client);
- $sender->setMaxBufferLength(64000);
-
- $client
- ->expects(self::exactly(1))
- ->method('emitBatch');
-
- $sender->append($span);
- $sender->append($span);
- $sender->append($span);
-
- self::assertEquals(3, $sender->flush());
- }
-
- public function testEmitBatch() {
- $client = $this->createMock(AgentClient::class);
- $sender = new JaegerSender($client);
- $sender->setMaxBufferLength(64000);
-
- $span = $this->createMock(Span::class);
- $span->method('getOperationName')->willReturn('dummy-operation');
- $span->method('getTracer')->willReturn($this->tracer);
- $span->method('getContext')->willReturn($this->context);
-
- $client
- ->expects($this->once())
- ->method('emitBatch')
- ->with($this->callback(function ($batch) {
- /** @var Batch $batch */
- $this->assertInstanceOf(Batch::class, $batch);
- $this->assertCount(1, $batch->spans);
-
- /** @var \Jaeger\Thrift\Span $span */
- $span = $batch->spans[0];
- $this->assertInstanceOf(\Jaeger\Thrift\Span::class, $span);
- $this->assertSame("dummy-operation", $span->operationName);
-
- return true;
-
- }));
-
- $sender->append($span);
- $this->assertEquals(1, $sender->flush());
- }
-
- public function testMaxBufferLength() {
- $tracer = $this->createMock(Tracer::class);
- $tracer->method('getIpAddress')->willReturn('');
- $tracer->method('getServiceName')->willReturn('');
-
- $context = $this->createMock(SpanContext::class);
-
- $span = $this->createMock(Span::class);
- $span->method('getOperationName')->willReturn('dummy-operation');
- $span->method('getTracer')->willReturn($tracer);
- $span->method('getContext')->willReturn($context);
-
- $client = $this->createMock(AgentClient::class);
-
- $mockBuilder = $this->getMockBuilder(JaegerSender::class);
- $mockMethods = ['emitJaegerBatch'];
- if (method_exists($mockBuilder, "onlyMethods")) {
- $mockBuilder = $mockBuilder->onlyMethods($mockMethods);
- } else {
- $mockBuilder = $mockBuilder->setMethods($mockMethods);
- }
- $sender = $mockBuilder->setConstructorArgs([$client])->getMock();
- $sender->setMaxBufferLength(800);
- $sender->expects(self::exactly(2))
- ->method('emitJaegerBatch')
- ->withConsecutive(
- [self::countOf(2)],
- [self::countOf(1)]
- );
-
- // jaeger batch overhead parameter = 512
- $sender->append($span); // 512 + 143 < 800 - chunk 1
- $sender->append($span); // 512 + 143*2 => 798 < 800 - chunk 1
- $sender->append($span); // 512 + 143*3 > 800 - chunk 2
-
- self::assertEquals(3, $sender->flush());
- }
-}
diff --git a/vendor/jonahgeorge/jaeger-client-php/tests/Jaeger/Sender/UdpSenderTest.php b/vendor/jonahgeorge/jaeger-client-php/tests/Jaeger/Sender/UdpSenderTest.php
deleted file mode 100644
index 9011d00e3..000000000
--- a/vendor/jonahgeorge/jaeger-client-php/tests/Jaeger/Sender/UdpSenderTest.php
+++ /dev/null
@@ -1,116 +0,0 @@
-<?php
-
-namespace Jaeger\Tests\Sender;
-
-use Jaeger\Sender\UdpSender;
-use Jaeger\Span;
-use Jaeger\SpanContext;
-use Jaeger\Thrift\Agent\AgentClient;
-use Jaeger\Thrift\Agent\Zipkin\Annotation as ZipkinAnnotation;
-use Jaeger\Thrift\Agent\Zipkin\Span as ZipkinSpan;
-use Jaeger\Tracer;
-use PHPUnit\Framework\TestCase;
-
-class UdpSenderTest extends TestCase
-{
- /**
- * @var UdpSender
- */
- private $sender;
-
- /**
- * @var AgentClient
- */
- private $client;
-
- public function setUp(): void
- {
- $this->client = $this->createMock(AgentClient::class);
- $this->sender = new UdpSender($this->client, 64000);
- }
-
- public function testMaxBufferLength(): void
- {
- $tracer = $this->createMock(Tracer::class);
- $tracer->method('getIpAddress')->willReturn('');
- $tracer->method('getServiceName')->willReturn('');
-
- $context = $this->createMock(SpanContext::class);
-
- $span = $this->createMock(Span::class);
- $span->method('getOperationName')->willReturn('dummy-operation');
- $span->method('getTracer')->willReturn($tracer);
- $span->method('getContext')->willReturn($context);
-
- $sender = new UdpSender($this->client, 100);
-
- $this->client
- ->expects(self::exactly(2))
- ->method('emitZipkinBatch')
- ->withConsecutive(
- [self::countOf(2)],
- [self::countOf(1)]
- );
-
- // one span has a length of ~25
- $sender->append($span); // 30 + 25 < 100 - chunk 1
- $sender->append($span); // 30 + 25 * 2 < 100 - chunk 1
- $sender->append($span); // 30 + 25 * 3 > 100 - chunk 2
-
- self::assertEquals(3, $sender->flush());
- }
-
- public function testFlush(): void
- {
- $this->assertEquals(0, $this->sender->flush());
-
- $logTimeStamp = (int) (microtime(true) * 1000000);
-
- $tracer = $this->createMock(Tracer::class);
- $tracer->method('getIpAddress')->willReturn('');
- $tracer->method('getServiceName')->willReturn('');
- $context = $this->createMock(SpanContext::class);
- $span = $this->createMock(Span::class);
- $span->method('getTracer')->willReturn($tracer);
- $span->method('getContext')->willReturn($context);
- $span
- ->expects($this->atLeastOnce())
- ->method('getLogs')
- ->willReturn([
- [
- 'timestamp' => $logTimeStamp,
- 'fields' => [
- 'foo' => 'bar',
- ],
- ],
- ]);
-
- $this->client
- ->expects($this->once())
- ->method('emitZipkinBatch')
- ->with($this->callback(function ($spans) use ($logTimeStamp) {
- $this->assertCount(1, $spans);
-
- /* @var $annotation ZipkinSpan */
- $span = $spans[0];
- $this->assertInstanceOf(ZipkinSpan::class, $span);
- $this->assertCount(1, $span->annotations);
-
- /* @var $annotation ZipkinAnnotation */
- $annotation = $span->annotations[0];
- $this->assertInstanceOf(ZipkinAnnotation::class, $annotation);
- $this->assertSame($logTimeStamp, $annotation->timestamp);
- $this->assertSame(
- json_encode([
- 'foo' => 'bar',
- ]),
- $annotation->value
- );
-
- return true;
- }));
-
- $this->sender->append($span);
- $this->assertEquals(1, $this->sender->flush());
- }
-}