Skip to content

Commit 3ca0123

Browse files
Stephen Belangerrochdev
authored andcommitted
Use Span rather than opentracing.Span in d.ts plugin hooks (#2982)
1 parent 8dbbd87 commit 3ca0123

File tree

2 files changed

+32
-18
lines changed

2 files changed

+32
-18
lines changed

docs/test.ts

Lines changed: 24 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,7 @@ const httpOptions = {
133133
const httpServerOptions = {
134134
...httpOptions,
135135
hooks: {
136-
request: (span, req, res) => {}
136+
request: (span: Span, req, res) => {}
137137
}
138138
};
139139

@@ -142,7 +142,7 @@ const httpClientOptions = {
142142
splitByDomain: true,
143143
propagationBlocklist: ['url', /url/, url => true],
144144
hooks: {
145-
request: (span, req, res) => {}
145+
request: (span: Span, req, res) => {}
146146
}
147147
};
148148

@@ -155,6 +155,13 @@ const http2ClientOptions = {
155155
splitByDomain: true
156156
};
157157

158+
const nextOptions = {
159+
service: 'test',
160+
hooks: {
161+
request: (span: Span, params) => { },
162+
},
163+
};
164+
158165
const graphqlOptions = {
159166
service: 'test',
160167
depth: 2,
@@ -163,24 +170,24 @@ const graphqlOptions = {
163170
collapse: false,
164171
signature: false,
165172
hooks: {
166-
execute: (span, args, res) => {},
167-
validate: (span, document, errors) => {},
168-
parse: (span, source, document) => {}
173+
execute: (span: Span, args, res) => {},
174+
validate: (span: Span, document, errors) => {},
175+
parse: (span: Span, source, document) => {}
169176
}
170177
};
171178

172179
const elasticsearchOptions = {
173180
service: 'test',
174181
hooks: {
175-
query: (span, params) => {},
182+
query: (span: Span, params) => {},
176183
},
177184
};
178185

179186
const awsSdkOptions = {
180187
service: 'test',
181188
splitByAwsService: false,
182189
hooks: {
183-
request: (span, response) => {},
190+
request: (span: Span, response) => {},
184191
},
185192
s3: false,
186193
sqs: {
@@ -198,8 +205,8 @@ const redisOptions = {
198205
const sharedbOptions = {
199206
service: 'test',
200207
hooks: {
201-
receive: (span, request) => {},
202-
reply: (span, request, reply) => {},
208+
receive: (span: Span, request) => {},
209+
reply: (span: Span, request, reply) => {},
203210
},
204211
};
205212

@@ -215,12 +222,13 @@ const moleculerOptions = {
215222
const openSearchOptions = {
216223
service: 'test',
217224
hooks: {
218-
query: (span, params) => {},
225+
query: (span: Span, params) => {},
219226
},
220227
};
221228

222229
tracer.use('amqp10');
223230
tracer.use('amqplib');
231+
tracer.use('aws-sdk');
224232
tracer.use('aws-sdk', awsSdkOptions);
225233
tracer.use('bunyan');
226234
tracer.use('couchbase');
@@ -231,6 +239,7 @@ tracer.use('cypress');
231239
tracer.use('cucumber')
232240
tracer.use('cucumber', { service: 'cucumber-service' });
233241
tracer.use('dns');
242+
tracer.use('elasticsearch');
234243
tracer.use('elasticsearch', elasticsearchOptions);
235244
tracer.use('express');
236245
tracer.use('express', httpServerOptions);
@@ -239,6 +248,7 @@ tracer.use('fastify', httpServerOptions);
239248
tracer.use('fs');
240249
tracer.use('generic-pool');
241250
tracer.use('google-cloud-pubsub');
251+
tracer.use('graphql');
242252
tracer.use('graphql', graphqlOptions);
243253
tracer.use('graphql', { variables: ['foo', 'bar'] });
244254
tracer.use('grpc');
@@ -273,6 +283,7 @@ tracer.use('koa');
273283
tracer.use('koa', httpServerOptions);
274284
tracer.use('mariadb', { service: () => `my-custom-mariadb` })
275285
tracer.use('memcached');
286+
tracer.use('microgateway-core');
276287
tracer.use('microgateway-core', httpServerOptions);
277288
tracer.use('mocha');
278289
tracer.use('mocha', { service: 'mocha-service' });
@@ -285,6 +296,8 @@ tracer.use('mysql2');
285296
tracer.use('mysql2', { service: () => `my-custom-mysql2` });
286297
tracer.use('net');
287298
tracer.use('next');
299+
tracer.use('next', nextOptions);
300+
tracer.use('opensearch');
288301
tracer.use('opensearch', openSearchOptions);
289302
tracer.use('oracledb');
290303
tracer.use('oracledb', { service: params => `${params.host}-${params.database}` });
@@ -300,6 +313,7 @@ tracer.use('restify');
300313
tracer.use('restify', httpServerOptions);
301314
tracer.use('rhea');
302315
tracer.use('router');
316+
tracer.use('sharedb');
303317
tracer.use('sharedb', sharedbOptions);
304318
tracer.use('tedious');
305319
tracer.use('winston');

index.d.ts

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -882,7 +882,7 @@ declare namespace plugins {
882882
/**
883883
* Hook to execute just before the request span finishes.
884884
*/
885-
request?: (span?: opentracing.Span, req?: IncomingMessage, res?: ServerResponse) => any;
885+
request?: (span?: Span, req?: IncomingMessage, res?: ServerResponse) => any;
886886
};
887887

888888
/**
@@ -918,7 +918,7 @@ declare namespace plugins {
918918
/**
919919
* Hook to execute just before the request span finishes.
920920
*/
921-
request?: (span?: opentracing.Span, req?: ClientRequest, res?: IncomingMessage) => any;
921+
request?: (span?: Span, req?: ClientRequest, res?: IncomingMessage) => any;
922922
};
923923

924924
/**
@@ -1008,7 +1008,7 @@ declare namespace plugins {
10081008
/**
10091009
* Hook to execute just before the aws span finishes.
10101010
*/
1011-
request?: (span?: opentracing.Span, response?: anyObject) => any;
1011+
request?: (span?: Span, response?: anyObject) => any;
10121012
};
10131013

10141014
/**
@@ -1077,7 +1077,7 @@ declare namespace plugins {
10771077
/**
10781078
* Hook to execute just before the query span finishes.
10791079
*/
1080-
query?: (span?: opentracing.Span, params?: TransportRequestParams) => any;
1080+
query?: (span?: Span, params?: TransportRequestParams) => any;
10811081
};
10821082
}
10831083

@@ -1252,7 +1252,7 @@ declare namespace plugins {
12521252
* Hook to execute just before the request span finishes.
12531253
*/
12541254
request?: (
1255-
span?: opentracing.Span,
1255+
span?: Span,
12561256
req?: IncomingMessage | ClientRequest,
12571257
res?: ServerResponse | IncomingMessage
12581258
) => any;
@@ -1445,7 +1445,7 @@ declare namespace plugins {
14451445
/**
14461446
* Hook to execute just before the request span finishes.
14471447
*/
1448-
request?: (span?: opentracing.Span, req?: IncomingMessage, res?: ServerResponse) => any;
1448+
request?: (span?: Span, req?: IncomingMessage, res?: ServerResponse) => any;
14491449
};
14501450
}
14511451

@@ -1564,12 +1564,12 @@ declare namespace plugins {
15641564
/**
15651565
* Hook to execute just when the span is created.
15661566
*/
1567-
receive?: (span?: opentracing.Span, request?: any) => any;
1567+
receive?: (span?: Span, request?: any) => any;
15681568

15691569
/**
15701570
* Hook to execute just when the span is finished.
15711571
*/
1572-
reply?: (span?: opentracing.Span, request?: any, response?: any) => any;
1572+
reply?: (span?: Span, request?: any, response?: any) => any;
15731573
};
15741574
}
15751575

0 commit comments

Comments
 (0)