store

README

Prefix-Sum B-Tree specification

This module implements a B-Tree suitable for efficiently computing a random prefix sum of data, while allowing the data to be efficiently updated.

The prefix sums for N elements x_1, x_2, ... x_N, each with a weight field, is the sequence y_1, y_2, ... y_N, where y_i = sum_{0 <= j <= i} x_j.weight. This data structure allows one to edit, insert, and delete entries in the x sequence efficiently, and efficiently retrieve the prefix sum at any index, where efficiently is O(log(N)) state operations. (Note that in the cosmos SDK stack, a state operation is itself liable to take O(log(N)) time)

This is built for the use-case of we have a series of data that is sorted by time. Each given time has an associated weight field. We want to be able to very quickly find the total weight for all leaves with times less than or equal to t. The actual implementation is agnostic to what is the field we sort by.

Data structure idea

The idea underlying this can be decomposed into two parts:

1. Do some extra (O(log(N))) work when modifying the data, to allow efficiently computing any prefix sum
2. Allow the data entries to be inserted into and deleted from, while remaining sorted

The solution for 1. is to build a balanced tree on top of the data. Every inner node in the tree will be augmented with an "accumulated weight" field, which contains the sum of the weights of all entries below it. Notice that upon updating the weight of any leaf, the weights of all nodes that are "above" this node can be updated efficiently. (As there ought to only be log(N) such nodes) Furthermore, the root of the tree's augmented value is the sum of all weights in the tree.

Then to query the jth prefix sum, you first identify the path to the jth node in the tree. You keep a running tally of "prefix sum thus far", which is initialized to the sum of all weights in the tree. Then as you walk the path from the tree root to the jth leaf, whenever there are siblings on the right, you subtract their weight from your running total. The weight when you arrive at the leaf is then the prefix sum.

Lets illustrate this with a binary tree.

If we want the prefix sum for leaf 12 we compute it as 1.weight - 7.weight - 13.weight. (We took a subtraction every time we took a left)

Now notice that this solution works for any tree type, where efficiency just depends on number of siblings * depth and as long as that is parameterized to be O(log(N)) we maintain our definition of efficient.

Thus we immediately get a solution to 2., by using a tree that supports efficient inserts, and deletions, while still maintaining log depth and a constant number of siblings. We opt for using a B+ tree for this, as it performs the task well and does not require rebalance operations. (Which can be costly in an adversarial environment)

<!---
TODO: Improve diagrams showing this accumulated weight concept with a binary tree, and show how you query a random prefix sum.
-->

Implementation Details

The B-Tree implementation under osmosis/store is designed specifically for allowing efficient computation of a random prefix sum, with the underlying data being updatable as explained above.

Every Leaf has a Weight field, and the address its stored at in state is the key which we want to sort by. The implementation sorts leaves as byteslices, Leafs are sorted under their byteslice key, and the branch nodes have accumulation for each childs.

A node is pointed by a node struct, used internally.

type node struct {
    t Tree
    level uint8
    key []byte
}

A node struct is a pointer to the key-value pair under nodeKey(node.level, node.key)

A leaf node is simply a uint64 integer value stored under nodeKey(0, key). The key is arbitrary length of byte slice.

type Leaf struct {
    Value uint64
}

A branch node consists of keys and accumulation of the children nodes.

type Branch struct {
    Children []Child    
}

type Child struct {
    Key []byte
    Acc uint64
}

The following constraints are valid for all branch nodes:

1. For c in node.Branch().Children, the node corresponding to c is stored under nodeKey(node.level-1, c.Key).
2. For c in node.Branch().Children, c.Acc is the sum of all c'.Acc where c' is in c.Children. If c' is leaf node, substitute c'.Acc to Leaf.Value.
3. For c in node.Branch().Children, c.Key is equal or greater than node.key and lesser than node.rightSibling().key.
4. There are no duplicate child stored in more than one of node's .Children.

Example

Here is an example tree data:

- Level 2 nil
  - Level 1 0xaaaa 
    - Level 0 0xaaaa Value 10
    - Level 0 0xaaaa01 Value 20
    - Level 0 0xaabb Value 30
  - Level 1 0xbb44
    - Level 0 0xbb55 Value 100
    - Level 0 0xbe Value 200
  - Level 1 0xeeaaaa
    - Level 0 0xef1234 Value 300
    - Level 0 0xffff Value 400

The branch nodes will have the following childrens:

require.Equal(store.Get(nodeKey(2, nil)), Children{{0xaaaa, 60}, {0xbb44, 300}, {0xeeaaaa, 700}})
require.Equal(store.Get(nodeKey(1, 0xaaaa)), Children{{0xaaaa, 10}, {0xaaaa01, 20}, {0xaabb, 30}})
require.Equal(store.Get(nodeKey(1, 0xbb44)), Children{{0xbb55, 100}, {0xbe, 200}})
require.Equal(store.Get(nodeKey(1, 0xeeaaaa)), Children{{0xef1234, 300}, {0xffff, 400}})

