Package io.dapr.v1
Class DaprGrpc.DaprStub
java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractAsyncStub<DaprGrpc.DaprStub>
io.dapr.v1.DaprGrpc.DaprStub
- Enclosing class:
- DaprGrpc
public static final class DaprGrpc.DaprStub
extends io.grpc.stub.AbstractAsyncStub<DaprGrpc.DaprStub>
A stub to allow clients to do asynchronous 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 TypeMethodDescriptionvoidbatchQueryVectorsAlpha1(DaprVectorProtos.BatchQueryVectorsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprVectorProtos.BatchQueryVectorsResponseAlpha1> responseObserver) Issue multiple queries against the same collection, each succeeding or failing on its own.protected DaprGrpc.DaprStubbuild(io.grpc.Channel channel, io.grpc.CallOptions callOptions) voidbulkPublishEvent(DaprPubsubProtos.BulkPublishRequest request, io.grpc.stub.StreamObserver<DaprPubsubProtos.BulkPublishResponse> responseObserver) Bulk Publishes multiple events to the specified topic.voidbulkPublishEventAlpha1(DaprPubsubProtos.BulkPublishRequest request, io.grpc.stub.StreamObserver<DaprPubsubProtos.BulkPublishResponse> responseObserver) Deprecated.voidconverseAlpha1(DaprAiProtos.ConversationRequest request, io.grpc.stub.StreamObserver<DaprAiProtos.ConversationResponse> responseObserver) Converse with a LLM servicevoidconverseAlpha2(DaprAiProtos.ConversationRequestAlpha2 request, io.grpc.stub.StreamObserver<DaprAiProtos.ConversationResponseAlpha2> responseObserver) Converse with a LLM service via alpha2 apivoidcreateCollectionAlpha1(DaprVectorProtos.CreateCollectionRequestAlpha1 request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Create a collection.voidcreateIndexAlpha1(DaprSearchProtos.CreateIndexRequestAlpha1 request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Create an index.io.grpc.stub.StreamObserver<DaprCryptoProtos.DecryptRequest>decryptAlpha1(io.grpc.stub.StreamObserver<DaprCryptoProtos.DecryptResponse> responseObserver) DecryptAlpha1 decrypts a message using the Dapr encryption scheme and a key stored in the vault.voiddeleteBinaryFileAlpha1(DaprBinaryStoreProtos.DeleteBinaryFileRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprBinaryStoreProtos.DeleteBinaryFileResponseAlpha1> responseObserver) Deletes a binary file.voiddeleteBulkState(DaprStateProtos.DeleteBulkStateRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deletes a bulk of state items for a list of keysvoiddeleteCollectionAlpha1(DaprVectorProtos.DeleteCollectionRequestAlpha1 request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Delete a collection.voiddeleteDocumentsAlpha1(DaprSearchProtos.DeleteDocumentsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprSearchProtos.DeleteDocumentsResponseAlpha1> responseObserver) Delete documents by ID.voiddeleteIndexAlpha1(DaprSearchProtos.DeleteIndexRequestAlpha1 request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Delete an index.voiddeleteJob(DaprJobsProtos.DeleteJobRequest request, io.grpc.stub.StreamObserver<DaprJobsProtos.DeleteJobResponse> responseObserver) Delete a jobvoiddeleteJobAlpha1(DaprJobsProtos.DeleteJobRequest request, io.grpc.stub.StreamObserver<DaprJobsProtos.DeleteJobResponse> responseObserver) Deprecated.voiddeleteJobsByPrefix(DaprJobsProtos.DeleteJobsByPrefixRequest request, io.grpc.stub.StreamObserver<DaprJobsProtos.DeleteJobsByPrefixResponse> responseObserver) Delete jobs by name prefixvoiddeleteJobsByPrefixAlpha1(DaprJobsProtos.DeleteJobsByPrefixRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprJobsProtos.DeleteJobsByPrefixResponseAlpha1> responseObserver) Deprecated.voiddeleteState(DaprStateProtos.DeleteStateRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deletes the state for a specific key.voiddeleteVectorsAlpha1(DaprVectorProtos.DeleteVectorsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprVectorProtos.DeleteVectorsResponseAlpha1> responseObserver) Delete vectors by ID.io.grpc.stub.StreamObserver<DaprCryptoProtos.EncryptRequest>encryptAlpha1(io.grpc.stub.StreamObserver<DaprCryptoProtos.EncryptResponse> responseObserver) EncryptAlpha1 encrypts a message using the Dapr encryption scheme and a key stored in the vault.voidexecuteActorStateTransaction(DaprActorsProtos.ExecuteActorStateTransactionRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Executes state transactions for a specified actorvoidexecuteStateTransaction(DaprStateProtos.ExecuteStateTransactionRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Executes transactions for a specified storevoidgetActorReminder(DaprActorsProtos.GetActorReminderRequest request, io.grpc.stub.StreamObserver<DaprActorsProtos.GetActorReminderResponse> responseObserver) Gets an actor reminder.voidgetActorState(DaprActorsProtos.GetActorStateRequest request, io.grpc.stub.StreamObserver<DaprActorsProtos.GetActorStateResponse> responseObserver) Gets the state for a specific actor.voidgetActorTimer(DaprActorsProtos.GetActorTimerRequest request, io.grpc.stub.StreamObserver<DaprActorsProtos.GetActorTimerResponse> responseObserver) Gets a timer registered on this host for an actor.voidgetBinaryFileAlpha1(DaprBinaryStoreProtos.GetBinaryFileRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprBinaryStoreProtos.GetBinaryFileResponseAlpha1> responseObserver) Retrieves a binary file as a stream of chunks.voidgetBulkSecret(DaprSecretProtos.GetBulkSecretRequest request, io.grpc.stub.StreamObserver<DaprSecretProtos.GetBulkSecretResponse> responseObserver) Gets a bulk of secretsvoidgetBulkState(DaprStateProtos.GetBulkStateRequest request, io.grpc.stub.StreamObserver<DaprStateProtos.GetBulkStateResponse> responseObserver) Gets a bulk of state items for a list of keysvoidgetCollectionAlpha1(DaprVectorProtos.GetCollectionRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprVectorProtos.GetCollectionResponseAlpha1> responseObserver) Get a collection.voidgetConfiguration(DaprConfigurationProtos.GetConfigurationRequest request, io.grpc.stub.StreamObserver<DaprConfigurationProtos.GetConfigurationResponse> responseObserver) GetConfiguration gets configuration from configuration store.voidgetConfigurationAlpha1(DaprConfigurationProtos.GetConfigurationRequest request, io.grpc.stub.StreamObserver<DaprConfigurationProtos.GetConfigurationResponse> responseObserver) GetConfiguration gets configuration from configuration store.voidgetDocumentsAlpha1(DaprSearchProtos.GetDocumentsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprSearchProtos.GetDocumentsResponseAlpha1> responseObserver) Get documents by ID.voidgetIndexAlpha1(DaprSearchProtos.GetIndexRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprSearchProtos.GetIndexResponseAlpha1> responseObserver) Get an index.voidgetJob(DaprJobsProtos.GetJobRequest request, io.grpc.stub.StreamObserver<DaprJobsProtos.GetJobResponse> responseObserver) Gets a scheduled jobvoidgetJobAlpha1(DaprJobsProtos.GetJobRequest request, io.grpc.stub.StreamObserver<DaprJobsProtos.GetJobResponse> responseObserver) Deprecated.voidgetMetadata(DaprMetadataProtos.GetMetadataRequest request, io.grpc.stub.StreamObserver<DaprMetadataProtos.GetMetadataResponse> responseObserver) Gets metadata of the sidecarvoidgetSecret(DaprSecretProtos.GetSecretRequest request, io.grpc.stub.StreamObserver<DaprSecretProtos.GetSecretResponse> responseObserver) Gets secrets from secret stores.voidgetState(DaprStateProtos.GetStateRequest request, io.grpc.stub.StreamObserver<DaprStateProtos.GetStateResponse> responseObserver) Gets the state for a specific key.voidgetVectorsAlpha1(DaprVectorProtos.GetVectorsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprVectorProtos.GetVectorsResponseAlpha1> responseObserver) Get vectors by ID.voidgetWorkflowAlpha1(DaprWorkflowProtos.GetWorkflowRequest request, io.grpc.stub.StreamObserver<DaprWorkflowProtos.GetWorkflowResponse> responseObserver) Deprecated.voidgetWorkflowBeta1(DaprWorkflowProtos.GetWorkflowRequest request, io.grpc.stub.StreamObserver<DaprWorkflowProtos.GetWorkflowResponse> responseObserver) Gets details about a started workflow instancevoidindexDocumentsAlpha1(DaprSearchProtos.IndexDocumentsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprSearchProtos.IndexDocumentsResponseAlpha1> responseObserver) Index (keyed upsert) documents.voidinvokeActor(DaprActorsProtos.InvokeActorRequest request, io.grpc.stub.StreamObserver<DaprActorsProtos.InvokeActorResponse> responseObserver) InvokeActor calls a method on an actor.voidinvokeBinding(DaprBindingsProtos.InvokeBindingRequest request, io.grpc.stub.StreamObserver<DaprBindingsProtos.InvokeBindingResponse> responseObserver) Invokes binding data to specific output bindingsvoidinvokeService(DaprInvokeProtos.InvokeServiceRequest request, io.grpc.stub.StreamObserver<CommonProtos.InvokeResponse> responseObserver) Invokes a method on a remote Dapr app.voidlistActorReminders(DaprActorsProtos.ListActorRemindersRequest request, io.grpc.stub.StreamObserver<DaprActorsProtos.ListActorRemindersResponse> responseObserver) voidlistActorTimers(DaprActorsProtos.ListActorTimersRequest request, io.grpc.stub.StreamObserver<DaprActorsProtos.ListActorTimersResponse> responseObserver) Lists the timers registered on this host for an actor.voidlistCollectionsAlpha1(DaprVectorProtos.ListCollectionsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprVectorProtos.ListCollectionsResponseAlpha1> responseObserver) List collections.voidlistIndexesAlpha1(DaprSearchProtos.ListIndexesRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprSearchProtos.ListIndexesResponseAlpha1> responseObserver) List indexes.voidlistJobs(DaprJobsProtos.ListJobsRequest request, io.grpc.stub.StreamObserver<DaprJobsProtos.ListJobsResponse> responseObserver) List all jobsvoidlistJobsAlpha1(DaprJobsProtos.ListJobsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprJobsProtos.ListJobsResponseAlpha1> responseObserver) Deprecated.voidpauseWorkflowAlpha1(DaprWorkflowProtos.PauseWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.voidpauseWorkflowBeta1(DaprWorkflowProtos.PauseWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Pauses a running workflow instancevoidpublishEvent(DaprPubsubProtos.PublishEventRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Publishes events to the specific topic.voidpurgeWorkflowAlpha1(DaprWorkflowProtos.PurgeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.voidpurgeWorkflowBeta1(DaprWorkflowProtos.PurgeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Purge WorkflowvoidqueryStateAlpha1(DaprStateProtos.QueryStateRequest request, io.grpc.stub.StreamObserver<DaprStateProtos.QueryStateResponse> responseObserver) Queries the state.voidqueryVectorsAlpha1(DaprVectorProtos.QueryVectorsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprVectorProtos.QueryVectorsResponseAlpha1> responseObserver) Query vectors.voidraiseEventWorkflowAlpha1(DaprWorkflowProtos.RaiseEventWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.voidraiseEventWorkflowBeta1(DaprWorkflowProtos.RaiseEventWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Raise an event to a running workflow instancevoidregisterActorReminder(DaprActorsProtos.RegisterActorReminderRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Register an actor reminder.voidregisterActorTimer(DaprActorsProtos.RegisterActorTimerRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Register an actor timer.voidresumeWorkflowAlpha1(DaprWorkflowProtos.ResumeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.voidresumeWorkflowBeta1(DaprWorkflowProtos.ResumeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Resumes a paused workflow instancevoidsaveState(DaprStateProtos.SaveStateRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Saves the state for a specific key.voidscheduleJob(DaprJobsProtos.ScheduleJobRequest request, io.grpc.stub.StreamObserver<DaprJobsProtos.ScheduleJobResponse> responseObserver) Create and schedule a jobvoidscheduleJobAlpha1(DaprJobsProtos.ScheduleJobRequest request, io.grpc.stub.StreamObserver<DaprJobsProtos.ScheduleJobResponse> responseObserver) Deprecated.voidsearchAlpha1(DaprSearchProtos.SearchRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprSearchProtos.SearchResponseAlpha1> responseObserver) Search an index.io.grpc.stub.StreamObserver<DaprBinaryStoreProtos.SetBinaryFileRequestAlpha1>setBinaryFileAlpha1(io.grpc.stub.StreamObserver<DaprBinaryStoreProtos.SetBinaryFileResponseAlpha1> responseObserver) Stores a binary file using a streaming request.voidsetMetadata(DaprMetadataProtos.SetMetadataRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Sets value in extended metadata of the sidecarvoidshutdown(DaprProtos.ShutdownRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Shutdown the sidecarvoidstartWorkflowAlpha1(DaprWorkflowProtos.StartWorkflowRequest request, io.grpc.stub.StreamObserver<DaprWorkflowProtos.StartWorkflowResponse> responseObserver) Deprecated.voidstartWorkflowBeta1(DaprWorkflowProtos.StartWorkflowRequest request, io.grpc.stub.StreamObserver<DaprWorkflowProtos.StartWorkflowResponse> responseObserver) Starts a new instance of a workflowio.grpc.stub.StreamObserver<DaprActorsProtos.SubscribeActorEventsRequestAlpha1>subscribeActorEventsAlpha1(io.grpc.stub.StreamObserver<DaprActorsProtos.SubscribeActorEventsResponseAlpha1> responseObserver) SubscribeActorEventsAlpha1 is the app-initiated stream over which an actor host receives invocation, reminder, timer, and deactivation callbacks from Dapr.voidsubscribeConfiguration(DaprConfigurationProtos.SubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprConfigurationProtos.SubscribeConfigurationResponse> responseObserver) SubscribeConfiguration gets configuration from configuration store and subscribe the updates event by grpc streamvoidsubscribeConfigurationAlpha1(DaprConfigurationProtos.SubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprConfigurationProtos.SubscribeConfigurationResponse> responseObserver) SubscribeConfiguration gets configuration from configuration store and subscribe the updates event by grpc streamio.grpc.stub.StreamObserver<DaprPubsubProtos.SubscribeTopicEventsRequestAlpha1>subscribeTopicEventsAlpha1(io.grpc.stub.StreamObserver<DaprPubsubProtos.SubscribeTopicEventsResponseAlpha1> responseObserver) SubscribeTopicEventsAlpha1 subscribes to a PubSub topic and receives topic events from it.voidsubtleDecryptAlpha1(DaprCryptoProtos.SubtleDecryptRequest request, io.grpc.stub.StreamObserver<DaprCryptoProtos.SubtleDecryptResponse> responseObserver) SubtleDecryptAlpha1 decrypts a small message using a key stored in the vault.voidsubtleEncryptAlpha1(DaprCryptoProtos.SubtleEncryptRequest request, io.grpc.stub.StreamObserver<DaprCryptoProtos.SubtleEncryptResponse> responseObserver) SubtleEncryptAlpha1 encrypts a small message using a key stored in the vault.voidsubtleGetKeyAlpha1(DaprCryptoProtos.SubtleGetKeyRequest request, io.grpc.stub.StreamObserver<DaprCryptoProtos.SubtleGetKeyResponse> responseObserver) SubtleGetKeyAlpha1 returns the public part of an asymmetric key stored in the vault.voidsubtleSignAlpha1(DaprCryptoProtos.SubtleSignRequest request, io.grpc.stub.StreamObserver<DaprCryptoProtos.SubtleSignResponse> responseObserver) SubtleSignAlpha1 signs a message using a key stored in the vault.voidsubtleUnwrapKeyAlpha1(DaprCryptoProtos.SubtleUnwrapKeyRequest request, io.grpc.stub.StreamObserver<DaprCryptoProtos.SubtleUnwrapKeyResponse> responseObserver) SubtleUnwrapKeyAlpha1 unwraps a key using a key stored in the vault.voidsubtleVerifyAlpha1(DaprCryptoProtos.SubtleVerifyRequest request, io.grpc.stub.StreamObserver<DaprCryptoProtos.SubtleVerifyResponse> responseObserver) SubtleVerifyAlpha1 verifies the signature of a message using a key stored in the vault.voidsubtleWrapKeyAlpha1(DaprCryptoProtos.SubtleWrapKeyRequest request, io.grpc.stub.StreamObserver<DaprCryptoProtos.SubtleWrapKeyResponse> responseObserver) SubtleWrapKeyAlpha1 wraps a key using a key stored in the vault.voidterminateWorkflowAlpha1(DaprWorkflowProtos.TerminateWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.voidterminateWorkflowBeta1(DaprWorkflowProtos.TerminateWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Terminates a running workflow instancevoidtryLockAlpha1(DaprLockProtos.TryLockRequest request, io.grpc.stub.StreamObserver<DaprLockProtos.TryLockResponse> responseObserver) TryLockAlpha1 tries to get a lock with an expiry.voidunlockAlpha1(DaprLockProtos.UnlockRequest request, io.grpc.stub.StreamObserver<DaprLockProtos.UnlockResponse> responseObserver) UnlockAlpha1 unlocks a lock.voidunregisterActorReminder(DaprActorsProtos.UnregisterActorReminderRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Unregister an actor reminder.voidunregisterActorRemindersByType(DaprActorsProtos.UnregisterActorRemindersByTypeRequest request, io.grpc.stub.StreamObserver<DaprActorsProtos.UnregisterActorRemindersByTypeResponse> responseObserver) voidunregisterActorTimer(DaprActorsProtos.UnregisterActorTimerRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Unregister an actor timer.voidunsubscribeConfiguration(DaprConfigurationProtos.UnsubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprConfigurationProtos.UnsubscribeConfigurationResponse> responseObserver) UnSubscribeConfiguration unsubscribe the subscription of configurationvoidunsubscribeConfigurationAlpha1(DaprConfigurationProtos.UnsubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprConfigurationProtos.UnsubscribeConfigurationResponse> responseObserver) UnSubscribeConfiguration unsubscribe the subscription of configurationvoidupsertVectorsAlpha1(DaprVectorProtos.UpsertVectorsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprVectorProtos.UpsertVectorsResponseAlpha1> responseObserver) Upsert (keyed) vectors.Methods inherited from class io.grpc.stub.AbstractAsyncStub
newStub, newStubMethods inherited from class io.grpc.stub.AbstractStub
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady
-
Method Details
-
build
- Specified by:
buildin classio.grpc.stub.AbstractStub<DaprGrpc.DaprStub>
-
invokeService
public void invokeService(DaprInvokeProtos.InvokeServiceRequest request, io.grpc.stub.StreamObserver<CommonProtos.InvokeResponse> responseObserver) Invokes a method on a remote Dapr app. Deprecated: Use proxy mode service invocation instead.
-
getState
public void getState(DaprStateProtos.GetStateRequest request, io.grpc.stub.StreamObserver<DaprStateProtos.GetStateResponse> responseObserver) Gets the state for a specific key.
-
getBulkState
public void getBulkState(DaprStateProtos.GetBulkStateRequest request, io.grpc.stub.StreamObserver<DaprStateProtos.GetBulkStateResponse> responseObserver) Gets a bulk of state items for a list of keys
-
saveState
public void saveState(DaprStateProtos.SaveStateRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Saves the state for a specific key.
-
queryStateAlpha1
public void queryStateAlpha1(DaprStateProtos.QueryStateRequest request, io.grpc.stub.StreamObserver<DaprStateProtos.QueryStateResponse> responseObserver) Queries the state.
-
deleteState
public void deleteState(DaprStateProtos.DeleteStateRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deletes the state for a specific key.
-
deleteBulkState
public void deleteBulkState(DaprStateProtos.DeleteBulkStateRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deletes a bulk of state items for a list of keys
-
executeStateTransaction
public void executeStateTransaction(DaprStateProtos.ExecuteStateTransactionRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Executes transactions for a specified store
-
publishEvent
public void publishEvent(DaprPubsubProtos.PublishEventRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Publishes events to the specific topic.
-
bulkPublishEventAlpha1
@Deprecated public void bulkPublishEventAlpha1(DaprPubsubProtos.BulkPublishRequest request, io.grpc.stub.StreamObserver<DaprPubsubProtos.BulkPublishResponse> responseObserver) Deprecated.Deprecated: Bulk Publishes multiple events to the specified topic.
-
bulkPublishEvent
public void bulkPublishEvent(DaprPubsubProtos.BulkPublishRequest request, io.grpc.stub.StreamObserver<DaprPubsubProtos.BulkPublishResponse> responseObserver) Bulk Publishes multiple events to the specified topic.
-
subscribeTopicEventsAlpha1
public io.grpc.stub.StreamObserver<DaprPubsubProtos.SubscribeTopicEventsRequestAlpha1> subscribeTopicEventsAlpha1(io.grpc.stub.StreamObserver<DaprPubsubProtos.SubscribeTopicEventsResponseAlpha1> responseObserver) SubscribeTopicEventsAlpha1 subscribes to a PubSub topic and receives topic events from it.
-
invokeBinding
public void invokeBinding(DaprBindingsProtos.InvokeBindingRequest request, io.grpc.stub.StreamObserver<DaprBindingsProtos.InvokeBindingResponse> responseObserver) Invokes binding data to specific output bindings
-
getSecret
public void getSecret(DaprSecretProtos.GetSecretRequest request, io.grpc.stub.StreamObserver<DaprSecretProtos.GetSecretResponse> responseObserver) Gets secrets from secret stores.
-
getBulkSecret
public void getBulkSecret(DaprSecretProtos.GetBulkSecretRequest request, io.grpc.stub.StreamObserver<DaprSecretProtos.GetBulkSecretResponse> responseObserver) Gets a bulk of secrets
-
registerActorTimer
public void registerActorTimer(DaprActorsProtos.RegisterActorTimerRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Register an actor timer.
-
unregisterActorTimer
public void unregisterActorTimer(DaprActorsProtos.UnregisterActorTimerRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Unregister an actor timer.
-
registerActorReminder
public void registerActorReminder(DaprActorsProtos.RegisterActorReminderRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Register an actor reminder.
-
unregisterActorReminder
public void unregisterActorReminder(DaprActorsProtos.UnregisterActorReminderRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Unregister an actor reminder.
-
unregisterActorRemindersByType
public void unregisterActorRemindersByType(DaprActorsProtos.UnregisterActorRemindersByTypeRequest request, io.grpc.stub.StreamObserver<DaprActorsProtos.UnregisterActorRemindersByTypeResponse> responseObserver) -
listActorReminders
public void listActorReminders(DaprActorsProtos.ListActorRemindersRequest request, io.grpc.stub.StreamObserver<DaprActorsProtos.ListActorRemindersResponse> responseObserver) -
listActorTimers
public void listActorTimers(DaprActorsProtos.ListActorTimersRequest request, io.grpc.stub.StreamObserver<DaprActorsProtos.ListActorTimersResponse> responseObserver) Lists the timers registered on this host for an actor.
-
getActorState
public void getActorState(DaprActorsProtos.GetActorStateRequest request, io.grpc.stub.StreamObserver<DaprActorsProtos.GetActorStateResponse> responseObserver) Gets the state for a specific actor.
-
getActorReminder
public void getActorReminder(DaprActorsProtos.GetActorReminderRequest request, io.grpc.stub.StreamObserver<DaprActorsProtos.GetActorReminderResponse> responseObserver) Gets an actor reminder.
-
getActorTimer
public void getActorTimer(DaprActorsProtos.GetActorTimerRequest request, io.grpc.stub.StreamObserver<DaprActorsProtos.GetActorTimerResponse> responseObserver) Gets a timer registered on this host for an actor.
-
executeActorStateTransaction
public void executeActorStateTransaction(DaprActorsProtos.ExecuteActorStateTransactionRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Executes state transactions for a specified actor
-
invokeActor
public void invokeActor(DaprActorsProtos.InvokeActorRequest request, io.grpc.stub.StreamObserver<DaprActorsProtos.InvokeActorResponse> responseObserver) InvokeActor calls a method on an actor.
-
subscribeActorEventsAlpha1
public io.grpc.stub.StreamObserver<DaprActorsProtos.SubscribeActorEventsRequestAlpha1> subscribeActorEventsAlpha1(io.grpc.stub.StreamObserver<DaprActorsProtos.SubscribeActorEventsResponseAlpha1> responseObserver) SubscribeActorEventsAlpha1 is the app-initiated stream over which an actor host receives invocation, reminder, timer, and deactivation callbacks from Dapr. The first message the app sends must be a SubscribeActorEventsRequestInitialAlpha1 registering the actor types it hosts. Apps using this RPC do not need to expose a server port for actor callbacks.
-
getConfigurationAlpha1
public void getConfigurationAlpha1(DaprConfigurationProtos.GetConfigurationRequest request, io.grpc.stub.StreamObserver<DaprConfigurationProtos.GetConfigurationResponse> responseObserver) GetConfiguration gets configuration from configuration store.
-
getConfiguration
public void getConfiguration(DaprConfigurationProtos.GetConfigurationRequest request, io.grpc.stub.StreamObserver<DaprConfigurationProtos.GetConfigurationResponse> responseObserver) GetConfiguration gets configuration from configuration store.
-
subscribeConfigurationAlpha1
public void subscribeConfigurationAlpha1(DaprConfigurationProtos.SubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprConfigurationProtos.SubscribeConfigurationResponse> responseObserver) SubscribeConfiguration gets configuration from configuration store and subscribe the updates event by grpc stream
-
subscribeConfiguration
public void subscribeConfiguration(DaprConfigurationProtos.SubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprConfigurationProtos.SubscribeConfigurationResponse> responseObserver) SubscribeConfiguration gets configuration from configuration store and subscribe the updates event by grpc stream
-
unsubscribeConfigurationAlpha1
public void unsubscribeConfigurationAlpha1(DaprConfigurationProtos.UnsubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprConfigurationProtos.UnsubscribeConfigurationResponse> responseObserver) UnSubscribeConfiguration unsubscribe the subscription of configuration
-
unsubscribeConfiguration
public void unsubscribeConfiguration(DaprConfigurationProtos.UnsubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprConfigurationProtos.UnsubscribeConfigurationResponse> responseObserver) UnSubscribeConfiguration unsubscribe the subscription of configuration
-
tryLockAlpha1
public void tryLockAlpha1(DaprLockProtos.TryLockRequest request, io.grpc.stub.StreamObserver<DaprLockProtos.TryLockResponse> responseObserver) TryLockAlpha1 tries to get a lock with an expiry.
-
unlockAlpha1
public void unlockAlpha1(DaprLockProtos.UnlockRequest request, io.grpc.stub.StreamObserver<DaprLockProtos.UnlockResponse> responseObserver) UnlockAlpha1 unlocks a lock.
-
encryptAlpha1
public io.grpc.stub.StreamObserver<DaprCryptoProtos.EncryptRequest> encryptAlpha1(io.grpc.stub.StreamObserver<DaprCryptoProtos.EncryptResponse> responseObserver) EncryptAlpha1 encrypts a message using the Dapr encryption scheme and a key stored in the vault.
-
decryptAlpha1
public io.grpc.stub.StreamObserver<DaprCryptoProtos.DecryptRequest> decryptAlpha1(io.grpc.stub.StreamObserver<DaprCryptoProtos.DecryptResponse> responseObserver) DecryptAlpha1 decrypts a message using the Dapr encryption scheme and a key stored in the vault.
-
getMetadata
public void getMetadata(DaprMetadataProtos.GetMetadataRequest request, io.grpc.stub.StreamObserver<DaprMetadataProtos.GetMetadataResponse> responseObserver) Gets metadata of the sidecar
-
setMetadata
public void setMetadata(DaprMetadataProtos.SetMetadataRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Sets value in extended metadata of the sidecar
-
subtleGetKeyAlpha1
public void subtleGetKeyAlpha1(DaprCryptoProtos.SubtleGetKeyRequest request, io.grpc.stub.StreamObserver<DaprCryptoProtos.SubtleGetKeyResponse> responseObserver) SubtleGetKeyAlpha1 returns the public part of an asymmetric key stored in the vault.
-
subtleEncryptAlpha1
public void subtleEncryptAlpha1(DaprCryptoProtos.SubtleEncryptRequest request, io.grpc.stub.StreamObserver<DaprCryptoProtos.SubtleEncryptResponse> responseObserver) SubtleEncryptAlpha1 encrypts a small message using a key stored in the vault.
-
subtleDecryptAlpha1
public void subtleDecryptAlpha1(DaprCryptoProtos.SubtleDecryptRequest request, io.grpc.stub.StreamObserver<DaprCryptoProtos.SubtleDecryptResponse> responseObserver) SubtleDecryptAlpha1 decrypts a small message using a key stored in the vault.
-
subtleWrapKeyAlpha1
public void subtleWrapKeyAlpha1(DaprCryptoProtos.SubtleWrapKeyRequest request, io.grpc.stub.StreamObserver<DaprCryptoProtos.SubtleWrapKeyResponse> responseObserver) SubtleWrapKeyAlpha1 wraps a key using a key stored in the vault.
-
subtleUnwrapKeyAlpha1
public void subtleUnwrapKeyAlpha1(DaprCryptoProtos.SubtleUnwrapKeyRequest request, io.grpc.stub.StreamObserver<DaprCryptoProtos.SubtleUnwrapKeyResponse> responseObserver) SubtleUnwrapKeyAlpha1 unwraps a key using a key stored in the vault.
-
subtleSignAlpha1
public void subtleSignAlpha1(DaprCryptoProtos.SubtleSignRequest request, io.grpc.stub.StreamObserver<DaprCryptoProtos.SubtleSignResponse> responseObserver) SubtleSignAlpha1 signs a message using a key stored in the vault.
-
subtleVerifyAlpha1
public void subtleVerifyAlpha1(DaprCryptoProtos.SubtleVerifyRequest request, io.grpc.stub.StreamObserver<DaprCryptoProtos.SubtleVerifyResponse> responseObserver) SubtleVerifyAlpha1 verifies the signature of a message using a key stored in the vault.
-
startWorkflowAlpha1
@Deprecated public void startWorkflowAlpha1(DaprWorkflowProtos.StartWorkflowRequest request, io.grpc.stub.StreamObserver<DaprWorkflowProtos.StartWorkflowResponse> responseObserver) Deprecated.Starts a new instance of a workflow
-
getWorkflowAlpha1
@Deprecated public void getWorkflowAlpha1(DaprWorkflowProtos.GetWorkflowRequest request, io.grpc.stub.StreamObserver<DaprWorkflowProtos.GetWorkflowResponse> responseObserver) Deprecated.Gets details about a started workflow instance
-
purgeWorkflowAlpha1
@Deprecated public void purgeWorkflowAlpha1(DaprWorkflowProtos.PurgeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.Purge Workflow
-
terminateWorkflowAlpha1
@Deprecated public void terminateWorkflowAlpha1(DaprWorkflowProtos.TerminateWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.Terminates a running workflow instance
-
pauseWorkflowAlpha1
@Deprecated public void pauseWorkflowAlpha1(DaprWorkflowProtos.PauseWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.Pauses a running workflow instance
-
resumeWorkflowAlpha1
@Deprecated public void resumeWorkflowAlpha1(DaprWorkflowProtos.ResumeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.Resumes a paused workflow instance
-
raiseEventWorkflowAlpha1
@Deprecated public void raiseEventWorkflowAlpha1(DaprWorkflowProtos.RaiseEventWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.Raise an event to a running workflow instance
-
startWorkflowBeta1
public void startWorkflowBeta1(DaprWorkflowProtos.StartWorkflowRequest request, io.grpc.stub.StreamObserver<DaprWorkflowProtos.StartWorkflowResponse> responseObserver) Starts a new instance of a workflow
-
getWorkflowBeta1
public void getWorkflowBeta1(DaprWorkflowProtos.GetWorkflowRequest request, io.grpc.stub.StreamObserver<DaprWorkflowProtos.GetWorkflowResponse> responseObserver) Gets details about a started workflow instance
-
purgeWorkflowBeta1
public void purgeWorkflowBeta1(DaprWorkflowProtos.PurgeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Purge Workflow
-
terminateWorkflowBeta1
public void terminateWorkflowBeta1(DaprWorkflowProtos.TerminateWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Terminates a running workflow instance
-
pauseWorkflowBeta1
public void pauseWorkflowBeta1(DaprWorkflowProtos.PauseWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Pauses a running workflow instance
-
resumeWorkflowBeta1
public void resumeWorkflowBeta1(DaprWorkflowProtos.ResumeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Resumes a paused workflow instance
-
raiseEventWorkflowBeta1
public void raiseEventWorkflowBeta1(DaprWorkflowProtos.RaiseEventWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Raise an event to a running workflow instance
-
shutdown
public void shutdown(DaprProtos.ShutdownRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Shutdown the sidecar
-
scheduleJobAlpha1
@Deprecated public void scheduleJobAlpha1(DaprJobsProtos.ScheduleJobRequest request, io.grpc.stub.StreamObserver<DaprJobsProtos.ScheduleJobResponse> responseObserver) Deprecated.Deprecated: Create and schedule a job
-
scheduleJob
public void scheduleJob(DaprJobsProtos.ScheduleJobRequest request, io.grpc.stub.StreamObserver<DaprJobsProtos.ScheduleJobResponse> responseObserver) Create and schedule a job
-
getJobAlpha1
@Deprecated public void getJobAlpha1(DaprJobsProtos.GetJobRequest request, io.grpc.stub.StreamObserver<DaprJobsProtos.GetJobResponse> responseObserver) Deprecated.Deprecated: Gets a scheduled job
-
getJob
public void getJob(DaprJobsProtos.GetJobRequest request, io.grpc.stub.StreamObserver<DaprJobsProtos.GetJobResponse> responseObserver) Gets a scheduled job
-
deleteJobAlpha1
@Deprecated public void deleteJobAlpha1(DaprJobsProtos.DeleteJobRequest request, io.grpc.stub.StreamObserver<DaprJobsProtos.DeleteJobResponse> responseObserver) Deprecated.Deprecated: Delete a job
-
deleteJob
public void deleteJob(DaprJobsProtos.DeleteJobRequest request, io.grpc.stub.StreamObserver<DaprJobsProtos.DeleteJobResponse> responseObserver) Delete a job
-
deleteJobsByPrefixAlpha1
@Deprecated public void deleteJobsByPrefixAlpha1(DaprJobsProtos.DeleteJobsByPrefixRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprJobsProtos.DeleteJobsByPrefixResponseAlpha1> responseObserver) Deprecated.Deprecated: Delete jobs by name prefix
-
deleteJobsByPrefix
public void deleteJobsByPrefix(DaprJobsProtos.DeleteJobsByPrefixRequest request, io.grpc.stub.StreamObserver<DaprJobsProtos.DeleteJobsByPrefixResponse> responseObserver) Delete jobs by name prefix
-
listJobsAlpha1
@Deprecated public void listJobsAlpha1(DaprJobsProtos.ListJobsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprJobsProtos.ListJobsResponseAlpha1> responseObserver) Deprecated.Deprecated: List all jobs
-
listJobs
public void listJobs(DaprJobsProtos.ListJobsRequest request, io.grpc.stub.StreamObserver<DaprJobsProtos.ListJobsResponse> responseObserver) List all jobs
-
converseAlpha1
public void converseAlpha1(DaprAiProtos.ConversationRequest request, io.grpc.stub.StreamObserver<DaprAiProtos.ConversationResponse> responseObserver) Converse with a LLM service
-
converseAlpha2
public void converseAlpha2(DaprAiProtos.ConversationRequestAlpha2 request, io.grpc.stub.StreamObserver<DaprAiProtos.ConversationResponseAlpha2> responseObserver) Converse with a LLM service via alpha2 api
-
createIndexAlpha1
public void createIndexAlpha1(DaprSearchProtos.CreateIndexRequestAlpha1 request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Create an index.
-
getIndexAlpha1
public void getIndexAlpha1(DaprSearchProtos.GetIndexRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprSearchProtos.GetIndexResponseAlpha1> responseObserver) Get an index.
-
listIndexesAlpha1
public void listIndexesAlpha1(DaprSearchProtos.ListIndexesRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprSearchProtos.ListIndexesResponseAlpha1> responseObserver) List indexes.
-
deleteIndexAlpha1
public void deleteIndexAlpha1(DaprSearchProtos.DeleteIndexRequestAlpha1 request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Delete an index.
-
indexDocumentsAlpha1
public void indexDocumentsAlpha1(DaprSearchProtos.IndexDocumentsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprSearchProtos.IndexDocumentsResponseAlpha1> responseObserver) Index (keyed upsert) documents.
-
getDocumentsAlpha1
public void getDocumentsAlpha1(DaprSearchProtos.GetDocumentsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprSearchProtos.GetDocumentsResponseAlpha1> responseObserver) Get documents by ID.
-
deleteDocumentsAlpha1
public void deleteDocumentsAlpha1(DaprSearchProtos.DeleteDocumentsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprSearchProtos.DeleteDocumentsResponseAlpha1> responseObserver) Delete documents by ID.
-
searchAlpha1
public void searchAlpha1(DaprSearchProtos.SearchRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprSearchProtos.SearchResponseAlpha1> responseObserver) Search an index.
-
createCollectionAlpha1
public void createCollectionAlpha1(DaprVectorProtos.CreateCollectionRequestAlpha1 request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Create a collection.
-
getCollectionAlpha1
public void getCollectionAlpha1(DaprVectorProtos.GetCollectionRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprVectorProtos.GetCollectionResponseAlpha1> responseObserver) Get a collection.
-
listCollectionsAlpha1
public void listCollectionsAlpha1(DaprVectorProtos.ListCollectionsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprVectorProtos.ListCollectionsResponseAlpha1> responseObserver) List collections.
-
deleteCollectionAlpha1
public void deleteCollectionAlpha1(DaprVectorProtos.DeleteCollectionRequestAlpha1 request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Delete a collection.
-
upsertVectorsAlpha1
public void upsertVectorsAlpha1(DaprVectorProtos.UpsertVectorsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprVectorProtos.UpsertVectorsResponseAlpha1> responseObserver) Upsert (keyed) vectors.
-
deleteVectorsAlpha1
public void deleteVectorsAlpha1(DaprVectorProtos.DeleteVectorsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprVectorProtos.DeleteVectorsResponseAlpha1> responseObserver) Delete vectors by ID.
-
getVectorsAlpha1
public void getVectorsAlpha1(DaprVectorProtos.GetVectorsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprVectorProtos.GetVectorsResponseAlpha1> responseObserver) Get vectors by ID.
-
queryVectorsAlpha1
public void queryVectorsAlpha1(DaprVectorProtos.QueryVectorsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprVectorProtos.QueryVectorsResponseAlpha1> responseObserver) Query vectors.
-
batchQueryVectorsAlpha1
public void batchQueryVectorsAlpha1(DaprVectorProtos.BatchQueryVectorsRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprVectorProtos.BatchQueryVectorsResponseAlpha1> responseObserver) Issue multiple queries against the same collection, each succeeding or failing on its own.
-
setBinaryFileAlpha1
public io.grpc.stub.StreamObserver<DaprBinaryStoreProtos.SetBinaryFileRequestAlpha1> setBinaryFileAlpha1(io.grpc.stub.StreamObserver<DaprBinaryStoreProtos.SetBinaryFileResponseAlpha1> responseObserver) Stores a binary file using a streaming request. The first message must contain the options; subsequent messages carry the file content as chunks.
-
getBinaryFileAlpha1
public void getBinaryFileAlpha1(DaprBinaryStoreProtos.GetBinaryFileRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprBinaryStoreProtos.GetBinaryFileResponseAlpha1> responseObserver) Retrieves a binary file as a stream of chunks.
-
deleteBinaryFileAlpha1
public void deleteBinaryFileAlpha1(DaprBinaryStoreProtos.DeleteBinaryFileRequestAlpha1 request, io.grpc.stub.StreamObserver<DaprBinaryStoreProtos.DeleteBinaryFileResponseAlpha1> responseObserver) Deletes a binary file.
-