- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 124 for opset (0.06 sec)
-
pkg/proxy/ipvs/ipset/testing/fake.go
"k8s.io/kubernetes/pkg/proxy/ipvs/ipset" ) // FakeIPSet is a no-op implementation of ipset Interface type FakeIPSet struct { // version of ipset util Version string // The key of Sets map is the ip set name Sets map[string]*ipset.IPSet // The key of Entries map is the ip set name where the entries exists Entries map[string]sets.String } // NewFake create a new fake ipset interface - it initialize the FakeIPSet.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 3.6K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
// allow overriding for tests netnsRunner func(fdable NetnsFd, toRun func() error) error hostsideProbeIPSet ipset.IPSet } var _ MeshDataplane = &NetServer{} func newNetServer(ztunnelServer ZtunnelServer, podNsMap *podNetnsCache, iptablesConfigurator *iptables.IptablesConfigurator, podNs PodNetnsFinder, probeSet ipset.IPSet, ) *NetServer { return &NetServer{ ztunnelServer: ztunnelServer, currentPodSnapshot: podNsMap,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 13.4K bytes - Viewed (0) -
pkg/proxy/ipvs/ipset/types.go
See the License for the specific language governing permissions and limitations under the License. */ package ipset // Type represents the ipset type type Type string const ( // HashIPPort represents the `hash:ip,port` type ipset. The hash:ip,port is similar to hash:ip but // you can store IP address and protocol-port pairs in it. TCP, SCTP, UDP, UDPLITE, ICMP and ICMPv6 are supported
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/proxy/ipvs/ipset_test.go
}, { name: "ipset sync, remove old and add new", set: &utilipset.IPSet{ Name: "c-c-c", }, setType: utilipset.BitmapPort, activeEntries: []string{"8080", "9090"}, currentEntries: []string{"80"}, expectedEntries: []string{"8080", "9090"}, }, { name: "ipset sync, remove many stale ports", set: &utilipset.IPSet{ Name: "NODE-PORT", },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 7.5K bytes - Viewed (0) -
cni/pkg/ipset/nldeps_linux.go
err := netlink.IpsetFlush(name) if err != nil { return fmt.Errorf("failed to flush ipset %s: %w", name, err) } return nil } // Alpine and some distros struggles with this - ipset CLI utilities support this, but // the kernel can be out of sync with the CLI utility, leading to errors like: // // ipset v7.10: Argument `comment' is supported in the kernel module of the set type hash:ip
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 30 18:07:05 UTC 2024 - 3.9K bytes - Viewed (0) -
pkg/proxy/ipvs/ipset/testing/fake_test.go
t.Errorf("Unexpected version mismatch, expected: %s, got: %s", testVersion, version) } // create a set set := &ipset.IPSet{ Name: "foo", SetType: ipset.HashIPPort, HashFamily: ipset.ProtocolFamilyIPV4, } if err := fake.CreateSet(set, true); err != nil { t.Errorf("Unexpected error: %v", err) } // add two entries err = fake.AddEntry("192.168.1.1,tcp:8080", set, true) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 4.4K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
ipsetDeps *ipset.MockedIpsetDeps } func getTestFixure(ctx context.Context) netTestFixture { podNsMap := newPodNetnsCache(openNsTestOverride) nlDeps := &fakeIptablesDeps{} iptablesConfigurator, _ := iptables.NewIptablesConfigurator(nil, &dependencies.DependenciesStub{}, nlDeps) ztunnelServer := &fakeZtunnel{} fakeIPSetDeps := ipset.FakeNLDeps()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 17.8K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
ipset: ipset, nodePortAddresses: nodePortAddresses, networkInterfacer: proxyutil.RealNetwork{}, gracefuldeleteManager: NewGracefulTerminationManager(ipvs), logger: logger, } // initialize ipsetList with all sets we needed proxier.ipsetList = make(map[string]*IPSet) for _, is := range ipsetInfo {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
} // createHostsideProbeIpset creates an ipset. This is designed to be called from the host netns. // Note that if the ipset already exist by name, Create will not return an error. // // We will unconditionally flush our set before use here, so it shouldn't matter. func createHostsideProbeIpset(isV6 bool) (ipset.IPSet, error) { linDeps := ipset.RealNlDeps() probeSet, err := ipset.NewIPSet(iptables.ProbeIPSet, isV6, linDeps)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 7.2K bytes - Viewed (0) -
pkg/proxy/ipvs/testing/util.go
type ExpectedIptablesChain map[string][]ExpectedIptablesRule // ExpectedIptablesRule is the expected iptables rules with jump chain and match ipset name type ExpectedIptablesRule struct { SourceAddress string JumpChain string MatchSet string } // ExpectedIPSet is the expected ipset with set name and entries name
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 1.6K bytes - Viewed (0)