Package io.dapr.v1
Class DaprGrpc.DaprFutureStub
java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractFutureStub<DaprGrpc.DaprFutureStub>
io.dapr.v1.DaprGrpc.DaprFutureStub
- Enclosing class:
- DaprGrpc
public static final class DaprGrpc.DaprFutureStub
extends io.grpc.stub.AbstractFutureStub<DaprGrpc.DaprFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service Dapr.
Dapr service provides APIs to user application to access Dapr building blocks.
-
Nested Class Summary
Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub
io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>
-
Method Summary
Modifier and TypeMethodDescriptionprotected DaprGrpc.DaprFutureStub
build
(io.grpc.Channel channel, io.grpc.CallOptions callOptions) com.google.common.util.concurrent.ListenableFuture<DaprProtos.BulkPublishResponse>
Bulk Publishes multiple events to the specified topic.com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Deletes a bulk of state items for a list of keyscom.google.common.util.concurrent.ListenableFuture<DaprProtos.DeleteJobResponse>
Delete a jobcom.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
deleteState
(DaprProtos.DeleteStateRequest request) Deletes the state for a specific key.com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Executes state transactions for a specified actorcom.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Executes transactions for a specified storecom.google.common.util.concurrent.ListenableFuture<DaprProtos.GetActorStateResponse>
Gets the state for a specific actor.com.google.common.util.concurrent.ListenableFuture<DaprProtos.GetBulkSecretResponse>
Gets a bulk of secretscom.google.common.util.concurrent.ListenableFuture<DaprProtos.GetBulkStateResponse>
Gets a bulk of state items for a list of keyscom.google.common.util.concurrent.ListenableFuture<DaprProtos.GetConfigurationResponse>
GetConfiguration gets configuration from configuration store.com.google.common.util.concurrent.ListenableFuture<DaprProtos.GetConfigurationResponse>
GetConfiguration gets configuration from configuration store.com.google.common.util.concurrent.ListenableFuture<DaprProtos.GetJobResponse>
getJobAlpha1
(DaprProtos.GetJobRequest request) Gets a scheduled jobcom.google.common.util.concurrent.ListenableFuture<DaprProtos.GetMetadataResponse>
getMetadata
(DaprProtos.GetMetadataRequest request) Gets metadata of the sidecarcom.google.common.util.concurrent.ListenableFuture<DaprProtos.GetSecretResponse>
getSecret
(DaprProtos.GetSecretRequest request) Gets secrets from secret stores.com.google.common.util.concurrent.ListenableFuture<DaprProtos.GetStateResponse>
getState
(DaprProtos.GetStateRequest request) Gets the state for a specific key.com.google.common.util.concurrent.ListenableFuture<DaprProtos.GetWorkflowResponse>
Gets details about a started workflow instancecom.google.common.util.concurrent.ListenableFuture<DaprProtos.GetWorkflowResponse>
Gets details about a started workflow instancecom.google.common.util.concurrent.ListenableFuture<DaprProtos.InvokeActorResponse>
invokeActor
(DaprProtos.InvokeActorRequest request) InvokeActor calls a method on an actor.com.google.common.util.concurrent.ListenableFuture<DaprProtos.InvokeBindingResponse>
Invokes binding data to specific output bindingscom.google.common.util.concurrent.ListenableFuture<CommonProtos.InvokeResponse>
Invokes a method on a remote Dapr app.com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Pauses a running workflow instancecom.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Pauses a running workflow instancecom.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Publishes events to the specific topic.com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Purge Workflowcom.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Purge Workflowcom.google.common.util.concurrent.ListenableFuture<DaprProtos.QueryStateResponse>
Queries the state.com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Raise an event to a running workflow instancecom.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Raise an event to a running workflow instancecom.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Register an actor reminder.com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Register an actor timer.com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Resumes a paused workflow instancecom.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Resumes a paused workflow instancecom.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
saveState
(DaprProtos.SaveStateRequest request) Saves the state for a specific key.com.google.common.util.concurrent.ListenableFuture<DaprProtos.ScheduleJobResponse>
Create and schedule a jobcom.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
setMetadata
(DaprProtos.SetMetadataRequest request) Sets value in extended metadata of the sidecarcom.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
shutdown
(DaprProtos.ShutdownRequest request) Shutdown the sidecarcom.google.common.util.concurrent.ListenableFuture<DaprProtos.StartWorkflowResponse>
Starts a new instance of a workflowcom.google.common.util.concurrent.ListenableFuture<DaprProtos.StartWorkflowResponse>
Starts a new instance of a workflowcom.google.common.util.concurrent.ListenableFuture<DaprProtos.SubtleDecryptResponse>
SubtleDecryptAlpha1 decrypts a small message using a key stored in the vault.com.google.common.util.concurrent.ListenableFuture<DaprProtos.SubtleEncryptResponse>
SubtleEncryptAlpha1 encrypts a small message using a key stored in the vault.com.google.common.util.concurrent.ListenableFuture<DaprProtos.SubtleGetKeyResponse>
SubtleGetKeyAlpha1 returns the public part of an asymmetric key stored in the vault.com.google.common.util.concurrent.ListenableFuture<DaprProtos.SubtleSignResponse>
SubtleSignAlpha1 signs a message using a key stored in the vault.com.google.common.util.concurrent.ListenableFuture<DaprProtos.SubtleUnwrapKeyResponse>
SubtleUnwrapKeyAlpha1 unwraps a key using a key stored in the vault.com.google.common.util.concurrent.ListenableFuture<DaprProtos.SubtleVerifyResponse>
SubtleVerifyAlpha1 verifies the signature of a message using a key stored in the vault.com.google.common.util.concurrent.ListenableFuture<DaprProtos.SubtleWrapKeyResponse>
SubtleWrapKeyAlpha1 wraps a key using a key stored in the vault.com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Terminates a running workflow instancecom.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Terminates a running workflow instancecom.google.common.util.concurrent.ListenableFuture<DaprProtos.TryLockResponse>
tryLockAlpha1
(DaprProtos.TryLockRequest request) TryLockAlpha1 tries to get a lock with an expiry.com.google.common.util.concurrent.ListenableFuture<DaprProtos.UnlockResponse>
unlockAlpha1
(DaprProtos.UnlockRequest request) UnlockAlpha1 unlocks a lock.com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Unregister an actor reminder.com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Unregister an actor timer.com.google.common.util.concurrent.ListenableFuture<DaprProtos.UnsubscribeConfigurationResponse>
UnSubscribeConfiguration unsubscribe the subscription of configurationcom.google.common.util.concurrent.ListenableFuture<DaprProtos.UnsubscribeConfigurationResponse>
UnSubscribeConfiguration unsubscribe the subscription of configurationMethods inherited from class io.grpc.stub.AbstractFutureStub
newStub, newStub
Methods inherited from class io.grpc.stub.AbstractStub
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady
-
Method Details
-
build
- Specified by:
build
in classio.grpc.stub.AbstractStub<DaprGrpc.DaprFutureStub>
-
invokeService
public com.google.common.util.concurrent.ListenableFuture<CommonProtos.InvokeResponse> invokeService(DaprProtos.InvokeServiceRequest request) Invokes a method on a remote Dapr app. Deprecated: Use proxy mode service invocation instead.
-
getState
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.GetStateResponse> getState(DaprProtos.GetStateRequest request) Gets the state for a specific key.
-
getBulkState
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.GetBulkStateResponse> getBulkState(DaprProtos.GetBulkStateRequest request) Gets a bulk of state items for a list of keys
-
saveState
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> saveState(DaprProtos.SaveStateRequest request) Saves the state for a specific key.
-
queryStateAlpha1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.QueryStateResponse> queryStateAlpha1(DaprProtos.QueryStateRequest request) Queries the state.
-
deleteState
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteState(DaprProtos.DeleteStateRequest request) Deletes the state for a specific key.
-
deleteBulkState
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteBulkState(DaprProtos.DeleteBulkStateRequest request) Deletes a bulk of state items for a list of keys
-
executeStateTransaction
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> executeStateTransaction(DaprProtos.ExecuteStateTransactionRequest request) Executes transactions for a specified store
-
publishEvent
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> publishEvent(DaprProtos.PublishEventRequest request) Publishes events to the specific topic.
-
bulkPublishEventAlpha1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.BulkPublishResponse> bulkPublishEventAlpha1(DaprProtos.BulkPublishRequest request) Bulk Publishes multiple events to the specified topic.
-
invokeBinding
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.InvokeBindingResponse> invokeBinding(DaprProtos.InvokeBindingRequest request) Invokes binding data to specific output bindings
-
getSecret
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.GetSecretResponse> getSecret(DaprProtos.GetSecretRequest request) Gets secrets from secret stores.
-
getBulkSecret
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.GetBulkSecretResponse> getBulkSecret(DaprProtos.GetBulkSecretRequest request) Gets a bulk of secrets
-
registerActorTimer
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> registerActorTimer(DaprProtos.RegisterActorTimerRequest request) Register an actor timer.
-
unregisterActorTimer
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> unregisterActorTimer(DaprProtos.UnregisterActorTimerRequest request) Unregister an actor timer.
-
registerActorReminder
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> registerActorReminder(DaprProtos.RegisterActorReminderRequest request) Register an actor reminder.
-
unregisterActorReminder
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> unregisterActorReminder(DaprProtos.UnregisterActorReminderRequest request) Unregister an actor reminder.
-
getActorState
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.GetActorStateResponse> getActorState(DaprProtos.GetActorStateRequest request) Gets the state for a specific actor.
-
executeActorStateTransaction
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> executeActorStateTransaction(DaprProtos.ExecuteActorStateTransactionRequest request) Executes state transactions for a specified actor
-
invokeActor
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.InvokeActorResponse> invokeActor(DaprProtos.InvokeActorRequest request) InvokeActor calls a method on an actor.
-
getConfigurationAlpha1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.GetConfigurationResponse> getConfigurationAlpha1(DaprProtos.GetConfigurationRequest request) GetConfiguration gets configuration from configuration store.
-
getConfiguration
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.GetConfigurationResponse> getConfiguration(DaprProtos.GetConfigurationRequest request) GetConfiguration gets configuration from configuration store.
-
unsubscribeConfigurationAlpha1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.UnsubscribeConfigurationResponse> unsubscribeConfigurationAlpha1(DaprProtos.UnsubscribeConfigurationRequest request) UnSubscribeConfiguration unsubscribe the subscription of configuration
-
unsubscribeConfiguration
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.UnsubscribeConfigurationResponse> unsubscribeConfiguration(DaprProtos.UnsubscribeConfigurationRequest request) UnSubscribeConfiguration unsubscribe the subscription of configuration
-
tryLockAlpha1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.TryLockResponse> tryLockAlpha1(DaprProtos.TryLockRequest request) TryLockAlpha1 tries to get a lock with an expiry.
-
unlockAlpha1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.UnlockResponse> unlockAlpha1(DaprProtos.UnlockRequest request) UnlockAlpha1 unlocks a lock.
-
getMetadata
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.GetMetadataResponse> getMetadata(DaprProtos.GetMetadataRequest request) Gets metadata of the sidecar
-
setMetadata
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> setMetadata(DaprProtos.SetMetadataRequest request) Sets value in extended metadata of the sidecar
-
subtleGetKeyAlpha1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.SubtleGetKeyResponse> subtleGetKeyAlpha1(DaprProtos.SubtleGetKeyRequest request) SubtleGetKeyAlpha1 returns the public part of an asymmetric key stored in the vault.
-
subtleEncryptAlpha1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.SubtleEncryptResponse> subtleEncryptAlpha1(DaprProtos.SubtleEncryptRequest request) SubtleEncryptAlpha1 encrypts a small message using a key stored in the vault.
-
subtleDecryptAlpha1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.SubtleDecryptResponse> subtleDecryptAlpha1(DaprProtos.SubtleDecryptRequest request) SubtleDecryptAlpha1 decrypts a small message using a key stored in the vault.
-
subtleWrapKeyAlpha1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.SubtleWrapKeyResponse> subtleWrapKeyAlpha1(DaprProtos.SubtleWrapKeyRequest request) SubtleWrapKeyAlpha1 wraps a key using a key stored in the vault.
-
subtleUnwrapKeyAlpha1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.SubtleUnwrapKeyResponse> subtleUnwrapKeyAlpha1(DaprProtos.SubtleUnwrapKeyRequest request) SubtleUnwrapKeyAlpha1 unwraps a key using a key stored in the vault.
-
subtleSignAlpha1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.SubtleSignResponse> subtleSignAlpha1(DaprProtos.SubtleSignRequest request) SubtleSignAlpha1 signs a message using a key stored in the vault.
-
subtleVerifyAlpha1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.SubtleVerifyResponse> subtleVerifyAlpha1(DaprProtos.SubtleVerifyRequest request) SubtleVerifyAlpha1 verifies the signature of a message using a key stored in the vault.
-
startWorkflowAlpha1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.StartWorkflowResponse> startWorkflowAlpha1(DaprProtos.StartWorkflowRequest request) Starts a new instance of a workflow
-
getWorkflowAlpha1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.GetWorkflowResponse> getWorkflowAlpha1(DaprProtos.GetWorkflowRequest request) Gets details about a started workflow instance
-
purgeWorkflowAlpha1
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> purgeWorkflowAlpha1(DaprProtos.PurgeWorkflowRequest request) Purge Workflow
-
terminateWorkflowAlpha1
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> terminateWorkflowAlpha1(DaprProtos.TerminateWorkflowRequest request) Terminates a running workflow instance
-
pauseWorkflowAlpha1
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> pauseWorkflowAlpha1(DaprProtos.PauseWorkflowRequest request) Pauses a running workflow instance
-
resumeWorkflowAlpha1
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> resumeWorkflowAlpha1(DaprProtos.ResumeWorkflowRequest request) Resumes a paused workflow instance
-
raiseEventWorkflowAlpha1
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> raiseEventWorkflowAlpha1(DaprProtos.RaiseEventWorkflowRequest request) Raise an event to a running workflow instance
-
startWorkflowBeta1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.StartWorkflowResponse> startWorkflowBeta1(DaprProtos.StartWorkflowRequest request) Starts a new instance of a workflow
-
getWorkflowBeta1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.GetWorkflowResponse> getWorkflowBeta1(DaprProtos.GetWorkflowRequest request) Gets details about a started workflow instance
-
purgeWorkflowBeta1
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> purgeWorkflowBeta1(DaprProtos.PurgeWorkflowRequest request) Purge Workflow
-
terminateWorkflowBeta1
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> terminateWorkflowBeta1(DaprProtos.TerminateWorkflowRequest request) Terminates a running workflow instance
-
pauseWorkflowBeta1
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> pauseWorkflowBeta1(DaprProtos.PauseWorkflowRequest request) Pauses a running workflow instance
-
resumeWorkflowBeta1
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> resumeWorkflowBeta1(DaprProtos.ResumeWorkflowRequest request) Resumes a paused workflow instance
-
raiseEventWorkflowBeta1
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> raiseEventWorkflowBeta1(DaprProtos.RaiseEventWorkflowRequest request) Raise an event to a running workflow instance
-
shutdown
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> shutdown(DaprProtos.ShutdownRequest request) Shutdown the sidecar
-
scheduleJobAlpha1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.ScheduleJobResponse> scheduleJobAlpha1(DaprProtos.ScheduleJobRequest request) Create and schedule a job
-
getJobAlpha1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.GetJobResponse> getJobAlpha1(DaprProtos.GetJobRequest request) Gets a scheduled job
-
deleteJobAlpha1
public com.google.common.util.concurrent.ListenableFuture<DaprProtos.DeleteJobResponse> deleteJobAlpha1(DaprProtos.DeleteJobRequest request) Delete a job
-