From 6d4738cf0ce78c8bf62d1e73289077366d0b5268 Mon Sep 17 00:00:00 2001 From: Barak Michener Date: Wed, 6 Aug 2014 16:24:31 -0400 Subject: [PATCH] convert to using real quads --- graph/quadwriter.go | 6 +++--- writer/single.go | 12 ++++++------ 2 files changed, 9 insertions(+), 9 deletions(-) diff --git a/graph/quadwriter.go b/graph/quadwriter.go index 782a2e6..5cfd171 100644 --- a/graph/quadwriter.go +++ b/graph/quadwriter.go @@ -48,14 +48,14 @@ var ErrQuadNotExist = errors.New("Quad doesn't exist") type QuadWriter interface { // Add a quad to the store. - AddQuad(*quad.Quad) error + AddQuad(quad.Quad) error // Add a set of quads to the store, atomically if possible. - AddQuadSet([]*quad.Quad) error + AddQuadSet([]quad.Quad) error // Removes a quad matching the given one from the database, // if it exists. Does nothing otherwise. - RemoveQuad(*quad.Quad) error + RemoveQuad(quad.Quad) error } type NewQuadWriterFunc func(TripleStore, Options) (QuadWriter, error) diff --git a/writer/single.go b/writer/single.go index a455e02..51641ca 100644 --- a/writer/single.go +++ b/writer/single.go @@ -44,23 +44,23 @@ func (s *Single) AcquireNextID() int64 { return id } -func (s *Single) AddQuad(q *quad.Quad) error { +func (s *Single) AddQuad(q quad.Quad) error { deltas := make([]*graph.Delta, 1) deltas[0] = &graph.Delta{ ID: s.AcquireNextID(), - Quad: *q, + Quad: q, Action: graph.Add, Timestamp: time.Now(), } return s.ts.ApplyDeltas(deltas) } -func (s *Single) AddQuadSet(set []*quad.Quad) error { +func (s *Single) AddQuadSet(set []quad.Quad) error { deltas := make([]*graph.Delta, len(set)) for i, q := range set { deltas[i] = &graph.Delta{ ID: s.AcquireNextID(), - Quad: *q, + Quad: q, Action: graph.Add, Timestamp: time.Now(), } @@ -69,11 +69,11 @@ func (s *Single) AddQuadSet(set []*quad.Quad) error { return nil } -func (s *Single) RemoveQuad(q *quad.Quad) error { +func (s *Single) RemoveQuad(q quad.Quad) error { deltas := make([]*graph.Delta, 1) deltas[0] = &graph.Delta{ ID: s.AcquireNextID(), - Quad: *q, + Quad: q, Action: graph.Delete, Timestamp: time.Now(), }