- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for utilipvs (0.14 sec)
-
pkg/proxy/ipvs/graceful_termination_test.go
import ( "fmt" "reflect" "testing" netutils "k8s.io/utils/net" utilipvs "k8s.io/kubernetes/pkg/proxy/ipvs/util" utilipvstest "k8s.io/kubernetes/pkg/proxy/ipvs/util/testing" ) func Test_GracefulDeleteRS(t *testing.T) { tests := []struct { name string vs *utilipvs.VirtualServer rs *utilipvs.RealServer existingIPVS *utilipvstest.FakeIPVS expectedIPVS *utilipvstest.FakeIPVS
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 11K bytes - Viewed (0) -
pkg/proxy/ipvs/util/testing/fake.go
return &FakeIPVS{ Services: make(map[ServiceKey]*utilipvs.VirtualServer), Destinations: make(map[ServiceKey][]*utilipvs.RealServer), } } func toServiceKey(serv *utilipvs.VirtualServer) ServiceKey { return ServiceKey{ IP: serv.Address.String(), Port: serv.Port, Protocol: serv.Protocol, } } func toRealServerKey(rs *utilipvs.RealServer) *RealServerKey { return &RealServerKey{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 7K bytes - Viewed (0) -
pkg/proxy/ipvs/util/testing/fake_test.go
package testing import ( "testing" utilipvs "k8s.io/kubernetes/pkg/proxy/ipvs/util" netutils "k8s.io/utils/net" ) func TestVirtualServer(t *testing.T) { // Initialize fake := NewFake() // Add a virtual server vs1 := &utilipvs.VirtualServer{ Address: netutils.ParseIPSloppy("1.2.3.4"), Port: uint16(80), Protocol: string("TCP"), Flags: utilipvs.FlagHashed, } err := fake.AddVirtualServer(vs1)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 5.6K bytes - Viewed (0) -
pkg/proxy/ipvs/graceful_termination.go
"k8s.io/klog/v2" utilipvs "k8s.io/kubernetes/pkg/proxy/ipvs/util" ) const ( rsCheckDeleteInterval = 1 * time.Minute ) // listItem stores real server information and the process time. // If nothing special happened, real server will be delete after process time. type listItem struct { VirtualServer *utilipvs.VirtualServer RealServer *utilipvs.RealServer }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 6.6K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier_test.go
} if f.vsCreated { vs := []*utilipvs.VirtualServer{{}} return vs, nil } return nil, nil } func (f *fakeIpvs) AddRealServer(*utilipvs.VirtualServer, *utilipvs.RealServer) error { return nil } func (f *fakeIpvs) GetRealServers(*utilipvs.VirtualServer) ([]*utilipvs.RealServer, error) { return nil, nil } func (f *fakeIpvs) DeleteRealServer(*utilipvs.VirtualServer, *utilipvs.RealServer) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
// ipvs call serv := &utilipvs.VirtualServer{ Address: svcInfo.ClusterIP(), Port: uint16(svcInfo.Port()), Protocol: string(svcInfo.Protocol()), Scheduler: proxier.ipvsScheduler, } // Set session affinity flag and timeout for IPVS service if svcInfo.SessionAffinityType() == v1.ServiceAffinityClientIP { serv.Flags |= utilipvs.FlagPersistent
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
cmd/kube-proxy/app/server_linux.go
"k8s.io/kubernetes/pkg/proxy" proxyconfigapi "k8s.io/kubernetes/pkg/proxy/apis/config" "k8s.io/kubernetes/pkg/proxy/iptables" "k8s.io/kubernetes/pkg/proxy/ipvs" utilipset "k8s.io/kubernetes/pkg/proxy/ipvs/ipset" utilipvs "k8s.io/kubernetes/pkg/proxy/ipvs/util" "k8s.io/kubernetes/pkg/proxy/nftables" proxyutil "k8s.io/kubernetes/pkg/proxy/util" utiliptables "k8s.io/kubernetes/pkg/util/iptables" "k8s.io/utils/exec" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 18.1K bytes - Viewed (0) -
platforms/documentation/docs/src/samples/java/modules-with-transform/README.adoc
It uses `commons-cli` (not a module) to parse the command line arguments, which can contain a JSON String, and `gson` (a proper module) to parse the JSON string. It also utilises `commons-lang3` (an automatic module) and `commons-beanutils` (not a module) which brings in some additional dependencies that are also not modules.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 1.8K bytes - Viewed (0) -
ci/official/wheel_test/README.md
description will be provided once it's integrated into presubmit. ### test_import_api_packages This Python test verifies whether the API v2 packages can be imported from the current build. It utilizes the `_api/v2/api_packages.txt` list of packages from the local wheel file specified in the `requirements_lock_<python_version>.txt`. Packages are imported one by one in alphabetical order during runtime.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Aug 31 18:17:57 UTC 2023 - 3.3K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/stablehlo/cc/pass_pipeline.h
const ::stablehlo::quantization::QuantizationSpecs& specs, const ::stablehlo::quantization::DebuggerConfig& debugger_config); // Adds passes for static-range quantization post-calibration. Utilizes tensor // statistics collected from the calibration step and performs quantization. void AddPostCalibrationPasses( OpPassManager& pm, const ::stablehlo::quantization::PipelineConfig& pipeline_config,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Apr 15 12:53:33 UTC 2024 - 3.6K bytes - Viewed (0)