1 | import { Handler } from "../handler";
|
2 |
|
3 | export type KinesisStreamHandler = Handler<KinesisStreamEvent, void>;
|
4 |
|
5 |
|
6 |
|
7 | export interface KinesisStreamRecordPayload {
|
8 | approximateArrivalTimestamp: number;
|
9 | data: string;
|
10 | kinesisSchemaVersion: string;
|
11 | partitionKey: string;
|
12 | sequenceNumber: string;
|
13 | }
|
14 |
|
15 | export interface KinesisStreamRecord {
|
16 | awsRegion: string;
|
17 | eventID: string;
|
18 | eventName: string;
|
19 | eventSource: string;
|
20 | eventSourceARN: string;
|
21 | eventVersion: string;
|
22 | invokeIdentityArn: string;
|
23 | kinesis: KinesisStreamRecordPayload;
|
24 | }
|
25 |
|
26 | export interface KinesisStreamEvent {
|
27 | Records: KinesisStreamRecord[];
|
28 | }
|