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 TypeMethodDescriptionprotected DaprGrpc.DaprStubbuild(io.grpc.Channel channel, io.grpc.CallOptions callOptions) voidbulkPublishEventAlpha1(DaprProtos.BulkPublishRequest request, io.grpc.stub.StreamObserver<DaprProtos.BulkPublishResponse> responseObserver) Bulk Publishes multiple events to the specified topic.voidconverseAlpha1(DaprProtos.ConversationRequest request, io.grpc.stub.StreamObserver<DaprProtos.ConversationResponse> responseObserver) Converse with a LLM servicevoidconverseAlpha2(DaprProtos.ConversationRequestAlpha2 request, io.grpc.stub.StreamObserver<DaprProtos.ConversationResponseAlpha2> responseObserver) Converse with a LLM service via alpha2 apiio.grpc.stub.StreamObserver<DaprProtos.DecryptRequest>decryptAlpha1(io.grpc.stub.StreamObserver<DaprProtos.DecryptResponse> responseObserver) DecryptAlpha1 decrypts a message using the Dapr encryption scheme and a key stored in the vault.voiddeleteBulkState(DaprProtos.DeleteBulkStateRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deletes a bulk of state items for a list of keysvoiddeleteJobAlpha1(DaprProtos.DeleteJobRequest request, io.grpc.stub.StreamObserver<DaprProtos.DeleteJobResponse> responseObserver) Delete a jobvoiddeleteState(DaprProtos.DeleteStateRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deletes the state for a specific key.io.grpc.stub.StreamObserver<DaprProtos.EncryptRequest>encryptAlpha1(io.grpc.stub.StreamObserver<DaprProtos.EncryptResponse> responseObserver) EncryptAlpha1 encrypts a message using the Dapr encryption scheme and a key stored in the vault.voidexecuteActorStateTransaction(DaprProtos.ExecuteActorStateTransactionRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Executes state transactions for a specified actorvoidexecuteStateTransaction(DaprProtos.ExecuteStateTransactionRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Executes transactions for a specified storevoidgetActorState(DaprProtos.GetActorStateRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetActorStateResponse> responseObserver) Gets the state for a specific actor.voidgetBulkSecret(DaprProtos.GetBulkSecretRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetBulkSecretResponse> responseObserver) Gets a bulk of secretsvoidgetBulkState(DaprProtos.GetBulkStateRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetBulkStateResponse> responseObserver) Gets a bulk of state items for a list of keysvoidgetConfiguration(DaprProtos.GetConfigurationRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetConfigurationResponse> responseObserver) GetConfiguration gets configuration from configuration store.voidgetConfigurationAlpha1(DaprProtos.GetConfigurationRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetConfigurationResponse> responseObserver) GetConfiguration gets configuration from configuration store.voidgetJobAlpha1(DaprProtos.GetJobRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetJobResponse> responseObserver) Gets a scheduled jobvoidgetMetadata(DaprProtos.GetMetadataRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetMetadataResponse> responseObserver) Gets metadata of the sidecarvoidgetSecret(DaprProtos.GetSecretRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetSecretResponse> responseObserver) Gets secrets from secret stores.voidgetState(DaprProtos.GetStateRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetStateResponse> responseObserver) Gets the state for a specific key.voidgetWorkflowAlpha1(DaprProtos.GetWorkflowRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetWorkflowResponse> responseObserver) Deprecated.voidgetWorkflowBeta1(DaprProtos.GetWorkflowRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetWorkflowResponse> responseObserver) Gets details about a started workflow instancevoidinvokeActor(DaprProtos.InvokeActorRequest request, io.grpc.stub.StreamObserver<DaprProtos.InvokeActorResponse> responseObserver) InvokeActor calls a method on an actor.voidinvokeBinding(DaprProtos.InvokeBindingRequest request, io.grpc.stub.StreamObserver<DaprProtos.InvokeBindingResponse> responseObserver) Invokes binding data to specific output bindingsvoidinvokeService(DaprProtos.InvokeServiceRequest request, io.grpc.stub.StreamObserver<CommonProtos.InvokeResponse> responseObserver) Invokes a method on a remote Dapr app.voidpauseWorkflowAlpha1(DaprProtos.PauseWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.voidpauseWorkflowBeta1(DaprProtos.PauseWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Pauses a running workflow instancevoidpublishEvent(DaprProtos.PublishEventRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Publishes events to the specific topic.voidpurgeWorkflowAlpha1(DaprProtos.PurgeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.voidpurgeWorkflowBeta1(DaprProtos.PurgeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Purge WorkflowvoidqueryStateAlpha1(DaprProtos.QueryStateRequest request, io.grpc.stub.StreamObserver<DaprProtos.QueryStateResponse> responseObserver) Queries the state.voidraiseEventWorkflowAlpha1(DaprProtos.RaiseEventWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.voidraiseEventWorkflowBeta1(DaprProtos.RaiseEventWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Raise an event to a running workflow instancevoidregisterActorReminder(DaprProtos.RegisterActorReminderRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Register an actor reminder.voidregisterActorTimer(DaprProtos.RegisterActorTimerRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Register an actor timer.voidresumeWorkflowAlpha1(DaprProtos.ResumeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.voidresumeWorkflowBeta1(DaprProtos.ResumeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Resumes a paused workflow instancevoidsaveState(DaprProtos.SaveStateRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Saves the state for a specific key.voidscheduleJobAlpha1(DaprProtos.ScheduleJobRequest request, io.grpc.stub.StreamObserver<DaprProtos.ScheduleJobResponse> responseObserver) Create and schedule a jobvoidsetMetadata(DaprProtos.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(DaprProtos.StartWorkflowRequest request, io.grpc.stub.StreamObserver<DaprProtos.StartWorkflowResponse> responseObserver) Deprecated.voidstartWorkflowBeta1(DaprProtos.StartWorkflowRequest request, io.grpc.stub.StreamObserver<DaprProtos.StartWorkflowResponse> responseObserver) Starts a new instance of a workflowvoidsubscribeConfiguration(DaprProtos.SubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubscribeConfigurationResponse> responseObserver) SubscribeConfiguration gets configuration from configuration store and subscribe the updates event by grpc streamvoidsubscribeConfigurationAlpha1(DaprProtos.SubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubscribeConfigurationResponse> responseObserver) SubscribeConfiguration gets configuration from configuration store and subscribe the updates event by grpc streamio.grpc.stub.StreamObserver<DaprProtos.SubscribeTopicEventsRequestAlpha1>subscribeTopicEventsAlpha1(io.grpc.stub.StreamObserver<DaprProtos.SubscribeTopicEventsResponseAlpha1> responseObserver) SubscribeTopicEventsAlpha1 subscribes to a PubSub topic and receives topic events from it.voidsubtleDecryptAlpha1(DaprProtos.SubtleDecryptRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleDecryptResponse> responseObserver) SubtleDecryptAlpha1 decrypts a small message using a key stored in the vault.voidsubtleEncryptAlpha1(DaprProtos.SubtleEncryptRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleEncryptResponse> responseObserver) SubtleEncryptAlpha1 encrypts a small message using a key stored in the vault.voidsubtleGetKeyAlpha1(DaprProtos.SubtleGetKeyRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleGetKeyResponse> responseObserver) SubtleGetKeyAlpha1 returns the public part of an asymmetric key stored in the vault.voidsubtleSignAlpha1(DaprProtos.SubtleSignRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleSignResponse> responseObserver) SubtleSignAlpha1 signs a message using a key stored in the vault.voidsubtleUnwrapKeyAlpha1(DaprProtos.SubtleUnwrapKeyRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleUnwrapKeyResponse> responseObserver) SubtleUnwrapKeyAlpha1 unwraps a key using a key stored in the vault.voidsubtleVerifyAlpha1(DaprProtos.SubtleVerifyRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleVerifyResponse> responseObserver) SubtleVerifyAlpha1 verifies the signature of a message using a key stored in the vault.voidsubtleWrapKeyAlpha1(DaprProtos.SubtleWrapKeyRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleWrapKeyResponse> responseObserver) SubtleWrapKeyAlpha1 wraps a key using a key stored in the vault.voidterminateWorkflowAlpha1(DaprProtos.TerminateWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.voidterminateWorkflowBeta1(DaprProtos.TerminateWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Terminates a running workflow instancevoidtryLockAlpha1(DaprProtos.TryLockRequest request, io.grpc.stub.StreamObserver<DaprProtos.TryLockResponse> responseObserver) TryLockAlpha1 tries to get a lock with an expiry.voidunlockAlpha1(DaprProtos.UnlockRequest request, io.grpc.stub.StreamObserver<DaprProtos.UnlockResponse> responseObserver) UnlockAlpha1 unlocks a lock.voidunregisterActorReminder(DaprProtos.UnregisterActorReminderRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Unregister an actor reminder.voidunregisterActorTimer(DaprProtos.UnregisterActorTimerRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Unregister an actor timer.voidunsubscribeConfiguration(DaprProtos.UnsubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprProtos.UnsubscribeConfigurationResponse> responseObserver) UnSubscribeConfiguration unsubscribe the subscription of configurationvoidunsubscribeConfigurationAlpha1(DaprProtos.UnsubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprProtos.UnsubscribeConfigurationResponse> responseObserver) UnSubscribeConfiguration unsubscribe the subscription of configurationMethods 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(DaprProtos.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(DaprProtos.GetStateRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetStateResponse> responseObserver) Gets the state for a specific key.
-
getBulkState
public void getBulkState(DaprProtos.GetBulkStateRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetBulkStateResponse> responseObserver) Gets a bulk of state items for a list of keys
-
saveState
public void saveState(DaprProtos.SaveStateRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Saves the state for a specific key.
-
queryStateAlpha1
public void queryStateAlpha1(DaprProtos.QueryStateRequest request, io.grpc.stub.StreamObserver<DaprProtos.QueryStateResponse> responseObserver) Queries the state.
-
deleteState
public void deleteState(DaprProtos.DeleteStateRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deletes the state for a specific key.
-
deleteBulkState
public void deleteBulkState(DaprProtos.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(DaprProtos.ExecuteStateTransactionRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Executes transactions for a specified store
-
publishEvent
public void publishEvent(DaprProtos.PublishEventRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Publishes events to the specific topic.
-
bulkPublishEventAlpha1
public void bulkPublishEventAlpha1(DaprProtos.BulkPublishRequest request, io.grpc.stub.StreamObserver<DaprProtos.BulkPublishResponse> responseObserver) Bulk Publishes multiple events to the specified topic.
-
subscribeTopicEventsAlpha1
public io.grpc.stub.StreamObserver<DaprProtos.SubscribeTopicEventsRequestAlpha1> subscribeTopicEventsAlpha1(io.grpc.stub.StreamObserver<DaprProtos.SubscribeTopicEventsResponseAlpha1> responseObserver) SubscribeTopicEventsAlpha1 subscribes to a PubSub topic and receives topic events from it.
-
invokeBinding
public void invokeBinding(DaprProtos.InvokeBindingRequest request, io.grpc.stub.StreamObserver<DaprProtos.InvokeBindingResponse> responseObserver) Invokes binding data to specific output bindings
-
getSecret
public void getSecret(DaprProtos.GetSecretRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetSecretResponse> responseObserver) Gets secrets from secret stores.
-
getBulkSecret
public void getBulkSecret(DaprProtos.GetBulkSecretRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetBulkSecretResponse> responseObserver) Gets a bulk of secrets
-
registerActorTimer
public void registerActorTimer(DaprProtos.RegisterActorTimerRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Register an actor timer.
-
unregisterActorTimer
public void unregisterActorTimer(DaprProtos.UnregisterActorTimerRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Unregister an actor timer.
-
registerActorReminder
public void registerActorReminder(DaprProtos.RegisterActorReminderRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Register an actor reminder.
-
unregisterActorReminder
public void unregisterActorReminder(DaprProtos.UnregisterActorReminderRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Unregister an actor reminder.
-
getActorState
public void getActorState(DaprProtos.GetActorStateRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetActorStateResponse> responseObserver) Gets the state for a specific actor.
-
executeActorStateTransaction
public void executeActorStateTransaction(DaprProtos.ExecuteActorStateTransactionRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Executes state transactions for a specified actor
-
invokeActor
public void invokeActor(DaprProtos.InvokeActorRequest request, io.grpc.stub.StreamObserver<DaprProtos.InvokeActorResponse> responseObserver) InvokeActor calls a method on an actor.
-
getConfigurationAlpha1
public void getConfigurationAlpha1(DaprProtos.GetConfigurationRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetConfigurationResponse> responseObserver) GetConfiguration gets configuration from configuration store.
-
getConfiguration
public void getConfiguration(DaprProtos.GetConfigurationRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetConfigurationResponse> responseObserver) GetConfiguration gets configuration from configuration store.
-
subscribeConfigurationAlpha1
public void subscribeConfigurationAlpha1(DaprProtos.SubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubscribeConfigurationResponse> responseObserver) SubscribeConfiguration gets configuration from configuration store and subscribe the updates event by grpc stream
-
subscribeConfiguration
public void subscribeConfiguration(DaprProtos.SubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubscribeConfigurationResponse> responseObserver) SubscribeConfiguration gets configuration from configuration store and subscribe the updates event by grpc stream
-
unsubscribeConfigurationAlpha1
public void unsubscribeConfigurationAlpha1(DaprProtos.UnsubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprProtos.UnsubscribeConfigurationResponse> responseObserver) UnSubscribeConfiguration unsubscribe the subscription of configuration
-
unsubscribeConfiguration
public void unsubscribeConfiguration(DaprProtos.UnsubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprProtos.UnsubscribeConfigurationResponse> responseObserver) UnSubscribeConfiguration unsubscribe the subscription of configuration
-
tryLockAlpha1
public void tryLockAlpha1(DaprProtos.TryLockRequest request, io.grpc.stub.StreamObserver<DaprProtos.TryLockResponse> responseObserver) TryLockAlpha1 tries to get a lock with an expiry.
-
unlockAlpha1
public void unlockAlpha1(DaprProtos.UnlockRequest request, io.grpc.stub.StreamObserver<DaprProtos.UnlockResponse> responseObserver) UnlockAlpha1 unlocks a lock.
-
encryptAlpha1
public io.grpc.stub.StreamObserver<DaprProtos.EncryptRequest> encryptAlpha1(io.grpc.stub.StreamObserver<DaprProtos.EncryptResponse> responseObserver) EncryptAlpha1 encrypts a message using the Dapr encryption scheme and a key stored in the vault.
-
decryptAlpha1
public io.grpc.stub.StreamObserver<DaprProtos.DecryptRequest> decryptAlpha1(io.grpc.stub.StreamObserver<DaprProtos.DecryptResponse> responseObserver) DecryptAlpha1 decrypts a message using the Dapr encryption scheme and a key stored in the vault.
-
getMetadata
public void getMetadata(DaprProtos.GetMetadataRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetMetadataResponse> responseObserver) Gets metadata of the sidecar
-
setMetadata
public void setMetadata(DaprProtos.SetMetadataRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Sets value in extended metadata of the sidecar
-
subtleGetKeyAlpha1
public void subtleGetKeyAlpha1(DaprProtos.SubtleGetKeyRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleGetKeyResponse> responseObserver) SubtleGetKeyAlpha1 returns the public part of an asymmetric key stored in the vault.
-
subtleEncryptAlpha1
public void subtleEncryptAlpha1(DaprProtos.SubtleEncryptRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleEncryptResponse> responseObserver) SubtleEncryptAlpha1 encrypts a small message using a key stored in the vault.
-
subtleDecryptAlpha1
public void subtleDecryptAlpha1(DaprProtos.SubtleDecryptRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleDecryptResponse> responseObserver) SubtleDecryptAlpha1 decrypts a small message using a key stored in the vault.
-
subtleWrapKeyAlpha1
public void subtleWrapKeyAlpha1(DaprProtos.SubtleWrapKeyRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleWrapKeyResponse> responseObserver) SubtleWrapKeyAlpha1 wraps a key using a key stored in the vault.
-
subtleUnwrapKeyAlpha1
public void subtleUnwrapKeyAlpha1(DaprProtos.SubtleUnwrapKeyRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleUnwrapKeyResponse> responseObserver) SubtleUnwrapKeyAlpha1 unwraps a key using a key stored in the vault.
-
subtleSignAlpha1
public void subtleSignAlpha1(DaprProtos.SubtleSignRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleSignResponse> responseObserver) SubtleSignAlpha1 signs a message using a key stored in the vault.
-
subtleVerifyAlpha1
public void subtleVerifyAlpha1(DaprProtos.SubtleVerifyRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleVerifyResponse> responseObserver) SubtleVerifyAlpha1 verifies the signature of a message using a key stored in the vault.
-
startWorkflowAlpha1
@Deprecated public void startWorkflowAlpha1(DaprProtos.StartWorkflowRequest request, io.grpc.stub.StreamObserver<DaprProtos.StartWorkflowResponse> responseObserver) Deprecated.Starts a new instance of a workflow
-
getWorkflowAlpha1
@Deprecated public void getWorkflowAlpha1(DaprProtos.GetWorkflowRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetWorkflowResponse> responseObserver) Deprecated.Gets details about a started workflow instance
-
purgeWorkflowAlpha1
@Deprecated public void purgeWorkflowAlpha1(DaprProtos.PurgeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.Purge Workflow
-
terminateWorkflowAlpha1
@Deprecated public void terminateWorkflowAlpha1(DaprProtos.TerminateWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.Terminates a running workflow instance
-
pauseWorkflowAlpha1
@Deprecated public void pauseWorkflowAlpha1(DaprProtos.PauseWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.Pauses a running workflow instance
-
resumeWorkflowAlpha1
@Deprecated public void resumeWorkflowAlpha1(DaprProtos.ResumeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.Resumes a paused workflow instance
-
raiseEventWorkflowAlpha1
@Deprecated public void raiseEventWorkflowAlpha1(DaprProtos.RaiseEventWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deprecated.Raise an event to a running workflow instance
-
startWorkflowBeta1
public void startWorkflowBeta1(DaprProtos.StartWorkflowRequest request, io.grpc.stub.StreamObserver<DaprProtos.StartWorkflowResponse> responseObserver) Starts a new instance of a workflow
-
getWorkflowBeta1
public void getWorkflowBeta1(DaprProtos.GetWorkflowRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetWorkflowResponse> responseObserver) Gets details about a started workflow instance
-
purgeWorkflowBeta1
public void purgeWorkflowBeta1(DaprProtos.PurgeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Purge Workflow
-
terminateWorkflowBeta1
public void terminateWorkflowBeta1(DaprProtos.TerminateWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Terminates a running workflow instance
-
pauseWorkflowBeta1
public void pauseWorkflowBeta1(DaprProtos.PauseWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Pauses a running workflow instance
-
resumeWorkflowBeta1
public void resumeWorkflowBeta1(DaprProtos.ResumeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Resumes a paused workflow instance
-
raiseEventWorkflowBeta1
public void raiseEventWorkflowBeta1(DaprProtos.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
public void scheduleJobAlpha1(DaprProtos.ScheduleJobRequest request, io.grpc.stub.StreamObserver<DaprProtos.ScheduleJobResponse> responseObserver) Create and schedule a job
-
getJobAlpha1
public void getJobAlpha1(DaprProtos.GetJobRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetJobResponse> responseObserver) Gets a scheduled job
-
deleteJobAlpha1
public void deleteJobAlpha1(DaprProtos.DeleteJobRequest request, io.grpc.stub.StreamObserver<DaprProtos.DeleteJobResponse> responseObserver) Delete a job
-
converseAlpha1
public void converseAlpha1(DaprProtos.ConversationRequest request, io.grpc.stub.StreamObserver<DaprProtos.ConversationResponse> responseObserver) Converse with a LLM service
-
converseAlpha2
public void converseAlpha2(DaprProtos.ConversationRequestAlpha2 request, io.grpc.stub.StreamObserver<DaprProtos.ConversationResponseAlpha2> responseObserver) Converse with a LLM service via alpha2 api
-