Documentation
¶
Overview ¶
Package stream implements a time-series-based storage which is consists of a sequence of element. Each element drops in a arbitrary interval. They are immutable, can not be updated or overwritten.
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrStreamNotExist denotes a stream doesn't exist in the metadata repo. ErrStreamNotExist = errors.New("stream doesn't exist") )
Functions ¶
This section is empty.
Types ¶
type Query ¶
type Query interface {
LoadGroup(name string) (schema.Group, bool)
Stream(stream *commonv1.Metadata) (Stream, error)
}
Query allow to retrieve elements in a series of streams.
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.
type Stream ¶
type Stream interface {
io.Closer
GetSchema() *databasev1.Stream
GetIndexRules() []*databasev1.IndexRule
Query(ctx context.Context, opts pbv1.StreamQueryOptions) (pbv1.StreamQueryResult, error)
Sort(ctx context.Context, opts pbv1.StreamSortOptions) (pbv1.StreamSortResult, error)
Filter(ctx context.Context, opts pbv1.StreamFilterOptions) (pbv1.StreamFilterResult, error)
}
Stream allows inspecting elements' details.
Source Files
¶
- block.go
- block_metadata.go
- block_reader.go
- block_writer.go
- elements.go
- flusher.go
- gc.go
- index.go
- introducer.go
- iter.go
- iter_builder.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
- stream.go
- tag.go
- tag_metadata.go
- tstable.go
- write.go
Click to show internal directories.
Click to hide internal directories.