- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for withFts (0.25 sec)
-
pkg/scheduler/framework/runtime/registry.go
// them when the caller expects the older PluginFactory method. func FactoryAdapter(fts plfeature.Features, withFts PluginFactoryWithFts) PluginFactory { return func(ctx context.Context, plArgs runtime.Object, fh framework.Handle) (framework.Plugin, error) { return withFts(ctx, plArgs, fh, fts) } } // DecodeInto decodes configuration whose type is *runtime.Unknown to the interface into.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 20 09:49:54 UTC 2023 - 3.3K bytes - Viewed (0) -
pilot/pkg/networking/core/route/retry/retry_test.go
testCases := []struct { name string route *networking.HTTPRoute assertFunc func(g *WithT, policy *envoyroute.RetryPolicy) }{ { name: "TestNilRetryShouldReturnDefault", // Create a route where no retry policy has been explicitly set. route: &networking.HTTPRoute{}, assertFunc: func(g *WithT, policy *envoyroute.RetryPolicy) { g.Expect(policy).To(Not(BeNil()))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 7.7K bytes - Viewed (0) -
manifests/addons/dashboards/lib/dashboard.libsonnet
{ new(name): g.dashboard.new(name) + g.dashboard.graphTooltip.withSharedCrosshair() + g.dashboard.withRefresh('15s') + g.dashboard.time.withFrom('now-30m') + g.dashboard.time.withTo('now') + g.dashboard.withVariables([variables.datasource]),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 20:46:28 UTC 2024 - 354 bytes - Viewed (0) -
operator/cmd/mesh/test-util_test.go
func mustGetService(g *WithT, objs *ObjectSet, name string) *object.K8sObject { obj := objs.kind(name2.ServiceStr).nameEquals(name) g.Expect(obj).Should(Not(BeNil())) return obj } // mustGetDeployment returns the deployment with the given name or fails if it's not found in objs. func mustGetDeployment(g *WithT, objs *ObjectSet, deploymentName string) *object.K8sObject {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 15.3K bytes - Viewed (0) -
platforms/jvm/language-java/src/main/java/org/gradle/jvm/component/internal/JvmSoftwareComponentInternal.java
* we do not want to extend that interface here, as it is slated for removal. */ public interface JvmSoftwareComponentInternal extends SoftwareComponent { // TODO: These with* names are not ideally named. Traditionally, "withers" create a new // instance with the value changed, but these mutate the component. However, other names // like like "enableJavadocJar" or "addJavadocJar" are also not great since their names // are not declarative.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 17 21:17:58 UTC 2023 - 4K bytes - Viewed (0) -
staging/src/k8s.io/client-go/applyconfigurations/core/v1/persistentvolumespec.go
b.Glusterfs = value return b } // WithNFS sets the NFS field in the declarative configuration to the given value // and returns the receiver, so that objects can be built by chaining "With" function invocations. // If called multiple times, the NFS field is set to the value of the last call. func (b *PersistentVolumeSpecApplyConfiguration) WithNFS(value *NFSVolumeSourceApplyConfiguration) *PersistentVolumeSpecApplyConfiguration {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 03:26:35 UTC 2023 - 16.6K bytes - Viewed (0) -
pilot/pkg/simulation/traffic.go
} // withT swaps out the testing struct. This allows executing sub tests. func (sim *Simulation) withT(t *testing.T) *Simulation { cpy := *sim cpy.t = t return &cpy } func (sim *Simulation) RunExpectations(es []Expect) { for _, e := range es { sim.t.Run(e.Name, func(t *testing.T) { sim.withT(t).Run(e.Call).Matches(t, e.Result) }) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 19.4K bytes - Viewed (0) -
src/net/http/transport_internal_test.go
c, err := ln.Accept() if err != nil { t.Error(err) return } connc <- c }() tr := new(Transport) req, _ := NewRequest("GET", "http://"+ln.Addr().String(), nil) req = req.WithT(t) ctx, cancel := context.WithCancelCause(context.Background()) treq := &transportRequest{Request: req, ctx: ctx, cancel: cancel} cm := connectMethod{targetScheme: "http", targetAddr: ln.Addr().String()}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 15:57:17 UTC 2024 - 6.2K bytes - Viewed (0) -
src/net/http/export_test.go
states := map[ConnState]int{} s.mu.Lock() defer s.mu.Unlock() for c := range s.activeConn { st, _ := c.getState() states[st] += 1 } return states } func (r *Request) WithT(t *testing.T) *Request { return r.WithContext(context.WithValue(r.Context(), tLogKey{}, t.Logf)) } func ExportSetH2GoawayTimeout(d time.Duration) (restore func()) { old := http2goAwayTimeout
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:11:57 UTC 2024 - 8.7K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate_test.go
testResourceFile := "duplicate_mwc" testCases := []struct { name string force bool assertFunc func(g *WithT, objs *ObjectSet, err error) }{ { name: "Duplicate MutatingWebhookConfiguration should be allowed when --force is enabled", force: true, assertFunc: func(g *WithT, objs *ObjectSet, err error) { g.Expect(err).Should(BeNil())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 04 18:05:06 UTC 2024 - 43.5K bytes - Viewed (0)