db

Jun 6, 2018

Changes in this version

+ const OWL_NAMESPACE

+ const RDF_NAMESPACE

+ var INVERSEOF = turtle.URI

+ type HodDB struct

+ func NewHodDB(cfg *config.Config) (*HodDB, error)

+ func (hod *HodDB) Close()

+ func (hod *HodDB) Databases() []string

+ func (hod *HodDB) QueryToClassDOT(q string) (string, error)

+ func (hod *HodDB) QueryToDOT(q string) (string, error)

+ func (hod *HodDB) RunQuery(q *sparql.Query) (QueryResult, error)

+ func (hod *HodDB) RunQueryString(querystring string) (result QueryResult, err error)

+ func (hod *HodDB) Search(q string, n int) ([]string, error)

type QueryResult

+ Errors []string

type Row

+ func NewRowWithNum(withnum int) *Row

Dec 31, 2017

Changes in this version

type MultiDB

+ func (mdb *MultiDB) Databases() []string

Dec 19, 2017

Changes in this version

+ var EMPTYROW = [32]byte

+ var ROWPOOL = sync.Pool

type Key

+ func (k Key) LessThan(other Key) bool

+ type MultiDB struct

+ func NewMultiDB(cfg *config.Config) (*MultiDB, error)

+ func (mdb *MultiDB) Close()

+ func (mdb *MultiDB) QueryToClassDOT(q string) (string, error)

+ func (mdb *MultiDB) QueryToDOT(q string) (string, error)

+ func (mdb *MultiDB) RunQuery(q *sparql.Query) (QueryResult, error)

+ func (mdb *MultiDB) RunQueryString(querystring string) (QueryResult, error)

+ func (mdb *MultiDB) Search(q string, n int) ([]string, error)

type PredicateEntity

+ func (e *PredicateEntity) Dump(db *DB)

+ type Relation struct

+ func NewRelation(vars []string) *Relation

+ type Row [32]byte

+ func NewRow() *Row

Jun 29, 2017

Changes in this version

+ const BTREE_DEGREE

May 23, 2017

Changes in this version

type DB

+ func (db *DB) GetEntityIndexFromHash(hash Key) (*EntityExtendedIndex, error)

+ func (db *DB) GetEntityIndexFromHashTx(extendtx *leveldb.Transaction, hash Key) (*EntityExtendedIndex, error)

+ func (db *DB) MustGetEntityIndexFromHash(hash Key) *EntityExtendedIndex

+ type EntityExtendedIndex struct

+ InPlusEdges map[string][]Key

+ OutPlusEdges map[string][]Key

+ PK Key

+ func NewEntityExtendedIndex() *EntityExtendedIndex

+ func (e *EntityExtendedIndex) AddInPlusEdge(predicate, endpoint Key) bool

+ func (e *EntityExtendedIndex) AddOutPlusEdge(predicate, endpoint Key) bool

+ func (z *EntityExtendedIndex) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *EntityExtendedIndex) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *EntityExtendedIndex) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *EntityExtendedIndex) Msgsize() (s int)

+ func (z *EntityExtendedIndex) UnmarshalMsg(bts []byte) (o []byte, err error)

type QueryResult

+ func (z *QueryResult) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *QueryResult) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *QueryResult) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *QueryResult) Msgsize() (s int)

+ func (z *QueryResult) UnmarshalMsg(bts []byte) (o []byte, err error)

type ResultMap

+ func (z *ResultMap) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ResultMap) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z ResultMap) EncodeMsg(en *msgp.Writer) (err error)

+ func (z ResultMap) MarshalMsg(b []byte) (o []byte, err error)

+ func (z ResultMap) Msgsize() (s int)

May 15, 2017

Changes in this version

type DB

+ func (db *DB) Abbreviate(uri turtle.URI) string

+ func (db *DB) Close()

type LinkResultMap

+ func (m LinkResultMap) MarshalJSON() ([]byte, error)

type QueryResult

+ Elapsed time.Duration

+ func (qr QueryResult) DumpToCSV(usePrefixes bool, db *DB, w io.Writer) error

Jan 12, 2017

Changes in this version

type DB

+ func (db *DB) QueryToClassDOT(querystring io.Reader) (string, error)

type Key

+ func (k Key) String() string

Jan 10, 2017

Changes in this version

type Entity

+ func (e *Entity) Less(than btree.Item) bool

+ type Key [4]byte

+ func (k *Key) FromSlice(src []byte)

+ func (k Key) Less(than btree.Item) bool

+ func (z *Key) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Key) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *Key) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *Key) Msgsize() (s int)

