Skip to content

Commit

Permalink
chore: cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
abhilash-sivan committed Dec 6, 2024
1 parent f684b31 commit 3723ce6
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 41 deletions.
17 changes: 0 additions & 17 deletions packages/collector/test/tracing/database/couchbase/test.js
Original file line number Diff line number Diff line change
Expand Up @@ -455,14 +455,6 @@ mochaSuiteFn('tracing/couchbase', function () {
verifySpans(agentControls, controls, {
spanLength: 9,
verifyCustom: (entrySpan, spans) => {
// expectExactlyOneMatching(
// spans,
// verifyCouchbaseSpan(controls, entrySpan, {
// bucket: 'projects',
// type: 'membase',
// sql: 'NOW SELECT '
// })
// );
expectExactlyNMatching(
spans,
1,
Expand Down Expand Up @@ -490,15 +482,6 @@ mochaSuiteFn('tracing/couchbase', function () {
sql: 'CREATE INDEX '
})
);
// expectExactlyNMatching(
// spans,
// 1,
// verifyCouchbaseSpan(controls, entrySpan, {
// bucket: '',
// type: '',
// sql: 'SELECT'
// })
// );
expectExactlyNMatching(
spans,
1,
Expand Down
25 changes: 1 addition & 24 deletions packages/core/src/tracing/instrumentation/database/couchbase.js
Original file line number Diff line number Diff line change
Expand Up @@ -94,7 +94,7 @@ function instrumentCluster(cluster, connectionStr) {
// #### FTS SERVICE (.searchIndexes().)
instrumentSearchIndexes(cluster, connectionStr);

// #### ANALYTICS SERVICES (.analyticsIndexes().) version >= 4.4.4
// #### ANALYTICS SERVICES (.analyticsIndexes().)
instrumentAnalyticsIndexes(cluster, connectionStr);

// #### N1QL SERVICE (.queryIndexes().)
Expand All @@ -119,29 +119,6 @@ function instrumentCluster(cluster, connectionStr) {
).apply(originalThis, originalArgs);
};
});

// #### ANALYTICS SERVICE (.analyticsIndexes().) v <= 4.4.3
shimmer.wrap(cluster, 'analyticsQuery', function instanaClusterAnalyticsQuery(original) {
return function instanaClusterAnalyticsQueryWrapped() {
const originalThis = this;
const originalArgs = arguments;
const sqlStatement = originalArgs[0] || '';

return instrumentOperation(
{
connectionStr,
sql: tracingUtil.shortenDatabaseStatement(sqlStatement),
resultHandler: (span, result) => {
if (result && result.rows && result.rows.length > 0 && result.rows[0].BucketName) {
span.data.couchbase.bucket = result.rows[0].BucketName;
span.data.couchbase.type = bucketLookup[span.data.couchbase.bucket];
}
}
},
original
).apply(originalThis, originalArgs);
};
});
}

function instrumentCollection(cluster, connectionStr) {
Expand Down

0 comments on commit 3723ce6

Please sign in to comment.