Home
last modified time | relevance | path

Searched refs:QuadWriter (Results 1 – 16 of 16) sorted by relevance

/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/
H A Dimports_pre19.go12 type QuadWriter graph.QuadWriter type
18 graph.QuadWriter anonMember
22 err := h.QuadWriter.Close()
H A Dimports_19.go12 type QuadWriter = graph.QuadWriter talias
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/graph/
H A Dquadwriter.go67 QuadWriter anonMember
75 err := h.QuadWriter.Close()
140 type QuadWriter interface { interface
164 type NewQuadWriterFunc func(QuadStore, Options) (QuadWriter, error)
175 func NewQuadWriter(name string, qs QuadStore, opts Options) (QuadWriter, error) {
200 func NewWriter(qs QuadWriter) BatchWriter { argument
205 qs QuadWriter
265 func NewRemover(qs QuadWriter) BatchWriter { argument
270 qs QuadWriter
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/internal/
H A Dload.go21 func Load(qw graph.QuadWriter, batch int, path, typ string) error { argument
124 func DecompressAndLoad(qw graph.QuadWriter, batch int, path, typ string, writerFunc func(graph.Quad… argument
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/internal/http/
H A Dwrite.go93 if err = h.QuadWriter.AddQuadSet(quads); err != nil {
128 qw := graph.NewWriter(h.QuadWriter)
163 err = h.QuadWriter.RemoveQuad(q)
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/writer/
H A Dsingle.go31 func NewSingle(qs graph.QuadStore, opts graph.IgnoreOpts) (graph.QuadWriter, error) {
38 func NewSingleReplication(qs graph.QuadStore, opts graph.Options) (graph.QuadWriter, error) {
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/cmd/cayley/command/
H A Ddatabase.go116 if err = internal.Load(h.QuadWriter, quad.DefaultBatch, load, typ); err != nil {
209 return &graph.Handle{QuadStore: qs, QuadWriter: qw}, nil
246 if err = internal.Load(h.QuadWriter, quad.DefaultBatch, load, typ); err != nil {
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/internal/repl/
H A Drepl.go168 err = h.QuadWriter.AddQuad(quad)
182 err = h.QuadWriter.RemoveQuad(quad)
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/server/http/
H A Dcommon.go44 return &graph.Handle{QuadStore: qs, QuadWriter: qw}, nil
H A Dapi_v2_test.go42 qw, err := cli.QuadWriter()
H A Dapi_v2.go196 qw := graph.NewWriter(h.QuadWriter)
236 qw := graph.NewRemover(h.QuadWriter)
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/graph/graphtest/testutil/
H A Dtestutil.go42 …eWriter(t testing.TB, qs graph.QuadStore, opts graph.Options, data ...quad.Quad) graph.QuadWriter {
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/appengine/
H A Dappengine.go116 return &graph.Handle{QuadStore: qs, QuadWriter: qw}, nil
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/client/
H A Dclient.go73 func (c *Client) QuadWriter() (quad.WriteCloser, error) { func
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/graph/memstore/
H A Dquadstore_test.go58 func makeTestStore(data []quad.Quad) (*QuadStore, graph.QuadWriter, []pair) {
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/graph/graphtest/
H A Dintegration.go472 h := &graph.Handle{QuadStore: qs, QuadWriter: qw}
479 err = internal.Load(h.QuadWriter, 0, filepath.Join(p, "../../data/30kmoviedata.nq.gz"), format)