Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ Deno.test('mongodb instrumentation: orchestrion:mongodb:command channel produces
assertEquals(mongoSpan!.data?.['db.namespace'], 'mydb');
assertEquals(mongoSpan!.data?.['db.collection.name'], 'users');
assertEquals(mongoSpan!.data?.['db.operation.name'], 'find');
assertEquals(mongoSpan!.data?.['net.peer.name'], '127.0.0.1');
assertEquals(mongoSpan!.data?.['net.peer.port'], 27017);
assertEquals(mongoSpan!.data?.['server.address'], '127.0.0.1');
assertEquals(mongoSpan!.data?.['server.port'], 27017);
assertEquals(mongoSpan!.data?.['sentry.origin'], 'auto.db.mongo');
});
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ Deno.test('mongoose instrumentation: orchestrion:mongoose:model_save channel pro
assertEquals(mongooseSpan!.data?.['db.collection.name'], 'blogposts');
assertEquals(mongooseSpan!.data?.['db.operation.name'], 'save');
assertEquals(mongooseSpan!.data?.['db.user'], 'root');
assertEquals(mongooseSpan!.data?.['net.peer.name'], '127.0.0.1');
assertEquals(mongooseSpan!.data?.['net.peer.port'], 27017);
assertEquals(mongooseSpan!.data?.['server.address'], '127.0.0.1');
assertEquals(mongooseSpan!.data?.['server.port'], 27017);
assertEquals(mongooseSpan!.data?.['sentry.origin'], 'auto.db.mongoose');
});
Original file line number Diff line number Diff line change
Expand Up @@ -92,8 +92,8 @@ Deno.test('mysql instrumentation: orchestrion:mysql:query channel produces a nes
assertEquals(mysqlSpan!.description, 'SELECT 1 AS solution');
assertEquals(mysqlSpan!.data?.['db.system.name'], 'mysql');
assertEquals(mysqlSpan!.data?.['db.query.text'], 'SELECT 1 AS solution');
assertEquals(mysqlSpan!.data?.['net.peer.name'], '127.0.0.1');
assertEquals(mysqlSpan!.data?.['net.peer.port'], 3306);
assertEquals(mysqlSpan!.data?.['server.address'], '127.0.0.1');
assertEquals(mysqlSpan!.data?.['server.port'], 3306);
assertEquals(mysqlSpan!.data?.['db.user'], 'root');
assertEquals(mysqlSpan!.data?.['sentry.origin'], 'auto.db.mysql');
});
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ Deno.test('mysql2 instrumentation: orchestrion:mysql2:query channel produces a n
assertEquals(mysqlSpan!.data?.['db.query.text'], 'SELECT 1 AS solution');
assertEquals(mysqlSpan!.data?.['db.namespace'], 'mydb');
assertEquals(mysqlSpan!.data?.['db.user'], 'root');
assertEquals(mysqlSpan!.data?.['net.peer.name'], '127.0.0.1');
assertEquals(mysqlSpan!.data?.['net.peer.port'], 3306);
assertEquals(mysqlSpan!.data?.['server.address'], '127.0.0.1');
assertEquals(mysqlSpan!.data?.['server.port'], 3306);
assertEquals(mysqlSpan!.data?.['sentry.origin'], 'auto.db.mysql2');
});
Original file line number Diff line number Diff line change
Expand Up @@ -92,8 +92,8 @@ Deno.test('pg instrumentation: orchestrion:pg:query channel produces a nested db
assertEquals(pgSpan!.description, 'SELECT 1 AS solution');
assertEquals(pgSpan!.data?.['db.system.name'], 'postgresql');
assertEquals(pgSpan!.data?.['db.query.text'], 'SELECT 1 AS solution');
assertEquals(pgSpan!.data?.['net.peer.name'], '127.0.0.1');
assertEquals(pgSpan!.data?.['net.peer.port'], 5432);
assertEquals(pgSpan!.data?.['server.address'], '127.0.0.1');
assertEquals(pgSpan!.data?.['server.port'], 5432);
assertEquals(pgSpan!.data?.['db.user'], 'root');
assertEquals(pgSpan!.data?.['sentry.origin'], 'auto.db.postgres');
});
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ Deno.test('tedious instrumentation: orchestrion:tedious:execSql channel produces
assertEquals(tediousSpan!.data?.['db.namespace'], 'mydb');
assertEquals(tediousSpan!.data?.['db.user'], 'sa');
assertEquals(tediousSpan!.data?.['db.query.text'], 'SELECT 1');
assertEquals(tediousSpan!.data?.['net.peer.name'], '127.0.0.1');
assertEquals(tediousSpan!.data?.['net.peer.port'], 1433);
assertEquals(tediousSpan!.data?.['server.address'], '127.0.0.1');
assertEquals(tediousSpan!.data?.['server.port'], 1433);
assertEquals(tediousSpan!.data?.['sentry.origin'], 'auto.db.tedious');
});
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,8 @@ test('a real mysql query emits a db span with orchestrion-channel attributes', a
expect(firstQuery!.data?.['sentry.origin']).toBe('auto.db.mysql');
expect(firstQuery!.data?.['db.system.name']).toBe('mysql');
expect(firstQuery!.data?.['db.query.text']).toBe('SELECT 1 + 1 AS solution');
expect(firstQuery!.data?.['net.peer.name']).toBe('127.0.0.1');
expect(firstQuery!.data?.['net.peer.port']).toBe(3306);
expect(firstQuery!.data?.['server.address']).toBe('127.0.0.1');
expect(firstQuery!.data?.['server.port']).toBe(3306);
expect(firstQuery!.data?.['db.user']).toBe('root');
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -63,8 +63,8 @@ test('Instruments mysql automatically', async ({ baseURL }) => {
'db.query.text': 'SELECT 1 + 1 AS solution',
'db.user': 'root',
'db.connection_string': expect.any(String),
'net.peer.name': expect.any(String),
'net.peer.port': 3306,
'server.address': expect.any(String),
'server.port': 3306,
}),
}),
);
Expand All @@ -79,8 +79,8 @@ test('Instruments mysql automatically', async ({ baseURL }) => {
'db.query.text': 'SELECT NOW()',
'db.user': 'root',
'db.connection_string': expect.any(String),
'net.peer.name': expect.any(String),
'net.peer.port': 3306,
'server.address': expect.any(String),
'server.port': 3306,
}),
}),
);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ test('mysql queries emit a db span with orchestrion-channel attributes', async (
expect(firstQuery!.data?.['sentry.origin']).toBe('auto.db.mysql');
expect(firstQuery!.data?.['db.system.name']).toBe('mysql');
expect(firstQuery!.data?.['db.query.text']).toBe('SELECT 1 + 1 AS solution');
expect(firstQuery!.data?.['net.peer.port']).toBe(3306);
expect(firstQuery!.data?.['server.port']).toBe(3306);
expect(firstQuery!.data?.['db.user']).toBe('root');
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,8 +27,8 @@ test('a real mysql query emits a db span with orchestrion-channel attributes', a
expect(firstQuery!.data?.['sentry.origin']).toBe('auto.db.mysql');
expect(firstQuery!.data?.['db.system.name']).toBe('mysql');
expect(firstQuery!.data?.['db.query.text']).toBe('SELECT 1 + 1 AS solution');
expect(firstQuery!.data?.['net.peer.name']).toBe('127.0.0.1');
expect(firstQuery!.data?.['net.peer.port']).toBe(3306);
expect(firstQuery!.data?.['server.address']).toBe('127.0.0.1');
expect(firstQuery!.data?.['server.port']).toBe(3306);
expect(firstQuery!.data?.['db.user']).toBe('root');
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -69,8 +69,8 @@ test.describe('orchestrion DB instrumentation', () => {
'db.query.text': 'SELECT 1 + 1 AS solution',
'db.user': 'root',
'db.connection_string': expect.any(String),
'net.peer.name': expect.any(String),
'net.peer.port': 3306,
'server.address': expect.any(String),
'server.port': 3306,
}),
}),
);
Expand All @@ -85,8 +85,8 @@ test.describe('orchestrion DB instrumentation', () => {
'db.query.text': 'SELECT NOW()',
'db.user': 'root',
'db.connection_string': expect.any(String),
'net.peer.name': expect.any(String),
'net.peer.port': 3306,
'server.address': expect.any(String),
'server.port': 3306,
}),
}),
);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ test('mysql queries emit a db span with orchestrion-channel attributes', async (
expect(firstQuery!.data?.['sentry.origin']).toBe('auto.db.mysql');
expect(firstQuery!.data?.['db.system.name']).toBe('mysql');
expect(firstQuery!.data?.['db.query.text']).toBe('SELECT 1 + 1 AS solution');
expect(firstQuery!.data?.['net.peer.port']).toBe(3306);
expect(firstQuery!.data?.['server.port']).toBe(3306);
expect(firstQuery!.data?.['db.user']).toBe('root');
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ test('pg queries emit a db span with orchestrion-channel attributes', async ({ b
expect(firstQuery!.data?.['sentry.origin']).toBe('auto.db.postgres');
expect(firstQuery!.data?.['db.system.name']).toBe('postgresql');
expect(firstQuery!.data?.['db.query.text']).toBe('SELECT 1 + 1 AS solution');
expect(firstQuery!.data?.['net.peer.port']).toBe(5432);
expect(firstQuery!.data?.['server.port']).toBe(5432);
expect(firstQuery!.data?.['db.user']).toBe('postgres');
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,8 @@ test('a real mysql query emits a db span with orchestrion-channel attributes', a
expect(firstQuery!.data?.['sentry.origin']).toBe('auto.db.mysql');
expect(firstQuery!.data?.['db.system.name']).toBe('mysql');
expect(firstQuery!.data?.['db.query.text']).toBe('SELECT 1 + 1 AS solution');
expect(firstQuery!.data?.['net.peer.name']).toBe('127.0.0.1');
expect(firstQuery!.data?.['net.peer.port']).toBe(3306);
expect(firstQuery!.data?.['server.address']).toBe('127.0.0.1');
expect(firstQuery!.data?.['server.port']).toBe(3306);
expect(firstQuery!.data?.['db.user']).toBe('root');
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -75,8 +75,8 @@ test('Instruments mysql automatically', async ({ baseURL }) => {
'db.query.text': 'SELECT 1 + 1 AS solution',
'db.user': 'root',
'db.connection_string': expect.any(String),
'net.peer.name': expect.any(String),
'net.peer.port': 3306,
'server.address': expect.any(String),
'server.port': 3306,
}),
}),
);
Expand All @@ -91,8 +91,8 @@ test('Instruments mysql automatically', async ({ baseURL }) => {
'db.query.text': 'SELECT NOW()',
'db.user': 'root',
'db.connection_string': expect.any(String),
'net.peer.name': expect.any(String),
'net.peer.port': 3306,
'server.address': expect.any(String),
'server.port': 3306,
}),
}),
);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -89,8 +89,8 @@ test.describe('server - orchestrion build-time db instrumentation', () => {
'db.query.text': 'SELECT 1 + 1 AS solution',
'db.user': 'root',
'db.connection_string': expect.any(String),
'net.peer.name': expect.any(String),
'net.peer.port': 3306,
'server.address': expect.any(String),
'server.port': 3306,
}),
}),
);
Expand All @@ -105,8 +105,8 @@ test.describe('server - orchestrion build-time db instrumentation', () => {
'db.query.text': 'SELECT NOW()',
'db.user': 'root',
'db.connection_string': expect.any(String),
'net.peer.name': expect.any(String),
'net.peer.port': 3306,
'server.address': expect.any(String),
'server.port': 3306,
}),
}),
);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,8 @@ test('a real mysql query emits a db span with orchestrion-channel attributes', a
expect(firstQuery!.data?.['sentry.origin']).toBe('auto.db.mysql');
expect(firstQuery!.data?.['db.system.name']).toBe('mysql');
expect(firstQuery!.data?.['db.query.text']).toBe('SELECT 1 + 1 AS solution');
expect(firstQuery!.data?.['net.peer.name']).toBe('127.0.0.1');
expect(firstQuery!.data?.['net.peer.port']).toBe(3306);
expect(firstQuery!.data?.['server.address']).toBe('127.0.0.1');
expect(firstQuery!.data?.['server.port']).toBe(3306);
expect(firstQuery!.data?.['db.user']).toBe('root');
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -62,8 +62,8 @@ test('Instruments mysql automatically via build-time orchestrion', async ({ base
'db.query.text': 'SELECT 1 + 1 AS solution',
'db.user': 'root',
'db.connection_string': expect.any(String),
'net.peer.name': expect.any(String),
'net.peer.port': 3306,
'server.address': expect.any(String),
'server.port': 3306,
}),
}),
);
Expand All @@ -78,8 +78,8 @@ test('Instruments mysql automatically via build-time orchestrion', async ({ base
'db.query.text': 'SELECT NOW()',
'db.user': 'root',
'db.connection_string': expect.any(String),
'net.peer.name': expect.any(String),
'net.peer.port': 3306,
'server.address': expect.any(String),
'server.port': 3306,
}),
}),
);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -63,8 +63,8 @@ test('Instruments mysql automatically', async ({ baseURL }) => {
'db.query.text': 'SELECT 1 + 1 AS solution',
'db.user': 'root',
'db.connection_string': expect.any(String),
'net.peer.name': expect.any(String),
'net.peer.port': 3306,
'server.address': expect.any(String),
'server.port': 3306,
}),
}),
);
Expand All @@ -79,8 +79,8 @@ test('Instruments mysql automatically', async ({ baseURL }) => {
'db.query.text': 'SELECT NOW()',
'db.user': 'root',
'db.connection_string': expect.any(String),
'net.peer.name': expect.any(String),
'net.peer.port': 3306,
'server.address': expect.any(String),
'server.port': 3306,
}),
}),
);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,8 +25,8 @@ test('a real mysql query emits a db span with orchestrion-channel attributes', a
expect(firstQuery!.data?.['sentry.origin']).toBe('auto.db.mysql');
expect(firstQuery!.data?.['db.system.name']).toBe('mysql');
expect(firstQuery!.data?.['db.query.text']).toBe('SELECT 1 + 1 AS solution');
expect(firstQuery!.data?.['net.peer.name']).toBe('127.0.0.1');
expect(firstQuery!.data?.['net.peer.port']).toBe(3306);
expect(firstQuery!.data?.['server.address']).toBe('127.0.0.1');
expect(firstQuery!.data?.['server.port']).toBe(3306);
expect(firstQuery!.data?.['db.user']).toBe('root');
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -72,8 +72,8 @@ test('Instruments mysql automatically', async ({ baseURL }) => {
'db.query.text': 'SELECT 1 + 1 AS solution',
'db.user': 'root',
'db.connection_string': expect.any(String),
'net.peer.name': expect.any(String),
'net.peer.port': 3306,
'server.address': expect.any(String),
'server.port': 3306,
}),
}),
);
Expand All @@ -88,8 +88,8 @@ test('Instruments mysql automatically', async ({ baseURL }) => {
'db.query.text': 'SELECT NOW()',
'db.user': 'root',
'db.connection_string': expect.any(String),
'net.peer.name': expect.any(String),
'net.peer.port': 3306,
'server.address': expect.any(String),
'server.port': 3306,
}),
}),
);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,8 +18,6 @@ const expectedProducerSpan = (routingKey: string) =>
'messaging.url': 'amqp://sentry:***@localhost:5672/',
'messaging.protocol': 'AMQP',
'messaging.protocol_version': '0.9.1',
'net.peer.name': 'localhost',
'net.peer.port': 5672,
'messaging.operation.type': 'send',
'messaging.destination.name': '',
'messaging.rabbitmq.destination.routing_key': routingKey,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,8 +21,8 @@ describeWithDockerCompose('knex auto instrumentation', { workingDirectory: [__di
'db.user': 'root',
'sentry.origin': ORIGIN,
'sentry.op': 'db',
'net.peer.name': 'localhost',
'net.peer.port': 3307,
'server.address': 'localhost',
'server.port': 3307,
}),
status: 'ok',
description:
Expand All @@ -37,8 +37,8 @@ describeWithDockerCompose('knex auto instrumentation', { workingDirectory: [__di
'db.user': 'root',
'sentry.origin': ORIGIN,
'sentry.op': 'db',
'net.peer.name': 'localhost',
'net.peer.port': 3307,
'server.address': 'localhost',
'server.port': 3307,
}),
status: 'ok',
description: 'insert into `User` (`email`, `name`) values (?, ?)',
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,8 @@ describe('knex auto instrumentation', () => {
'db.namespace': 'tests',
'sentry.origin': ORIGIN,
'sentry.op': 'db',
'net.peer.name': 'localhost',
'net.peer.port': 5445,
'server.address': 'localhost',
'server.port': 5445,
}),
status: 'ok',
description:
Expand All @@ -35,8 +35,8 @@ describe('knex auto instrumentation', () => {
'db.namespace': 'tests',
'sentry.origin': ORIGIN,
'sentry.op': 'db',
'net.peer.name': 'localhost',
'net.peer.port': 5445,
'server.address': 'localhost',
'server.port': 5445,
}),
status: 'ok',
// In the knex-otel spans, the placeholders (e.g., `$1`) are replaced by a `?`.
Expand Down
Loading
Loading