datapipeline/aws.sdk.kotlin.services.datapipeline.paginators

Package-level declarations

Functions

describeObjectsPaginated

fun DataPipelineClient.describeObjectsPaginated(initialRequest: DescribeObjectsRequest): Flow<DescribeObjectsResponse>

fun DataPipelineClient.describeObjectsPaginated(block: DescribeObjectsRequest.Builder.() -> Unit): Flow<DescribeObjectsResponse>

Paginate over DescribeObjectsResponse results.

@JvmName(name = "queryObjectsResponseId")

fun Flow<QueryObjectsResponse>.ids(): Flow<String>

This paginator transforms the flow returned by queryObjectsPaginated to access the nested member Id

listPipelinesPaginated

fun DataPipelineClient.listPipelinesPaginated(initialRequest: ListPipelinesRequest = ListPipelinesRequest { }): Flow<ListPipelinesResponse>

fun DataPipelineClient.listPipelinesPaginated(block: ListPipelinesRequest.Builder.() -> Unit): Flow<ListPipelinesResponse>

Paginate over ListPipelinesResponse results.

@JvmName(name = "listPipelinesResponsePipelineIdName")

fun Flow<ListPipelinesResponse>.pipelineIdList(): Flow<PipelineIdName>

This paginator transforms the flow returned by listPipelinesPaginated to access the nested member PipelineIdName

pipelineObjects

@JvmName(name = "describeObjectsResponsePipelineObject")

fun Flow<DescribeObjectsResponse>.pipelineObjects(): Flow<PipelineObject>

This paginator transforms the flow returned by describeObjectsPaginated to access the nested member PipelineObject

queryObjectsPaginated

fun DataPipelineClient.queryObjectsPaginated(initialRequest: QueryObjectsRequest): Flow<QueryObjectsResponse>

fun DataPipelineClient.queryObjectsPaginated(block: QueryObjectsRequest.Builder.() -> Unit): Flow<QueryObjectsResponse>

Paginate over QueryObjectsResponse results.