mirror of
https://github.com/hanzoai/traces.git
synced 2026-10-30 18:20:41 +00:00
Martin DisibioandGitHub
011f1b0fcc
* test * Refactor dupe errors, skip compaction, fix error handling in search * Lint, tests * Fix tests
42 lines
752 B
Go
42 lines
752 B
Go
package vparquet3
|
|
|
|
import (
|
|
"context"
|
|
"sync"
|
|
|
|
"github.com/grafana/tempo/pkg/util"
|
|
"github.com/grafana/tempo/tempodb/backend"
|
|
"github.com/grafana/tempo/tempodb/encoding/common"
|
|
"go.opentelemetry.io/otel"
|
|
)
|
|
|
|
const (
|
|
DataFileName = "data.parquet"
|
|
)
|
|
|
|
var tracer = otel.Tracer("tempodb/encoding/vparquet3")
|
|
|
|
type backendBlock struct {
|
|
meta *backend.BlockMeta
|
|
r backend.Reader
|
|
|
|
openMtx sync.Mutex
|
|
}
|
|
|
|
var _ common.BackendBlock = (*backendBlock)(nil)
|
|
|
|
func newBackendBlock(meta *backend.BlockMeta, r backend.Reader) *backendBlock {
|
|
return &backendBlock{
|
|
meta: meta,
|
|
r: r,
|
|
}
|
|
}
|
|
|
|
func (b *backendBlock) BlockMeta() *backend.BlockMeta {
|
|
return b.meta
|
|
}
|
|
|
|
func (b *backendBlock) Validate(context.Context) error {
|
|
return util.ErrUnsupported
|
|
}
|