index

Documentation

Index

• type IndexReader
  • func NewIndexReader(reader *bluge.Reader, version int64) *IndexReader
  • func (r *IndexReader) BlugeReader() *bluge.Reader
  • func (r *IndexReader) Version() int64
• type IndexReaders
  • func NewIndexReaders(logger *zap.Logger) *IndexReaders
  • func (i *IndexReaders) Close(indexName string, shardName string) error
  • func (i *IndexReaders) CloseAll() error
  • func (i *IndexReaders) Contains(indexName string, shardName string) bool
  • func (i *IndexReaders) Get(indexName string, shardName string) (*IndexReader, error)
  • func (i *IndexReaders) Indexes() []string
  • func (i *IndexReaders) Open(indexName string, shardName string, indexMetadata *metastore.IndexMetadata, ...) error
  • func (i *IndexReaders) Reopen(indexName string, shardName string, indexMetadata *metastore.IndexMetadata, ...) error
  • func (i *IndexReaders) Shards(indexName string) []string
  • func (i *IndexReaders) Version(indexName string, shardName string) int64
• type IndexWriters
  • func NewIndexWriters(logger *zap.Logger) *IndexWriters
  • func (i *IndexWriters) Close(indexName string, shardName string) error
  • func (i *IndexWriters) CloseAll() error
  • func (i *IndexWriters) Contains(indexName string, shardName string) bool
  • func (i *IndexWriters) Get(indexName string, shardName string) (*bluge.Writer, error)
  • func (i *IndexWriters) Indexes() []string
  • func (i *IndexWriters) Open(indexName string, shardName string, indexMetadata *metastore.IndexMetadata, ...) error
  • func (i *IndexWriters) Reopen(indexName string, shardName string, indexMetadata *metastore.IndexMetadata, ...) error
  • func (i *IndexWriters) Shards(indexName string) []string

Types

type IndexReader

type IndexReader struct {
	*bluge.Reader
	// contains filtered or unexported fields
}

func NewIndexReader

func NewIndexReader(reader *bluge.Reader, version int64) *IndexReader

func (*IndexReader) BlugeReader

func (r *IndexReader) BlugeReader() *bluge.Reader

func (*IndexReader) Version

func (r *IndexReader) Version() int64

type IndexReaders

type IndexReaders struct {
	// contains filtered or unexported fields
}

func NewIndexReaders

func NewIndexReaders(logger *zap.Logger) *IndexReaders

func (*IndexReaders) Close

func (i *IndexReaders) Close(indexName string, shardName string) error

func (*IndexReaders) CloseAll

func (i *IndexReaders) CloseAll() error

func (*IndexReaders) Contains

func (i *IndexReaders) Contains(indexName string, shardName string) bool

func (*IndexReaders) Get

func (i *IndexReaders) Get(indexName string, shardName string) (*IndexReader, error)

func (*IndexReaders) Indexes

func (i *IndexReaders) Indexes() []string

func (*IndexReaders) Open

func (i *IndexReaders) Open(indexName string, shardName string, indexMetadata *metastore.IndexMetadata, shardMetadata *metastore.ShardMetadata) error

func (*IndexReaders) Reopen

func (i *IndexReaders) Reopen(indexName string, shardName string, indexMetadata *metastore.IndexMetadata, shardMetadata *metastore.ShardMetadata) error

func (*IndexReaders) Shards

func (i *IndexReaders) Shards(indexName string) []string

func (*IndexReaders) Version

func (i *IndexReaders) Version(indexName string, shardName string) int64

type IndexWriters

type IndexWriters struct {
	// contains filtered or unexported fields
}

func NewIndexWriters

func NewIndexWriters(logger *zap.Logger) *IndexWriters

func (*IndexWriters) Close

func (i *IndexWriters) Close(indexName string, shardName string) error

func (*IndexWriters) CloseAll

func (i *IndexWriters) CloseAll() error

func (*IndexWriters) Contains

func (i *IndexWriters) Contains(indexName string, shardName string) bool

func (*IndexWriters) Get

func (i *IndexWriters) Get(indexName string, shardName string) (*bluge.Writer, error)

func (*IndexWriters) Indexes

func (i *IndexWriters) Indexes() []string

func (*IndexWriters) Open

func (i *IndexWriters) Open(indexName string, shardName string, indexMetadata *metastore.IndexMetadata, shardMetadata *metastore.ShardMetadata) error

func (*IndexWriters) Reopen

func (i *IndexWriters) Reopen(indexName string, shardName string, indexMetadata *metastore.IndexMetadata, shardMetadata *metastore.ShardMetadata) error

func (*IndexWriters) Shards

func (i *IndexWriters) Shards(indexName string) []string