kafkaconnect/aws.sdk.kotlin.services.kafkaconnect.paginators

Package-level declarations

Inherited functions

connectorOperations

fun Flow<ListConnectorOperationsResponse>.connectorOperations(): Flow<ConnectorOperationSummary>

This paginator transforms the flow returned by listConnectorOperationsPaginated to access the nested member ConnectorOperationSummary

fun Flow<ListConnectorsResponse>.connectors(): Flow<ConnectorSummary>

This paginator transforms the flow returned by listConnectorsPaginated to access the nested member ConnectorSummary

fun Flow<ListCustomPluginsResponse>.customPlugins(): Flow<CustomPluginSummary>

This paginator transforms the flow returned by listCustomPluginsPaginated to access the nested member CustomPluginSummary

listConnectorOperationsPaginated

fun KafkaConnectClient.listConnectorOperationsPaginated(initialRequest: ListConnectorOperationsRequest): Flow<ListConnectorOperationsResponse>

fun KafkaConnectClient.listConnectorOperationsPaginated(block: ListConnectorOperationsRequest.Builder.() -> Unit): Flow<ListConnectorOperationsResponse>

Paginate over ListConnectorOperationsResponse results.

listConnectorsPaginated

fun KafkaConnectClient.listConnectorsPaginated(initialRequest: ListConnectorsRequest = ListConnectorsRequest { }): Flow<ListConnectorsResponse>

fun KafkaConnectClient.listConnectorsPaginated(block: ListConnectorsRequest.Builder.() -> Unit): Flow<ListConnectorsResponse>

Paginate over ListConnectorsResponse results.

listCustomPluginsPaginated

fun KafkaConnectClient.listCustomPluginsPaginated(initialRequest: ListCustomPluginsRequest = ListCustomPluginsRequest { }): Flow<ListCustomPluginsResponse>

fun KafkaConnectClient.listCustomPluginsPaginated(block: ListCustomPluginsRequest.Builder.() -> Unit): Flow<ListCustomPluginsResponse>

Paginate over ListCustomPluginsResponse results.

listWorkerConfigurationsPaginated

fun KafkaConnectClient.listWorkerConfigurationsPaginated(initialRequest: ListWorkerConfigurationsRequest = ListWorkerConfigurationsRequest { }): Flow<ListWorkerConfigurationsResponse>

fun KafkaConnectClient.listWorkerConfigurationsPaginated(block: ListWorkerConfigurationsRequest.Builder.() -> Unit): Flow<ListWorkerConfigurationsResponse>

Paginate over ListWorkerConfigurationsResponse results.

workerConfigurations

fun Flow<ListWorkerConfigurationsResponse>.workerConfigurations(): Flow<WorkerConfigurationSummary>

This paginator transforms the flow returned by listWorkerConfigurationsPaginated to access the nested member WorkerConfigurationSummary