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.DaprStub
build
(io.grpc.Channel channel, io.grpc.CallOptions callOptions) void
bulkPublishEventAlpha1
(DaprProtos.BulkPublishRequest request, io.grpc.stub.StreamObserver<DaprProtos.BulkPublishResponse> responseObserver) Bulk Publishes multiple events to the specified topic.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.void
deleteBulkState
(DaprProtos.DeleteBulkStateRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Deletes a bulk of state items for a list of keysvoid
deleteJobAlpha1
(DaprProtos.DeleteJobRequest request, io.grpc.stub.StreamObserver<DaprProtos.DeleteJobResponse> responseObserver) Delete a jobvoid
deleteState
(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.void
executeActorStateTransaction
(DaprProtos.ExecuteActorStateTransactionRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Executes state transactions for a specified actorvoid
executeStateTransaction
(DaprProtos.ExecuteStateTransactionRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Executes transactions for a specified storevoid
getActorState
(DaprProtos.GetActorStateRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetActorStateResponse> responseObserver) Gets the state for a specific actor.void
getBulkSecret
(DaprProtos.GetBulkSecretRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetBulkSecretResponse> responseObserver) Gets a bulk of secretsvoid
getBulkState
(DaprProtos.GetBulkStateRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetBulkStateResponse> responseObserver) Gets a bulk of state items for a list of keysvoid
getConfiguration
(DaprProtos.GetConfigurationRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetConfigurationResponse> responseObserver) GetConfiguration gets configuration from configuration store.void
getConfigurationAlpha1
(DaprProtos.GetConfigurationRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetConfigurationResponse> responseObserver) GetConfiguration gets configuration from configuration store.void
getJobAlpha1
(DaprProtos.GetJobRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetJobResponse> responseObserver) Gets a scheduled jobvoid
getMetadata
(DaprProtos.GetMetadataRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetMetadataResponse> responseObserver) Gets metadata of the sidecarvoid
getSecret
(DaprProtos.GetSecretRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetSecretResponse> responseObserver) Gets secrets from secret stores.void
getState
(DaprProtos.GetStateRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetStateResponse> responseObserver) Gets the state for a specific key.void
getWorkflowAlpha1
(DaprProtos.GetWorkflowRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetWorkflowResponse> responseObserver) Gets details about a started workflow instancevoid
getWorkflowBeta1
(DaprProtos.GetWorkflowRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetWorkflowResponse> responseObserver) Gets details about a started workflow instancevoid
invokeActor
(DaprProtos.InvokeActorRequest request, io.grpc.stub.StreamObserver<DaprProtos.InvokeActorResponse> responseObserver) InvokeActor calls a method on an actor.void
invokeBinding
(DaprProtos.InvokeBindingRequest request, io.grpc.stub.StreamObserver<DaprProtos.InvokeBindingResponse> responseObserver) Invokes binding data to specific output bindingsvoid
invokeService
(DaprProtos.InvokeServiceRequest request, io.grpc.stub.StreamObserver<CommonProtos.InvokeResponse> responseObserver) Invokes a method on a remote Dapr app.void
pauseWorkflowAlpha1
(DaprProtos.PauseWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Pauses a running workflow instancevoid
pauseWorkflowBeta1
(DaprProtos.PauseWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Pauses a running workflow instancevoid
publishEvent
(DaprProtos.PublishEventRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Publishes events to the specific topic.void
purgeWorkflowAlpha1
(DaprProtos.PurgeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Purge Workflowvoid
purgeWorkflowBeta1
(DaprProtos.PurgeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Purge Workflowvoid
queryStateAlpha1
(DaprProtos.QueryStateRequest request, io.grpc.stub.StreamObserver<DaprProtos.QueryStateResponse> responseObserver) Queries the state.void
raiseEventWorkflowAlpha1
(DaprProtos.RaiseEventWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Raise an event to a running workflow instancevoid
raiseEventWorkflowBeta1
(DaprProtos.RaiseEventWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Raise an event to a running workflow instancevoid
registerActorReminder
(DaprProtos.RegisterActorReminderRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Register an actor reminder.void
registerActorTimer
(DaprProtos.RegisterActorTimerRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Register an actor timer.void
resumeWorkflowAlpha1
(DaprProtos.ResumeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Resumes a paused workflow instancevoid
resumeWorkflowBeta1
(DaprProtos.ResumeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Resumes a paused workflow instancevoid
saveState
(DaprProtos.SaveStateRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Saves the state for a specific key.void
scheduleJobAlpha1
(DaprProtos.ScheduleJobRequest request, io.grpc.stub.StreamObserver<DaprProtos.ScheduleJobResponse> responseObserver) Create and schedule a jobvoid
setMetadata
(DaprProtos.SetMetadataRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Sets value in extended metadata of the sidecarvoid
shutdown
(DaprProtos.ShutdownRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Shutdown the sidecarvoid
startWorkflowAlpha1
(DaprProtos.StartWorkflowRequest request, io.grpc.stub.StreamObserver<DaprProtos.StartWorkflowResponse> responseObserver) Starts a new instance of a workflowvoid
startWorkflowBeta1
(DaprProtos.StartWorkflowRequest request, io.grpc.stub.StreamObserver<DaprProtos.StartWorkflowResponse> responseObserver) Starts a new instance of a workflowvoid
subscribeConfiguration
(DaprProtos.SubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubscribeConfigurationResponse> responseObserver) SubscribeConfiguration gets configuration from configuration store and subscribe the updates event by grpc streamvoid
subscribeConfigurationAlpha1
(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<DaprAppCallbackProtos.TopicEventRequest> responseObserver) SubscribeTopicEventsAlpha1 subscribes to a PubSub topic and receives topic events from it.void
subtleDecryptAlpha1
(DaprProtos.SubtleDecryptRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleDecryptResponse> responseObserver) SubtleDecryptAlpha1 decrypts a small message using a key stored in the vault.void
subtleEncryptAlpha1
(DaprProtos.SubtleEncryptRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleEncryptResponse> responseObserver) SubtleEncryptAlpha1 encrypts a small message using a key stored in the vault.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.void
subtleSignAlpha1
(DaprProtos.SubtleSignRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleSignResponse> responseObserver) SubtleSignAlpha1 signs a message using a key stored in the vault.void
subtleUnwrapKeyAlpha1
(DaprProtos.SubtleUnwrapKeyRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleUnwrapKeyResponse> responseObserver) SubtleUnwrapKeyAlpha1 unwraps a key using a key stored in the vault.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.void
subtleWrapKeyAlpha1
(DaprProtos.SubtleWrapKeyRequest request, io.grpc.stub.StreamObserver<DaprProtos.SubtleWrapKeyResponse> responseObserver) SubtleWrapKeyAlpha1 wraps a key using a key stored in the vault.void
terminateWorkflowAlpha1
(DaprProtos.TerminateWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Terminates a running workflow instancevoid
terminateWorkflowBeta1
(DaprProtos.TerminateWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Terminates a running workflow instancevoid
tryLockAlpha1
(DaprProtos.TryLockRequest request, io.grpc.stub.StreamObserver<DaprProtos.TryLockResponse> responseObserver) TryLockAlpha1 tries to get a lock with an expiry.void
unlockAlpha1
(DaprProtos.UnlockRequest request, io.grpc.stub.StreamObserver<DaprProtos.UnlockResponse> responseObserver) UnlockAlpha1 unlocks a lock.void
unregisterActorReminder
(DaprProtos.UnregisterActorReminderRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Unregister an actor reminder.void
unregisterActorTimer
(DaprProtos.UnregisterActorTimerRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Unregister an actor timer.void
unsubscribeConfiguration
(DaprProtos.UnsubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprProtos.UnsubscribeConfigurationResponse> responseObserver) UnSubscribeConfiguration unsubscribe the subscription of configurationvoid
unsubscribeConfigurationAlpha1
(DaprProtos.UnsubscribeConfigurationRequest request, io.grpc.stub.StreamObserver<DaprProtos.UnsubscribeConfigurationResponse> responseObserver) UnSubscribeConfiguration unsubscribe the subscription of configurationMethods inherited from class io.grpc.stub.AbstractAsyncStub
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.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<DaprAppCallbackProtos.TopicEventRequest> 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
public void startWorkflowAlpha1(DaprProtos.StartWorkflowRequest request, io.grpc.stub.StreamObserver<DaprProtos.StartWorkflowResponse> responseObserver) Starts a new instance of a workflow
-
getWorkflowAlpha1
public void getWorkflowAlpha1(DaprProtos.GetWorkflowRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetWorkflowResponse> responseObserver) Gets details about a started workflow instance
-
purgeWorkflowAlpha1
public void purgeWorkflowAlpha1(DaprProtos.PurgeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Purge Workflow
-
terminateWorkflowAlpha1
public void terminateWorkflowAlpha1(DaprProtos.TerminateWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Terminates a running workflow instance
-
pauseWorkflowAlpha1
public void pauseWorkflowAlpha1(DaprProtos.PauseWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Pauses a running workflow instance
-
resumeWorkflowAlpha1
public void resumeWorkflowAlpha1(DaprProtos.ResumeWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) Resumes a paused workflow instance
-
raiseEventWorkflowAlpha1
public void raiseEventWorkflowAlpha1(DaprProtos.RaiseEventWorkflowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) 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
-