- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 66 for dine (0.15 sec)
-
cni/pkg/nodeagent/informers_test.go
"", ).Return(nil) server := &meshDataplane{ kubeClient: client.Kube(), netServer: fs, } handlers := setupHandlers(ctx, client, server, "istio-system") client.RunAndWait(ctx.Done()) go handlers.Start() // label the namespace labelsPatch := []byte(fmt.Sprintf(`{"metadata":{"labels":{"%s":"%s"}}}`, constants.DataplaneMode, constants.DataplaneModeAmbient))
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 01:03:24 GMT 2024 - 15.8K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
common/scripts/lint_copyright_banner.sh
Shell Script - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Sep 11 23:32:21 GMT 2019 - 1.2K bytes - Viewed (0) -
common/scripts/fix_copyright_banner.sh
Shell Script - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Nov 17 04:35:57 GMT 2022 - 1.3K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
err = adscConn.Send(dr) if err != nil { return nil, err } response, err := adscConn.WaitVersion(opts.Timeout, dr.TypeUrl, "") return response, err } // DialOptions constructs gRPC dial options from command line configuration func DialOptions(opts clioptions.CentralControlPlaneOptions, ns, serviceAccount string, kubeClient kube.CLIClient, ) ([]grpc.DialOption, error) { ctx := context.TODO()
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Dec 19 22:42:42 GMT 2023 - 3.7K bytes - Viewed (0) -
common-protos/k8s.io/apimachinery/pkg/api/resource/generated.proto
// +k8s:deepcopy-gen=true // +k8s:openapi-gen=true message Quantity { optional string string = 1; } // QuantityValue makes it possible to use a Quantity as value for a command // line parameter. // // +protobuf=true // +protobuf.embed=string // +protobuf.options.marshal=false // +protobuf.options.(gogoproto.goproto_stringer)=false // +k8s:deepcopy-gen=true message QuantityValue {
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 3.9K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
// make sure the uid was taken from cache and netns closed netns := fixture.podNsMap.Take(string(pod.UID)) assert.Equal(t, nil, netns) // run gc to clean up ns: //revive:disable-next-line:call-to-gc Just a test that we are cleaning up the netns runtime.GC() assertNSClosed(t, closed) } func TestServerDeletePod(t *testing.T) { ctx, cancel := context.WithCancel(context.Background())
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cni/test/install_cni.go
cancel() wg.Wait() }() go func() { runInstall(ctx, tempCNIConfDir, tempCNIBinDir, tempK8sSvcAcctDir, envPreconf, filepath.Join(env.IstioSrc, "cni/test/testdata/bindir"), chainedCNIPlugin, t) wg.Done() }() resultFile := tempCNIConfDir + "/" + resultFileName if chainedCNIPlugin && delayedConfFile != "" { retry.UntilSuccessOrFail(t, func() error {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
cfg: cfg, } // By detecting iptables versions *here* once-for-all we are // committing to using the same binary/variant (legacy or nft) // within all pods as we do on the host. // // This should be fine, as the host binaries are all we have to work with here anyway, // as we are running within a privileged container - and we don't want to take the time to // redetect for each pod anyway. // // Extreme corner case:
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 19.6K bytes - Viewed (0) -
common-protos/k8s.io/api/autoscaling/v2beta2/generated.proto
// StabilizationWindowSeconds must be greater than or equal to zero and less than or equal to 3600 (one hour). // If not set, use the default values: // - For scale up: 0 (i.e. no stabilization is done). // - For scale down: 300 (i.e. the stabilization window is 300 seconds long). // +optional optional int32 stabilizationWindowSeconds = 3; // selectPolicy is used to specify which policy should be used.
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 21K bytes - Viewed (0)