From 259f5ac3b9c96fbf77c5fbb2b6d96db9986546ee Mon Sep 17 00:00:00 2001 From: Cody Soyland Date: Thu, 5 Jul 2018 21:53:29 -0500 Subject: [PATCH] Unexport Row.InvalidateCount --- executor.go | 8 ++++---- fragment.go | 2 +- row.go | 6 +++--- 3 files changed, 8 insertions(+), 8 deletions(-) diff --git a/executor.go b/executor.go index c0513b6ae..34eca4026 100644 --- a/executor.go +++ b/executor.go @@ -661,7 +661,7 @@ func (e *executor) executeDifferenceShard(ctx context.Context, index string, c * other = other.Difference(row) } } - other.InvalidateCount() + other.invalidateCount() return other, nil } @@ -715,7 +715,7 @@ func (e *executor) executeIntersectShard(ctx context.Context, index string, c *p other = other.intersect(row) } } - other.InvalidateCount() + other.invalidateCount() return other, nil } @@ -937,7 +937,7 @@ func (e *executor) executeUnionShard(ctx context.Context, index string, c *pql.C other = other.Union(row) } } - other.InvalidateCount() + other.invalidateCount() return other, nil } @@ -956,7 +956,7 @@ func (e *executor) executeXorShard(ctx context.Context, index string, c *pql.Cal other = other.Xor(row) } } - other.InvalidateCount() + other.invalidateCount() return other, nil } diff --git a/fragment.go b/fragment.go index 1614c2163..dc7ded5b8 100644 --- a/fragment.go +++ b/fragment.go @@ -349,7 +349,7 @@ func (f *fragment) unprotectedRow(rowID uint64, checkRowCache bool, updateRowCac writable: false, }}, } - row.InvalidateCount() + row.invalidateCount() if updateRowCache { f.rowCache.Add(rowID, row) diff --git a/row.go b/row.go index 125fec08c..109dbc296 100644 --- a/row.go +++ b/row.go @@ -63,7 +63,7 @@ func (r *Row) Merge(other *Row) { } r.segments = segments - r.InvalidateCount() + r.invalidateCount() } // intersectionCount returns the number of intersections between r and other. @@ -208,8 +208,8 @@ func (r *Row) createSegmentIfNotExists(shard uint64) *RowSegment { return &r.segments[i] } -// InvalidateCount updates the cached count in the row. -func (r *Row) InvalidateCount() { +// invalidateCount updates the cached count in the row. +func (r *Row) invalidateCount() { for i := range r.segments { r.segments[i].InvalidateCount() }