Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 187 for Implementation (0.24 sec)

  1. pkg/volume/util/hostutil/hostutil_unsupported.go

    limitations under the License.
    */
    
    package hostutil
    
    import (
    	"errors"
    	"os"
    
    	"k8s.io/mount-utils"
    )
    
    // HostUtil is an HostUtils implementation that allows compilation on
    // unsupported platforms
    type HostUtil struct{}
    
    // NewHostUtil returns a struct that implements the HostUtils interface on
    // unsupported platforms
    func NewHostUtil() *HostUtil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 08 10:17:38 UTC 2022
    - 3.3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/api/scheduling/v1beta1/types_swagger_doc_generated.go

    */
    
    package v1beta1
    
    // 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
    - 3K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/util/dryrun/dryrun.go

    		}
    
    		fmt.Fprintf(w, "[dryrun] Would write file %q with content:\n", outputFilePath)
    		apiclient.PrintBytesWithLinePrefix(w, fileBytes, "\t")
    	}
    	return errorsutil.NewAggregate(errs)
    }
    
    // Waiter is an implementation of apiclient.Waiter that should be used for dry-running
    type Waiter struct{}
    
    // NewWaiter returns a new Waiter object that talks to the given Kubernetes cluster
    func NewWaiter() apiclient.Waiter {
    	return &Waiter{}
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 07:10:31 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top