Skip to content

Commit de930e7

Browse files
author
awstools
committed
feat(client-osis): Adds support for cross-account ingestion for push-based sources. This includes resource policies for sharing pipelines across accounts and features for managing pipeline endpoints which enable accessing pipelines across different VPCs, including VPCs in other accounts.
1 parent 8d88136 commit de930e7

26 files changed

+2867
-48
lines changed

clients/client-osis/README.md

Lines changed: 64 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -212,6 +212,14 @@ CreatePipeline
212212

213213
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/osis/command/CreatePipelineCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/CreatePipelineCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/CreatePipelineCommandOutput/)
214214

215+
</details>
216+
<details>
217+
<summary>
218+
CreatePipelineEndpoint
219+
</summary>
220+
221+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/osis/command/CreatePipelineEndpointCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/CreatePipelineEndpointCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/CreatePipelineEndpointCommandOutput/)
222+
215223
</details>
216224
<details>
217225
<summary>
@@ -220,6 +228,22 @@ DeletePipeline
220228

221229
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/osis/command/DeletePipelineCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/DeletePipelineCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/DeletePipelineCommandOutput/)
222230

231+
</details>
232+
<details>
233+
<summary>
234+
DeletePipelineEndpoint
235+
</summary>
236+
237+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/osis/command/DeletePipelineEndpointCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/DeletePipelineEndpointCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/DeletePipelineEndpointCommandOutput/)
238+
239+
</details>
240+
<details>
241+
<summary>
242+
DeleteResourcePolicy
243+
</summary>
244+
245+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/osis/command/DeleteResourcePolicyCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/DeleteResourcePolicyCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/DeleteResourcePolicyCommandOutput/)
246+
223247
</details>
224248
<details>
225249
<summary>
@@ -244,6 +268,14 @@ GetPipelineChangeProgress
244268

245269
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/osis/command/GetPipelineChangeProgressCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/GetPipelineChangeProgressCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/GetPipelineChangeProgressCommandOutput/)
246270

271+
</details>
272+
<details>
273+
<summary>
274+
GetResourcePolicy
275+
</summary>
276+
277+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/osis/command/GetResourcePolicyCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/GetResourcePolicyCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/GetResourcePolicyCommandOutput/)
278+
247279
</details>
248280
<details>
249281
<summary>
@@ -252,6 +284,22 @@ ListPipelineBlueprints
252284

253285
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/osis/command/ListPipelineBlueprintsCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/ListPipelineBlueprintsCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/ListPipelineBlueprintsCommandOutput/)
254286

287+
</details>
288+
<details>
289+
<summary>
290+
ListPipelineEndpointConnections
291+
</summary>
292+
293+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/osis/command/ListPipelineEndpointConnectionsCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/ListPipelineEndpointConnectionsCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/ListPipelineEndpointConnectionsCommandOutput/)
294+
295+
</details>
296+
<details>
297+
<summary>
298+
ListPipelineEndpoints
299+
</summary>
300+
301+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/osis/command/ListPipelineEndpointsCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/ListPipelineEndpointsCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/ListPipelineEndpointsCommandOutput/)
302+
255303
</details>
256304
<details>
257305
<summary>
@@ -268,6 +316,22 @@ ListTagsForResource
268316

269317
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/osis/command/ListTagsForResourceCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/ListTagsForResourceCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/ListTagsForResourceCommandOutput/)
270318

319+
</details>
320+
<details>
321+
<summary>
322+
PutResourcePolicy
323+
</summary>
324+
325+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/osis/command/PutResourcePolicyCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/PutResourcePolicyCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/PutResourcePolicyCommandOutput/)
326+
327+
</details>
328+
<details>
329+
<summary>
330+
RevokePipelineEndpointConnections
331+
</summary>
332+
333+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/osis/command/RevokePipelineEndpointConnectionsCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/RevokePipelineEndpointConnectionsCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-osis/Interface/RevokePipelineEndpointConnectionsCommandOutput/)
334+
271335
</details>
272336
<details>
273337
<summary>

clients/client-osis/src/OSIS.ts

