diff --git a/boltdb/attrstore.go b/boltdb/attrstore.go index 40d478f3a..3849e0964 100644 --- a/boltdb/attrstore.go +++ b/boltdb/attrstore.go @@ -63,8 +63,8 @@ func (c *attrCache) Set(id uint64, attrs map[string]interface{}) { c.attrs[id] = attrs } -// AttrStore represents a storage layer for attributes. -type AttrStore struct { +// attrStore represents a storage layer for attributes. +type attrStore struct { mu sync.RWMutex path string db *bolt.DB @@ -80,17 +80,17 @@ func NewAttrCache() *attrCache { // NewAttrStore returns a new instance of AttrStore. func NewAttrStore(path string) pilosa.AttrStore { - return &AttrStore{ + return &attrStore{ path: path, attrCache: NewAttrCache(), } } // Path returns path to the store's data file. -func (s *AttrStore) Path() string { return s.path } +func (s *attrStore) Path() string { return s.path } // Open opens and initializes the store. -func (s *AttrStore) Open() error { +func (s *attrStore) Open() error { // Open storage. db, err := bolt.Open(s.path, 0666, &bolt.Options{Timeout: 1 * time.Second}) if err != nil { @@ -112,7 +112,7 @@ func (s *AttrStore) Open() error { } // Close closes the store. -func (s *AttrStore) Close() error { +func (s *attrStore) Close() error { if s.db != nil { s.db.Close() } @@ -120,7 +120,7 @@ func (s *AttrStore) Close() error { } // Attrs returns a set of attributes by ID. -func (s *AttrStore) Attrs(id uint64) (m map[string]interface{}, err error) { +func (s *attrStore) Attrs(id uint64) (m map[string]interface{}, err error) { s.mu.RLock() defer s.mu.RUnlock() @@ -147,7 +147,7 @@ func (s *AttrStore) Attrs(id uint64) (m map[string]interface{}, err error) { } // SetAttrs sets attribute values for a given ID. -func (s *AttrStore) SetAttrs(id uint64, m map[string]interface{}) error { +func (s *attrStore) SetAttrs(id uint64, m map[string]interface{}) error { // Ignore empty maps. if len(m) == 0 { return nil @@ -184,7 +184,7 @@ func (s *AttrStore) SetAttrs(id uint64, m map[string]interface{}) error { } // SetBulkAttrs sets attribute values for a set of ids. -func (s *AttrStore) SetBulkAttrs(m map[uint64]map[string]interface{}) error { +func (s *attrStore) SetBulkAttrs(m map[uint64]map[string]interface{}) error { s.mu.Lock() defer s.mu.Unlock() @@ -220,7 +220,7 @@ func (s *AttrStore) SetBulkAttrs(m map[uint64]map[string]interface{}) error { } // Blocks returns a list of all blocks in the store. -func (s *AttrStore) Blocks() ([]pilosa.AttrBlock, error) { +func (s *attrStore) Blocks() ([]pilosa.AttrBlock, error) { tx, err := s.db.Begin(false) if err != nil { return nil, errors.Wrap(err, "starting transaction") @@ -251,7 +251,7 @@ func (s *AttrStore) Blocks() ([]pilosa.AttrBlock, error) { } // BlockData returns all data for a single block. -func (s *AttrStore) BlockData(i uint64) (map[uint64]map[string]interface{}, error) { +func (s *attrStore) BlockData(i uint64) (map[uint64]map[string]interface{}, error) { m := make(map[uint64]map[string]interface{}) // Start read-only transaction.