Documentation
¶
Overview ¶
Package measure implements a time-series-based storage which is consists of a sequence of data points. Each data point contains tags and fields. They arrive in a fixed interval. A data point could be updated by one with the identical entity(series_id) and timestamp.
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrMeasureNotExist denotes a measure doesn't exist in the metadata repo. ErrMeasureNotExist = errors.New("measure doesn't exist") )
Functions ¶
This section is empty.
Types ¶
type Measure ¶
type Measure interface {
io.Closer
Query(ctx context.Context, opts pbv1.MeasureQueryOptions) (pbv1.MeasureQueryResult, error)
GetSchema() *databasev1.Measure
GetIndexRules() []*databasev1.IndexRule
SetSchema(schema *databasev1.Measure)
}
Measure allows inspecting measure data points' details.
type Query ¶
type Query interface {
LoadGroup(name string) (resourceSchema.Group, bool)
Measure(measure *commonv1.Metadata) (Measure, error)
}
Query allow to retrieve measure data points.
type SchemaService ¶ added in v0.5.0
type SchemaService interface {
Query
Close()
}
SchemaService allows querying schema information.
func NewPortableRepository ¶ added in v0.5.0
func NewPortableRepository(metadata metadata.Repo, l *logger.Logger) SchemaService
NewPortableRepository creates a new portable repository.
Source Files
¶
- block.go
- block_metadata.go
- block_reader.go
- block_writer.go
- column.go
- column_metadata.go
- datapoints.go
- flusher.go
- gc.go
- introducer.go
- measure.go
- merger.go
- merger_policy.go
- metadata.go
- part.go
- part_iter.go
- part_metadata.go
- primary_metadata.go
- query.go
- service.go
- snapshot.go
- topn.go
- tstable.go
- write.go
Click to show internal directories.
Click to hide internal directories.