Method Find

tempodb/backend/s3/s3.go:505–543

Find implements backend.Reader

(ctx context.Context, keypath backend.KeyPath, f backend.FindFunc)

// Find implements backend.Reader
func (rw *readerWriter) Find(ctx context.Context, keypath backend.KeyPath, f backend.FindFunc) (err error) {
	keypath = backend.KeyPathWithPrefix(keypath, rw.cfg.Prefix)
	prefix := path.Join(keypath...)

	if len(prefix) > 0 {
		prefix += "/"
	}

	nextToken := ""
	isTruncated := true
	var res minio.ListBucketV2Result

	for isTruncated {
		select {
		case <-ctx.Done():
			return
		default:
			res, err = rw.core.ListObjectsV2(rw.cfg.Bucket, prefix, "", nextToken, "", 0)
			if err != nil {
				return fmt.Errorf("error finding objects in s3 bucket, bucket: %s: %w", rw.cfg.Bucket, err)
			}

			isTruncated = res.IsTruncated
			nextToken = res.NextContinuationToken

			if len(res.Contents) > 0 {
				for _, c := range res.Contents {
					opts := backend.FindMatch{
						Key:      strings.TrimPrefix(c.Key, rw.cfg.Prefix),
						Modified: c.LastModified,
					}
					f(opts)
				}
			}
		}
	}

	return
}

// Read implements backend.Reader
func (rw *readerWriter) Read(ctx context.Context, name string, keypath backend.KeyPath, _ *backend.CacheInfo) (io.ReadCloser, int64, error) {