- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of about 10,000 for recur1 (0.13 sec)
-
pilot/pkg/leaderelection/k8sleaderelection/k8sresourcelock/endpointslock.go
if found { if err := json.Unmarshal(recordBytes, &record); err != nil { return nil, nil, err } } return &record, recordBytes, nil } // Create attempts to create a LeaderElectionRecord annotation func (el *EndpointsLock) Create(ctx context.Context, ler LeaderElectionRecord) error { recordBytes, err := json.Marshal(ler) if err != nil { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Oct 11 16:58:48 UTC 2021 - 3.7K bytes - Viewed (0) -
internal/s3select/json/preader.go
} // Read - reads single record. // Once Read is called the previous record should no longer be referenced. func (r *PReader) Read(dst sql.Record) (sql.Record, error) { // If we have have any records left, return these before any error. for len(r.current) <= r.recordsRead { if r.err != nil { return nil, r.err } // Move to next block item, ok := <-r.queue if !ok {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Mar 05 04:57:35 UTC 2023 - 6.4K bytes - Viewed (0) -
pkg/controller/job/backoff_utils.go
store cache.Store } func (s *backoffStore) updateBackoffRecord(record backoffRecord) error { b, ok, err := s.store.GetByKey(record.key) if err != nil { return err } if !ok { err = s.store.Add(&record) if err != nil { return err } } else { backoffRecord := b.(*backoffRecord) backoffRecord.failuresAfterLastSuccess = record.failuresAfterLastSuccess
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 07:46:41 UTC 2024 - 8.3K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/k8sresourcelock/leaselock.go
lease *coordinationv1.Lease } // Get returns the election record from a Lease spec func (ll *LeaseLock) Get(ctx context.Context) (*LeaderElectionRecord, []byte, error) { var err error ll.lease, err = ll.Client.Leases(ll.LeaseMeta.Namespace).Get(ctx, ll.LeaseMeta.Name, metav1.GetOptions{}) if err != nil { return nil, nil, err } record := LeaseSpecToLeaderElectionRecord(&ll.lease.Spec)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Jun 04 16:02:26 UTC 2022 - 4.3K bytes - Viewed (0) -
platforms/software/resources/src/main/java/org/gradle/internal/resource/transfer/DefaultExternalResourceConnector.java
switch (this) { case none: return NoOpStats.INSTANCE; case count: return new CountingStats(); case trace: return new MemoizingStats(); } throw new UnsupportedOperationException(); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 8.8K bytes - Viewed (0) -
platforms/extensibility/plugin-use/src/main/java/org/gradle/plugin/use/resolve/internal/PluginResolutionResult.java
this.found = found; this.notFoundList = notFoundList; } /** * Record that the plugin was not found in some source of plugins. */ public static PluginResolutionResult notFound() { return new PluginResolutionResult(null, ImmutableList.of()); } /** * Record that the plugin was not found in some source of plugins. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 12 20:19:43 UTC 2024 - 4.9K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/go/analysis/passes/printf/types.go
// acceptable false negatives. return true } m.seen[typ] = true switch typ := typ.(type) { case *types.Signature: return m.t == argPointer case *types.Map: if m.t == argPointer { return true } // Recur: map[int]int matches %d. return m.match(typ.Key(), false) && m.match(typ.Elem(), false) case *types.Chan: return m.t&argPointer != 0 case *types.Array:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 02:20:05 UTC 2024 - 8.6K bytes - Viewed (0) -
pkg/monitoring/monitoring_test.go
mt := monitortest.New(t) testGauge.Record(42) testGauge.Record(77) mt.Assert(testGauge.Name(), nil, monitortest.Exactly(77)) } func TestGaugeLabels(t *testing.T) { mt := monitortest.New(t) testGauge.With(kind.Value("foo")).Record(42) testGauge.With(kind.Value("bar")).Record(77) testGauge.With(kind.Value("bar")).Record(72)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Sep 13 16:04:48 UTC 2023 - 8.4K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/options.go
return err } if err := s.KubeCloudShared.ApplyTo(&c.ComponentConfig.KubeCloudShared); err != nil { return err } if err := s.AttachDetachController.ApplyTo(&c.ComponentConfig.AttachDetachController); err != nil { return err } if err := s.CSRSigningController.ApplyTo(&c.ComponentConfig.CSRSigningController); err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 20:41:50 UTC 2023 - 20.7K bytes - Viewed (0) -
internal/s3select/sql/funceval.go
switch { case e.SFunc != nil: return FuncName(strings.ToUpper(e.SFunc.FunctionName)) case e.Count != nil: return aggFnCount case e.Cast != nil: return sqlFnCast case e.Substring != nil: return sqlFnSubstring case e.Extract != nil: return sqlFnExtract case e.Trim != nil: return sqlFnTrim case e.DateAdd != nil: return sqlFnDateAdd case e.DateDiff != nil: return sqlFnDateDiff
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 13.2K bytes - Viewed (0)