Skip to content

Commit 5b9354b

Browse files
Stephen Belangerrochdev
authored andcommitted
Use Span rather than opentracing.Span in d.ts plugin hooks (#2982)
1 parent feac874 commit 5b9354b

2 files changed

Lines changed: 32 additions & 18 deletions

File tree

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,13 +239,15 @@ 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);
237246
tracer.use('fastify');
238247
tracer.use('fastify', httpServerOptions);
239248
tracer.use('generic-pool');
240249
tracer.use('google-cloud-pubsub');
250+
tracer.use('graphql');
241251
tracer.use('graphql', graphqlOptions);
242252
tracer.use('graphql', { variables: ['foo', 'bar'] });
243253
tracer.use('grpc');
@@ -272,6 +282,7 @@ tracer.use('koa');
272282
tracer.use('koa', httpServerOptions);
273283
tracer.use('mariadb', { service: () => `my-custom-mariadb` })
274284
tracer.use('memcached');
285+
tracer.use('microgateway-core');
275286
tracer.use('microgateway-core', httpServerOptions);
276287
tracer.use('mocha');
277288
tracer.use('mocha', { service: 'mocha-service' });
@@ -284,6 +295,8 @@ tracer.use('mysql2');
284295
tracer.use('mysql2', { service: () => `my-custom-mysql2` });
285296
tracer.use('net');
286297
tracer.use('next');
298+
tracer.use('next', nextOptions);
299+
tracer.use('opensearch');
287300
tracer.use('opensearch', openSearchOptions);
288301
tracer.use('oracledb');
289302
tracer.use('oracledb', { service: params => `${params.host}-${params.database}` });
@@ -299,6 +312,7 @@ tracer.use('restify');
299312
tracer.use('restify', httpServerOptions);
300313
tracer.use('rhea');
301314
tracer.use('router');
315+
tracer.use('sharedb');
302316
tracer.use('sharedb', sharedbOptions);
303317
tracer.use('tedious');
304318
tracer.use('winston');

index.d.ts

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -871,7 +871,7 @@ declare namespace plugins {
871871
/**
872872
* Hook to execute just before the request span finishes.
873873
*/
874-
request?: (span?: opentracing.Span, req?: IncomingMessage, res?: ServerResponse) => any;
874+
request?: (span?: Span, req?: IncomingMessage, res?: ServerResponse) => any;
875875
};
876876

877877
/**
@@ -907,7 +907,7 @@ declare namespace plugins {
907907
/**
908908
* Hook to execute just before the request span finishes.
909909
*/
910-
request?: (span?: opentracing.Span, req?: ClientRequest, res?: IncomingMessage) => any;
910+
request?: (span?: Span, req?: ClientRequest, res?: IncomingMessage) => any;
911911
};
912912

913913
/**
@@ -997,7 +997,7 @@ declare namespace plugins {
997997
/**
998998
* Hook to execute just before the aws span finishes.
999999
*/
1000-
request?: (span?: opentracing.Span, response?: anyObject) => any;
1000+
request?: (span?: Span, response?: anyObject) => any;
10011001
};
10021002

10031003
/**
@@ -1066,7 +1066,7 @@ declare namespace plugins {
10661066
/**
10671067
* Hook to execute just before the query span finishes.
10681068
*/
1069-
query?: (span?: opentracing.Span, params?: TransportRequestParams) => any;
1069+
query?: (span?: Span, params?: TransportRequestParams) => any;
10701070
};
10711071
}
10721072

@@ -1235,7 +1235,7 @@ declare namespace plugins {
12351235
* Hook to execute just before the request span finishes.
12361236
*/
12371237
request?: (
1238-
span?: opentracing.Span,
1238+
span?: Span,
12391239
req?: IncomingMessage | ClientRequest,
12401240
res?: ServerResponse | IncomingMessage
12411241
) => any;
@@ -1428,7 +1428,7 @@ declare namespace plugins {
14281428
/**
14291429
* Hook to execute just before the request span finishes.
14301430
*/
1431-
request?: (span?: opentracing.Span, req?: IncomingMessage, res?: ServerResponse) => any;
1431+
request?: (span?: Span, req?: IncomingMessage, res?: ServerResponse) => any;
14321432
};
14331433
}
14341434

@@ -1547,12 +1547,12 @@ declare namespace plugins {
15471547
/**
15481548
* Hook to execute just when the span is created.
15491549
*/
1550-
receive?: (span?: opentracing.Span, request?: any) => any;
1550+
receive?: (span?: Span, request?: any) => any;
15511551

15521552
/**
15531553
* Hook to execute just when the span is finished.
15541554
*/
1555-
reply?: (span?: opentracing.Span, request?: any, response?: any) => any;
1555+
reply?: (span?: Span, request?: any, response?: any) => any;
15561556
};
15571557
}
15581558

0 commit comments

Comments
 (0)