merge main
This commit is contained in:
@@ -1,53 +0,0 @@
|
||||
package resource
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"github.com/grafana/grafana/pkg/storage/unified/resourcepb"
|
||||
)
|
||||
|
||||
// Some list queries can be calculated with simple reads or search index
|
||||
func (s *server) tryFieldSelector(ctx context.Context, req *resourcepb.ListRequest) *resourcepb.ListResponse {
|
||||
if req.Source != resourcepb.ListRequest_STORE || req.Options.Key.Namespace == "" {
|
||||
return nil
|
||||
}
|
||||
|
||||
var names []string
|
||||
for _, v := range req.Options.Fields {
|
||||
if v.Key == "metadata.name" && v.Operator == `=` {
|
||||
names = v.Values
|
||||
continue
|
||||
}
|
||||
|
||||
// TODO: support other field selectors
|
||||
}
|
||||
|
||||
// The required names
|
||||
if len(names) > 0 {
|
||||
read := &resourcepb.ReadRequest{
|
||||
Key: req.Options.Key,
|
||||
ResourceVersion: req.ResourceVersion,
|
||||
}
|
||||
rsp := &resourcepb.ListResponse{
|
||||
ResourceVersion: 1, // TODO, search result should include when it was indexed
|
||||
}
|
||||
for _, name := range names {
|
||||
read.Key.Name = name
|
||||
found, err := s.Read(ctx, read)
|
||||
if err != nil {
|
||||
return &resourcepb.ListResponse{Error: AsErrorResult(err)}
|
||||
}
|
||||
if len(found.Value) > 0 {
|
||||
rsp.Items = append(rsp.Items, &resourcepb.ResourceWrapper{
|
||||
Value: found.Value,
|
||||
ResourceVersion: found.ResourceVersion,
|
||||
})
|
||||
if found.ResourceVersion > rsp.ResourceVersion {
|
||||
rsp.ResourceVersion = found.ResourceVersion
|
||||
}
|
||||
}
|
||||
}
|
||||
return rsp
|
||||
}
|
||||
return nil
|
||||
}
|
||||
Reference in New Issue
Block a user