+ func (z *Key) UnmarshalMsg(bts []byte) (o []byte, err error)

Jan 3, 2017

Changes in this version

+ const MaxKeyLength

+ const MaxValLength

+ const RESOLVED

+ const UNRESOLVED

+ var ErrKeyTooLong = errors.New("Key is more than 12 bytes")

+ type DB struct

+ func NewDB(cfg *config.Config) (*DB, error)

+ func (db *DB) DumpEntity(ent *Entity)

+ func (db *DB) GetEntity(uri turtle.URI) (*Entity, error)

+ func (db *DB) GetEntityFromHash(hash [4]byte) (*Entity, error)

+ func (db *DB) GetEntityFromHashTx(graphtx *leveldb.Transaction, hash [4]byte) (*Entity, error)

+ func (db *DB) GetEntityTx(graphtx *leveldb.Transaction, uri turtle.URI) (*Entity, error)

+ func (db *DB) GetHash(entity turtle.URI) ([4]byte, error)

+ func (db *DB) GetURI(hash [4]byte) (turtle.URI, error)

+ func (db *DB) LoadDataset(dataset turtle.DataSet) error

+ func (db *DB) MustGetEntityFromHash(hash [4]byte) *Entity

+ func (db *DB) MustGetHash(entity turtle.URI) [4]byte

+ func (db *DB) MustGetURI(hash [4]byte) turtle.URI

+ func (db *DB) MustGetURIStringHash(hash string) turtle.URI

+ func (db *DB) QueryToDOT(querystring io.Reader) (string, error)

+ func (db *DB) RunQuery(q query.Query) QueryResult

+ func (db *DB) UpdateLinks(updates *LinkUpdates) error

+ type Entity struct

+ InEdges map[string][][4]byte

+ OutEdges map[string][][4]byte

+ PK [4]byte

+ func NewEntity() *Entity

+ func (e *Entity) AddInEdge(predicate, endpoint [4]byte) bool

+ func (e *Entity) AddOutEdge(predicate, endpoint [4]byte) bool

+ func (z *Entity) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Entity) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *Entity) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *Entity) Msgsize() (s int)

+ func (z *Entity) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type Item [4]byte

+ func (i Item) Less(than btree.Item) bool

+ type Link struct

+ Key []byte

+ URI turtle.URI

+ Value []byte

+ func (l Link) Valid() bool

+ type LinkResultMap map[turtle.URI]map[string]string

+ type LinkUpdates struct

+ Adding []*Link

+ Removing []*Link

+ func (updates *LinkUpdates) UnmarshalJSON(b []byte) (err error)

+ type NamespaceIndex map[string]string

+ func (z *NamespaceIndex) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *NamespaceIndex) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z NamespaceIndex) EncodeMsg(en *msgp.Writer) (err error)

+ func (z NamespaceIndex) MarshalMsg(b []byte) (o []byte, err error)

+ func (z NamespaceIndex) Msgsize() (s int)

+ type PredIndex map[string]*PredicateEntity

+ func (z *PredIndex) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *PredIndex) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z PredIndex) EncodeMsg(en *msgp.Writer) (err error)

+ func (z PredIndex) MarshalMsg(b []byte) (o []byte, err error)

+ func (z PredIndex) Msgsize() (s int)

+ type PredicateEntity struct

+ Objects map[string]map[string]uint32

+ PK [4]byte

+ Subjects map[string]map[string]uint32

+ func NewPredicateEntity() *PredicateEntity

+ func (e *PredicateEntity) AddSubjectObject(subject, object [4]byte)

+ func (z *PredicateEntity) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *PredicateEntity) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *PredicateEntity) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *PredicateEntity) Msgsize() (s int)

+ func (z *PredicateEntity) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type QueryResult struct

+ Count int

+ Links []LinkResultMap

+ Rows []ResultMap

+ func (qr QueryResult) Dump()

+ type RelshipIndex map[string]string

+ func (z *RelshipIndex) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *RelshipIndex) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z RelshipIndex) EncodeMsg(en *msgp.Writer) (err error)

+ func (z RelshipIndex) MarshalMsg(b []byte) (o []byte, err error)

+ func (z RelshipIndex) Msgsize() (s int)

+ type ResultEntity struct

+ Next map[string]*btree.BTree

+ PK [4]byte

+ func (re ResultEntity) Less(than btree.Item) bool

+ type ResultMap map[string]turtle.URI

+ type ResultRow []turtle.URI

+ func (rr ResultRow) Less(than btree.Item) bool