Native FerricStore Flow commands.
Functions accept the native typed-map payload documented by the protocol. Id-addressed payloads are routed to the relevant shard leader; keyless aggregate commands use the control connection.
Summary
Functions
Returns {:ok, PolicySnapshot.t()} including its monotonic generation.
Deep-patches a Flow policy and returns {:ok, PolicySnapshot.t()}.
Functions
@spec opcodes() :: map()
@spec policy_get(pid(), map(), keyword()) :: {:ok, FerricStore.Flow.PolicySnapshot.t()} | {:error, term()}
Returns {:ok, PolicySnapshot.t()} including its monotonic generation.
@spec policy_set(pid(), map(), keyword()) :: {:ok, FerricStore.Flow.PolicySnapshot.t()} | {:error, FerricStore.Flow.StalePolicyGenerationError.t() | term()}
Deep-patches a Flow policy and returns {:ok, PolicySnapshot.t()}.
Set replace to true for full replacement. An expected_generation CAS
mutation is never retried automatically.