fluxcd
/
source-controller
mirror of https://github.com/fluxcd/source-controller.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Bucket: add prefix support for GCP 

Signed-off-by: Stefan Prodan <stefan.prodan@gmail.com>
This commit is contained in:
Stefan Prodan 2023-10-17 14:50:13 +03:00
parent 6d4e654522
commit 674c287dbd
No known key found for this signature in database
GPG Key ID: 3299AEB0E4085BAF
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
docs/spec/v1beta2/buckets.md
View File

@ -790,8 +790,8 @@ details and examples.
`.spec.prefix` is an optional field to enable server-side filtering `.spec.prefix` is an optional field to enable server-side filtering
of files in the Bucket. of files in the Bucket.
**Note:** The server-side filtering works only with the `generic` and `aws` **Note:** The server-side filtering works only with the `generic`, `aws`
[provider](#provider) and is preferred over [`.spec.ignore`](#ignore) and `gcp` [provider](#provider) and is preferred over [`.spec.ignore`](#ignore)
as a more efficient way of excluding files. as a more efficient way of excluding files.
### Ignore ### Ignore

4
pkg/gcp/gcp.go
View File

@ -166,7 +166,9 @@ func (c *GCSClient) FGetObject(ctx context.Context, bucketName, objectName, loca
// If the underlying client or the visit callback returns an error, // If the underlying client or the visit callback returns an error,
// it returns early. // it returns early.
func (c *GCSClient) VisitObjects(ctx context.Context, bucketName string, prefix string, visit func(path, etag string) error) error { func (c *GCSClient) VisitObjects(ctx context.Context, bucketName string, prefix string, visit func(path, etag string) error) error {
items := c.Client.Bucket(bucketName).Objects(ctx, nil) items := c.Client.Bucket(bucketName).Objects(ctx, &gcpstorage.Query{
Prefix: prefix,
})
for { for {
object, err := items.Next() object, err := items.Next()
if err == IteratorDone { if err == IteratorDone {