stream

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 SchemaService
  • func NewPortableRepository(metadata metadata.Repo, l *logger.Logger) SchemaService
• type Service
  • func NewService(_ context.Context, metadata metadata.Repo, pipeline queue.Server) (Service, error)
• type Stream

Types

type Query

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

Query allow to retrieve elements in a series of streams.

type SchemaService

type SchemaService interface {
	Query
	Close()
}

SchemaService allows querying stream schema.

func NewPortableRepository

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.