@Generated(value="software.amazon.awssdk:codegen") public interface AppMeshAsyncClient extends SdkClient
builder()
method.
AWS App Mesh is a service mesh based on the Envoy proxy that makes it easy to monitor and control containerized microservices. App Mesh standardizes how your microservices communicate, giving you end-to-end visibility and helping to ensure high-availability for your applications.
App Mesh gives you consistent visibility and network traffic controls for every microservice in an application. You can use App Mesh with Amazon ECS (using the Amazon EC2 launch type), Amazon EKS, and Kubernetes on AWS.
App Mesh supports containerized microservice applications that use service discovery naming for their components. To
use App Mesh, you must have a containerized application running on Amazon EC2 instances, hosted in either Amazon ECS,
Amazon EKS, or Kubernetes on AWS. For more information about service discovery on Amazon ECS, see Service Discovery in the
Amazon Elastic Container Service Developer Guide. Kubernetes kube-dns
is supported. For more
information, see DNS for Services
and Pods in the Kubernetes documentation.
Modifier and Type | Field and Description |
---|---|
static String |
SERVICE_NAME |
Modifier and Type | Method and Description |
---|---|
static AppMeshAsyncClientBuilder |
builder()
Create a builder that can be used to configure and create a
AppMeshAsyncClient . |
static AppMeshAsyncClient |
create()
Create a
AppMeshAsyncClient with the region loaded from the
DefaultAwsRegionProviderChain and credentials loaded from the
DefaultCredentialsProvider . |
default CompletableFuture<CreateMeshResponse> |
createMesh(Consumer<CreateMeshRequest.Builder> createMeshRequest)
Creates a new service mesh.
|
default CompletableFuture<CreateMeshResponse> |
createMesh(CreateMeshRequest createMeshRequest)
Creates a new service mesh.
|
default CompletableFuture<CreateRouteResponse> |
createRoute(Consumer<CreateRouteRequest.Builder> createRouteRequest)
Creates a new route that is associated with a virtual router.
|
default CompletableFuture<CreateRouteResponse> |
createRoute(CreateRouteRequest createRouteRequest)
Creates a new route that is associated with a virtual router.
|
default CompletableFuture<CreateVirtualNodeResponse> |
createVirtualNode(Consumer<CreateVirtualNodeRequest.Builder> createVirtualNodeRequest)
Creates a new virtual node within a service mesh.
|
default CompletableFuture<CreateVirtualNodeResponse> |
createVirtualNode(CreateVirtualNodeRequest createVirtualNodeRequest)
Creates a new virtual node within a service mesh.
|
default CompletableFuture<CreateVirtualRouterResponse> |
createVirtualRouter(Consumer<CreateVirtualRouterRequest.Builder> createVirtualRouterRequest)
Creates a new virtual router within a service mesh.
|
default CompletableFuture<CreateVirtualRouterResponse> |
createVirtualRouter(CreateVirtualRouterRequest createVirtualRouterRequest)
Creates a new virtual router within a service mesh.
|
default CompletableFuture<DeleteMeshResponse> |
deleteMesh(Consumer<DeleteMeshRequest.Builder> deleteMeshRequest)
Deletes an existing service mesh.
|
default CompletableFuture<DeleteMeshResponse> |
deleteMesh(DeleteMeshRequest deleteMeshRequest)
Deletes an existing service mesh.
|
default CompletableFuture<DeleteRouteResponse> |
deleteRoute(Consumer<DeleteRouteRequest.Builder> deleteRouteRequest)
Deletes an existing route.
|
default CompletableFuture<DeleteRouteResponse> |
deleteRoute(DeleteRouteRequest deleteRouteRequest)
Deletes an existing route.
|
default CompletableFuture<DeleteVirtualNodeResponse> |
deleteVirtualNode(Consumer<DeleteVirtualNodeRequest.Builder> deleteVirtualNodeRequest)
Deletes an existing virtual node.
|
default CompletableFuture<DeleteVirtualNodeResponse> |
deleteVirtualNode(DeleteVirtualNodeRequest deleteVirtualNodeRequest)
Deletes an existing virtual node.
|
default CompletableFuture<DeleteVirtualRouterResponse> |
deleteVirtualRouter(Consumer<DeleteVirtualRouterRequest.Builder> deleteVirtualRouterRequest)
Deletes an existing virtual router.
|
default CompletableFuture<DeleteVirtualRouterResponse> |
deleteVirtualRouter(DeleteVirtualRouterRequest deleteVirtualRouterRequest)
Deletes an existing virtual router.
|
default CompletableFuture<DescribeMeshResponse> |
describeMesh(Consumer<DescribeMeshRequest.Builder> describeMeshRequest)
Describes an existing cluster.
|
default CompletableFuture<DescribeMeshResponse> |
describeMesh(DescribeMeshRequest describeMeshRequest)
Describes an existing cluster.
|
default CompletableFuture<DescribeRouteResponse> |
describeRoute(Consumer<DescribeRouteRequest.Builder> describeRouteRequest)
Describes an existing route.
|
default CompletableFuture<DescribeRouteResponse> |
describeRoute(DescribeRouteRequest describeRouteRequest)
Describes an existing route.
|
default CompletableFuture<DescribeVirtualNodeResponse> |
describeVirtualNode(Consumer<DescribeVirtualNodeRequest.Builder> describeVirtualNodeRequest)
Describes an existing virtual node.
|
default CompletableFuture<DescribeVirtualNodeResponse> |
describeVirtualNode(DescribeVirtualNodeRequest describeVirtualNodeRequest)
Describes an existing virtual node.
|
default CompletableFuture<DescribeVirtualRouterResponse> |
describeVirtualRouter(Consumer<DescribeVirtualRouterRequest.Builder> describeVirtualRouterRequest)
Describes an existing virtual router.
|
default CompletableFuture<DescribeVirtualRouterResponse> |
describeVirtualRouter(DescribeVirtualRouterRequest describeVirtualRouterRequest)
Describes an existing virtual router.
|
default CompletableFuture<ListMeshesResponse> |
listMeshes()
Returns a list of existing service meshes.
|
default CompletableFuture<ListMeshesResponse> |
listMeshes(Consumer<ListMeshesRequest.Builder> listMeshesRequest)
Returns a list of existing service meshes.
|
default CompletableFuture<ListMeshesResponse> |
listMeshes(ListMeshesRequest listMeshesRequest)
Returns a list of existing service meshes.
|
default ListMeshesPublisher |
listMeshesPaginator()
Returns a list of existing service meshes.
|
default ListMeshesPublisher |
listMeshesPaginator(Consumer<ListMeshesRequest.Builder> listMeshesRequest)
Returns a list of existing service meshes.
|
default ListMeshesPublisher |
listMeshesPaginator(ListMeshesRequest listMeshesRequest)
Returns a list of existing service meshes.
|
default CompletableFuture<ListRoutesResponse> |
listRoutes(Consumer<ListRoutesRequest.Builder> listRoutesRequest)
Returns a list of existing routes in a service mesh.
|
default CompletableFuture<ListRoutesResponse> |
listRoutes(ListRoutesRequest listRoutesRequest)
Returns a list of existing routes in a service mesh.
|
default ListRoutesPublisher |
listRoutesPaginator(Consumer<ListRoutesRequest.Builder> listRoutesRequest)
Returns a list of existing routes in a service mesh.
|
default ListRoutesPublisher |
listRoutesPaginator(ListRoutesRequest listRoutesRequest)
Returns a list of existing routes in a service mesh.
|
default CompletableFuture<ListVirtualNodesResponse> |
listVirtualNodes(Consumer<ListVirtualNodesRequest.Builder> listVirtualNodesRequest)
Returns a list of existing virtual nodes.
|
default CompletableFuture<ListVirtualNodesResponse> |
listVirtualNodes(ListVirtualNodesRequest listVirtualNodesRequest)
Returns a list of existing virtual nodes.
|
default ListVirtualNodesPublisher |
listVirtualNodesPaginator(Consumer<ListVirtualNodesRequest.Builder> listVirtualNodesRequest)
Returns a list of existing virtual nodes.
|
default ListVirtualNodesPublisher |
listVirtualNodesPaginator(ListVirtualNodesRequest listVirtualNodesRequest)
Returns a list of existing virtual nodes.
|
default CompletableFuture<ListVirtualRoutersResponse> |
listVirtualRouters(Consumer<ListVirtualRoutersRequest.Builder> listVirtualRoutersRequest)
Returns a list of existing virtual routers in a service mesh.
|
default CompletableFuture<ListVirtualRoutersResponse> |
listVirtualRouters(ListVirtualRoutersRequest listVirtualRoutersRequest)
Returns a list of existing virtual routers in a service mesh.
|
default ListVirtualRoutersPublisher |
listVirtualRoutersPaginator(Consumer<ListVirtualRoutersRequest.Builder> listVirtualRoutersRequest)
Returns a list of existing virtual routers in a service mesh.
|
default ListVirtualRoutersPublisher |
listVirtualRoutersPaginator(ListVirtualRoutersRequest listVirtualRoutersRequest)
Returns a list of existing virtual routers in a service mesh.
|
default CompletableFuture<UpdateRouteResponse> |
updateRoute(Consumer<UpdateRouteRequest.Builder> updateRouteRequest)
Updates an existing route for a specified service mesh and virtual router.
|
default CompletableFuture<UpdateRouteResponse> |
updateRoute(UpdateRouteRequest updateRouteRequest)
Updates an existing route for a specified service mesh and virtual router.
|
default CompletableFuture<UpdateVirtualNodeResponse> |
updateVirtualNode(Consumer<UpdateVirtualNodeRequest.Builder> updateVirtualNodeRequest)
Updates an existing virtual node in a specified service mesh.
|
default CompletableFuture<UpdateVirtualNodeResponse> |
updateVirtualNode(UpdateVirtualNodeRequest updateVirtualNodeRequest)
Updates an existing virtual node in a specified service mesh.
|
default CompletableFuture<UpdateVirtualRouterResponse> |
updateVirtualRouter(Consumer<UpdateVirtualRouterRequest.Builder> updateVirtualRouterRequest)
Updates an existing virtual router in a specified service mesh.
|
default CompletableFuture<UpdateVirtualRouterResponse> |
updateVirtualRouter(UpdateVirtualRouterRequest updateVirtualRouterRequest)
Updates an existing virtual router in a specified service mesh.
|
serviceName
close
static final String SERVICE_NAME
static AppMeshAsyncClient create()
AppMeshAsyncClient
with the region loaded from the
DefaultAwsRegionProviderChain
and credentials loaded from the
DefaultCredentialsProvider
.static AppMeshAsyncClientBuilder builder()
AppMeshAsyncClient
.default CompletableFuture<CreateMeshResponse> createMesh(CreateMeshRequest createMeshRequest)
Creates a new service mesh. A service mesh is a logical boundary for network traffic between the services that reside within it.
After you create your service mesh, you can create virtual nodes, virtual routers, and routes to distribute traffic between the applications in your mesh.
createMeshRequest
- default CompletableFuture<CreateMeshResponse> createMesh(Consumer<CreateMeshRequest.Builder> createMeshRequest)
Creates a new service mesh. A service mesh is a logical boundary for network traffic between the services that reside within it.
After you create your service mesh, you can create virtual nodes, virtual routers, and routes to distribute traffic between the applications in your mesh.
This is a convenience which creates an instance of the CreateMeshRequest.Builder
avoiding the need to
create one manually via CreateMeshRequest.builder()
createMeshRequest
- A Consumer
that will call methods on CreateMeshInput.Builder
to create a request.default CompletableFuture<CreateRouteResponse> createRoute(CreateRouteRequest createRouteRequest)
Creates a new route that is associated with a virtual router.
You can use the prefix
parameter in your route specification for path-based routing of requests. For
example, if your virtual router service name is my-service.local
, and you want the route to match
requests to my-service.local/metrics
, then your prefix should be /metrics
.
If your route matches a request, you can distribute traffic to one or more target virtual nodes with relative weighting.
createRouteRequest
- default CompletableFuture<CreateRouteResponse> createRoute(Consumer<CreateRouteRequest.Builder> createRouteRequest)
Creates a new route that is associated with a virtual router.
You can use the prefix
parameter in your route specification for path-based routing of requests. For
example, if your virtual router service name is my-service.local
, and you want the route to match
requests to my-service.local/metrics
, then your prefix should be /metrics
.
If your route matches a request, you can distribute traffic to one or more target virtual nodes with relative weighting.
This is a convenience which creates an instance of the CreateRouteRequest.Builder
avoiding the need to
create one manually via CreateRouteRequest.builder()
createRouteRequest
- A Consumer
that will call methods on CreateRouteInput.Builder
to create a request.default CompletableFuture<CreateVirtualNodeResponse> createVirtualNode(CreateVirtualNodeRequest createVirtualNodeRequest)
Creates a new virtual node within a service mesh.
A virtual node acts as logical pointer to a particular task group, such as an Amazon ECS service or a Kubernetes deployment. When you create a virtual node, you must specify the DNS service discovery name for your task group.
Any inbound traffic that your virtual node expects should be specified as a listener
. Any outbound
traffic that your virtual node expects to reach should be specified as a backend
.
The response metadata for your new virtual node contains the arn
that is associated with the virtual
node. Set this value (either the full ARN or the truncated resource name, for example,
mesh/default/virtualNode/simpleapp
, as the APPMESH_VIRTUAL_NODE_NAME
environment
variable for your task group's Envoy proxy container in your task definition or pod spec. This is then mapped to
the node.id
and node.cluster
Envoy parameters.
If you require your Envoy stats or tracing to use a different name, you can override the
node.cluster
value that is set by APPMESH_VIRTUAL_NODE_NAME
with the
APPMESH_VIRTUAL_NODE_CLUSTER
environment variable.
createVirtualNodeRequest
- default CompletableFuture<CreateVirtualNodeResponse> createVirtualNode(Consumer<CreateVirtualNodeRequest.Builder> createVirtualNodeRequest)
Creates a new virtual node within a service mesh.
A virtual node acts as logical pointer to a particular task group, such as an Amazon ECS service or a Kubernetes deployment. When you create a virtual node, you must specify the DNS service discovery name for your task group.
Any inbound traffic that your virtual node expects should be specified as a listener
. Any outbound
traffic that your virtual node expects to reach should be specified as a backend
.
The response metadata for your new virtual node contains the arn
that is associated with the virtual
node. Set this value (either the full ARN or the truncated resource name, for example,
mesh/default/virtualNode/simpleapp
, as the APPMESH_VIRTUAL_NODE_NAME
environment
variable for your task group's Envoy proxy container in your task definition or pod spec. This is then mapped to
the node.id
and node.cluster
Envoy parameters.
If you require your Envoy stats or tracing to use a different name, you can override the
node.cluster
value that is set by APPMESH_VIRTUAL_NODE_NAME
with the
APPMESH_VIRTUAL_NODE_CLUSTER
environment variable.
This is a convenience which creates an instance of the CreateVirtualNodeRequest.Builder
avoiding the need
to create one manually via CreateVirtualNodeRequest.builder()
createVirtualNodeRequest
- A Consumer
that will call methods on CreateVirtualNodeInput.Builder
to create a request.default CompletableFuture<CreateVirtualRouterResponse> createVirtualRouter(CreateVirtualRouterRequest createVirtualRouterRequest)
Creates a new virtual router within a service mesh.
Virtual routers handle traffic for one or more service names within your mesh. After you create your virtual router, create and associate routes for your virtual router that direct incoming requests to different virtual nodes.
createVirtualRouterRequest
- default CompletableFuture<CreateVirtualRouterResponse> createVirtualRouter(Consumer<CreateVirtualRouterRequest.Builder> createVirtualRouterRequest)
Creates a new virtual router within a service mesh.
Virtual routers handle traffic for one or more service names within your mesh. After you create your virtual router, create and associate routes for your virtual router that direct incoming requests to different virtual nodes.
This is a convenience which creates an instance of the CreateVirtualRouterRequest.Builder
avoiding the
need to create one manually via CreateVirtualRouterRequest.builder()
createVirtualRouterRequest
- A Consumer
that will call methods on CreateVirtualRouterInput.Builder
to create a request.default CompletableFuture<DeleteMeshResponse> deleteMesh(DeleteMeshRequest deleteMeshRequest)
Deletes an existing service mesh.
You must delete all resources (routes, virtual routers, virtual nodes) in the service mesh before you can delete the mesh itself.
deleteMeshRequest
- default CompletableFuture<DeleteMeshResponse> deleteMesh(Consumer<DeleteMeshRequest.Builder> deleteMeshRequest)
Deletes an existing service mesh.
You must delete all resources (routes, virtual routers, virtual nodes) in the service mesh before you can delete the mesh itself.
This is a convenience which creates an instance of the DeleteMeshRequest.Builder
avoiding the need to
create one manually via DeleteMeshRequest.builder()
deleteMeshRequest
- A Consumer
that will call methods on DeleteMeshInput.Builder
to create a request.default CompletableFuture<DeleteRouteResponse> deleteRoute(DeleteRouteRequest deleteRouteRequest)
Deletes an existing route.
deleteRouteRequest
- default CompletableFuture<DeleteRouteResponse> deleteRoute(Consumer<DeleteRouteRequest.Builder> deleteRouteRequest)
Deletes an existing route.
This is a convenience which creates an instance of the DeleteRouteRequest.Builder
avoiding the need to
create one manually via DeleteRouteRequest.builder()
deleteRouteRequest
- A Consumer
that will call methods on DeleteRouteInput.Builder
to create a request.default CompletableFuture<DeleteVirtualNodeResponse> deleteVirtualNode(DeleteVirtualNodeRequest deleteVirtualNodeRequest)
Deletes an existing virtual node.
deleteVirtualNodeRequest
- default CompletableFuture<DeleteVirtualNodeResponse> deleteVirtualNode(Consumer<DeleteVirtualNodeRequest.Builder> deleteVirtualNodeRequest)
Deletes an existing virtual node.
This is a convenience which creates an instance of the DeleteVirtualNodeRequest.Builder
avoiding the need
to create one manually via DeleteVirtualNodeRequest.builder()
deleteVirtualNodeRequest
- A Consumer
that will call methods on DeleteVirtualNodeInput.Builder
to create a request.default CompletableFuture<DeleteVirtualRouterResponse> deleteVirtualRouter(DeleteVirtualRouterRequest deleteVirtualRouterRequest)
Deletes an existing virtual router.
You must delete any routes associated with the virtual router before you can delete the router itself.
deleteVirtualRouterRequest
- default CompletableFuture<DeleteVirtualRouterResponse> deleteVirtualRouter(Consumer<DeleteVirtualRouterRequest.Builder> deleteVirtualRouterRequest)
Deletes an existing virtual router.
You must delete any routes associated with the virtual router before you can delete the router itself.
This is a convenience which creates an instance of the DeleteVirtualRouterRequest.Builder
avoiding the
need to create one manually via DeleteVirtualRouterRequest.builder()
deleteVirtualRouterRequest
- A Consumer
that will call methods on DeleteVirtualRouterInput.Builder
to create a request.default CompletableFuture<DescribeMeshResponse> describeMesh(DescribeMeshRequest describeMeshRequest)
Describes an existing cluster.
describeMeshRequest
- default CompletableFuture<DescribeMeshResponse> describeMesh(Consumer<DescribeMeshRequest.Builder> describeMeshRequest)
Describes an existing cluster.
This is a convenience which creates an instance of the DescribeMeshRequest.Builder
avoiding the need to
create one manually via DescribeMeshRequest.builder()
describeMeshRequest
- A Consumer
that will call methods on DescribeMeshInput.Builder
to create a request.default CompletableFuture<DescribeRouteResponse> describeRoute(DescribeRouteRequest describeRouteRequest)
Describes an existing route.
describeRouteRequest
- default CompletableFuture<DescribeRouteResponse> describeRoute(Consumer<DescribeRouteRequest.Builder> describeRouteRequest)
Describes an existing route.
This is a convenience which creates an instance of the DescribeRouteRequest.Builder
avoiding the need to
create one manually via DescribeRouteRequest.builder()
describeRouteRequest
- A Consumer
that will call methods on DescribeRouteInput.Builder
to create a request.default CompletableFuture<DescribeVirtualNodeResponse> describeVirtualNode(DescribeVirtualNodeRequest describeVirtualNodeRequest)
Describes an existing virtual node.
describeVirtualNodeRequest
- default CompletableFuture<DescribeVirtualNodeResponse> describeVirtualNode(Consumer<DescribeVirtualNodeRequest.Builder> describeVirtualNodeRequest)
Describes an existing virtual node.
This is a convenience which creates an instance of the DescribeVirtualNodeRequest.Builder
avoiding the
need to create one manually via DescribeVirtualNodeRequest.builder()
describeVirtualNodeRequest
- A Consumer
that will call methods on DescribeVirtualNodeInput.Builder
to create a request.default CompletableFuture<DescribeVirtualRouterResponse> describeVirtualRouter(DescribeVirtualRouterRequest describeVirtualRouterRequest)
Describes an existing virtual router.
describeVirtualRouterRequest
- default CompletableFuture<DescribeVirtualRouterResponse> describeVirtualRouter(Consumer<DescribeVirtualRouterRequest.Builder> describeVirtualRouterRequest)
Describes an existing virtual router.
This is a convenience which creates an instance of the DescribeVirtualRouterRequest.Builder
avoiding the
need to create one manually via DescribeVirtualRouterRequest.builder()
describeVirtualRouterRequest
- A Consumer
that will call methods on DescribeVirtualRouterInput.Builder
to create a
request.default CompletableFuture<ListMeshesResponse> listMeshes(ListMeshesRequest listMeshesRequest)
Returns a list of existing service meshes.
listMeshesRequest
- default CompletableFuture<ListMeshesResponse> listMeshes(Consumer<ListMeshesRequest.Builder> listMeshesRequest)
Returns a list of existing service meshes.
This is a convenience which creates an instance of the ListMeshesRequest.Builder
avoiding the need to
create one manually via ListMeshesRequest.builder()
listMeshesRequest
- A Consumer
that will call methods on ListMeshesInput.Builder
to create a request.default CompletableFuture<ListMeshesResponse> listMeshes()
Returns a list of existing service meshes.
default ListMeshesPublisher listMeshesPaginator()
Returns a list of existing service meshes.
This is a variant of listMeshes(software.amazon.awssdk.services.appmesh.model.ListMeshesRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.appmesh.paginators.ListMeshesPublisher publisher = client.listMeshesPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.appmesh.paginators.ListMeshesPublisher publisher = client.listMeshesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.appmesh.model.ListMeshesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.appmesh.model.ListMeshesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listMeshes(software.amazon.awssdk.services.appmesh.model.ListMeshesRequest)
operation.
default ListMeshesPublisher listMeshesPaginator(ListMeshesRequest listMeshesRequest)
Returns a list of existing service meshes.
This is a variant of listMeshes(software.amazon.awssdk.services.appmesh.model.ListMeshesRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.appmesh.paginators.ListMeshesPublisher publisher = client.listMeshesPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.appmesh.paginators.ListMeshesPublisher publisher = client.listMeshesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.appmesh.model.ListMeshesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.appmesh.model.ListMeshesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listMeshes(software.amazon.awssdk.services.appmesh.model.ListMeshesRequest)
operation.
listMeshesRequest
- default ListMeshesPublisher listMeshesPaginator(Consumer<ListMeshesRequest.Builder> listMeshesRequest)
Returns a list of existing service meshes.
This is a variant of listMeshes(software.amazon.awssdk.services.appmesh.model.ListMeshesRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.appmesh.paginators.ListMeshesPublisher publisher = client.listMeshesPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.appmesh.paginators.ListMeshesPublisher publisher = client.listMeshesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.appmesh.model.ListMeshesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.appmesh.model.ListMeshesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listMeshes(software.amazon.awssdk.services.appmesh.model.ListMeshesRequest)
operation.
This is a convenience which creates an instance of the ListMeshesRequest.Builder
avoiding the need to
create one manually via ListMeshesRequest.builder()
listMeshesRequest
- A Consumer
that will call methods on ListMeshesInput.Builder
to create a request.default CompletableFuture<ListRoutesResponse> listRoutes(ListRoutesRequest listRoutesRequest)
Returns a list of existing routes in a service mesh.
listRoutesRequest
- default CompletableFuture<ListRoutesResponse> listRoutes(Consumer<ListRoutesRequest.Builder> listRoutesRequest)
Returns a list of existing routes in a service mesh.
This is a convenience which creates an instance of the ListRoutesRequest.Builder
avoiding the need to
create one manually via ListRoutesRequest.builder()
listRoutesRequest
- A Consumer
that will call methods on ListRoutesInput.Builder
to create a request.default ListRoutesPublisher listRoutesPaginator(ListRoutesRequest listRoutesRequest)
Returns a list of existing routes in a service mesh.
This is a variant of listRoutes(software.amazon.awssdk.services.appmesh.model.ListRoutesRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.appmesh.paginators.ListRoutesPublisher publisher = client.listRoutesPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.appmesh.paginators.ListRoutesPublisher publisher = client.listRoutesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.appmesh.model.ListRoutesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.appmesh.model.ListRoutesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listRoutes(software.amazon.awssdk.services.appmesh.model.ListRoutesRequest)
operation.
listRoutesRequest
- default ListRoutesPublisher listRoutesPaginator(Consumer<ListRoutesRequest.Builder> listRoutesRequest)
Returns a list of existing routes in a service mesh.
This is a variant of listRoutes(software.amazon.awssdk.services.appmesh.model.ListRoutesRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.appmesh.paginators.ListRoutesPublisher publisher = client.listRoutesPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.appmesh.paginators.ListRoutesPublisher publisher = client.listRoutesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.appmesh.model.ListRoutesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.appmesh.model.ListRoutesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listRoutes(software.amazon.awssdk.services.appmesh.model.ListRoutesRequest)
operation.
This is a convenience which creates an instance of the ListRoutesRequest.Builder
avoiding the need to
create one manually via ListRoutesRequest.builder()
listRoutesRequest
- A Consumer
that will call methods on ListRoutesInput.Builder
to create a request.default CompletableFuture<ListVirtualNodesResponse> listVirtualNodes(ListVirtualNodesRequest listVirtualNodesRequest)
Returns a list of existing virtual nodes.
listVirtualNodesRequest
- default CompletableFuture<ListVirtualNodesResponse> listVirtualNodes(Consumer<ListVirtualNodesRequest.Builder> listVirtualNodesRequest)
Returns a list of existing virtual nodes.
This is a convenience which creates an instance of the ListVirtualNodesRequest.Builder
avoiding the need
to create one manually via ListVirtualNodesRequest.builder()
listVirtualNodesRequest
- A Consumer
that will call methods on ListVirtualNodesInput.Builder
to create a request.default ListVirtualNodesPublisher listVirtualNodesPaginator(ListVirtualNodesRequest listVirtualNodesRequest)
Returns a list of existing virtual nodes.
This is a variant of
listVirtualNodes(software.amazon.awssdk.services.appmesh.model.ListVirtualNodesRequest)
operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.appmesh.paginators.ListVirtualNodesPublisher publisher = client.listVirtualNodesPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.appmesh.paginators.ListVirtualNodesPublisher publisher = client.listVirtualNodesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.appmesh.model.ListVirtualNodesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.appmesh.model.ListVirtualNodesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listVirtualNodes(software.amazon.awssdk.services.appmesh.model.ListVirtualNodesRequest)
operation.
listVirtualNodesRequest
- default ListVirtualNodesPublisher listVirtualNodesPaginator(Consumer<ListVirtualNodesRequest.Builder> listVirtualNodesRequest)
Returns a list of existing virtual nodes.
This is a variant of
listVirtualNodes(software.amazon.awssdk.services.appmesh.model.ListVirtualNodesRequest)
operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.appmesh.paginators.ListVirtualNodesPublisher publisher = client.listVirtualNodesPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.appmesh.paginators.ListVirtualNodesPublisher publisher = client.listVirtualNodesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.appmesh.model.ListVirtualNodesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.appmesh.model.ListVirtualNodesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listVirtualNodes(software.amazon.awssdk.services.appmesh.model.ListVirtualNodesRequest)
operation.
This is a convenience which creates an instance of the ListVirtualNodesRequest.Builder
avoiding the need
to create one manually via ListVirtualNodesRequest.builder()
listVirtualNodesRequest
- A Consumer
that will call methods on ListVirtualNodesInput.Builder
to create a request.default CompletableFuture<ListVirtualRoutersResponse> listVirtualRouters(ListVirtualRoutersRequest listVirtualRoutersRequest)
Returns a list of existing virtual routers in a service mesh.
listVirtualRoutersRequest
- default CompletableFuture<ListVirtualRoutersResponse> listVirtualRouters(Consumer<ListVirtualRoutersRequest.Builder> listVirtualRoutersRequest)
Returns a list of existing virtual routers in a service mesh.
This is a convenience which creates an instance of the ListVirtualRoutersRequest.Builder
avoiding the
need to create one manually via ListVirtualRoutersRequest.builder()
listVirtualRoutersRequest
- A Consumer
that will call methods on ListVirtualRoutersInput.Builder
to create a request.default ListVirtualRoutersPublisher listVirtualRoutersPaginator(ListVirtualRoutersRequest listVirtualRoutersRequest)
Returns a list of existing virtual routers in a service mesh.
This is a variant of
listVirtualRouters(software.amazon.awssdk.services.appmesh.model.ListVirtualRoutersRequest)
operation.
The return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.appmesh.paginators.ListVirtualRoutersPublisher publisher = client.listVirtualRoutersPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.appmesh.paginators.ListVirtualRoutersPublisher publisher = client.listVirtualRoutersPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.appmesh.model.ListVirtualRoutersResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.appmesh.model.ListVirtualRoutersResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listVirtualRouters(software.amazon.awssdk.services.appmesh.model.ListVirtualRoutersRequest)
operation.
listVirtualRoutersRequest
- default ListVirtualRoutersPublisher listVirtualRoutersPaginator(Consumer<ListVirtualRoutersRequest.Builder> listVirtualRoutersRequest)
Returns a list of existing virtual routers in a service mesh.
This is a variant of
listVirtualRouters(software.amazon.awssdk.services.appmesh.model.ListVirtualRoutersRequest)
operation.
The return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.appmesh.paginators.ListVirtualRoutersPublisher publisher = client.listVirtualRoutersPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.appmesh.paginators.ListVirtualRoutersPublisher publisher = client.listVirtualRoutersPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.appmesh.model.ListVirtualRoutersResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.appmesh.model.ListVirtualRoutersResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listVirtualRouters(software.amazon.awssdk.services.appmesh.model.ListVirtualRoutersRequest)
operation.
This is a convenience which creates an instance of the ListVirtualRoutersRequest.Builder
avoiding the
need to create one manually via ListVirtualRoutersRequest.builder()
listVirtualRoutersRequest
- A Consumer
that will call methods on ListVirtualRoutersInput.Builder
to create a request.default CompletableFuture<UpdateRouteResponse> updateRoute(UpdateRouteRequest updateRouteRequest)
Updates an existing route for a specified service mesh and virtual router.
updateRouteRequest
- default CompletableFuture<UpdateRouteResponse> updateRoute(Consumer<UpdateRouteRequest.Builder> updateRouteRequest)
Updates an existing route for a specified service mesh and virtual router.
This is a convenience which creates an instance of the UpdateRouteRequest.Builder
avoiding the need to
create one manually via UpdateRouteRequest.builder()
updateRouteRequest
- A Consumer
that will call methods on UpdateRouteInput.Builder
to create a request.default CompletableFuture<UpdateVirtualNodeResponse> updateVirtualNode(UpdateVirtualNodeRequest updateVirtualNodeRequest)
Updates an existing virtual node in a specified service mesh.
updateVirtualNodeRequest
- default CompletableFuture<UpdateVirtualNodeResponse> updateVirtualNode(Consumer<UpdateVirtualNodeRequest.Builder> updateVirtualNodeRequest)
Updates an existing virtual node in a specified service mesh.
This is a convenience which creates an instance of the UpdateVirtualNodeRequest.Builder
avoiding the need
to create one manually via UpdateVirtualNodeRequest.builder()
updateVirtualNodeRequest
- A Consumer
that will call methods on UpdateVirtualNodeInput.Builder
to create a request.default CompletableFuture<UpdateVirtualRouterResponse> updateVirtualRouter(UpdateVirtualRouterRequest updateVirtualRouterRequest)
Updates an existing virtual router in a specified service mesh.
updateVirtualRouterRequest
- default CompletableFuture<UpdateVirtualRouterResponse> updateVirtualRouter(Consumer<UpdateVirtualRouterRequest.Builder> updateVirtualRouterRequest)
Updates an existing virtual router in a specified service mesh.
This is a convenience which creates an instance of the UpdateVirtualRouterRequest.Builder
avoiding the
need to create one manually via UpdateVirtualRouterRequest.builder()
updateVirtualRouterRequest
- A Consumer
that will call methods on UpdateVirtualRouterInput.Builder
to create a request.Copyright © 2017 Amazon Web Services, Inc. All Rights Reserved.