Package io.dapr.client
Interface DaprClient
- All Superinterfaces:
java.lang.AutoCloseable
,java.io.Closeable
- All Known Implementing Classes:
DaprClientGrpc
,DaprClientHttp
public interface DaprClient
extends java.io.Closeable
Generic Client Adapter to be used regardless of the GRPC or the HTTP Client implementation required.
-
Method Summary
Modifier and Type Method Description reactor.core.publisher.Mono<Response<java.lang.Void>>
deleteState(DeleteStateRequest request)
Delete a state.reactor.core.publisher.Mono<java.lang.Void>
deleteState(java.lang.String stateStoreName, java.lang.String key)
Delete a state.reactor.core.publisher.Mono<java.lang.Void>
deleteState(java.lang.String stateStoreName, java.lang.String key, java.lang.String etag, StateOptions options)
Delete a state.reactor.core.publisher.Mono<Response<java.lang.Void>>
executeTransaction(ExecuteStateTransactionRequest request)
Execute a transaction.reactor.core.publisher.Mono<java.lang.Void>
executeTransaction(java.lang.String stateStoreName, java.util.List<TransactionalStateOperation<?>> operations)
Execute a transaction.reactor.core.publisher.Mono<Response<java.util.Map<java.lang.String,java.lang.String>>>
getSecret(GetSecretRequest request)
Fetches a secret from the configured vault.reactor.core.publisher.Mono<java.util.Map<java.lang.String,java.lang.String>>
getSecret(java.lang.String secretStoreName, java.lang.String secretName)
Fetches a secret from the configured vault.reactor.core.publisher.Mono<java.util.Map<java.lang.String,java.lang.String>>
getSecret(java.lang.String secretStoreName, java.lang.String secretName, java.util.Map<java.lang.String,java.lang.String> metadata)
Fetches a secret from the configured vault.<T> reactor.core.publisher.Mono<Response<State<T>>>
getState(GetStateRequest request, TypeRef<T> type)
Retrieve a State based on their key.<T> reactor.core.publisher.Mono<State<T>>
getState(java.lang.String stateStoreName, State<T> state, TypeRef<T> type)
Retrieve a State based on their key.<T> reactor.core.publisher.Mono<State<T>>
getState(java.lang.String stateStoreName, State<T> state, java.lang.Class<T> clazz)
Retrieve a State based on their key.<T> reactor.core.publisher.Mono<State<T>>
getState(java.lang.String stateStoreName, java.lang.String key, TypeRef<T> type)
Retrieve a State based on their key.<T> reactor.core.publisher.Mono<State<T>>
getState(java.lang.String stateStoreName, java.lang.String key, java.lang.Class<T> clazz)
Retrieve a State based on their key.<T> reactor.core.publisher.Mono<State<T>>
getState(java.lang.String stateStoreName, java.lang.String key, java.lang.String etag, StateOptions options, TypeRef<T> type)
Retrieve a State based on their key.<T> reactor.core.publisher.Mono<State<T>>
getState(java.lang.String stateStoreName, java.lang.String key, java.lang.String etag, StateOptions options, java.lang.Class<T> clazz)
Retrieve a State based on their key.<T> reactor.core.publisher.Mono<Response<java.util.List<State<T>>>>
getStates(GetStatesRequest request, TypeRef<T> type)
Retrieve bulk States based on their keys.<T> reactor.core.publisher.Mono<java.util.List<State<T>>>
getStates(java.lang.String stateStoreName, java.util.List<java.lang.String> keys, TypeRef<T> type)
Retrieve bulk States based on their keys.<T> reactor.core.publisher.Mono<java.util.List<State<T>>>
getStates(java.lang.String stateStoreName, java.util.List<java.lang.String> keys, java.lang.Class<T> clazz)
Retrieve bulk States based on their keys.<T> reactor.core.publisher.Mono<Response<T>>
invokeBinding(InvokeBindingRequest request, TypeRef<T> type)
Invokes a Binding operation.reactor.core.publisher.Mono<byte[]>
invokeBinding(java.lang.String name, java.lang.String operation, byte[] data, java.util.Map<java.lang.String,java.lang.String> metadata)
Invokes a Binding operation, skipping serialization.reactor.core.publisher.Mono<java.lang.Void>
invokeBinding(java.lang.String name, java.lang.String operation, java.lang.Object data)
Invokes a Binding operation.<T> reactor.core.publisher.Mono<T>
invokeBinding(java.lang.String name, java.lang.String operation, java.lang.Object data, TypeRef<T> type)
Invokes a Binding operation.<T> reactor.core.publisher.Mono<T>
invokeBinding(java.lang.String name, java.lang.String operation, java.lang.Object data, java.lang.Class<T> clazz)
Invokes a Binding operation.<T> reactor.core.publisher.Mono<T>
invokeBinding(java.lang.String name, java.lang.String operation, java.lang.Object data, java.util.Map<java.lang.String,java.lang.String> metadata, TypeRef<T> type)
Invokes a Binding operation.<T> reactor.core.publisher.Mono<T>
invokeBinding(java.lang.String name, java.lang.String operation, java.lang.Object data, java.util.Map<java.lang.String,java.lang.String> metadata, java.lang.Class<T> clazz)
Invokes a Binding operation.<T> reactor.core.publisher.Mono<Response<T>>
invokeService(InvokeServiceRequest invokeServiceRequest, TypeRef<T> type)
Invoke a service method.reactor.core.publisher.Mono<byte[]>
invokeService(java.lang.String appId, java.lang.String method, byte[] request, HttpExtension httpExtension, java.util.Map<java.lang.String,java.lang.String> metadata)
Invoke a service method, without using serialization.reactor.core.publisher.Mono<java.lang.Void>
invokeService(java.lang.String appId, java.lang.String method, HttpExtension httpExtension, java.util.Map<java.lang.String,java.lang.String> metadata)
Invoke a service method, using serialization.<T> reactor.core.publisher.Mono<T>
invokeService(java.lang.String appId, java.lang.String method, HttpExtension httpExtension, java.util.Map<java.lang.String,java.lang.String> metadata, TypeRef<T> type)
Invoke a service method, using serialization.<T> reactor.core.publisher.Mono<T>
invokeService(java.lang.String appId, java.lang.String method, HttpExtension httpExtension, java.util.Map<java.lang.String,java.lang.String> metadata, java.lang.Class<T> clazz)
Invoke a service method, using serialization.reactor.core.publisher.Mono<java.lang.Void>
invokeService(java.lang.String appId, java.lang.String method, java.lang.Object request, HttpExtension httpExtension)
Invoke a service method, using serialization.<T> reactor.core.publisher.Mono<T>
invokeService(java.lang.String appId, java.lang.String method, java.lang.Object request, HttpExtension httpExtension, TypeRef<T> type)
Invoke a service method, using serialization.<T> reactor.core.publisher.Mono<T>
invokeService(java.lang.String appId, java.lang.String method, java.lang.Object request, HttpExtension httpExtension, java.lang.Class<T> clazz)
Invoke a service method, using serialization.reactor.core.publisher.Mono<java.lang.Void>
invokeService(java.lang.String appId, java.lang.String method, java.lang.Object request, HttpExtension httpExtension, java.util.Map<java.lang.String,java.lang.String> metadata)
Invoke a service method, using serialization.<T> reactor.core.publisher.Mono<T>
invokeService(java.lang.String appId, java.lang.String method, java.lang.Object request, HttpExtension httpExtension, java.util.Map<java.lang.String,java.lang.String> metadata, TypeRef<T> type)
Invoke a service method, using serialization.<T> reactor.core.publisher.Mono<T>
invokeService(java.lang.String appId, java.lang.String method, java.lang.Object request, HttpExtension httpExtension, java.util.Map<java.lang.String,java.lang.String> metadata, java.lang.Class<T> clazz)
Invoke a service method, using serialization.reactor.core.publisher.Mono<Response<java.lang.Void>>
publishEvent(PublishEventRequest request)
Publish an event.reactor.core.publisher.Mono<java.lang.Void>
publishEvent(java.lang.String pubsubName, java.lang.String topic, java.lang.Object data)
Publish an event.reactor.core.publisher.Mono<java.lang.Void>
publishEvent(java.lang.String pubsubName, java.lang.String topic, java.lang.Object data, java.util.Map<java.lang.String,java.lang.String> metadata)
Publish an event.reactor.core.publisher.Mono<java.lang.Void>
saveState(java.lang.String stateStoreName, java.lang.String key, java.lang.Object value)
Save/Update a state.reactor.core.publisher.Mono<java.lang.Void>
saveState(java.lang.String stateStoreName, java.lang.String key, java.lang.String etag, java.lang.Object value, StateOptions options)
Save/Update a state.reactor.core.publisher.Mono<Response<java.lang.Void>>
saveStates(SaveStateRequest request)
Save/Update a list of states.reactor.core.publisher.Mono<java.lang.Void>
saveStates(java.lang.String stateStoreName, java.util.List<State<?>> states)
Save/Update a list of states.
-
Method Details
-
publishEvent
reactor.core.publisher.Mono<java.lang.Void> publishEvent(java.lang.String pubsubName, java.lang.String topic, java.lang.Object data)Publish an event.- Parameters:
pubsubName
- the pubsub name we will publish the event totopic
- the topic where the event will be published.data
- the event's data to be published, use byte[] for skipping serialization.- Returns:
- a Mono plan of type Void.
-
publishEvent
reactor.core.publisher.Mono<java.lang.Void> publishEvent(java.lang.String pubsubName, java.lang.String topic, java.lang.Object data, java.util.Map<java.lang.String,java.lang.String> metadata)Publish an event.- Parameters:
pubsubName
- the pubsub name we will publish the event totopic
- the topic where the event will be published.data
- the event's data to be published, use byte[] for skipping serialization.metadata
- The metadata for the published event.- Returns:
- a Mono plan of type Void.
-
publishEvent
Publish an event.- Parameters:
request
- the request for the publish event.- Returns:
- a Mono plan of a Dapr's void response.
-
invokeService
<T> reactor.core.publisher.Mono<T> invokeService(java.lang.String appId, java.lang.String method, java.lang.Object request, HttpExtension httpExtension, java.util.Map<java.lang.String,java.lang.String> metadata, TypeRef<T> type)Invoke a service method, using serialization.- Type Parameters:
T
- The Type of the return, use byte[] to skip serialization.- Parameters:
appId
- The Application ID where the service is.method
- The actual Method to be call in the application.request
- The request to be sent to invoke the service, use byte[] to skip serialization.httpExtension
- Additional fields that are needed if the receiving app is listening on HTTP,HttpExtension.NONE
otherwise.metadata
- Metadata (in GRPC) or headers (in HTTP) to be sent in request.type
- The Type needed as return for the call.- Returns:
- A Mono Plan of type T.
-
invokeService
<T> reactor.core.publisher.Mono<T> invokeService(java.lang.String appId, java.lang.String method, java.lang.Object request, HttpExtension httpExtension, java.util.Map<java.lang.String,java.lang.String> metadata, java.lang.Class<T> clazz)Invoke a service method, using serialization.- Type Parameters:
T
- The Type of the return, use byte[] to skip serialization.- Parameters:
appId
- The Application ID where the service is.method
- The actual Method to be call in the application.request
- The request to be sent to invoke the service, use byte[] to skip serialization.httpExtension
- Additional fields that are needed if the receiving app is listening on HTTP,HttpExtension.NONE
otherwise.metadata
- Metadata (in GRPC) or headers (in HTTP) to be sent in request.clazz
- The type needed as return for the call.- Returns:
- A Mono Plan of type T.
-
invokeService
<T> reactor.core.publisher.Mono<T> invokeService(java.lang.String appId, java.lang.String method, java.lang.Object request, HttpExtension httpExtension, TypeRef<T> type)Invoke a service method, using serialization.- Type Parameters:
T
- The Type of the return, use byte[] to skip serialization.- Parameters:
appId
- The Application ID where the service is.method
- The actual Method to be call in the application.request
- The request to be sent to invoke the service, use byte[] to skip serialization.httpExtension
- Additional fields that are needed if the receiving app is listening on HTTP,HttpExtension.NONE
otherwise.type
- The Type needed as return for the call.- Returns:
- A Mono Plan of type T.
-
invokeService
<T> reactor.core.publisher.Mono<T> invokeService(java.lang.String appId, java.lang.String method, java.lang.Object request, HttpExtension httpExtension, java.lang.Class<T> clazz)Invoke a service method, using serialization.- Type Parameters:
T
- The Type of the return, use byte[] to skip serialization.- Parameters:
appId
- The Application ID where the service is.method
- The actual Method to be call in the application.request
- The request to be sent to invoke the service, use byte[] to skip serialization.httpExtension
- Additional fields that are needed if the receiving app is listening on HTTP,HttpExtension.NONE
otherwise.clazz
- The type needed as return for the call.- Returns:
- A Mono Plan of type T.
-
invokeService
<T> reactor.core.publisher.Mono<T> invokeService(java.lang.String appId, java.lang.String method, HttpExtension httpExtension, java.util.Map<java.lang.String,java.lang.String> metadata, TypeRef<T> type)Invoke a service method, using serialization.- Type Parameters:
T
- The Type of the return, use byte[] to skip serialization.- Parameters:
appId
- The Application ID where the service is.method
- The actual Method to be call in the application.httpExtension
- Additional fields that are needed if the receiving app is listening on HTTP,HttpExtension.NONE
otherwise.metadata
- Metadata (in GRPC) or headers (in HTTP) to be sent in request.type
- The Type needed as return for the call.- Returns:
- A Mono Plan of type T.
-
invokeService
<T> reactor.core.publisher.Mono<T> invokeService(java.lang.String appId, java.lang.String method, HttpExtension httpExtension, java.util.Map<java.lang.String,java.lang.String> metadata, java.lang.Class<T> clazz)Invoke a service method, using serialization.- Type Parameters:
T
- The Type of the return, use byte[] to skip serialization.- Parameters:
appId
- The Application ID where the service is.method
- The actual Method to be call in the application.httpExtension
- Additional fields that are needed if the receiving app is listening on HTTP,HttpExtension.NONE
otherwise.metadata
- Metadata (in GRPC) or headers (in HTTP) to be sent in request.clazz
- The type needed as return for the call.- Returns:
- A Mono Plan of type T.
-
invokeService
reactor.core.publisher.Mono<java.lang.Void> invokeService(java.lang.String appId, java.lang.String method, java.lang.Object request, HttpExtension httpExtension, java.util.Map<java.lang.String,java.lang.String> metadata)Invoke a service method, using serialization.- Parameters:
appId
- The Application ID where the service is.method
- The actual Method to be call in the application.request
- The request to be sent to invoke the service, use byte[] to skip serialization.httpExtension
- Additional fields that are needed if the receiving app is listening on HTTP,HttpExtension.NONE
otherwise.metadata
- Metadata (in GRPC) or headers (in HTTP) to be sent in request.- Returns:
- A Mono Plan of type Void.
-
invokeService
reactor.core.publisher.Mono<java.lang.Void> invokeService(java.lang.String appId, java.lang.String method, java.lang.Object request, HttpExtension httpExtension)Invoke a service method, using serialization.- Parameters:
appId
- The Application ID where the service is.method
- The actual Method to be call in the application.request
- The request to be sent to invoke the service, use byte[] to skip serialization.httpExtension
- Additional fields that are needed if the receiving app is listening on HTTP,HttpExtension.NONE
otherwise.- Returns:
- A Mono Plan of type Void.
-
invokeService
reactor.core.publisher.Mono<java.lang.Void> invokeService(java.lang.String appId, java.lang.String method, HttpExtension httpExtension, java.util.Map<java.lang.String,java.lang.String> metadata)Invoke a service method, using serialization.- Parameters:
appId
- The Application ID where the service is.method
- The actual Method to be call in the application.httpExtension
- Additional fields that are needed if the receiving app is listening on HTTP,HttpExtension.NONE
otherwise.metadata
- Metadata (in GRPC) or headers (in HTTP) to be sent in request.- Returns:
- A Mono Plan of type Void.
-
invokeService
reactor.core.publisher.Mono<byte[]> invokeService(java.lang.String appId, java.lang.String method, byte[] request, HttpExtension httpExtension, java.util.Map<java.lang.String,java.lang.String> metadata)Invoke a service method, without using serialization.- Parameters:
appId
- The Application ID where the service is.method
- The actual Method to be call in the application.request
- The request to be sent to invoke the service, use byte[] to skip serialization.httpExtension
- Additional fields that are needed if the receiving app is listening on HTTP,HttpExtension.NONE
otherwise.metadata
- Metadata (in GRPC) or headers (in HTTP) to be sent in request.- Returns:
- A Mono Plan of type byte[].
-
invokeService
<T> reactor.core.publisher.Mono<Response<T>> invokeService(InvokeServiceRequest invokeServiceRequest, TypeRef<T> type)Invoke a service method.- Type Parameters:
T
- The Type of the return, use byte[] to skip serialization.- Parameters:
invokeServiceRequest
- Request object.type
- The Type needed as return for the call.- Returns:
- A Mono Plan of type T.
-
invokeBinding
reactor.core.publisher.Mono<java.lang.Void> invokeBinding(java.lang.String name, java.lang.String operation, java.lang.Object data)Invokes a Binding operation.- Parameters:
name
- The name of the biding to call.operation
- The operation to be performed by the binding request processor.data
- The data to be processed, use byte[] to skip serialization.- Returns:
- an empty Mono.
-
invokeBinding
reactor.core.publisher.Mono<byte[]> invokeBinding(java.lang.String name, java.lang.String operation, byte[] data, java.util.Map<java.lang.String,java.lang.String> metadata)Invokes a Binding operation, skipping serialization.- Parameters:
name
- The name of the biding to call.operation
- The operation to be performed by the binding request processor.data
- The data to be processed, skipping serialization.metadata
- The metadata map.- Returns:
- a Mono plan of type byte[].
-
invokeBinding
<T> reactor.core.publisher.Mono<T> invokeBinding(java.lang.String name, java.lang.String operation, java.lang.Object data, TypeRef<T> type)Invokes a Binding operation.- Type Parameters:
T
- The type of the return- Parameters:
name
- The name of the biding to call.operation
- The operation to be performed by the binding request processor.data
- The data to be processed, use byte[] to skip serialization.type
- The type being returned.- Returns:
- a Mono plan of type T.
-
invokeBinding
<T> reactor.core.publisher.Mono<T> invokeBinding(java.lang.String name, java.lang.String operation, java.lang.Object data, java.lang.Class<T> clazz)Invokes a Binding operation.- Type Parameters:
T
- The type of the return- Parameters:
name
- The name of the biding to call.operation
- The operation to be performed by the binding request processor.data
- The data to be processed, use byte[] to skip serialization.clazz
- The type being returned.- Returns:
- a Mono plan of type T.
-
invokeBinding
<T> reactor.core.publisher.Mono<T> invokeBinding(java.lang.String name, java.lang.String operation, java.lang.Object data, java.util.Map<java.lang.String,java.lang.String> metadata, TypeRef<T> type)Invokes a Binding operation.- Type Parameters:
T
- The type of the return- Parameters:
name
- The name of the biding to call.operation
- The operation to be performed by the binding request processor.data
- The data to be processed, use byte[] to skip serialization.metadata
- The metadata map.type
- The type being returned.- Returns:
- a Mono plan of type T.
-
invokeBinding
<T> reactor.core.publisher.Mono<T> invokeBinding(java.lang.String name, java.lang.String operation, java.lang.Object data, java.util.Map<java.lang.String,java.lang.String> metadata, java.lang.Class<T> clazz)Invokes a Binding operation.- Type Parameters:
T
- The type of the return- Parameters:
name
- The name of the biding to call.operation
- The operation to be performed by the binding request processor.data
- The data to be processed, use byte[] to skip serialization.metadata
- The metadata map.clazz
- The type being returned.- Returns:
- a Mono plan of type T.
-
invokeBinding
<T> reactor.core.publisher.Mono<Response<T>> invokeBinding(InvokeBindingRequest request, TypeRef<T> type)Invokes a Binding operation.- Type Parameters:
T
- The type of the return- Parameters:
request
- The binding invocation request.type
- The type being returned.- Returns:
- a Mono plan of type T.
-
getState
<T> reactor.core.publisher.Mono<State<T>> getState(java.lang.String stateStoreName, State<T> state, TypeRef<T> type)Retrieve a State based on their key.- Type Parameters:
T
- The type of the return.- Parameters:
stateStoreName
- The name of the state store.state
- State to be re-retrieved.type
- The type of State needed as return.- Returns:
- A Mono Plan for the requested State.
-
getState
<T> reactor.core.publisher.Mono<State<T>> getState(java.lang.String stateStoreName, State<T> state, java.lang.Class<T> clazz)Retrieve a State based on their key.- Type Parameters:
T
- The type of the return.- Parameters:
stateStoreName
- The name of the state store.state
- State to be re-retrieved.clazz
- The type of State needed as return.- Returns:
- A Mono Plan for the requested State.
-
getState
<T> reactor.core.publisher.Mono<State<T>> getState(java.lang.String stateStoreName, java.lang.String key, TypeRef<T> type)Retrieve a State based on their key.- Type Parameters:
T
- The type of the return.- Parameters:
stateStoreName
- The name of the state store.key
- The key of the State to be retrieved.type
- The type of State needed as return.- Returns:
- A Mono Plan for the requested State.
-
getState
<T> reactor.core.publisher.Mono<State<T>> getState(java.lang.String stateStoreName, java.lang.String key, java.lang.Class<T> clazz)Retrieve a State based on their key.- Type Parameters:
T
- The type of the return.- Parameters:
stateStoreName
- The name of the state store.key
- The key of the State to be retrieved.clazz
- The type of State needed as return.- Returns:
- A Mono Plan for the requested State.
-
getState
<T> reactor.core.publisher.Mono<State<T>> getState(java.lang.String stateStoreName, java.lang.String key, java.lang.String etag, StateOptions options, TypeRef<T> type)Retrieve a State based on their key.- Type Parameters:
T
- The Type of the return.- Parameters:
stateStoreName
- The name of the state store.key
- The key of the State to be retrieved.etag
- Optional etag for conditional getoptions
- Optional settings for retrieve operation.type
- The Type of State needed as return.- Returns:
- A Mono Plan for the requested State.
-
getState
<T> reactor.core.publisher.Mono<State<T>> getState(java.lang.String stateStoreName, java.lang.String key, java.lang.String etag, StateOptions options, java.lang.Class<T> clazz)Retrieve a State based on their key.- Type Parameters:
T
- The Type of the return.- Parameters:
stateStoreName
- The name of the state store.key
- The key of the State to be retrieved.etag
- Optional etag for conditional getoptions
- Optional settings for retrieve operation.clazz
- The Type of State needed as return.- Returns:
- A Mono Plan for the requested State.
-
getState
<T> reactor.core.publisher.Mono<Response<State<T>>> getState(GetStateRequest request, TypeRef<T> type)Retrieve a State based on their key.- Type Parameters:
T
- The Type of the return.- Parameters:
request
- The request to get state.type
- The Type of State needed as return.- Returns:
- A Mono Plan for the requested State.
-
getStates
<T> reactor.core.publisher.Mono<java.util.List<State<T>>> getStates(java.lang.String stateStoreName, java.util.List<java.lang.String> keys, TypeRef<T> type)Retrieve bulk States based on their keys.- Type Parameters:
T
- The type of the return.- Parameters:
stateStoreName
- The name of the state store.keys
- The keys of the State to be retrieved.type
- The type of State needed as return.- Returns:
- A Mono Plan for the requested State.
-
getStates
<T> reactor.core.publisher.Mono<java.util.List<State<T>>> getStates(java.lang.String stateStoreName, java.util.List<java.lang.String> keys, java.lang.Class<T> clazz)Retrieve bulk States based on their keys.- Type Parameters:
T
- The type of the return.- Parameters:
stateStoreName
- The name of the state store.keys
- The keys of the State to be retrieved.clazz
- The type of State needed as return.- Returns:
- A Mono Plan for the requested State.
-
getStates
<T> reactor.core.publisher.Mono<Response<java.util.List<State<T>>>> getStates(GetStatesRequest request, TypeRef<T> type)Retrieve bulk States based on their keys.- Type Parameters:
T
- The Type of the return.- Parameters:
request
- The request to get state.type
- The Type of State needed as return.- Returns:
- A Mono Plan for the requested State.
-
executeTransaction
reactor.core.publisher.Mono<java.lang.Void> executeTransaction(java.lang.String stateStoreName, java.util.List<TransactionalStateOperation<?>> operations)Execute a transaction.- Parameters:
stateStoreName
- The name of the state store.operations
- The operations to be performed.- Returns:
- a Mono plan of type Void
-
executeTransaction
reactor.core.publisher.Mono<Response<java.lang.Void>> executeTransaction(ExecuteStateTransactionRequest request)Execute a transaction.- Parameters:
request
- Request to execute transaction.- Returns:
- a Mono plan of type Response Void
-
saveStates
reactor.core.publisher.Mono<java.lang.Void> saveStates(java.lang.String stateStoreName, java.util.List<State<?>> states)Save/Update a list of states.- Parameters:
stateStoreName
- The name of the state store.states
- The States to be saved.- Returns:
- a Mono plan of type Void.
-
saveStates
Save/Update a list of states.- Parameters:
request
- Request to save states.- Returns:
- a Mono plan of type Void.
-
saveState
reactor.core.publisher.Mono<java.lang.Void> saveState(java.lang.String stateStoreName, java.lang.String key, java.lang.Object value)Save/Update a state.- Parameters:
stateStoreName
- The name of the state store.key
- The key of the state.value
- The value of the state.- Returns:
- a Mono plan of type Void.
-
saveState
reactor.core.publisher.Mono<java.lang.Void> saveState(java.lang.String stateStoreName, java.lang.String key, java.lang.String etag, java.lang.Object value, StateOptions options)Save/Update a state.- Parameters:
stateStoreName
- The name of the state store.key
- The key of the state.etag
- The etag to be used.value
- The value of the state.options
- The Options to use for each state.- Returns:
- a Mono plan of type Void.
-
deleteState
reactor.core.publisher.Mono<java.lang.Void> deleteState(java.lang.String stateStoreName, java.lang.String key)Delete a state.- Parameters:
stateStoreName
- The name of the state store.key
- The key of the State to be removed.- Returns:
- a Mono plan of type Void.
-
deleteState
reactor.core.publisher.Mono<java.lang.Void> deleteState(java.lang.String stateStoreName, java.lang.String key, java.lang.String etag, StateOptions options)Delete a state.- Parameters:
stateStoreName
- The name of the state store.key
- The key of the State to be removed.etag
- Optional etag for conditional delete.options
- Optional settings for state operation.- Returns:
- a Mono plan of type Void.
-
deleteState
Delete a state.- Parameters:
request
- Request to delete a state.- Returns:
- a Mono plan of type Void.
-
getSecret
reactor.core.publisher.Mono<java.util.Map<java.lang.String,java.lang.String>> getSecret(java.lang.String secretStoreName, java.lang.String secretName, java.util.Map<java.lang.String,java.lang.String> metadata)Fetches a secret from the configured vault.- Parameters:
secretStoreName
- Name of vault component in Dapr.secretName
- Secret to be fetched.metadata
- Optional metadata.- Returns:
- Key-value pairs for the secret.
-
getSecret
reactor.core.publisher.Mono<java.util.Map<java.lang.String,java.lang.String>> getSecret(java.lang.String secretStoreName, java.lang.String secretName)Fetches a secret from the configured vault.- Parameters:
secretStoreName
- Name of vault component in Dapr.secretName
- Secret to be fetched.- Returns:
- Key-value pairs for the secret.
-
getSecret
reactor.core.publisher.Mono<Response<java.util.Map<java.lang.String,java.lang.String>>> getSecret(GetSecretRequest request)Fetches a secret from the configured vault.- Parameters:
request
- Request to fetch secret.- Returns:
- Key-value pairs for the secret.
-