Package io.fluxcapacitor.common.api.keyvalue

Class StoreValues

java.lang.Object
io.fluxcapacitor.common.api.Request
io.fluxcapacitor.common.api.Command
io.fluxcapacitor.common.api.keyvalue.StoreValues
All Implemented Interfaces:
JsonType
public class StoreValues extends Command
Legacy API: This command stores key-value pairs in the legacy key-value store mechanism.

While still supported, this approach is considered obsolete and retained primarily for backward compatibility. For most use cases, prefer using DocumentStore for flexible and queryable persistence.

Fields

  • values – A list of key-value pairs to store
  • guarantee – Defines delivery/storage guarantees (e.g., Guarantee.STORED)

Routing

The first key in the value list is used as the routing key for load distribution.

Metrics

The command emits a lightweight StoreValues.Metric representation with the keys and count.
See Also:

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static class 
    StoreValues.Metric
    Lightweight metric representation of this command.

  • Constructor Summary

    Constructors
    Constructor
    Description
    StoreValues()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    routingKey()
    Optionally specifies a routing key for this command, which may be used to partition work or apply consistent hashing when processed in the Flux platform.
    Object
    toMetric()
    Converts this object into a compact metric representation for logging or monitoring.
    String
    toString()
     

    Methods inherited from class io.fluxcapacitor.common.api.Command

    getGuarantee

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • StoreValues

      public StoreValues()

  • Method Details

    • toMetric

      public Object toMetric()
      Description copied from interface: JsonType
      Converts this object into a compact metric representation for logging or monitoring.

      Used by the Flux client to avoid logging large payloads directly while still tracking platform usage.

      Returns:
      a safe and compact object suitable for serialization to the metrics log

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • routingKey

      public String routingKey()
      Description copied from class: Command
      Optionally specifies a routing key for this command, which may be used to partition work or apply consistent hashing when processed in the Flux platform.
      Overrides:
      routingKey in class Command
      Returns:
      a routing key string, or null if not specified