pqptree

Documentation

Overview

   conflux - Distributed database synchronization library
	Based on the algorithm described in
		"Set Reconciliation with Nearly Optimal	Communication Complexity",
			Yaron Minsky, Ari Trachtenberg, and Richard Zippel, 2004.

   Copyright (C) 2012  Casey Marshall <casey.marshall@gmail.com>

   This program is free software: you can redistribute it and/or modify
   it under the terms of the GNU Affero General Public License as published by
   the Free Software Foundation, version 3.

   This program is distributed in the hope that it will be useful,
   but WITHOUT ANY WARRANTY; without even the implied warranty of
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   GNU Affero General Public License for more details.

   You should have received a copy of the GNU Affero General Public License
   along with this program.  If not, see <http://www.gnu.org/licenses/>.

Index

• Constants
• func ErrDuplicateElement(z *Zp) error
• func New(namespace string, db *sqlx.DB, settings *Settings) (ptree recon.PrefixTree, err error)
• type PElement
• type PNode
• type Settings
  • func DefaultSettings() *Settings
  • func NewSettings(reconSettings *recon.Settings) *Settings
  • func (s *Settings) DSN() string
  • func (s *Settings) Driver() string
  • func (s *Settings) Namespace() string

Constants

const CreateIndex_PElement_NodeKey = `
CREATE INDEX {{.Namespace}}_pelement_node_key ON {{.Namespace}}_pelement (node_key)`

const CreateTable_PElement = `` /* 193-byte string literal not displayed */

const CreateTable_PNode = `` /* 188-byte string literal not displayed */

Functions

func ErrDuplicateElement

func ErrDuplicateElement(z *Zp) error

func New

func New(namespace string, db *sqlx.DB, settings *Settings) (ptree recon.PrefixTree, err error)

Types

type PElement

type PElement struct {
	NodeKey string `db:"node_key"`
	Element []byte `db:"element"`
}

type PNode

type PNode struct {
	NodeKey        string `db:"node_key"`
	SValues        []byte `db:"svalues"`
	NumElements    int    `db:"num_elements"`
	ChildKeyString string `db:"child_keys"`
	// contains filtered or unexported fields
}

type Settings

type Settings struct {
	*recon.Settings
}

func DefaultSettings

func DefaultSettings() *Settings

func NewSettings

func NewSettings(reconSettings *recon.Settings) *Settings

func (*Settings) DSN

func (s *Settings) DSN() string

func (*Settings) Driver

func (s *Settings) Driver() string

func (*Settings) Namespace

func (s *Settings) Namespace() string