Method Find

tempodb/backend/azure/azure.go:265–300

Find implements backend.Reader

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

// Find implements backend.Reader
func (rw *Azure) 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 += dir
	}

	pager := rw.containerClient.NewListBlobsFlatPager(&container.ListBlobsFlatOptions{
		Prefix: &prefix,
	})

	var o string
	for pager.More() {
		page, err := pager.NextPage(ctx)
		if err != nil {
			return fmt.Errorf("iterating objects: %w", err)
		}

		for _, b := range page.Segment.BlobItems {
			if b == nil || b.Name == nil {
				continue
			}

			o = strings.TrimSuffix(*b.Name, dir)
			opts := backend.FindMatch{
				Key:      strings.TrimPrefix(o, rw.cfg.Prefix),
				Modified: *b.Properties.LastModified,
			}
			f(opts)
		}

	}

	return
}

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