metastore

Documentation

Index

• type ClusterConsensus
• type Field
  • func (f *Field) IdAsBytes() []byte
  • func (f *Field) String() string
• type Store
  • func NewStore() *Store
  • func NewStoreFromJson(data []byte) (*Store, error)
  • func (self *Store) DropDatabase(database string) ([]*Field, error)
  • func (self *Store) DropSeries(database, series string) ([]*Field, error)
  • func (self *Store) GetFieldsForDatabase(database string) []*Field
  • func (self *Store) GetFieldsForSeries(database, series string) []*Field
  • func (self *Store) GetOrSetFieldIds(database string, series []*protocol.Series) error
  • func (self *Store) GetSeriesForDatabase(database string) []string
  • func (self *Store) GetSeriesForDatabaseAndRegex(database string, regex *regexp.Regexp) []string
  • func (self *Store) ReplaceFieldNamesWithFieldIds(database string, series []*protocol.Series) error
  • func (self *Store) SetClusterConsensus(c ClusterConsensus)
  • func (self *Store) ToJson() ([]byte, error)
  • func (self *Store) UpdateFromSnapshot(other *Store)

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

func (f *Field) IdAsBytes() []byte

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)