- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 52 for opset (0.1 sec)
-
pkg/proxy/ipvs/ipset.go
) // IPSetVersioner can query the current ipset version. type IPSetVersioner interface { // returns "X.Y" GetVersion() (string, error) } // IPSet wraps util/ipset which is used by IPVS proxier. type IPSet struct { utilipset.IPSet // activeEntries is the current active entries of the ipset. activeEntries sets.Set[string] // handle is the util ipset interface handle. handle utilipset.Interface }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 7.3K bytes - Viewed (0) -
cni/pkg/ipset/ipset.go
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package ipset import ( "errors" "fmt" "net/netip" ) type IPSet struct { V4Name string V6Name string Prefix string Deps NetlinkIpsetDeps } const ( V4Name = "%s-v4" V6Name = "%s-v6" )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 22:24:38 UTC 2024 - 3.9K bytes - Viewed (0) -
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) -
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/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) -
src/runtime/cgo/gcc_linux_s390x.c
{ setg_gcc = setg; _cgo_set_stacklo(g, NULL); } void _cgo_sys_thread_start(ThreadStart *ts) { pthread_attr_t attr; sigset_t ign, oset; pthread_t p; size_t size; int err; sigfillset(&ign); pthread_sigmask(SIG_SETMASK, &ign, &oset); pthread_attr_init(&attr); pthread_attr_getstacksize(&attr, &size); // Leave stacklo=0 and set stackhi=size; mstart will do the rest. ts->g->stackhi = size;
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Aug 09 03:13:11 UTC 2023 - 1.3K bytes - Viewed (0)