Interface DaprPreviewClient

All Superinterfaces:
AutoCloseable
All Known Implementing Classes:
DaprClientGrpc, DaprClientHttp

public interface DaprPreviewClient extends AutoCloseable
Generic client interface for preview or alpha APIs in Dapr, regardless of GRPC or HTTP.
See Also:
for information on how to make instance for this interface.
  • Method Details

    • getConfiguration

      reactor.core.publisher.Mono<ConfigurationItem> getConfiguration(String storeName, String key)
      Retrieve a configuration based on a provided key.
      Parameters:
      storeName - Name of the configuration store
      key - key of the configuration item which is to be retrieved
      Returns:
      Mono of the Configuration Item
    • getConfiguration

      reactor.core.publisher.Mono<ConfigurationItem> getConfiguration(String storeName, String key, Map<String,​String> metadata)
      Retrieve a configuration based on a provided key.
      Parameters:
      storeName - Name of the configuration store
      key - key of the configuration item which is to be retrieved
      metadata - optional metadata
      Returns:
      Mono of the Configuration Item
    • getConfiguration

      reactor.core.publisher.Mono<List<ConfigurationItem>> getConfiguration(String storeName, String... keys)
      Retrieve List of configurations based on a provided variable number of keys.
      Parameters:
      storeName - Name of the configuration store
      keys - keys of the configurations which are to be retrieved
      Returns:
      Mono of List of ConfigurationItems
    • getConfiguration

      reactor.core.publisher.Mono<List<ConfigurationItem>> getConfiguration(String storeName, List<String> keys, Map<String,​String> metadata)
      Retrieve List of configurations based on a provided variable number of keys.
      Parameters:
      storeName - Name of the configuration store
      keys - keys of the configurations which are to be retrieved
      metadata - optional metadata
      Returns:
      Mono of List of ConfigurationItems
    • getConfiguration

      reactor.core.publisher.Mono<List<ConfigurationItem>> getConfiguration(GetConfigurationRequest request)
      Retrieve List of configurations based on a provided configuration request object.
      Parameters:
      request - request for retrieving Configurations for a list keys
      Returns:
      Mono of List of ConfigurationItems
    • subscribeToConfiguration

      reactor.core.publisher.Flux<List<ConfigurationItem>> subscribeToConfiguration(String storeName, String... keys)
      Subscribe to the keys for any change.
      Parameters:
      storeName - Name of the configuration store
      keys - keys of the configurations which are to be subscribed
      Returns:
      Flux of List of configuration items
    • subscribeToConfiguration

      reactor.core.publisher.Flux<List<ConfigurationItem>> subscribeToConfiguration(String storeName, List<String> keys, Map<String,​String> metadata)
      Subscribe to the keys for any change.
      Parameters:
      storeName - Name of the configuration store
      keys - keys of the configurations which are to be subscribed
      metadata - optional metadata
      Returns:
      Flux of List of configuration items
    • subscribeToConfiguration

      reactor.core.publisher.Flux<List<ConfigurationItem>> subscribeToConfiguration(SubscribeConfigurationRequest request)
      Subscribe to the keys for any change.
      Parameters:
      request - request for subscribing to any change for the given keys in request
      Returns:
      Flux of List of configuration items