Documentation ¶
Index ¶
- Variables
- func DeleteDirectory(uri string) error
- func DirectoryExists(uri string) (bool, error)
- func FileSystemIndexConfig(uri string, logger *zap.Logger) bluge.Config
- func InMemoryIndexConfig(uri string, logger *zap.Logger) bluge.Config
- func MinioIndexConfig(uri string, lockUri string, logger *zap.Logger) bluge.Config
- func NewFileSystemDirectoryWithUri(uri string, logger *zap.Logger) *index.FileSystemDirectory
- func NewInMemoryDirectoryWithUri(uri string, logger *zap.Logger) *index.InMemoryDirectory
- func NewIndexConfigWithUri(uri string, lockUri string, logger *zap.Logger) (bluge.Config, error)
- func S3IndexConfig(uri string, lockUri string, logger *zap.Logger) bluge.Config
- type MinioDirectory
- func (d *MinioDirectory) List(kind string) ([]uint64, error)
- func (d *MinioDirectory) Load(kind string, id uint64) (*segment.Data, io.Closer, error)
- func (d *MinioDirectory) Lock() error
- func (d *MinioDirectory) Persist(kind string, id uint64, w index.WriterTo, closeCh chan struct{}) error
- func (d *MinioDirectory) Remove(kind string, id uint64) error
- func (d *MinioDirectory) Setup(readOnly bool) error
- func (d *MinioDirectory) Stats() (uint64, uint64)
- func (d *MinioDirectory) Sync() error
- func (d *MinioDirectory) Unlock() error
- type S3Directory
- func (d *S3Directory) List(kind string) ([]uint64, error)
- func (d *S3Directory) Load(kind string, id uint64) (*segment.Data, io.Closer, error)
- func (d *S3Directory) Lock() error
- func (d *S3Directory) Persist(kind string, id uint64, w index.WriterTo, closeCh chan struct{}) error
- func (d *S3Directory) Remove(kind string, id uint64) error
- func (d *S3Directory) Setup(readOnly bool) error
- func (d *S3Directory) Stats() (uint64, uint64)
- func (d *S3Directory) Sync() error
- func (d *S3Directory) Unlock() error
- type SchemeType
Constants ¶
This section is empty.
Variables ¶
View Source
var ( SchemeType_name = map[SchemeType]string{ SchemeTypeUnknown: "unknown", SchemeTypeMem: "mem", SchemeTypeFile: "file", SchemeTypeMinio: "minio", SchemeTypeS3: "s3", } SchemeType_value = map[string]SchemeType{ "unknown": SchemeTypeUnknown, "mem": SchemeTypeMem, "file": SchemeTypeFile, "minio": SchemeTypeMinio, "s3": SchemeTypeS3, } )
Enum value maps for SchemeType.
Functions ¶
func DeleteDirectory ¶
func DirectoryExists ¶
func FileSystemIndexConfig ¶
func MinioIndexConfig ¶
func NewFileSystemDirectoryWithUri ¶
func NewFileSystemDirectoryWithUri(uri string, logger *zap.Logger) *index.FileSystemDirectory
func NewInMemoryDirectoryWithUri ¶
func NewInMemoryDirectoryWithUri(uri string, logger *zap.Logger) *index.InMemoryDirectory
func NewIndexConfigWithUri ¶
Types ¶
type MinioDirectory ¶
type MinioDirectory struct {
// contains filtered or unexported fields
}
func NewMinioDirectoryWithUri ¶
func NewMinioDirectoryWithUri(uri string, lockUri string, logger *zap.Logger) *MinioDirectory
func (*MinioDirectory) Lock ¶
func (d *MinioDirectory) Lock() error
func (*MinioDirectory) Setup ¶
func (d *MinioDirectory) Setup(readOnly bool) error
func (*MinioDirectory) Stats ¶
func (d *MinioDirectory) Stats() (uint64, uint64)
func (*MinioDirectory) Sync ¶
func (d *MinioDirectory) Sync() error
func (*MinioDirectory) Unlock ¶
func (d *MinioDirectory) Unlock() error
type S3Directory ¶ added in v0.3.0
type S3Directory struct {
// contains filtered or unexported fields
}
func NewS3DirectoryWithUri ¶ added in v0.3.0
func NewS3DirectoryWithUri(uri string, lockUri string, logger *zap.Logger) *S3Directory
func (*S3Directory) List ¶ added in v0.3.0
func (d *S3Directory) List(kind string) ([]uint64, error)
func (*S3Directory) Lock ¶ added in v0.3.0
func (d *S3Directory) Lock() error
func (*S3Directory) Remove ¶ added in v0.3.0
func (d *S3Directory) Remove(kind string, id uint64) error
func (*S3Directory) Setup ¶ added in v0.3.0
func (d *S3Directory) Setup(readOnly bool) error
func (*S3Directory) Stats ¶ added in v0.3.0
func (d *S3Directory) Stats() (uint64, uint64)
func (*S3Directory) Sync ¶ added in v0.3.0
func (d *S3Directory) Sync() error
func (*S3Directory) Unlock ¶ added in v0.3.0
func (d *S3Directory) Unlock() error
type SchemeType ¶
type SchemeType int
const ( SchemeTypeUnknown SchemeType = iota SchemeTypeMem SchemeTypeFile SchemeTypeMinio SchemeTypeS3 )
Click to show internal directories.
Click to hide internal directories.