Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for withFts (0.25 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top