@Generated(value="OracleSDKGenerator", comments="API Version: 20180418") public interface StreamAdminAsync extends AutoCloseable
close
void setEndpoint(String endpoint)
Sets the endpoint to call (ex, https://www.example.com).
endpoint
- The endpoint of the serice.void setRegion(Region region)
Sets the region to call (ex, Region.US_PHOENIX_1).
Note, this will call setEndpoint
after resolving the endpoint. If the service is not available in this region, however, an IllegalArgumentException will be raised.
region
- The region of the service.void setRegion(String regionId)
Sets the region to call (ex, ‘us-phoenix-1’).
Note, this will first try to map the region ID to a known Region and call setRegion
.
If no known Region could be determined, it will create an endpoint based on the default endpoint format (Region.formatDefaultRegionEndpoint(Service, String)
and then call setEndpoint
.
regionId
- The public region ID.Future<CreateStreamResponse> createStream(CreateStreamRequest request, AsyncHandler<CreateStreamRequest,CreateStreamResponse> handler)
Starts the provisioning of a new stream. To track the progress of the provisioning, you can periodically call getStream
. In the response, the lifecycleState
parameter of the Stream
object tells you its current state.
request
- The request object containing the details to sendhandler
- The request handler to invoke upon completion, may be null.Future<DeleteStreamResponse> deleteStream(DeleteStreamRequest request, AsyncHandler<DeleteStreamRequest,DeleteStreamResponse> handler)
Deletes a stream and its content. Stream contents are deleted immediately. The service retains records of the stream itself for 90 days after deletion. The lifeCycleState
parameter of the Stream
object changes to DELETING
and the stream becomes inaccessible for read or write operations. To verify that a stream has been deleted, make a getStream
request. If the call returns the stream’s lifecycle state as DELETED
, then the stream has been deleted. If the call returns a "404 Not Found" error, that means all records of the stream have been deleted.
request
- The request object containing the details to sendhandler
- The request handler to invoke upon completion, may be null.Future<GetStreamResponse> getStream(GetStreamRequest request, AsyncHandler<GetStreamRequest,GetStreamResponse> handler)
Gets detailed information about a stream, including the number of partitions.
request
- The request object containing the details to sendhandler
- The request handler to invoke upon completion, may be null.Future<ListStreamsResponse> listStreams(ListStreamsRequest request, AsyncHandler<ListStreamsRequest,ListStreamsResponse> handler)
Lists the streams.
request
- The request object containing the details to sendhandler
- The request handler to invoke upon completion, may be null.Future<UpdateStreamResponse> updateStream(UpdateStreamRequest request, AsyncHandler<UpdateStreamRequest,UpdateStreamResponse> handler)
Updates the tags applied to the stream.
request
- The request object containing the details to sendhandler
- The request handler to invoke upon completion, may be null.Copyright © 2016–2019. All rights reserved.