measure

Documentation

Index

• Constants
• Variables
• func OrderBy(sort modelv1.Sort) streaming.TopNOption
• type Measure
• type Query
• type Service
  • func NewService(_ context.Context, metadata metadata.Repo, repo discovery.ServiceRepo, ...) (Service, error)

Constants

const (
	TopNTagFamily = "__topN__"
)

Variables

var (
	ErrEmptyRootPath   = errors.New("root path is empty")
	ErrMeasureNotExist = errors.New("measure doesn't exist")
)

var ErrMalformedElement = errors.New("element is malformed")

var ErrTagFamilyNotExist = errors.New("tag family doesn't exist")

var (
	TopNValueFieldSpec = &databasev1.FieldSpec{
		Name:              "value",
		FieldType:         databasev1.FieldType_FIELD_TYPE_INT,
		EncodingMethod:    databasev1.EncodingMethod_ENCODING_METHOD_GORILLA,
		CompressionMethod: databasev1.CompressionMethod_COMPRESSION_METHOD_ZSTD,
	}
)

Functions

func OrderBy

func OrderBy(sort modelv1.Sort) streaming.TopNOption

Types

type Measure

type Measure interface {
	io.Closer
	Write(value *measurev1.DataPointValue) error
	Shards(entity tsdb.Entity) ([]tsdb.Shard, error)
	CompanionShards(metadata *commonv1.Metadata) ([]tsdb.Shard, error)
	Shard(id common.ShardID) (tsdb.Shard, error)
	ParseTagFamily(family string, item tsdb.Item) (*modelv1.TagFamily, error)
	ParseField(name string, item tsdb.Item) (*measurev1.DataPoint_Field, error)
	GetSchema() *databasev1.Measure
	GetIndexRules() []*databasev1.IndexRule
	GetInterval() time.Duration
}

type Query

type Query interface {
	LoadGroup(name string) (resourceSchema.Group, bool)
	Measure(measure *commonv1.Metadata) (Measure, error)
}

type Service

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

func NewService

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

NewService returns a new service