bleve

Documentation

Index

• func NewBleveDAO(boltDB boltdb.DB, bleveIndex indexer.Indexer) docstore.DAO
• type BleveServer
  • func NewBleveEngine(db boltdb.DB, index indexer.Indexer) *BleveServer
  • func (s *BleveServer) CloseAndDrop(ctx context.Context) error
  • func (s *BleveServer) CountDocuments(ctx context.Context, storeID string, query *proto.DocumentQuery) (int, error)
  • func (s *BleveServer) DeleteDocument(ctx context.Context, storeID string, docID string) error
  • func (s *BleveServer) DeleteDocuments(ctx context.Context, storeID string, query *proto.DocumentQuery) (int, error)
  • func (s *BleveServer) PutDocument(ctx context.Context, storeID string, doc *proto.Document) error
  • func (s *BleveServer) QueryDocuments(ctx context.Context, storeID string, query *proto.DocumentQuery) (chan *proto.Document, error)
  • func (s *BleveServer) Reset() error
• type BoltStore
  • func (s *BoltStore) DeleteDocument(storeID string, docID string) error
  • func (s *BoltStore) GetDocument(ctx context.Context, storeID string, docId string) (*docstore.Document, error)
  • func (s *BoltStore) GetStore(tx *bolt.Tx, storeID string, mode string) (*bolt.Bucket, error)
  • func (s *BoltStore) ListDocuments(storeID string, query *docstore.DocumentQuery) (chan *docstore.Document, error)
  • func (s *BoltStore) ListStores(context.Context) ([]string, error)
  • func (s *BoltStore) PutDocument(ctx context.Context, storeID string, doc *docstore.Document) error
• type IndexableDoc
  • func (i IndexableDoc) IndexID() string

Functions

func NewBleveDAO

func NewBleveDAO(boltDB boltdb.DB, bleveIndex indexer.Indexer) docstore.DAO

Types

type BleveServer

type BleveServer struct {
	// Internal Bolt
	*BoltStore
	// Internal Bleve database
	Engine indexer.Indexer
}

func NewBleveEngine

func NewBleveEngine(db boltdb.DB, index indexer.Indexer) *BleveServer

func (*BleveServer) CloseAndDrop

func (s *BleveServer) CloseAndDrop(ctx context.Context) error

func (*BleveServer) CountDocuments

func (s *BleveServer) CountDocuments(ctx context.Context, storeID string, query *proto.DocumentQuery) (int, error)

func (*BleveServer) DeleteDocument

func (s *BleveServer) DeleteDocument(ctx context.Context, storeID string, docID string) error

func (*BleveServer) DeleteDocuments

func (s *BleveServer) DeleteDocuments(ctx context.Context, storeID string, query *proto.DocumentQuery) (int, error)

func (*BleveServer) PutDocument

func (s *BleveServer) PutDocument(ctx context.Context, storeID string, doc *proto.Document) error

func (*BleveServer) QueryDocuments

func (s *BleveServer) QueryDocuments(ctx context.Context, storeID string, query *proto.DocumentQuery) (chan *proto.Document, error)

func (*BleveServer) Reset

func (s *BleveServer) Reset() error

type BoltStore

type BoltStore struct {
	// Internal DB
	boltdb.DB
	// Path to the DB file
	DbPath string
}

func (*BoltStore) DeleteDocument

func (s *BoltStore) DeleteDocument(storeID string, docID string) error

func (*BoltStore) GetDocument

func (s *BoltStore) GetDocument(ctx context.Context, storeID string, docId string) (*docstore.Document, error)

func (*BoltStore) GetStore

func (s *BoltStore) GetStore(tx *bolt.Tx, storeID string, mode string) (*bolt.Bucket, error)

func (*BoltStore) ListDocuments

func (s *BoltStore) ListDocuments(storeID string, query *docstore.DocumentQuery) (chan *docstore.Document, error)

func (*BoltStore) ListStores

func (s *BoltStore) ListStores(context.Context) ([]string, error)

ListStores list all buckets

func (*BoltStore) PutDocument

func (s *BoltStore) PutDocument(ctx context.Context, storeID string, doc *docstore.Document) error

type IndexableDoc

type IndexableDoc map[string]any

func (IndexableDoc) IndexID

func (i IndexableDoc) IndexID() string