bluge_db

Documentation

Index

• type BlugeDB
  • func NewDB(name string, path string) *BlugeDB
  • func (b *BlugeDB) Close() error
  • func (b *BlugeDB) Path() string
  • func (b *BlugeDB) QueryDB(ctx context.Context, query IndexQuery, callback segment.StoredFieldVisitor) error
  • func (b *BlugeDB) WriteToDB(ctx context.Context, writes TableWrites) error
• type BlugeWriteBatch
  • func NewWriteBatch() *BlugeWriteBatch
  • func (b *BlugeWriteBatch) Add(tableName, hashValue string, rangeValue []byte, value []byte)
  • func (b *BlugeWriteBatch) AddJson(tableName string, data []byte)
  • func (b *BlugeWriteBatch) Delete(tableName, hashValue string, rangeValue []byte)
• type IndexQuery
• type TableWrites

Types

type BlugeDB

type BlugeDB struct {
	Name   string
	Folder string // snpseg
}

func NewDB

func NewDB(name string, path string) *BlugeDB

func (*BlugeDB) Close

func (b *BlugeDB) Close() error

func (*BlugeDB) Path

func (b *BlugeDB) Path() string

func (*BlugeDB) QueryDB

func (b *BlugeDB) QueryDB(ctx context.Context, query IndexQuery, callback segment.StoredFieldVisitor) error

ctx context.Context, query chunk.IndexQuery, callback func(chunk.IndexQuery, chunk.ReadBatch) (shouldContinue bool)

func (*BlugeDB) WriteToDB

func (b *BlugeDB) WriteToDB(ctx context.Context, writes TableWrites) error

type BlugeWriteBatch

type BlugeWriteBatch struct {
	Writes map[string]TableWrites
}

func NewWriteBatch

func NewWriteBatch() *BlugeWriteBatch

func (*BlugeWriteBatch) Add

func (b *BlugeWriteBatch) Add(tableName, hashValue string, rangeValue []byte, value []byte)

func (*BlugeWriteBatch) AddJson

func (b *BlugeWriteBatch) AddJson(tableName string, data []byte)

func (*BlugeWriteBatch) Delete

func (b *BlugeWriteBatch) Delete(tableName, hashValue string, rangeValue []byte)

type IndexQuery

type IndexQuery struct {
	TableName string
	Query     bluge.Query
}

type TableWrites

type TableWrites struct {
	Puts map[string]interface{} // puts map[string][]byte

}