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, 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
-