This commit is contained in:
2023-06-07 11:28:07 +02:00
parent e89e2c18f2
commit a4b5f33d15
2 changed files with 10 additions and 6 deletions

View File

@@ -58,6 +58,10 @@ func (c *Coll[TData]) List(ctx context.Context, filter ct.Filter, pageSize *int,
return entities, nextToken, nil
}
type countRes struct {
Count int64 `bson:"c"`
}
func (c *Coll[TData]) Count(ctx context.Context, filter ct.Filter) (int64, error) {
pipeline := filter.FilterQuery()
@@ -68,12 +72,8 @@ func (c *Coll[TData]) Count(ctx context.Context, filter ct.Filter) (int64, error
return 0, err
}
type res struct {
Count int64 `bson:"c"`
}
if cursor.Next(ctx) {
v := res{}
v := countRes{}
err = cursor.Decode(&v)
if err != nil {
return 0, err