directory

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 NewMinioDirectoryWithUri(uri string, lockUri string, logger *zap.Logger) *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 NewS3DirectoryWithUri(uri string, lockUri string, logger *zap.Logger) *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

Variables

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 DeleteDirectory(uri string) error

func DirectoryExists

func DirectoryExists(uri string) (bool, error)

func FileSystemIndexConfig

func FileSystemIndexConfig(uri string, logger *zap.Logger) bluge.Config

func InMemoryIndexConfig

func InMemoryIndexConfig(uri string, logger *zap.Logger) bluge.Config

func MinioIndexConfig

func MinioIndexConfig(uri string, lockUri string, logger *zap.Logger) bluge.Config

func NewFileSystemDirectoryWithUri

func NewFileSystemDirectoryWithUri(uri string, logger *zap.Logger) *index.FileSystemDirectory

func NewInMemoryDirectoryWithUri

func NewInMemoryDirectoryWithUri(uri string, logger *zap.Logger) *index.InMemoryDirectory

func NewIndexConfigWithUri

func NewIndexConfigWithUri(uri string, lockUri string, logger *zap.Logger) (bluge.Config, error)

func S3IndexConfig

func S3IndexConfig(uri string, lockUri string, logger *zap.Logger) bluge.Config

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) List

func (d *MinioDirectory) List(kind string) ([]uint64, error)

func (*MinioDirectory) Load

func (d *MinioDirectory) Load(kind string, id uint64) (*segment.Data, io.Closer, error)

func (*MinioDirectory) Lock

func (d *MinioDirectory) Lock() error

func (*MinioDirectory) Persist

func (d *MinioDirectory) Persist(kind string, id uint64, w index.WriterTo, closeCh chan struct{}) error

func (*MinioDirectory) Remove

func (d *MinioDirectory) Remove(kind string, id uint64) 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

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

func NewS3DirectoryWithUri

func NewS3DirectoryWithUri(uri string, lockUri string, logger *zap.Logger) *S3Directory

func (*S3Directory) List

func (d *S3Directory) List(kind string) ([]uint64, error)

func (*S3Directory) Load

func (d *S3Directory) Load(kind string, id uint64) (*segment.Data, io.Closer, error)

func (*S3Directory) Lock

func (d *S3Directory) Lock() error

func (*S3Directory) Persist

func (d *S3Directory) Persist(kind string, id uint64, w index.WriterTo, closeCh chan struct{}) error

func (*S3Directory) Remove

func (d *S3Directory) Remove(kind string, id uint64) error

func (*S3Directory) Setup

func (d *S3Directory) Setup(readOnly bool) error

func (*S3Directory) Stats

func (d *S3Directory) Stats() (uint64, uint64)

func (*S3Directory) Sync

func (d *S3Directory) Sync() error

func (*S3Directory) Unlock

func (d *S3Directory) Unlock() error

type SchemeType

type SchemeType int

const (
	SchemeTypeUnknown SchemeType = iota
	SchemeTypeMem
	SchemeTypeFile
	SchemeTypeMinio
	SchemeTypeS3
)