Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 115 for Implementation (1.09 sec)

  1. pkg/kubelet/logs/container_log_manager.go

    	compressSuffix = ".gz"
    	// tmpSuffix is the suffix for temporary file.
    	tmpSuffix = ".tmp"
    )
    
    // ContainerLogManager manages lifecycle of all container logs.
    //
    // Implementation is thread-safe.
    type ContainerLogManager interface {
    	// TODO(random-liu): Add RotateLogs function and call it under disk pressure.
    	// Start container log manager.
    	Start()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 15K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/cmd/config.go

    type ImagesList struct {
    	cfg *kubeadmapi.InitConfiguration
    }
    
    // imageTextPrinter prints image info in a text form
    type imageTextPrinter struct {
    	output.TextPrinter
    }
    
    // PrintObj is an implementation of ResourcePrinter.PrintObj for plain text output
    func (itp *imageTextPrinter) PrintObj(obj runtime.Object, writer io.Writer) error {
    	var err error
    	if imgs, ok := obj.(*outputapiv1alpha3.Images); ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 06:58:01 UTC 2024
    - 18.9K bytes
    - Viewed (0)
  3. plugin/pkg/admission/serviceaccount/admission.go

    var _ = genericadmissioninitializer.WantsExternalKubeClientSet(&Plugin{})
    var _ = genericadmissioninitializer.WantsExternalKubeInformerFactory(&Plugin{})
    
    // NewServiceAccount returns an admission.Interface implementation which limits admission of Pod CREATE requests based on the pod's ServiceAccount:
    // 1. If the pod does not specify a ServiceAccount, it sets the pod's ServiceAccount to "default"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 17:49:30 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/cmd/upgrade/plan.go

    }
    
    // upgradePlanTextPrinter prints upgrade plan in a text form
    type upgradePlanTextPrinter struct {
    	output.TextPrinter
    }
    
    // PrintObj is an implementation of ResourcePrinter.PrintObj for upgrade plan plain text output
    func (printer *upgradePlanTextPrinter) PrintObj(obj runtime.Object, writer io.Writer) error {
    	plan, ok := obj.(*outputapiv1alpha3.UpgradePlan)
    	if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Mar 03 03:03:29 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  5. pkg/kubelet/stats/helper.go

    	"k8s.io/kubernetes/pkg/kubelet/cadvisor"
    	"k8s.io/kubernetes/pkg/kubelet/server/stats"
    )
    
    // defaultNetworkInterfaceName is used for collectng network stats.
    // This logic relies on knowledge of the container runtime implementation and
    // is not reliable.
    const defaultNetworkInterfaceName = "eth0"
    
    func cadvisorInfoToCPUandMemoryStats(info *cadvisorapiv2.ContainerInfo) (*statsapi.CPUStats, *statsapi.MemoryStats) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 17 23:40:02 UTC 2023
    - 14.8K bytes
    - Viewed (0)
  6. pkg/kubelet/util/manager/watch_based_manager.go

    	return store
    }
    
    func (c *objectCache) newStore() *cacheStore {
    	// TODO: We may consider created a dedicated store keeping just a single
    	// item, instead of using a generic store implementation for this purpose.
    	// However, simple benchmarks show that memory overhead in that case is
    	// decrease from ~600B to ~300B per object. So we are not optimizing it
    	// until we will see a good reason for that.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/podtopologyspread/filtering.go

    	}
    	for tpPair, matchNum := range s.TpPairToMatchNum {
    		copy.TpPairToMatchNum[tpPair] = matchNum
    	}
    	return &copy
    }
    
    // CAVEAT: the reason that `[2]criticalPath` can work is based on the implementation of current
    // preemption algorithm, in particular the following 2 facts:
    // Fact 1: we only preempt pods on the same node, instead of pods on multiple nodes.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/storage/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: Tue Oct 31 03:26:35 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apimachinery/pkg/util/validation/field/errors.go

    */
    
    package field
    
    import (
    	"fmt"
    	"reflect"
    	"strconv"
    	"strings"
    
    	utilerrors "k8s.io/apimachinery/pkg/util/errors"
    	"k8s.io/apimachinery/pkg/util/sets"
    )
    
    // Error is an implementation of the 'error' interface, which represents a
    // field-level validation error.
    type Error struct {
    	Type     ErrorType
    	Field    string
    	BadValue interface{}
    	Detail   string
    }
    
    var _ error = &Error{}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Oct 28 07:31:28 UTC 2023
    - 11.1K bytes
    - Viewed (0)
  10. pkg/proxy/util/nfacct/nfacct_linux_test.go

    */
    
    package nfacct
    
    import (
    	"syscall"
    	"testing"
    
    	"github.com/stretchr/testify/assert"
    	"github.com/vishvananda/netlink/nl"
    	"golang.org/x/sys/unix"
    )
    
    // fakeHandler is a mock implementation of the handler interface, designed for testing.
    type fakeHandler struct {
    	// requests stores instances of fakeRequest, capturing new requests.
    	requests []*fakeRequest
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 06:47:50 UTC 2024
    - 18.8K bytes
    - Viewed (0)
Back to top