← Back to branch summary

~ubuntu-branches/debian/sid/golang-github-blevesearch-bleve/sid

« back to all changes in this revision

Viewing changes to index/store/boltdb/reader.go

  • Committer: Package Import Robot
  • Author(s): Michael Lustfield
  • Date: 2017-03-30 16:06:03 UTC
  • Revision ID: package-import@ubuntu.com-20170330160603-0oogmb960l7918jx
Tags: upstream-0.5.0+git20170324.202.4702785f
Import upstream version 0.5.0+git20170324.202.4702785f

Show diffs side-by-side

added added

removed removed

Lines of Context:
index/store/boltdb/reader.go
 
1
//  Copyright (c) 2014 Couchbase, Inc.
 
2
//
 
3
// Licensed under the Apache License, Version 2.0 (the "License");
 
4
// you may not use this file except in compliance with the License.
 
5
// You may obtain a copy of the License at
 
6
//
 
7
//              http://www.apache.org/licenses/LICENSE-2.0
 
8
//
 
9
// Unless required by applicable law or agreed to in writing, software
 
10
// distributed under the License is distributed on an "AS IS" BASIS,
 
11
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 
12
// See the License for the specific language governing permissions and
 
13
// limitations under the License.
 
14
 
 
15
package boltdb
 
16
 
 
17
import (
 
18
        "github.com/blevesearch/bleve/index/store"
 
19
        "github.com/boltdb/bolt"
 
20
)
 
21
 
 
22
type Reader struct {
 
23
        store  *Store
 
24
        tx     *bolt.Tx
 
25
        bucket *bolt.Bucket
 
26
}
 
27
 
 
28
func (r *Reader) Get(key []byte) ([]byte, error) {
 
29
        var rv []byte
 
30
        v := r.bucket.Get(key)
 
31
        if v != nil {
 
32
                rv = make([]byte, len(v))
 
33
                copy(rv, v)
 
34
        }
 
35
        return rv, nil
 
36
}
 
37
 
 
38
func (r *Reader) MultiGet(keys [][]byte) ([][]byte, error) {
 
39
        return store.MultiGet(r, keys)
 
40
}
 
41
 
 
42
func (r *Reader) PrefixIterator(prefix []byte) store.KVIterator {
 
43
        cursor := r.bucket.Cursor()
 
44
 
 
45
        rv := &Iterator{
 
46
                store:  r.store,
 
47
                tx:     r.tx,
 
48
                cursor: cursor,
 
49
                prefix: prefix,
 
50
        }
 
51
 
 
52
        rv.Seek(prefix)
 
53
        return rv
 
54
}
 
55
 
 
56
func (r *Reader) RangeIterator(start, end []byte) store.KVIterator {
 
57
        cursor := r.bucket.Cursor()
 
58
 
 
59
        rv := &Iterator{
 
60
                store:  r.store,
 
61
                tx:     r.tx,
 
62
                cursor: cursor,
 
63
                start:  start,
 
64
                end:    end,
 
65
        }
 
66
 
 
67
        rv.Seek(start)
 
68
        return rv
 
69
}
 
70
 
 
71
func (r *Reader) Close() error {
 
72
        return r.tx.Rollback()
 
73
}