Package io.dapr.v1

Class DaprGrpc.DaprImplBase

java.lang.Object

io.dapr.v1.DaprGrpc.DaprImplBase

All Implemented Interfaces:

io.grpc.BindableService

Enclosing class:

DaprGrpc

public abstract static class DaprGrpc.DaprImplBase
extends java.lang.Object
implements io.grpc.BindableService

 Dapr service provides APIs to user application to access Dapr building blocks.
 

Constructor Summary

Constructors

Constructor	Description
DaprImplBase()

Method Summary

Modifier and Type	Method	Description
io.grpc.ServerServiceDefinition	bindService()
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
void	deleteState(DaprProtos.DeleteStateRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)	Deletes the state for a specific key.
void	executeActorStateTransaction(DaprProtos.ExecuteActorStateTransactionRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)	Executes state transactions for a specified actor
void	executeStateTransaction(DaprProtos.ExecuteStateTransactionRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)	Executes transactions for a specified store
void	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 secrets
void	getBulkState(DaprProtos.GetBulkStateRequest request, io.grpc.stub.StreamObserver<DaprProtos.GetBulkStateResponse> responseObserver)	Gets a bulk of state items for a list of keys
void	getMetadata(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<DaprProtos.GetMetadataResponse> responseObserver)	Gets metadata of the sidecar
void	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	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 bindings
void	invokeService(DaprProtos.InvokeServiceRequest request, io.grpc.stub.StreamObserver<CommonProtos.InvokeResponse> responseObserver)	Invokes a method on a remote Dapr app.
void	publishEvent(DaprProtos.PublishEventRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)	Publishes events to the specific topic.
void	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	saveState(DaprProtos.SaveStateRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)	Saves the state for a specific key.
void	setMetadata(DaprProtos.SetMetadataRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)	Sets value in extended metadata of the sidecar
void	shutdown(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)	Shutdown the sidecar
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DaprImplBase

public DaprImplBase()

Method Details

invokeService

public void invokeService(DaprProtos.InvokeServiceRequest request,
io.grpc.stub.StreamObserver<CommonProtos.InvokeResponse> responseObserver)

 Invokes a method on a remote Dapr app.
 

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.
 

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.
 

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.
 

getMetadata

public void getMetadata(com.google.protobuf.Empty 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
 

shutdown

public void shutdown(com.google.protobuf.Empty request,
io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

 Shutdown the sidecar
 

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService