stream

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Oct 17, 2023 License: Apache-2.0 Imports: 35 Imported by: 0

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

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 SchemaService added in v0.5.0 

type SchemaService interface {
	Query
	Close()
}

SchemaService allows querying stream schema.

func NewPortableRepository added in v0.5.0 

func NewPortableRepository(metadata metadata.Repo, l *logger.Logger) SchemaService

NewPortableRepository creates a new portable repository.

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, pipeline queue.Server) (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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.