internal

Documentation

Index

• func DecompressAndLoad(qw graph.QuadWriter, cfg *config.Config, path, typ string, ...) error
• func Decompressor(r io.Reader) (io.Reader, error)
• func Dump(qs graph.QuadStore, outFile, typ string) error
• func Load(qw graph.QuadWriter, cfg *config.Config, path, typ string) error

Functions

func DecompressAndLoad

func DecompressAndLoad(qw graph.QuadWriter, cfg *config.Config, path, typ string, loadFn func(graph.QuadWriter, *config.Config, quad.Unmarshaler) error) error

DecompressAndLoad will load or fetch a graph from the given path, decompress it, and then call the given load function to process the decompressed graph. If no loadFn is provided, db.Load is called.

func Decompressor

func Decompressor(r io.Reader) (io.Reader, error)

Decompressor detects the file type of an io.Reader between bzip, gzip, or raw quad file.

func Dump

func Dump(qs graph.QuadStore, outFile, typ string) error

Dump the content of the database into a file based on a few different formats

func Load

func Load(qw graph.QuadWriter, cfg *config.Config, path, typ string) error

Load loads a graph from the given path and write it to qw. See DecompressAndLoad for more information.