Documentation

Index

• Variables
• type Child
  • func (*Child) Descriptor() ([]byte, []int)
  • func (m *Child) GetIndex() []byte
  • func (m *Child) Marshal() (dAtA []byte, err error)
  • func (m *Child) MarshalTo(dAtA []byte) (int, error)
  • func (m *Child) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Child) ProtoMessage()
  • func (m *Child) Reset()
  • func (m *Child) Size() (n int)
  • func (m *Child) String() string
  • func (m *Child) Unmarshal(dAtA []byte) error
  • func (m *Child) XXX_DiscardUnknown()
  • func (m *Child) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Child) XXX_Merge(src proto.Message)
  • func (m *Child) XXX_Size() int
  • func (m *Child) XXX_Unmarshal(b []byte) error
• type Leaf
  • func NewLeaf(key []byte, acc sdk.Int) *Leaf
  • func (*Leaf) Descriptor() ([]byte, []int)
  • func (m *Leaf) GetLeaf() *Child
  • func (m *Leaf) Marshal() (dAtA []byte, err error)
  • func (m *Leaf) MarshalTo(dAtA []byte) (int, error)
  • func (m *Leaf) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Leaf) ProtoMessage()
  • func (m *Leaf) Reset()
  • func (m *Leaf) Size() (n int)
  • func (m *Leaf) String() string
  • func (m *Leaf) Unmarshal(dAtA []byte) error
  • func (m *Leaf) XXX_DiscardUnknown()
  • func (m *Leaf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Leaf) XXX_Merge(src proto.Message)
  • func (m *Leaf) XXX_Size() int
  • func (m *Leaf) XXX_Unmarshal(b []byte) error
• type Node
  • func NewNode(cs ...*Child) *Node
  • func (*Node) Descriptor() ([]byte, []int)
  • func (m *Node) GetChildren() []*Child
  • func (m *Node) Marshal() (dAtA []byte, err error)
  • func (m *Node) MarshalTo(dAtA []byte) (int, error)
  • func (m *Node) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Node) ProtoMessage()
  • func (m *Node) Reset()
  • func (m *Node) Size() (n int)
  • func (m *Node) String() string
  • func (m *Node) Unmarshal(dAtA []byte) error
  • func (m *Node) XXX_DiscardUnknown()
  • func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Node) XXX_Merge(src proto.Message)
  • func (m *Node) XXX_Size() int
  • func (m *Node) XXX_Unmarshal(b []byte) error
• type Tree
  • func NewTree(store store.KVStore, m uint8) Tree
  • func (t Tree) Clear()
  • func (t Tree) DebugVisualize()
  • func (t Tree) Decrease(key []byte, amt sdk.Int)
  • func (t Tree) Get(key []byte) sdk.Int
  • func (t Tree) Increase(key []byte, amt sdk.Int)
  • func (t Tree) IsEmpty() bool
  • func (t Tree) Iterator(begin, end []byte) store.Iterator
  • func (t Tree) PrefixSum(key []byte) sdk.Int
  • func (t Tree) Remove(key []byte)
  • func (t Tree) ReverseIterator(begin, end []byte) store.Iterator
  • func (t Tree) Set(key []byte, acc sdk.Int)
  • func (t Tree) SplitAcc(key []byte) (sdk.Int, sdk.Int, sdk.Int)
  • func (t Tree) SubsetAccumulation(start []byte, end []byte) sdk.Int
  • func (t Tree) TotalAccumulatedValue() sdk.Int

Variables

var (
	ErrInvalidLengthTree        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTree          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTree = fmt.Errorf("proto: unexpected end of group")
)

Types

type Child

type Child struct {
	Index        []byte                                 `protobuf:"bytes,1,opt,name=index,proto3" json:"index,omitempty"`
	Accumulation github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,2,opt,name=accumulation,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"accumulation"`
}

func (*Child) Descriptor

func (*Child) Descriptor() ([]byte, []int)

func (*Child) GetIndex

func (m *Child) GetIndex() []byte

func (*Child) Marshal

func (m *Child) Marshal() (dAtA []byte, err error)

func (*Child) MarshalTo

func (m *Child) MarshalTo(dAtA []byte) (int, error)

func (*Child) MarshalToSizedBuffer

func (m *Child) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Child) ProtoMessage

func (*Child) ProtoMessage()

func (*Child) Reset

func (m *Child) Reset()

func (*Child) Size

func (m *Child) Size() (n int)

func (*Child) String

func (m *Child) String() string

func (*Child) Unmarshal

func (m *Child) Unmarshal(dAtA []byte) error

func (*Child) XXX_DiscardUnknown

func (m *Child) XXX_DiscardUnknown()

func (*Child) XXX_Marshal

func (m *Child) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Child) XXX_Merge

func (m *Child) XXX_Merge(src proto.Message)

func (*Child) XXX_Size

func (m *Child) XXX_Size() int

func (*Child) XXX_Unmarshal

func (m *Child) XXX_Unmarshal(b []byte) error

type Leaf

type Leaf struct {
	Leaf *Child `protobuf:"bytes,1,opt,name=leaf,proto3" json:"leaf,omitempty"`
}

func NewLeaf

func NewLeaf(key []byte, acc sdk.Int) *Leaf

func (*Leaf) Descriptor

func (*Leaf) Descriptor() ([]byte, []int)

func (*Leaf) GetLeaf

func (m *Leaf) GetLeaf() *Child

func (*Leaf) Marshal

func (m *Leaf) Marshal() (dAtA []byte, err error)

func (*Leaf) MarshalTo

func (m *Leaf) MarshalTo(dAtA []byte) (int, error)

func (*Leaf) MarshalToSizedBuffer

func (m *Leaf) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Leaf) ProtoMessage

func (*Leaf) ProtoMessage()

func (*Leaf) Reset

func (m *Leaf) Reset()

func (*Leaf) Size

func (m *Leaf) Size() (n int)

func (*Leaf) String

func (m *Leaf) String() string

func (*Leaf) Unmarshal

func (m *Leaf) Unmarshal(dAtA []byte) error

func (*Leaf) XXX_DiscardUnknown

func (m *Leaf) XXX_DiscardUnknown()

func (*Leaf) XXX_Marshal

func (m *Leaf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Leaf) XXX_Merge

func (m *Leaf) XXX_Merge(src proto.Message)

func (*Leaf) XXX_Size

func (m *Leaf) XXX_Size() int

func (*Leaf) XXX_Unmarshal

func (m *Leaf) XXX_Unmarshal(b []byte) error

type Node

type Node struct {
	Children []*Child `protobuf:"bytes,1,rep,name=children,proto3" json:"children,omitempty"`
}

func NewNode

func NewNode(cs ...*Child) *Node

func (*Node) Descriptor

func (*Node) Descriptor() ([]byte, []int)

func (*Node) GetChildren

func (m *Node) GetChildren() []*Child

func (*Node) Marshal

func (m *Node) Marshal() (dAtA []byte, err error)

func (*Node) MarshalTo

func (m *Node) MarshalTo(dAtA []byte) (int, error)

func (*Node) MarshalToSizedBuffer

func (m *Node) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) Reset

func (m *Node) Reset()

func (*Node) Size

func (m *Node) Size() (n int)

func (*Node) String

func (m *Node) String() string

func (*Node) Unmarshal

func (m *Node) Unmarshal(dAtA []byte) error

func (*Node) XXX_DiscardUnknown

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal

func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Node) XXX_Merge

func (m *Node) XXX_Merge(src proto.Message)

func (*Node) XXX_Size

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal

func (m *Node) XXX_Unmarshal(b []byte) error

type Tree

type Tree struct {
	// contains filtered or unexported fields
}

Tree is an augmented B+ tree implementation. Branches have m sized key index slice. Each key index represents the starting index of the child node's index(inclusive), and the ending index of the previous node of the child node's index(exclusive). TODO: We should abstract out the leaves of this tree to allow more data aside from the accumulation value to go there.

func NewTree

func NewTree(store store.KVStore, m uint8) Tree

func (Tree) Clear

func (t Tree) Clear()

func (Tree) DebugVisualize

func (t Tree) DebugVisualize()

DebugVisualize prints the entire tree to stdout.

func (Tree) Decrease

func (t Tree) Decrease(key []byte, amt sdk.Int)

func (Tree) Get

func (t Tree) Get(key []byte) sdk.Int

Get returns the (sdk.Int) accumulation value at a given leaf.

func (Tree) Increase

func (t Tree) Increase(key []byte, amt sdk.Int)

func (Tree) IsEmpty

func (t Tree) IsEmpty() bool

func (Tree) Iterator

func (t Tree) Iterator(begin, end []byte) store.Iterator

func (Tree) PrefixSum

func (t Tree) PrefixSum(key []byte) sdk.Int

Prefix sum returns the total weight of all leaves with keys <= to the provided key.

func (Tree) Remove

func (t Tree) Remove(key []byte)

func (Tree) ReverseIterator

func (t Tree) ReverseIterator(begin, end []byte) store.Iterator

func (Tree) Set

func (t Tree) Set(key []byte, acc sdk.Int)

func (Tree) SplitAcc

func (t Tree) SplitAcc(key []byte) (sdk.Int, sdk.Int, sdk.Int)

func (Tree) SubsetAccumulation

func (t Tree) SubsetAccumulation(start []byte, end []byte) sdk.Int

SubsetAccumulation returns the total value of all leaves with keys between start and end (inclusive of both ends) if start is nil, it is the beginning of the tree. if end is nil, it is the end of the tree.

func (Tree) TotalAccumulatedValue

func (t Tree) TotalAccumulatedValue() sdk.Int

TotalAccumulatedValue returns the sum of the weights for all leaves.