public class GreengrassCoreIPCClientV2 extends Object implements AutoCloseable
| Modifier and Type | Class and Description |
|---|---|
static class |
GreengrassCoreIPCClientV2.Builder |
static class |
GreengrassCoreIPCClientV2.StreamingResponse<T,U> |
public void close()
throws Exception
close in interface AutoCloseableExceptionpublic GreengrassCoreIPC getClient()
public static GreengrassCoreIPCClientV2.Builder builder()
public CreateDebugPasswordResponse createDebugPassword(CreateDebugPasswordRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<CreateDebugPasswordResponse> createDebugPasswordAsync(CreateDebugPasswordRequest request)
request - request objectpublic CreateLocalDeploymentResponse createLocalDeployment(CreateLocalDeploymentRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<CreateLocalDeploymentResponse> createLocalDeploymentAsync(CreateLocalDeploymentRequest request)
request - request objectpublic DeferComponentUpdateResponse deferComponentUpdate(DeferComponentUpdateRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<DeferComponentUpdateResponse> deferComponentUpdateAsync(DeferComponentUpdateRequest request)
request - request objectpublic DeleteThingShadowResponse deleteThingShadow(DeleteThingShadowRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<DeleteThingShadowResponse> deleteThingShadowAsync(DeleteThingShadowRequest request)
request - request objectpublic GetComponentDetailsResponse getComponentDetails(GetComponentDetailsRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<GetComponentDetailsResponse> getComponentDetailsAsync(GetComponentDetailsRequest request)
request - request objectpublic GetConfigurationResponse getConfiguration(GetConfigurationRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<GetConfigurationResponse> getConfigurationAsync(GetConfigurationRequest request)
request - request objectpublic GetLocalDeploymentStatusResponse getLocalDeploymentStatus(GetLocalDeploymentStatusRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<GetLocalDeploymentStatusResponse> getLocalDeploymentStatusAsync(GetLocalDeploymentStatusRequest request)
request - request objectpublic GetSecretValueResponse getSecretValue(GetSecretValueRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<GetSecretValueResponse> getSecretValueAsync(GetSecretValueRequest request)
request - request objectpublic GetThingShadowResponse getThingShadow(GetThingShadowRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<GetThingShadowResponse> getThingShadowAsync(GetThingShadowRequest request)
request - request objectpublic ListComponentsResponse listComponents(ListComponentsRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<ListComponentsResponse> listComponentsAsync(ListComponentsRequest request)
request - request objectpublic ListLocalDeploymentsResponse listLocalDeployments(ListLocalDeploymentsRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<ListLocalDeploymentsResponse> listLocalDeploymentsAsync(ListLocalDeploymentsRequest request)
request - request objectpublic ListNamedShadowsForThingResponse listNamedShadowsForThing(ListNamedShadowsForThingRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<ListNamedShadowsForThingResponse> listNamedShadowsForThingAsync(ListNamedShadowsForThingRequest request)
request - request objectpublic PauseComponentResponse pauseComponent(PauseComponentRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<PauseComponentResponse> pauseComponentAsync(PauseComponentRequest request)
request - request objectpublic PublishToIoTCoreResponse publishToIoTCore(PublishToIoTCoreRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<PublishToIoTCoreResponse> publishToIoTCoreAsync(PublishToIoTCoreRequest request)
request - request objectpublic PublishToTopicResponse publishToTopic(PublishToTopicRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<PublishToTopicResponse> publishToTopicAsync(PublishToTopicRequest request)
request - request objectpublic RestartComponentResponse restartComponent(RestartComponentRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<RestartComponentResponse> restartComponentAsync(RestartComponentRequest request)
request - request objectpublic ResumeComponentResponse resumeComponent(ResumeComponentRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<ResumeComponentResponse> resumeComponentAsync(ResumeComponentRequest request)
request - request objectpublic SendConfigurationValidityReportResponse sendConfigurationValidityReport(SendConfigurationValidityReportRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<SendConfigurationValidityReportResponse> sendConfigurationValidityReportAsync(SendConfigurationValidityReportRequest request)
request - request objectpublic StopComponentResponse stopComponent(StopComponentRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<StopComponentResponse> stopComponentAsync(StopComponentRequest request)
request - request objectpublic GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToComponentUpdatesResponse>,SubscribeToComponentUpdatesResponseHandler> subscribeToComponentUpdatesAsync(SubscribeToComponentUpdatesRequest request, Consumer<ComponentUpdatePolicyEvents> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed)
request - request objectonStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.onStreamError - Callback for stream errors. Return true to close the stream,
return false to keep the stream open. Even if an executor is provided,
this method will not run in the executor.onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.public GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToComponentUpdatesResponse,SubscribeToComponentUpdatesResponseHandler> subscribeToComponentUpdates(SubscribeToComponentUpdatesRequest request, Consumer<ComponentUpdatePolicyEvents> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed) throws InterruptedException
request - request objectonStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.onStreamError - Callback for stream errors. Return true to close the stream,
return false to keep the stream open. Even if an executor is provided,
this method will not run in the executor.onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.InterruptedException - if thread is interrupted while waiting for the responsepublic GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToComponentUpdatesResponse,SubscribeToComponentUpdatesResponseHandler> subscribeToComponentUpdates(SubscribeToComponentUpdatesRequest request, StreamResponseHandler<ComponentUpdatePolicyEvents> streamResponseHandler) throws InterruptedException
request - request objectstreamResponseHandler - Methods on this object will be called as stream events happen on this operation.
If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.InterruptedException - if thread is interrupted while waiting for the responsepublic GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToComponentUpdatesResponse>,SubscribeToComponentUpdatesResponseHandler> subscribeToComponentUpdatesAsync(SubscribeToComponentUpdatesRequest request, StreamResponseHandler<ComponentUpdatePolicyEvents> streamResponseHandler)
request - request objectstreamResponseHandler - Methods on this object will be called as stream events happen on this operation.
If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.public GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToConfigurationUpdateResponse>,SubscribeToConfigurationUpdateResponseHandler> subscribeToConfigurationUpdateAsync(SubscribeToConfigurationUpdateRequest request, Consumer<ConfigurationUpdateEvents> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed)
request - request objectonStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.onStreamError - Callback for stream errors. Return true to close the stream,
return false to keep the stream open. Even if an executor is provided,
this method will not run in the executor.onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.public GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToConfigurationUpdateResponse,SubscribeToConfigurationUpdateResponseHandler> subscribeToConfigurationUpdate(SubscribeToConfigurationUpdateRequest request, Consumer<ConfigurationUpdateEvents> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed) throws InterruptedException
request - request objectonStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.onStreamError - Callback for stream errors. Return true to close the stream,
return false to keep the stream open. Even if an executor is provided,
this method will not run in the executor.onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.InterruptedException - if thread is interrupted while waiting for the responsepublic GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToConfigurationUpdateResponse,SubscribeToConfigurationUpdateResponseHandler> subscribeToConfigurationUpdate(SubscribeToConfigurationUpdateRequest request, StreamResponseHandler<ConfigurationUpdateEvents> streamResponseHandler) throws InterruptedException
request - request objectstreamResponseHandler - Methods on this object will be called as stream events happen on this operation.
If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.InterruptedException - if thread is interrupted while waiting for the responsepublic GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToConfigurationUpdateResponse>,SubscribeToConfigurationUpdateResponseHandler> subscribeToConfigurationUpdateAsync(SubscribeToConfigurationUpdateRequest request, StreamResponseHandler<ConfigurationUpdateEvents> streamResponseHandler)
request - request objectstreamResponseHandler - Methods on this object will be called as stream events happen on this operation.
If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.public GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToIoTCoreResponse>,SubscribeToIoTCoreResponseHandler> subscribeToIoTCoreAsync(SubscribeToIoTCoreRequest request, Consumer<IoTCoreMessage> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed)
request - request objectonStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.onStreamError - Callback for stream errors. Return true to close the stream,
return false to keep the stream open. Even if an executor is provided,
this method will not run in the executor.onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.public GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToIoTCoreResponse,SubscribeToIoTCoreResponseHandler> subscribeToIoTCore(SubscribeToIoTCoreRequest request, Consumer<IoTCoreMessage> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed) throws InterruptedException
request - request objectonStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.onStreamError - Callback for stream errors. Return true to close the stream,
return false to keep the stream open. Even if an executor is provided,
this method will not run in the executor.onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.InterruptedException - if thread is interrupted while waiting for the responsepublic GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToIoTCoreResponse,SubscribeToIoTCoreResponseHandler> subscribeToIoTCore(SubscribeToIoTCoreRequest request, StreamResponseHandler<IoTCoreMessage> streamResponseHandler) throws InterruptedException
request - request objectstreamResponseHandler - Methods on this object will be called as stream events happen on this operation.
If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.InterruptedException - if thread is interrupted while waiting for the responsepublic GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToIoTCoreResponse>,SubscribeToIoTCoreResponseHandler> subscribeToIoTCoreAsync(SubscribeToIoTCoreRequest request, StreamResponseHandler<IoTCoreMessage> streamResponseHandler)
request - request objectstreamResponseHandler - Methods on this object will be called as stream events happen on this operation.
If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.public GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToTopicResponse>,SubscribeToTopicResponseHandler> subscribeToTopicAsync(SubscribeToTopicRequest request, Consumer<SubscriptionResponseMessage> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed)
request - request objectonStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.onStreamError - Callback for stream errors. Return true to close the stream,
return false to keep the stream open. Even if an executor is provided,
this method will not run in the executor.onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.public GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToTopicResponse,SubscribeToTopicResponseHandler> subscribeToTopic(SubscribeToTopicRequest request, Consumer<SubscriptionResponseMessage> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed) throws InterruptedException
request - request objectonStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.onStreamError - Callback for stream errors. Return true to close the stream,
return false to keep the stream open. Even if an executor is provided,
this method will not run in the executor.onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.InterruptedException - if thread is interrupted while waiting for the responsepublic GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToTopicResponse,SubscribeToTopicResponseHandler> subscribeToTopic(SubscribeToTopicRequest request, StreamResponseHandler<SubscriptionResponseMessage> streamResponseHandler) throws InterruptedException
request - request objectstreamResponseHandler - Methods on this object will be called as stream events happen on this operation.
If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.InterruptedException - if thread is interrupted while waiting for the responsepublic GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToTopicResponse>,SubscribeToTopicResponseHandler> subscribeToTopicAsync(SubscribeToTopicRequest request, StreamResponseHandler<SubscriptionResponseMessage> streamResponseHandler)
request - request objectstreamResponseHandler - Methods on this object will be called as stream events happen on this operation.
If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.public GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToValidateConfigurationUpdatesResponse>,SubscribeToValidateConfigurationUpdatesResponseHandler> subscribeToValidateConfigurationUpdatesAsync(SubscribeToValidateConfigurationUpdatesRequest request, Consumer<ValidateConfigurationUpdateEvents> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed)
request - request objectonStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.onStreamError - Callback for stream errors. Return true to close the stream,
return false to keep the stream open. Even if an executor is provided,
this method will not run in the executor.onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.public GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToValidateConfigurationUpdatesResponse,SubscribeToValidateConfigurationUpdatesResponseHandler> subscribeToValidateConfigurationUpdates(SubscribeToValidateConfigurationUpdatesRequest request, Consumer<ValidateConfigurationUpdateEvents> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed) throws InterruptedException
request - request objectonStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.onStreamError - Callback for stream errors. Return true to close the stream,
return false to keep the stream open. Even if an executor is provided,
this method will not run in the executor.onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.InterruptedException - if thread is interrupted while waiting for the responsepublic GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToValidateConfigurationUpdatesResponse,SubscribeToValidateConfigurationUpdatesResponseHandler> subscribeToValidateConfigurationUpdates(SubscribeToValidateConfigurationUpdatesRequest request, StreamResponseHandler<ValidateConfigurationUpdateEvents> streamResponseHandler) throws InterruptedException
request - request objectstreamResponseHandler - Methods on this object will be called as stream events happen on this operation.
If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.InterruptedException - if thread is interrupted while waiting for the responsepublic GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToValidateConfigurationUpdatesResponse>,SubscribeToValidateConfigurationUpdatesResponseHandler> subscribeToValidateConfigurationUpdatesAsync(SubscribeToValidateConfigurationUpdatesRequest request, StreamResponseHandler<ValidateConfigurationUpdateEvents> streamResponseHandler)
request - request objectstreamResponseHandler - Methods on this object will be called as stream events happen on this operation.
If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.public UpdateConfigurationResponse updateConfiguration(UpdateConfigurationRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<UpdateConfigurationResponse> updateConfigurationAsync(UpdateConfigurationRequest request)
request - request objectpublic UpdateStateResponse updateState(UpdateStateRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<UpdateStateResponse> updateStateAsync(UpdateStateRequest request)
request - request objectpublic UpdateThingShadowResponse updateThingShadow(UpdateThingShadowRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<UpdateThingShadowResponse> updateThingShadowAsync(UpdateThingShadowRequest request)
request - request objectpublic ValidateAuthorizationTokenResponse validateAuthorizationToken(ValidateAuthorizationTokenRequest request) throws InterruptedException
request - request objectInterruptedException - if thread is interrupted while waiting for the responsepublic CompletableFuture<ValidateAuthorizationTokenResponse> validateAuthorizationTokenAsync(ValidateAuthorizationTokenRequest request)
request - request objectCopyright ? 2021. All rights reserved.