database

package

v0.0.3 Latest Latest Go to latest Published: Jan 10, 2020 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/clems4ever/go-graphkb

Links

Open Source Insights

Documentation ¶

Index ¶

type AssetRegistry
- func (ar *AssetRegistry) Get(a knowledge.AssetKey) (int64, bool)
- func (ar *AssetRegistry) Set(a knowledge.AssetKey, idx int64)
type MariaDB
- func NewMariaDB(username string, password string, host string, databaseName string) *MariaDB
type MariaDBCursor
type SourceRelation

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type AssetRegistry ¶

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

AssetIDResolver store ID assets in a cache

func (*AssetRegistry) Get ¶

func (ar *AssetRegistry) Get(a knowledge.AssetKey) (int64, bool)

func (*AssetRegistry) Set ¶

func (ar *AssetRegistry) Set(a knowledge.AssetKey, idx int64)

type MariaDB ¶

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

MariaDB mariadb as graph storage backend

func NewMariaDB ¶

func NewMariaDB(username string, password string, host string, databaseName string) *MariaDB

NewMariaDB create an instance of mariadb

func (*MariaDB) Close ¶

func (m *MariaDB) Close() error

Close close the connection to maria

func (*MariaDB) CountAssets ¶

func (m *MariaDB) CountAssets() (int64, error)

CountAssets count the total number of assets in db.

func (*MariaDB) CountRelations ¶

func (m *MariaDB) CountRelations() (int64, error)

CountRelations count the total number of relations in db.

func (*MariaDB) FlushAll ¶

func (m *MariaDB) FlushAll() error

FlushAll flush the database

func (*MariaDB) InitializeSchema ¶

func (m *MariaDB) InitializeSchema() error

InitializeSchema initialize the schema of the database

func (*MariaDB) ListSources ¶

func (m *MariaDB) ListSources(ctx context.Context) ([]string, error)

func (*MariaDB) LoadSchema ¶

func (m *MariaDB) LoadSchema(ctx context.Context, sourceName string) (schema.SchemaGraph, error)

func (*MariaDB) Query ¶

func (m *MariaDB) Query(ctx context.Context, query *query.QueryIL) (*knowledge.GraphQueryResult, error)

Query the database with provided intermediate query representation

func (*MariaDB) ReadGraph ¶

func (m *MariaDB) ReadGraph(source string, graph *knowledge.Graph) error

ReadGraph read source subgraph

func (*MariaDB) SaveSchema ¶

func (m *MariaDB) SaveSchema(ctx context.Context, sourceName string, schema schema.SchemaGraph) error

func (*MariaDB) UpdateGraph ¶

func (m *MariaDB) UpdateGraph(source string, bulk *knowledge.GraphUpdatesBulk) error

UpdateGraph update graph with bulk of operations

type MariaDBCursor ¶

type MariaDBCursor struct {
	*sql.Rows

	Projections []knowledge.Projection
}

func (*MariaDBCursor) Close ¶

func (mc *MariaDBCursor) Close() error

func (*MariaDBCursor) HasMore ¶

func (mc *MariaDBCursor) HasMore() bool

func (*MariaDBCursor) Read ¶

func (mc *MariaDBCursor) Read(ctx context.Context, doc interface{}) error

type SourceRelation ¶

type SourceRelation struct {
	knowledge.Relation `json:",inline"`
	Source             string `json:"source"`
}

SourceRelation represent a relation coming from a source

Source Files ¶

View all Source files

mariadb.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL