Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 185 for Implementation (0.47 sec)

  1. 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)
  2. 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)
  3. 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)
  4. staging/src/k8s.io/api/core/v1/generated.proto

      // but should apply for any default implementation. If set, it is assumed that a load balancer
      // implementation is watching for Services with a matching class. Any default load balancer
      // implementation (e.g. cloud providers) should ignore Services that set this field.
      // This field can only be set when creating or updating a Service to type 'LoadBalancer'.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 280.3K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/interfaces.go

    	// current version of the object to avoid read operation from storage to get it.
    	// However, the implementations have to retry in case suggestion is stale.
    	//
    	// Example:
    	//
    	// s := /* implementation of Interface */
    	// err := s.GuaranteedUpdate(
    	//     "myKey", &MyType{}, true, preconditions,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 07:53:48 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  6. pkg/apis/core/types.go

    	// but should apply for any default implementation. If set, it is assumed that a load balancer
    	// implementation is watching for Services with a matching class. Any default load balancer
    	// implementation (e.g. cloud providers) should ignore Services that set this field.
    	// This field can only be set when creating or updating a Service to type 'LoadBalancer'.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 268.9K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apimachinery/pkg/util/proxy/upgradeaware.go

    // error format.
    type ErrorResponder interface {
    	Error(w http.ResponseWriter, req *http.Request, err error)
    }
    
    // SimpleErrorResponder is the legacy implementation of ErrorResponder for callers that only
    // service a single request/response per proxy.
    type SimpleErrorResponder interface {
    	Error(err error)
    }
    
    func NewErrorResponder(r SimpleErrorResponder) ErrorResponder {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 19:10:30 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/core/v1/types_swagger_doc_generated.go

    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 254.8K bytes
    - Viewed (0)
  9. pkg/volume/util/operationexecutor/operation_executor.go

    type VolumeLogger interface {
    	// Creates a detailed msg that can be used in logs
    	// The msg format follows the pattern "<prefixMsg> <volume details> <suffixMsg>",
    	// where each implementation provides the volume details
    	GenerateMsgDetailed(prefixMsg, suffixMsg string) (detailedMsg string)
    
    	// Creates a detailed error that can be used in logs.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  10. pkg/scheduler/testing/framework/fake_extender.go

    ) (map[string]*extenderv1.Victims, error) {
    	nodeNameToVictimsCopy := map[string]*extenderv1.Victims{}
    	// We don't want to change the original nodeNameToVictims
    	for k, v := range nodeNameToVictims {
    		// In real world implementation, extender's user should have their own way to get node object
    		// by name if needed (e.g. query kube-apiserver etc).
    		//
    		// For test purpose, we just use node from parameters directly.
    		nodeNameToVictimsCopy[k] = v
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 13.9K bytes
    - Viewed (0)
Back to top