Packages

khepri

0.1.0
0.19.0-beta.1 0.18.0 0.17.7 0.17.6 0.17.5 0.17.4 0.17.3 0.17.2 0.17.1 0.17.0 0.16.0 0.15.0 0.14.0 0.13.0 0.12.1 0.12.0 0.11.0 0.10.1 0.10.0 0.9.0 0.8.0 0.7.0 0.6.0 0.5.0 0.4.3 0.4.2 0.4.1 0.4.0 0.3.0 0.2.1 0.2.0 0.1.1 0.1.0

Tree-like replicated on-disk database library

HexDocs

Current section

Files

Jump to
Readme
33 Versions
1 Dependency
Dependants
Files
Activity
khepri src internal.hrl
Raw

src/internal.hrl 

%% This Source Code Form is subject to the terms of the Mozilla Public

%% License, v. 2.0. If a copy of the MPL was not distributed with this

%% file, You can obtain one at https://mozilla.org/MPL/2.0/.

%%

%% Copyright (c) 2021 VMware, Inc. or its affiliates.  All rights reserved.

%%



-define(INIT_DATA_VERSION, 1).

-define(INIT_CHILD_LIST_VERSION, 1).

-define(INIT_NODE_STAT, #{payload_version => ?INIT_DATA_VERSION,

                          child_list_version => ?INIT_CHILD_LIST_VERSION}).



-define(TX_STATE_KEY, khepri_tx_machine_state).

-define(TX_PROPS, khepri_tx_properties).



%% Structure representing each node in the tree, including the root node.

%% TODO: Rename stat to something more correct?

-record(node, {stat = ?INIT_NODE_STAT :: khepri_machine:stat(),

               payload = none :: khepri_machine:payload(),

               child_nodes = #{} :: #{khepri_path:component() := #node{}}}).



%% State machine commands.



-record(put, {path :: khepri_path:pattern(),

              payload = none :: khepri_machine:payload(),

              extra = #{} :: #{keep_until => [khepri_path:pattern()]}}).



-record(delete, {path :: khepri_path:pattern()}).



-record(tx, {'fun' :: khepri_fun:standalone_fun()}).



%% Structure representing an anonymous function "extracted" as a compiled

%% module for storage.

-record(standalone_fun, {module :: module(),

                         beam :: binary(),

                         arity :: arity(),

                         env :: list()}).