MCPcopy
hub / github.com/grafana/tempo / ReadVersioned

Method ReadVersioned

tempodb/backend/s3/s3.go:623–634  ·  view source on GitHub ↗
(ctx context.Context, name string, keypath backend.KeyPath)

Source from the content-addressed store, hash-verified

621}
622
623func (rw *readerWriter) ReadVersioned(ctx context.Context, name string, keypath backend.KeyPath) (io.ReadCloser, backend.Version, error) {
624 derivedCtx, span := tracer.Start(ctx, "s3.ReadVersioned")
625 defer span.End()
626
627 keypath = backend.KeyPathWithPrefix(keypath, rw.cfg.Prefix)
628 b, objectInfo, err := rw.readAllWithObjInfo(derivedCtx, backend.ObjectFileName(keypath, name))
629 if err != nil {
630 return nil, "", readError(err)
631 }
632
633 return io.NopCloser(bytes.NewReader(b)), backend.Version(objectInfo.ETag), nil
634}
635
636func (rw *readerWriter) readAll(ctx context.Context, name string) ([]byte, error) {
637 options := getObjectOptions(rw)

Callers 2

WriteVersionedMethod · 0.95
DeleteVersionedMethod · 0.95

Calls 6

readAllWithObjInfoMethod · 0.95
KeyPathWithPrefixFunction · 0.92
ObjectFileNameFunction · 0.92
VersionTypeAlias · 0.92
readErrorFunction · 0.70
StartMethod · 0.65

Tested by

no test coverage detected