metastore

package
v0.8.8 Latest Latest
Warning

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

Go to latest
Published: Dec 28, 2014 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClusterConsensus

type ClusterConsensus interface {
	// Will return a collection of series objects that have their name, fields, and fieldIds set.
	// This can be used to set the field ids and fill the cache.
	GetOrSetFieldIdsForSeries(database string, series []*protocol.Series) ([]*protocol.Series, error)
}

type Field

type Field struct {
	Id   uint64
	Name string
}

func (*Field) String

func (f *Field) String() string

type Store

type Store struct {

	// Map of databases > series > fields
	StringsToIds map[string]map[string]map[string]uint64
	// Map of ids to the field names. Don't need to know which database or series
	// they track to since we have that information elsewhere
	LastIdUsed uint64
	// contains filtered or unexported fields
}

func NewStore

func NewStore() *Store

func NewStoreFromJson

func NewStoreFromJson(data []byte) (*Store, error)

func (*Store) DropDatabase

func (self *Store) DropDatabase(database string) ([]*Field, error)

func (*Store) DropSeries

func (self *Store) DropSeries(database, series string) ([]*Field, error)

func (*Store) GetFieldsForDatabase

func (self *Store) GetFieldsForDatabase(database string) []*Field

func (*Store) GetFieldsForSeries

func (self *Store) GetFieldsForSeries(database, series string) []*Field

func (*Store) GetOrSetFieldIds

func (self *Store) GetOrSetFieldIds(database string, series []*protocol.Series) error

func (*Store) GetSeriesForDatabase

func (self *Store) GetSeriesForDatabase(database string) []string

func (*Store) GetSeriesForDatabaseAndRegex

func (self *Store) GetSeriesForDatabaseAndRegex(database string, regex *regexp.Regexp) []string

func (*Store) ReplaceFieldNamesWithFieldIds

func (self *Store) ReplaceFieldNamesWithFieldIds(database string, series []*protocol.Series) error

func (*Store) SetClusterConsensus

func (self *Store) SetClusterConsensus(c ClusterConsensus)

func (*Store) ToJson

func (self *Store) ToJson() ([]byte, error)

func (*Store) UpdateFromSnapshot

func (self *Store) UpdateFromSnapshot(other *Store)

Jump to

Keyboard shortcuts

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