PipesClient

Amazon EventBridge Pipes connects event sources to targets. Pipes reduces the need for specialized knowledge and integration code when developing event driven architectures. This helps ensures consistency across your company’s applications. With Pipes, the target can be any available EventBridge target. To set up a pipe, you select the event source, add optional event filtering, define optional enrichment, and select the target for the event data.

Properties

Link copied to clipboard
abstract override val config: PipesClient.Config

PipesClient's configuration

Functions

Link copied to clipboard
abstract suspend fun createPipe(input: CreatePipeRequest): CreatePipeResponse

Create a pipe. Amazon EventBridge Pipes connect event sources to targets and reduces the need for specialized knowledge and integration code.

Link copied to clipboard
abstract suspend fun deletePipe(input: DeletePipeRequest): DeletePipeResponse

Delete an existing pipe. For more information about pipes, see Amazon EventBridge Pipes in the Amazon EventBridge User Guide.

Link copied to clipboard

Get the information about an existing pipe. For more information about pipes, see Amazon EventBridge Pipes in the Amazon EventBridge User Guide.

Link copied to clipboard
abstract suspend fun listPipes(input: ListPipesRequest = ListPipesRequest { }): ListPipesResponse

Get the pipes associated with this account. For more information about pipes, see Amazon EventBridge Pipes in the Amazon EventBridge User Guide.

Link copied to clipboard

Displays the tags associated with a pipe.

Link copied to clipboard
abstract suspend fun startPipe(input: StartPipeRequest): StartPipeResponse

Start an existing pipe.

Link copied to clipboard
abstract suspend fun stopPipe(input: StopPipeRequest): StopPipeResponse

Stop an existing pipe.

Link copied to clipboard
abstract suspend fun tagResource(input: TagResourceRequest): TagResourceResponse

Assigns one or more tags (key-value pairs) to the specified pipe. Tags can help you organize and categorize your resources. You can also use them to scope user permissions by granting a user permission to access or change only resources with certain tag values.

Link copied to clipboard

Removes one or more tags from the specified pipes.

Link copied to clipboard
abstract suspend fun updatePipe(input: UpdatePipeRequest): UpdatePipeResponse

Update an existing pipe. When you call UpdatePipe, EventBridge only the updates fields you have specified in the request; the rest remain unchanged. The exception to this is if you modify any Amazon Web Services-service specific fields in the SourceParameters, EnrichmentParameters, or TargetParameters objects. For example, DynamoDBStreamParameters or EventBridgeEventBusParameters. EventBridge updates the fields in these objects atomically as one and overrides existing values. This is by design, and means that if you don't specify an optional field in one of these Parameters objects, EventBridge sets that field to its system-default value during the update.

Inherited functions

Link copied to clipboard
expect abstract fun close()
Link copied to clipboard
inline suspend fun PipesClient.createPipe(crossinline block: CreatePipeRequest.Builder.() -> Unit): CreatePipeResponse

Create a pipe. Amazon EventBridge Pipes connect event sources to targets and reduces the need for specialized knowledge and integration code.

Link copied to clipboard
inline suspend fun PipesClient.deletePipe(crossinline block: DeletePipeRequest.Builder.() -> Unit): DeletePipeResponse

Delete an existing pipe. For more information about pipes, see Amazon EventBridge Pipes in the Amazon EventBridge User Guide.

Link copied to clipboard
inline suspend fun PipesClient.describePipe(crossinline block: DescribePipeRequest.Builder.() -> Unit): DescribePipeResponse

Get the information about an existing pipe. For more information about pipes, see Amazon EventBridge Pipes in the Amazon EventBridge User Guide.

Link copied to clipboard
inline suspend fun PipesClient.listPipes(crossinline block: ListPipesRequest.Builder.() -> Unit): ListPipesResponse

Get the pipes associated with this account. For more information about pipes, see Amazon EventBridge Pipes in the Amazon EventBridge User Guide.

Link copied to clipboard
fun PipesClient.listPipesPaginated(initialRequest: ListPipesRequest = ListPipesRequest { }): Flow<ListPipesResponse>

Paginate over ListPipesResponse results.

Link copied to clipboard

Displays the tags associated with a pipe.

Link copied to clipboard
inline suspend fun PipesClient.startPipe(crossinline block: StartPipeRequest.Builder.() -> Unit): StartPipeResponse

Start an existing pipe.

Link copied to clipboard
inline suspend fun PipesClient.stopPipe(crossinline block: StopPipeRequest.Builder.() -> Unit): StopPipeResponse

Stop an existing pipe.

Link copied to clipboard
inline suspend fun PipesClient.tagResource(crossinline block: TagResourceRequest.Builder.() -> Unit): TagResourceResponse

Assigns one or more tags (key-value pairs) to the specified pipe. Tags can help you organize and categorize your resources. You can also use them to scope user permissions by granting a user permission to access or change only resources with certain tag values.

Link copied to clipboard

Removes one or more tags from the specified pipes.

Link copied to clipboard
inline suspend fun PipesClient.updatePipe(crossinline block: UpdatePipeRequest.Builder.() -> Unit): UpdatePipeResponse

Update an existing pipe. When you call UpdatePipe, EventBridge only the updates fields you have specified in the request; the rest remain unchanged. The exception to this is if you modify any Amazon Web Services-service specific fields in the SourceParameters, EnrichmentParameters, or TargetParameters objects. For example, DynamoDBStreamParameters or EventBridgeEventBusParameters. EventBridge updates the fields in these objects atomically as one and overrides existing values. This is by design, and means that if you don't specify an optional field in one of these Parameters objects, EventBridge sets that field to its system-default value during the update.

Link copied to clipboard

Create a copy of the client with one or more configuration values overridden. This method allows the caller to perform scoped config overrides for one or more client operations.