{"version":3,"file":"kinesis.js","sourceRoot":"","sources":["../../../src/services/kinesis.ts"],"names":[],"mappings":";;;AAAA;;;GAGG;AACH,4CAA0D;AAC1D,oCAA0C;AAI1C,MAAa,uBAAuB;IAClC,kBAAkB,CAChB,OAA0B,EAC1B,OAAoC;QAEpC,MAAM,UAAU,GAAG,OAAO,CAAC,YAAY,EAAE,UAAU,CAAC;QACpD,MAAM,QAAQ,GAAa,cAAQ,CAAC,MAAM,CAAC;QAC3C,MAAM,cAAc,GAAe,EAAE,CAAC;QAEtC,IAAI,UAAU,EAAE;YACd,cAAc,CAAC,sBAAc,CAAC,uBAAuB,CAAC,GAAG,UAAU,CAAC;SACrE;QAED,MAAM,UAAU,GAAG,KAAK,CAAC;QAEzB,OAAO;YACL,UAAU;YACV,cAAc;YACd,QAAQ;SACT,CAAC;IACJ,CAAC;CACF;AArBD,0DAqBC","sourcesContent":["/*\n * Copyright The OpenTelemetry Authors\n * SPDX-License-Identifier: Apache-2.0\n */\nimport { Attributes, SpanKind } from '@opentelemetry/api';\nimport { AttributeNames } from '../enums';\nimport { AwsSdkInstrumentationConfig, NormalizedRequest } from '../types';\nimport { RequestMetadata, ServiceExtension } from './ServiceExtension';\n\nexport class KinesisServiceExtension implements ServiceExtension {\n  requestPreSpanHook(\n    request: NormalizedRequest,\n    _config: AwsSdkInstrumentationConfig\n  ): RequestMetadata {\n    const streamName = request.commandInput?.StreamName;\n    const spanKind: SpanKind = SpanKind.CLIENT;\n    const spanAttributes: Attributes = {};\n\n    if (streamName) {\n      spanAttributes[AttributeNames.AWS_KINESIS_STREAM_NAME] = streamName;\n    }\n\n    const isIncoming = false;\n\n    return {\n      isIncoming,\n      spanAttributes,\n      spanKind,\n    };\n  }\n}\n"]}