Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 395 for Implementation (0.29 sec)

  1. pkg/kubelet/cm/topologymanager/bitmask/bitmask.go

    			bits = append(bits, int(i))
    		}
    	}
    	return bits
    }
    
    // And is a package level implementation of 'and' between first and masks
    func And(first BitMask, masks ...BitMask) BitMask {
    	s := *first.(*bitMask)
    	s.And(masks...)
    	return &s
    }
    
    // Or is a package level implementation of 'or' between first and masks
    func Or(first BitMask, masks ...BitMask) BitMask {
    	s := *first.(*bitMask)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 03 09:45:09 UTC 2022
    - 5.1K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/types.go

    type CgroupName []string
    
    // CgroupConfig holds the cgroup configuration information.
    // This is common object which is used to specify
    // cgroup information to both systemd and raw cgroup fs
    // implementation of the Cgroup Manager interface.
    type CgroupConfig struct {
    	// Fully qualified name prior to any driver specific conversions.
    	Name CgroupName
    	// ResourceParameters contains various cgroups settings to apply.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 24 18:21:21 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/etcd3/latency_tracker.go

    */
    
    package etcd3
    
    import (
    	"context"
    	"time"
    
    	clientv3 "go.etcd.io/etcd/client/v3"
    	endpointsrequest "k8s.io/apiserver/pkg/endpoints/request"
    )
    
    // NewETCDLatencyTracker returns an implementation of
    // clientv3.KV that times the calls from the specified
    // 'delegate' KV instance in order to track latency incurred.
    func NewETCDLatencyTracker(delegate clientv3.KV) clientv3.KV {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Dec 18 04:27:38 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/seat_seconds.go

    	"math"
    	"time"
    )
    
    // SeatSeconds is a measure of work, in units of seat-seconds, using a fixed-point representation.
    // `SeatSeconds(n)` represents `n/ssScale` seat-seconds.
    // The `ssScale` constant is private to the implementation here,
    // no other code should use it.
    type SeatSeconds uint64
    
    // MaxSeatsSeconds is the maximum representable value of SeatSeconds
    const MaxSeatSeconds = SeatSeconds(math.MaxUint64)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 20 09:16:46 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  5. pkg/scheduler/internal/cache/debugger/comparer.go

    	"k8s.io/klog/v2"
    	"k8s.io/kubernetes/pkg/scheduler/framework"
    	internalcache "k8s.io/kubernetes/pkg/scheduler/internal/cache"
    	internalqueue "k8s.io/kubernetes/pkg/scheduler/internal/queue"
    )
    
    // CacheComparer is an implementation of the Scheduler's cache comparer.
    type CacheComparer struct {
    	NodeLister corelisters.NodeLister
    	PodLister  corelisters.PodLister
    	Cache      internalcache.Cache
    	PodQueue   internalqueue.SchedulingQueue
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  6. pkg/controller/volume/expand/expand_controller.go

    	return nil, fmt.Errorf("NewWrapperMounter not supported by expand controller's VolumeHost implementation")
    }
    
    func (expc *expandController) NewWrapperUnmounter(volName string, spec volume.Spec, podUID types.UID) (volume.Unmounter, error) {
    	return nil, fmt.Errorf("NewWrapperUnmounter not supported by expand controller's VolumeHost implementation")
    }
    
    func (expc *expandController) GetMounter(pluginName string) mount.Interface {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apimachinery/pkg/api/meta/firsthit_restmapper.go

    		}
    		errors = append(errors, err)
    	}
    
    	return schema.GroupVersionKind{}, collapseAggregateErrors(errors)
    }
    
    // RESTMapping provides the REST mapping for the resource based on the
    // kind and version. This implementation supports multiple REST schemas and
    // return the first match.
    func (m FirstHitRESTMapper) RESTMapping(gk schema.GroupKind, versions ...string) (*RESTMapping, error) {
    	errors := []error{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 05 23:44:02 UTC 2021
    - 2.8K bytes
    - Viewed (0)
  8. pkg/controller/volume/persistentvolume/volume_host.go

    	"k8s.io/apimachinery/pkg/types"
    	clientset "k8s.io/client-go/kubernetes"
    	"k8s.io/client-go/tools/record"
    	vol "k8s.io/kubernetes/pkg/volume"
    	"k8s.io/kubernetes/pkg/volume/util/subpath"
    )
    
    // VolumeHost interface implementation for PersistentVolumeController.
    
    var _ vol.VolumeHost = &PersistentVolumeController{}
    
    func (ctrl *PersistentVolumeController) GetPluginDir(pluginName string) string {
    	return ""
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 11:00:37 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/imagepolicy/v1alpha1/types_swagger_doc_generated.go

    */
    
    package v1alpha1
    
    // This file contains a collection of methods that can be used from go-restful to
    // generate Swagger API documentation for its models. Please read this PR for more
    // information on the implementation: https://github.com/emicklei/go-restful/pull/215
    //
    // TODOs are ignored from the parser (e.g. TODO(andronat):... || TODO:...) if and only if
    // they are on one line! For multiple line or blocks that you want to ignore use ---.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 22 00:51:25 UTC 2023
    - 3.4K bytes
    - Viewed (0)
  10. pkg/proxy/ipvs/testing/fake_test.go

    */
    
    package testing
    
    import (
    	"testing"
    
    	"k8s.io/apimachinery/pkg/util/sets"
    	"k8s.io/kubernetes/pkg/proxy/ipvs"
    )
    
    // (I am unsure if this test has any value since it only tests the fake implementation)
    func TestSetGetLocalAddresses(t *testing.T) {
    	fake := NewFakeNetlinkHandle(false)
    	_ = ipvs.NetLinkHandle(fake) // Ensure that the interface is honored
    	fake.SetLocalAddresses("eth0", "1.2.3.4")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 2K bytes
    - Viewed (0)
Back to top