stream

package

v0.3.1 Latest Latest Go to latest Published: Feb 21, 2023 License: Apache-2.0 Imports: 29 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/apache/skywalking-banyandb

Links

Open Source Insights

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 ¶

type Query
type Service
- func NewService(_ context.Context, metadata metadata.Repo, repo discovery.ServiceRepo, ...) (Service, error)
type Stream

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Query ¶

type Query interface {
	Stream(stream *commonv1.Metadata) (Stream, error)
}

Query allow to retrieve elements in a series of streams.

type Service ¶

type Service interface {
	run.PreRunner
	run.Config
	run.Service
	Query
}

Service allows inspecting the stream elements.

func NewService ¶

func NewService(_ context.Context, metadata metadata.Repo, repo discovery.ServiceRepo, pipeline queue.Queue) (Service, error)

NewService returns a new service.

type Stream ¶

type Stream interface {
	io.Closer
	Shards(entity tsdb.Entity) ([]tsdb.Shard, error)
	Shard(id common.ShardID) (tsdb.Shard, error)
	ParseTagFamily(family string, item tsdb.Item) (*modelv1.TagFamily, error)
	ParseElementID(item tsdb.Item) (string, error)
	GetSchema() *databasev1.Stream
	GetIndexRules() []*databasev1.IndexRule
}

Stream allows inspecting elements' details.

Source Files ¶

View all Source files

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