- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 64 for IPFamily (0.14 sec)
-
pkg/registry/core/service/ipallocator/bitmap.go
func (r *Range) Has(ip net.IP) bool { ok, offset := r.contains(ip) if !ok { return false } return r.alloc.Has(offset) } // IPFamily returns the IP family of this range. func (r *Range) IPFamily() api.IPFamily { return r.family } // Snapshot saves the current state of the pool. func (r *Range) Snapshot(dst *api.RangeAllocation) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 25 20:32:40 UTC 2023 - 10.8K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/interfaces.go
// should be threadsafe. type Interface interface { Allocate(net.IP) error AllocateNext() (net.IP, error) Release(net.IP) error ForEach(func(net.IP)) CIDR() net.IPNet IPFamily() api.IPFamily Has(ip net.IP) bool Destroy() EnableMetrics() // DryRun offers a way to try operations without persisting them. DryRun() Interface } var ( ErrFull = errors.New("range is full")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:04 UTC 2023 - 1.6K bytes - Viewed (0) -
cmd/kube-apiserver/app/options/validation.go
// by the range set on --service-cluster-ip-range. If/when the user decides to use dual stack services // the Secondary* must be of different IPFamily than --service-cluster-ip-range if secondaryServiceClusterIPRangeUsed { // Should be dualstack IPFamily(PrimaryServiceClusterIPRange) != IPFamily(SecondaryServiceClusterIPRange)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 6.2K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
// Proxier is an hns based proxy for connections between a localhost:lport // and services that provide the actual backends. type Proxier struct { // ipFamily defines the IP family which this proxier is tracking. ipFamily v1.IPFamily // TODO(imroc): implement node handler for winkernel proxier. proxyconfig.NoopNodeHandler // endpointsChanges and serviceChanges contains all changes to endpoints and
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller.go
return nil } // Convert netutils.IPFamily to v1.IPFamily // TODO: consolidate helpers // copied from pkg/proxy/util/utils.go func convertToV1IPFamily(ipFamily netutils.IPFamily) v1.IPFamily { switch ipFamily { case netutils.IPv4: return v1.IPv4Protocol case netutils.IPv6: return v1.IPv6Protocol }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
proxier := &Proxier{ ipFamily: ipFamily, svcPortMap: make(proxy.ServicePortMap), serviceChanges: proxy.NewServiceChangeTracker(newServiceInfo, ipFamily, recorder, nil), endpointsMap: make(proxy.EndpointsMap), endpointsChanges: proxy.NewEndpointsChangeTracker(hostname, nil, ipFamily, recorder, nil), initialSync: true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
} proxier := &Proxier{ ipFamily: ipFamily, svcPortMap: make(proxy.ServicePortMap), serviceChanges: proxy.NewServiceChangeTracker(newServiceInfo, ipFamily, recorder, nil), endpointsMap: make(proxy.EndpointsMap), endpointsChanges: proxy.NewEndpointsChangeTracker(hostname, newEndpointInfo, ipFamily, recorder, nil), needFullSync: true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
staging/src/k8s.io/api/networking/v1alpha1/well_known_labels.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 v1alpha1 const ( // TODO: Use IPFamily as field with a field selector,And the value is set based on // the name at create time and immutable. // LabelIPAddressFamily is used to indicate the IP family of a Kubernetes IPAddress.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 22:56:44 UTC 2023 - 1.3K bytes - Viewed (0) -
staging/src/k8s.io/api/core/v1/types_test.go
for i := 0; i < obj.NumField(); i++ { f := obj.Field(i) protobufNum := strings.Split(f.Tag.Get("protobuf"), ",")[1] if protobufNum == "15" { t.Errorf("protobuf 15 in ServiceSpec is reserved for removed ipFamily field") } if protobufNum == "16" { t.Errorf("protobuf 16 in ServiceSpec is reserved for removed topologyKeys field") } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 20 03:01:07 UTC 2021 - 2.1K bytes - Viewed (0) -
pkg/proxy/endpointschangetracker.go
// NewEndpointsChangeTracker initializes an EndpointsChangeTracker func NewEndpointsChangeTracker(hostname string, makeEndpointInfo makeEndpointFunc, ipFamily v1.IPFamily, recorder events.EventRecorder, processEndpointsMapChange processEndpointsMapChangeFunc) *EndpointsChangeTracker { return &EndpointsChangeTracker{ lastChangeTriggerTimes: make(map[types.NamespacedName][]time.Time),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 13.2K bytes - Viewed (0)