Lines changed: 186 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,11 +7,26 @@ import {
77
CreatePipelineCommandInput,
88
CreatePipelineCommandOutput,
99
} from "./commands/CreatePipelineCommand";
10+
import {
11+
CreatePipelineEndpointCommand,
12+
CreatePipelineEndpointCommandInput,
13+
CreatePipelineEndpointCommandOutput,
14+
} from "./commands/CreatePipelineEndpointCommand";
1015
import {
1116
DeletePipelineCommand,
1217
DeletePipelineCommandInput,
1318
DeletePipelineCommandOutput,
1419
} from "./commands/DeletePipelineCommand";
20+
import {
21+
DeletePipelineEndpointCommand,
22+
DeletePipelineEndpointCommandInput,
23+
DeletePipelineEndpointCommandOutput,
24+
} from "./commands/DeletePipelineEndpointCommand";
25+
import {
26+
DeleteResourcePolicyCommand,
27+
DeleteResourcePolicyCommandInput,
28+
DeleteResourcePolicyCommandOutput,
29+
} from "./commands/DeleteResourcePolicyCommand";
1530
import {
1631
GetPipelineBlueprintCommand,
1732
GetPipelineBlueprintCommandInput,
@@ -23,11 +38,26 @@ import {
2338
GetPipelineChangeProgressCommandOutput,
2439
} from "./commands/GetPipelineChangeProgressCommand";
2540
import { GetPipelineCommand, GetPipelineCommandInput, GetPipelineCommandOutput } from "./commands/GetPipelineCommand";
41+
import {
42+
GetResourcePolicyCommand,
43+
GetResourcePolicyCommandInput,
44+
GetResourcePolicyCommandOutput,
45+
} from "./commands/GetResourcePolicyCommand";
2646
import {
2747
ListPipelineBlueprintsCommand,
2848
ListPipelineBlueprintsCommandInput,
2949
ListPipelineBlueprintsCommandOutput,
3050
} from "./commands/ListPipelineBlueprintsCommand";
51+
import {
52+
ListPipelineEndpointConnectionsCommand,
53+
ListPipelineEndpointConnectionsCommandInput,
54+
ListPipelineEndpointConnectionsCommandOutput,
55+
} from "./commands/ListPipelineEndpointConnectionsCommand";
56+
import {
57+
ListPipelineEndpointsCommand,
58+
ListPipelineEndpointsCommandInput,
59+
ListPipelineEndpointsCommandOutput,
60+
} from "./commands/ListPipelineEndpointsCommand";
3161
import {
3262
ListPipelinesCommand,
3363
ListPipelinesCommandInput,
@@ -38,6 +68,16 @@ import {
3868
ListTagsForResourceCommandInput,
3969
ListTagsForResourceCommandOutput,
4070
} from "./commands/ListTagsForResourceCommand";
71+
import {
72+
PutResourcePolicyCommand,
73+
PutResourcePolicyCommandInput,
74+
PutResourcePolicyCommandOutput,
75+
} from "./commands/PutResourcePolicyCommand";
76+
import {
77+
RevokePipelineEndpointConnectionsCommand,
78+
RevokePipelineEndpointConnectionsCommandInput,
79+
RevokePipelineEndpointConnectionsCommandOutput,
80+
} from "./commands/RevokePipelineEndpointConnectionsCommand";
4181
import {
4282
StartPipelineCommand,
4383
StartPipelineCommandInput,
@@ -68,13 +108,21 @@ import { OSISClient, OSISClientConfig } from "./OSISClient";
68108

69109
const commands = {
70110
CreatePipelineCommand,
111+
CreatePipelineEndpointCommand,
71112
DeletePipelineCommand,
113+
DeletePipelineEndpointCommand,
114+
DeleteResourcePolicyCommand,
72115
GetPipelineCommand,
73116
GetPipelineBlueprintCommand,
74117
GetPipelineChangeProgressCommand,
118+
GetResourcePolicyCommand,
75119
ListPipelineBlueprintsCommand,
120+
ListPipelineEndpointConnectionsCommand,
121+
ListPipelineEndpointsCommand,
76122
ListPipelinesCommand,
77123
ListTagsForResourceCommand,
124+
PutResourcePolicyCommand,
125+
RevokePipelineEndpointConnectionsCommand,
78126
StartPipelineCommand,
79127
StopPipelineCommand,
80128
TagResourceCommand,
@@ -98,6 +146,23 @@ export interface OSIS {
98146
cb: (err: any, data?: CreatePipelineCommandOutput) => void
99147
): void;
100148

149+
/**
150+
* @see {@link CreatePipelineEndpointCommand}
151+
*/
152+
createPipelineEndpoint(
153+
args: CreatePipelineEndpointCommandInput,
154+
options?: __HttpHandlerOptions
155+
): Promise<CreatePipelineEndpointCommandOutput>;
156+
createPipelineEndpoint(
157+
args: CreatePipelineEndpointCommandInput,
158+
cb: (err: any, data?: CreatePipelineEndpointCommandOutput) => void
159+
): void;
160+
createPipelineEndpoint(
161+
args: CreatePipelineEndpointCommandInput,
162+
options: __HttpHandlerOptions,
163+
cb: (err: any, data?: CreatePipelineEndpointCommandOutput) => void
164+
): void;
165+
101166
/**
102167
* @see {@link DeletePipelineCommand}
103168
*/
@@ -112,6 +177,40 @@ export interface OSIS {
112177
cb: (err: any, data?: DeletePipelineCommandOutput) => void
113178
): void;
114179

180+
/**
181+
* @see {@link DeletePipelineEndpointCommand}
182+
*/
183+
deletePipelineEndpoint(
184+
args: DeletePipelineEndpointCommandInput,
185+
options?: __HttpHandlerOptions
186+
): Promise<DeletePipelineEndpointCommandOutput>;
187+
deletePipelineEndpoint(
188+
args: DeletePipelineEndpointCommandInput,
189+
cb: (err: any, data?: DeletePipelineEndpointCommandOutput) => void
190+
): void;
191+
deletePipelineEndpoint(
192+
args: DeletePipelineEndpointCommandInput,
193+
options: __HttpHandlerOptions,
194+
cb: (err: any, data?: DeletePipelineEndpointCommandOutput) => void
195+
): void;
196+
197+
/**
198+
* @see {@link DeleteResourcePolicyCommand}
199+
*/
200+
deleteResourcePolicy(
201+
args: DeleteResourcePolicyCommandInput,
202+
options?: __HttpHandlerOptions
203+
): Promise<DeleteResourcePolicyCommandOutput>;
204+
deleteResourcePolicy(
205+
args: DeleteResourcePolicyCommandInput,
206+
cb: (err: any, data?: DeleteResourcePolicyCommandOutput) => void
207+
): void;
208+
deleteResourcePolicy(
209+
args: DeleteResourcePolicyCommandInput,
210+
options: __HttpHandlerOptions,
211+
cb: (err: any, data?: DeleteResourcePolicyCommandOutput) => void
212+
): void;
213+
115214
/**
116215
* @see {@link GetPipelineCommand}
117216
*/
@@ -157,6 +256,23 @@ export interface OSIS {
157256
cb: (err: any, data?: GetPipelineChangeProgressCommandOutput) => void
158257
): void;
159258

259+
/**
260+
* @see {@link GetResourcePolicyCommand}
261+
*/
262+
getResourcePolicy(
263+
args: GetResourcePolicyCommandInput,
264+
options?: __HttpHandlerOptions
265+
): Promise<GetResourcePolicyCommandOutput>;
266+
getResourcePolicy(
267+
args: GetResourcePolicyCommandInput,
268+
cb: (err: any, data?: GetResourcePolicyCommandOutput) => void
269+
): void;
270+
getResourcePolicy(
271+
args: GetResourcePolicyCommandInput,
272+
options: __HttpHandlerOptions,
273+
cb: (err: any, data?: GetResourcePolicyCommandOutput) => void
274+
): void;
275+
160276
/**
161277
* @see {@link ListPipelineBlueprintsCommand}
162278
*/
@@ -175,6 +291,42 @@ export interface OSIS {
175291
cb: (err: any, data?: ListPipelineBlueprintsCommandOutput) => void
176292
): void;
177293

294+
/**
295+
* @see {@link ListPipelineEndpointConnectionsCommand}
296+
*/
297+
listPipelineEndpointConnections(): Promise<ListPipelineEndpointConnectionsCommandOutput>;
298+
listPipelineEndpointConnections(
299+
args: ListPipelineEndpointConnectionsCommandInput,
300+
options?: __HttpHandlerOptions
301+
): Promise<ListPipelineEndpointConnectionsCommandOutput>;
302+
listPipelineEndpointConnections(
303+
args: ListPipelineEndpointConnectionsCommandInput,
304+
cb: (err: any, data?: ListPipelineEndpointConnectionsCommandOutput) => void
305+
): void;
306+
listPipelineEndpointConnections(
307+
args: ListPipelineEndpointConnectionsCommandInput,
308+
options: __HttpHandlerOptions,
309+
cb: (err: any, data?: ListPipelineEndpointConnectionsCommandOutput) => void
310+
): void;
311+
312+
/**
313+
* @see {@link ListPipelineEndpointsCommand}
314+
*/
315+
listPipelineEndpoints(): Promise<ListPipelineEndpointsCommandOutput>;
316+
listPipelineEndpoints(
317+
args: ListPipelineEndpointsCommandInput,
318+
options?: __HttpHandlerOptions
319+
): Promise<ListPipelineEndpointsCommandOutput>;
320+
listPipelineEndpoints(
321+
args: ListPipelineEndpointsCommandInput,
322+
cb: (err: any, data?: ListPipelineEndpointsCommandOutput) => void
323+
): void;
324+
listPipelineEndpoints(
325+
args: ListPipelineEndpointsCommandInput,
326+
options: __HttpHandlerOptions,
327+
cb: (err: any, data?: ListPipelineEndpointsCommandOutput) => void
328+
): void;
329+
178330
/**
179331
* @see {@link ListPipelinesCommand}
180332
*/
@@ -204,6 +356,40 @@ export interface OSIS {
204356
cb: (err: any, data?: ListTagsForResourceCommandOutput) => void
205357
): void;
206358

359+
/**
360+
* @see {@link PutResourcePolicyCommand}
361+
*/
362+
putResourcePolicy(
363+
args: PutResourcePolicyCommandInput,
364+
options?: __HttpHandlerOptions
365+
): Promise<PutResourcePolicyCommandOutput>;
366+
putResourcePolicy(
367+
args: PutResourcePolicyCommandInput,
368+
cb: (err: any, data?: PutResourcePolicyCommandOutput) => void
369+
): void;
370+
putResourcePolicy(
371+
args: PutResourcePolicyCommandInput,
372+
options: __HttpHandlerOptions,
373+
cb: (err: any, data?: PutResourcePolicyCommandOutput) => void
374+
): void;
375+
376+
/**
377+
* @see {@link RevokePipelineEndpointConnectionsCommand}
378+
*/
379+
revokePipelineEndpointConnections(
380+
args: RevokePipelineEndpointConnectionsCommandInput,
381+
options?: __HttpHandlerOptions
382+
): Promise<RevokePipelineEndpointConnectionsCommandOutput>;
383+
revokePipelineEndpointConnections(
384+
args: RevokePipelineEndpointConnectionsCommandInput,
385+
cb: (err: any, data?: RevokePipelineEndpointConnectionsCommandOutput) => void
386+
): void;
387+
revokePipelineEndpointConnections(
388+
args: RevokePipelineEndpointConnectionsCommandInput,
389+
options: __HttpHandlerOptions,
390+
cb: (err: any, data?: RevokePipelineEndpointConnectionsCommandOutput) => void
391+
): void;
392+
207393
/**
208394
* @see {@link StartPipelineCommand}
209395
*/

0 commit comments

Comments
 (0)