Package io.dapr.actors.runtime

Class ActorStateManager

  • public class ActorStateManager
extends Object
    Manages state changes of a given Actor instance. All changes are cached in-memory until save() is called.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <T> reactor.core.publisher.Mono<Void> add​(String stateName, T value)
      Adds a given key/value to the Actor's state store's cache.
      void clear()
      Clears all changes not yet saved to state store.
      reactor.core.publisher.Mono<Boolean> contains​(String stateName)
      Checks if a given state exists in state store or cache.
      <T> reactor.core.publisher.Mono<T> get​(String stateName, TypeRef<T> type)
      Fetches the most recent value for the given state, including cached value.
      <T> reactor.core.publisher.Mono<T> get​(String stateName, Class<T> clazz)
      Fetches the most recent value for the given state, including cached value.
      reactor.core.publisher.Mono<Void> remove​(String stateName)
      Removes a given state from state store's cache.
      reactor.core.publisher.Mono<Void> save()
      Saves all changes to state store.
      <T> reactor.core.publisher.Mono<Void> set​(String stateName, T value)
      Updates a given key/value pair in the state store's cache.

    • Method Detail

      • add

        public <T> reactor.core.publisher.Mono<Void> add​(String stateName,
                                                 T value)
        Adds a given key/value to the Actor's state store's cache.
        Type Parameters:
        T - Type of the object being added.
        Parameters:
        stateName - Name of the state being added.
        value - Value to be added.
        Returns:
        Asynchronous void operation.

      • get

        public <T> reactor.core.publisher.Mono<T> get​(String stateName,
                                              Class<T> clazz)
        Fetches the most recent value for the given state, including cached value.
        Type Parameters:
        T - Type being fetched.
        Parameters:
        stateName - Name of the state.
        clazz - Class type for the value being fetched.
        Returns:
        Asynchronous response with fetched object.

      • get

        public <T> reactor.core.publisher.Mono<T> get​(String stateName,
                                              TypeRef<T> type)
        Fetches the most recent value for the given state, including cached value.
        Type Parameters:
        T - Type being fetched.
        Parameters:
        stateName - Name of the state.
        type - Class type for the value being fetched.
        Returns:
        Asynchronous response with fetched object.

      • set

        public <T> reactor.core.publisher.Mono<Void> set​(String stateName,
                                                 T value)
        Updates a given key/value pair in the state store's cache.
        Type Parameters:
        T - Type of the value being set.
        Parameters:
        stateName - Name of the state being updated.
        value - Value to be set for given state.
        Returns:
        Asynchronous void result.

      • remove

        public reactor.core.publisher.Mono<Void> remove​(String stateName)
        Removes a given state from state store's cache.
        Parameters:
        stateName - State being stored.
        Returns:
        Asynchronous void result.

      • contains

        public reactor.core.publisher.Mono<Boolean> contains​(String stateName)
        Checks if a given state exists in state store or cache.
        Parameters:
        stateName - State being checked.
        Returns:
        Asynchronous boolean result indicating whether state is present.

      • save

        public reactor.core.publisher.Mono<Void> save()
        Saves all changes to state store.
        Returns:
        Asynchronous void result.

      • clear

        public void clear()
        Clears all changes not yet saved to state store.