diff --git a/go.mod b/go.mod index 23bb2ed0..19a3bc19 100644 --- a/go.mod +++ b/go.mod @@ -3,7 +3,7 @@ module github.com/thingzio/devpulse go 1.27.1 require ( - cloud.google.com/go/run v1.22.0 + cloud.google.com/go/run v1.23.0 github.com/golang-jwt/jwt/v5 v5.3.1 github.com/google/go-github/v83 v83.0.0 github.com/lib/pq v1.12.3 diff --git a/go.sum b/go.sum index f3d1c4cc..8095b6db 100644 --- a/go.sum +++ b/go.sum @@ -10,8 +10,8 @@ cloud.google.com/go/iam v1.13.0 h1:ufT3FPT5rFFXu6UtLkNoxaOaV5EuA1dsSkmemCSTo6U= cloud.google.com/go/iam v1.13.0/go.mod h1:gHXdDEiPDvqd1q1KwBDGQlgZY/BwY760zU2LhOZS5w0= cloud.google.com/go/longrunning v1.2.0 h1:WjYH3YHBGCxGJP9M4dWGHBfXr/cFIjMkNgWcJj7/iMM= cloud.google.com/go/longrunning v1.2.0/go.mod h1:5KMQALFGOCtFoi2xSOA1u3H7WKlhmckgiyFw7+LGQp0= -cloud.google.com/go/run v1.22.0 h1:U56fxJWdrT+yjo4S/Vrtw5m69NdNL11Cyv9jX2JOi1s= -cloud.google.com/go/run v1.22.0/go.mod h1:Wo0aTNrqfftGmbxPPraeOxSUDUZ2c7IVNg2dk8Qm1Bs= +cloud.google.com/go/run v1.23.0 h1:JvTkOn+8h+QicGzBPWjgSrwpTcs2b6zJkusfEnmvkGo= +cloud.google.com/go/run v1.23.0/go.mod h1:ZCGrir3QdVgAJsVChr2nlQTfaknro8nwpEZwJDRHHhI= dario.cat/mergo v1.0.2 h1:85+piFYR1tMbRrLcDwR18y4UKJ3aH1Tbzi24VRW1TK8= dario.cat/mergo v1.0.2/go.mod h1:E/hbnu0NxMFBjpMIE34DRGLWqDy0g5FuKDhCb31ngxA= github.com/AdaLogics/go-fuzz-headers v0.0.0-20240806141605-e8a1dd7889d6 h1:He8afgbRMd7mFxO99hRNu+6tazq8nFF9lIwo9JFroBk= diff --git a/vendor/cloud.google.com/go/run/apiv2/auxiliary.go b/vendor/cloud.google.com/go/run/apiv2/auxiliary.go index 18689e66..ac83e8ec 100644 --- a/vendor/cloud.google.com/go/run/apiv2/auxiliary.go +++ b/vendor/cloud.google.com/go/run/apiv2/auxiliary.go @@ -18,12 +18,14 @@ package run import ( "context" + "iter" "time" "cloud.google.com/go/longrunning" longrunningpb "cloud.google.com/go/longrunning/autogen/longrunningpb" runpb "cloud.google.com/go/run/apiv2/runpb" gax "github.com/googleapis/gax-go/v2" + gaxiter "github.com/googleapis/gax-go/v2/iterator" "google.golang.org/api/iterator" ) @@ -1115,6 +1117,12 @@ func (op *UpdateWorkerPoolOperation) Name() string { return op.lro.Name() } +// All returns an iterator. If an error is returned by the iterator, the +// iterator will stop after that iteration. +func (it *ExecutionIterator) All() iter.Seq2[*runpb.Execution, error] { + return gaxiter.RangeAdapter(it.Next) +} + // ExecutionIterator manages a stream of *runpb.Execution. type ExecutionIterator struct { items []*runpb.Execution @@ -1162,6 +1170,12 @@ func (it *ExecutionIterator) takeBuf() interface{} { return b } +// All returns an iterator. If an error is returned by the iterator, the +// iterator will stop after that iteration. +func (it *InstanceIterator) All() iter.Seq2[*runpb.Instance, error] { + return gaxiter.RangeAdapter(it.Next) +} + // InstanceIterator manages a stream of *runpb.Instance. type InstanceIterator struct { items []*runpb.Instance @@ -1209,6 +1223,12 @@ func (it *InstanceIterator) takeBuf() interface{} { return b } +// All returns an iterator. If an error is returned by the iterator, the +// iterator will stop after that iteration. +func (it *JobIterator) All() iter.Seq2[*runpb.Job, error] { + return gaxiter.RangeAdapter(it.Next) +} + // JobIterator manages a stream of *runpb.Job. type JobIterator struct { items []*runpb.Job @@ -1256,6 +1276,12 @@ func (it *JobIterator) takeBuf() interface{} { return b } +// All returns an iterator. If an error is returned by the iterator, the +// iterator will stop after that iteration. +func (it *OperationIterator) All() iter.Seq2[*longrunningpb.Operation, error] { + return gaxiter.RangeAdapter(it.Next) +} + // OperationIterator manages a stream of *longrunningpb.Operation. type OperationIterator struct { items []*longrunningpb.Operation @@ -1303,6 +1329,12 @@ func (it *OperationIterator) takeBuf() interface{} { return b } +// All returns an iterator. If an error is returned by the iterator, the +// iterator will stop after that iteration. +func (it *RevisionIterator) All() iter.Seq2[*runpb.Revision, error] { + return gaxiter.RangeAdapter(it.Next) +} + // RevisionIterator manages a stream of *runpb.Revision. type RevisionIterator struct { items []*runpb.Revision @@ -1350,6 +1382,12 @@ func (it *RevisionIterator) takeBuf() interface{} { return b } +// All returns an iterator. If an error is returned by the iterator, the +// iterator will stop after that iteration. +func (it *ServiceIterator) All() iter.Seq2[*runpb.Service, error] { + return gaxiter.RangeAdapter(it.Next) +} + // ServiceIterator manages a stream of *runpb.Service. type ServiceIterator struct { items []*runpb.Service @@ -1397,6 +1435,12 @@ func (it *ServiceIterator) takeBuf() interface{} { return b } +// All returns an iterator. If an error is returned by the iterator, the +// iterator will stop after that iteration. +func (it *TaskIterator) All() iter.Seq2[*runpb.Task, error] { + return gaxiter.RangeAdapter(it.Next) +} + // TaskIterator manages a stream of *runpb.Task. type TaskIterator struct { items []*runpb.Task @@ -1444,6 +1488,12 @@ func (it *TaskIterator) takeBuf() interface{} { return b } +// All returns an iterator. If an error is returned by the iterator, the +// iterator will stop after that iteration. +func (it *WorkerPoolIterator) All() iter.Seq2[*runpb.WorkerPool, error] { + return gaxiter.RangeAdapter(it.Next) +} + // WorkerPoolIterator manages a stream of *runpb.WorkerPool. type WorkerPoolIterator struct { items []*runpb.WorkerPool diff --git a/vendor/cloud.google.com/go/run/apiv2/auxiliary_go123.go b/vendor/cloud.google.com/go/run/apiv2/auxiliary_go123.go deleted file mode 100644 index 5b76089c..00000000 --- a/vendor/cloud.google.com/go/run/apiv2/auxiliary_go123.go +++ /dev/null @@ -1,75 +0,0 @@ -// Copyright 2026 Google LLC -// -// Licensed under the Apache License, Version 2.0 (the "License"); -// you may not use this file except in compliance with the License. -// You may obtain a copy of the License at -// -// https://www.apache.org/licenses/LICENSE-2.0 -// -// Unless required by applicable law or agreed to in writing, software -// distributed under the License is distributed on an "AS IS" BASIS, -// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -// See the License for the specific language governing permissions and -// limitations under the License. - -// Code generated by protoc-gen-go_gapic. DO NOT EDIT. - -//go:build go1.23 - -package run - -import ( - "iter" - - longrunningpb "cloud.google.com/go/longrunning/autogen/longrunningpb" - runpb "cloud.google.com/go/run/apiv2/runpb" - "github.com/googleapis/gax-go/v2/iterator" -) - -// All returns an iterator. If an error is returned by the iterator, the -// iterator will stop after that iteration. -func (it *ExecutionIterator) All() iter.Seq2[*runpb.Execution, error] { - return iterator.RangeAdapter(it.Next) -} - -// All returns an iterator. If an error is returned by the iterator, the -// iterator will stop after that iteration. -func (it *InstanceIterator) All() iter.Seq2[*runpb.Instance, error] { - return iterator.RangeAdapter(it.Next) -} - -// All returns an iterator. If an error is returned by the iterator, the -// iterator will stop after that iteration. -func (it *JobIterator) All() iter.Seq2[*runpb.Job, error] { - return iterator.RangeAdapter(it.Next) -} - -// All returns an iterator. If an error is returned by the iterator, the -// iterator will stop after that iteration. -func (it *OperationIterator) All() iter.Seq2[*longrunningpb.Operation, error] { - return iterator.RangeAdapter(it.Next) -} - -// All returns an iterator. If an error is returned by the iterator, the -// iterator will stop after that iteration. -func (it *RevisionIterator) All() iter.Seq2[*runpb.Revision, error] { - return iterator.RangeAdapter(it.Next) -} - -// All returns an iterator. If an error is returned by the iterator, the -// iterator will stop after that iteration. -func (it *ServiceIterator) All() iter.Seq2[*runpb.Service, error] { - return iterator.RangeAdapter(it.Next) -} - -// All returns an iterator. If an error is returned by the iterator, the -// iterator will stop after that iteration. -func (it *TaskIterator) All() iter.Seq2[*runpb.Task, error] { - return iterator.RangeAdapter(it.Next) -} - -// All returns an iterator. If an error is returned by the iterator, the -// iterator will stop after that iteration. -func (it *WorkerPoolIterator) All() iter.Seq2[*runpb.WorkerPool, error] { - return iterator.RangeAdapter(it.Next) -} diff --git a/vendor/cloud.google.com/go/run/internal/version.go b/vendor/cloud.google.com/go/run/internal/version.go index dcd9f62a..74355b09 100644 --- a/vendor/cloud.google.com/go/run/internal/version.go +++ b/vendor/cloud.google.com/go/run/internal/version.go @@ -17,4 +17,4 @@ package internal // Version is the current tagged release of the library. -const Version = "1.22.0" +const Version = "1.23.0" diff --git a/vendor/modules.txt b/vendor/modules.txt index ab8ce208..3abe76db 100644 --- a/vendor/modules.txt +++ b/vendor/modules.txt @@ -38,8 +38,8 @@ cloud.google.com/go/longrunning cloud.google.com/go/longrunning/autogen cloud.google.com/go/longrunning/autogen/longrunningpb cloud.google.com/go/longrunning/internal -# cloud.google.com/go/run v1.22.0 -## explicit; go 1.25.0 +# cloud.google.com/go/run v1.23.0 +## explicit; go 1.26.0 cloud.google.com/go/run/apiv2 cloud.google.com/go/run/apiv2/runpb cloud.google.com/go/run/internal