Help us shape the future of Go! Take the 2026 Go Developer Survey

pilosa

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 1, 2019 License: Apache-2.0 Imports: 26 Imported by: 1

Documentation

Index

Constants

View Source
const (
	// DriverID the unique name of the pilosa driver.
	DriverID = "pilosa"

	// IndexNamePrefix the pilosa's indexes prefix
	IndexNamePrefix = "idx"

	// FieldNamePrefix the pilosa's field prefix
	FieldNamePrefix = "fld"

	// ConfigFileName is the extension of an index config file.
	ConfigFileName = "config.yml"

	// ProcessingFileName is the extension of the lock/processing index file.
	ProcessingFileName = ".processing"

	// MappingFileNamePrefix is the prefix in mapping file <prefix>-<mappingKey><extension>
	MappingFileNamePrefix = "map"
	// MappingFileNameExtension is the extension in mapping file <prefix>-<mappingKey><extension>
	MappingFileNameExtension = ".db"
)

Variables

View Source
var (
	// RowsGauge describes a metric that takes number of indexes rows over time.
	RowsGauge = discard.NewGauge()
	// TotalHistogram  describes a metric that takes repeated observations of the total time to index values.
	TotalHistogram = discard.NewHistogram()
	// MappingHistogram  describes a metric that takes repeated observations of the total time to map values.
	MappingHistogram = discard.NewHistogram()
	// BitmapHistogram  describes a metric that takes repeated observations of the total time to store values in bitmaps
	BitmapHistogram = discard.NewHistogram()
)

Functions

This section is empty.

Types

type Driver

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

Driver implements sql.IndexDriver interface.

func NewDriver

func NewDriver(root string) *Driver

NewDriver returns a new instance of pilosa.Driver which satisfies sql.IndexDriver interface

func (*Driver) Create

func (d *Driver) Create(
	db, table, id string,
	expressions []sql.Expression,
	config map[string]string,
) (sql.Index, error)

Create a new index.

func (*Driver) Delete

func (d *Driver) Delete(i sql.Index, partitions sql.PartitionIter) error

Delete the given index for all partitions in the iterator.

func (*Driver) ID

func (*Driver) ID() string

ID returns the unique name of the driver.

func (*Driver) LoadAll

func (d *Driver) LoadAll(db, table string) ([]sql.Index, error)

LoadAll loads all indexes for given db and table

func (*Driver) Save

func (d *Driver) Save(
	ctx *sql.Context,
	i sql.Index,
	iter sql.PartitionIndexKeyValueIter,
) (err error)

Save the given index (mapping and bitmap)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL