DMleadgen
46d973904b
Next.js website for Rocky Mountain Vending company featuring: - Product catalog with Stripe integration - Service areas and parts pages - Admin dashboard with Clerk authentication - SEO optimized pages with JSON-LD structured data Co-authored-by: Cursor <cursoragent@cursor.com>
27 lines
No EOL
1.1 KiB
Text
27 lines
No EOL
1.1 KiB
Text
/// <reference types="node" />
|
|
import { Span } from '@opentelemetry/api';
|
|
import { InstrumentationConfig } from '@opentelemetry/instrumentation';
|
|
export interface KafkajsMessage {
|
|
key?: Buffer | string | null;
|
|
value: Buffer | string | null;
|
|
partition?: number;
|
|
headers?: Record<string, Buffer | string | (Buffer | string)[] | undefined>;
|
|
timestamp?: string;
|
|
}
|
|
export interface MessageInfo<T = KafkajsMessage> {
|
|
topic: string;
|
|
message: T;
|
|
}
|
|
export interface KafkaProducerCustomAttributeFunction<T = KafkajsMessage> {
|
|
(span: Span, info: MessageInfo<T>): void;
|
|
}
|
|
export interface KafkaConsumerCustomAttributeFunction<T = KafkajsMessage> {
|
|
(span: Span, info: MessageInfo<T>): void;
|
|
}
|
|
export interface KafkaJsInstrumentationConfig extends InstrumentationConfig {
|
|
/** hook for adding custom attributes before producer message is sent */
|
|
producerHook?: KafkaProducerCustomAttributeFunction;
|
|
/** hook for adding custom attributes before consumer message is processed */
|
|
consumerHook?: KafkaConsumerCustomAttributeFunction;
|
|
}
|
|
//# sourceMappingURL=types.d.ts.map |