Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 145 for Implementation (0.69 sec)

  1. 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)
  2. 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)
  3. pkg/volume/csi/csi_client.go

    // connection set up. It also returns a closer which must be called to close
    // the gRPC connection when the NodeClient is not used anymore.
    // This is the default implementation for the nodeV1ClientCreator, used in
    // newCsiDriverClient.
    func newV1NodeClient(addr csiAddr, metricsManager *MetricsManager) (nodeClient csipbv1.NodeClient, closer io.Closer, err error) {
    	var conn *grpc.ClientConn
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 20 10:15:36 UTC 2022
    - 22.1K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/cel/library/authz.go

    }
    
    type decisionVal struct {
    	receiverOnlyObjectVal
    	err          error
    	authDecision authorizer.Decision
    	reason       string
    }
    
    // receiverOnlyObjectVal provides an implementation of ref.Val for
    // any object type that has receiver functions but does not expose any fields to
    // CEL.
    type receiverOnlyObjectVal struct {
    	typeValue *types.Type
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 23 21:31:27 UTC 2023
    - 21.1K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/cel/types.go

    		expT, err := et.ExprType()
    		if err != nil {
    			return nil, false
    		}
    		return &ref.FieldType{
    			Type: expT,
    		}, true
    	}
    	return nil, false
    }
    
    // NativeToValue is an implementation of the ref.TypeAdapater interface which supports conversion
    // of rule values to CEL ref.Val instances.
    func (rt *DeclTypeProvider) NativeToValue(val interface{}) ref.Val {
    	return rt.typeAdapter.NativeToValue(val)
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 08 15:52:31 UTC 2023
    - 18K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness.go

    		return handler
    	}
    	initAPFOnce.Do(func() {
    		initMaxInFlight(0, 0)
    		// Fetching these gauges is delayed until after their underlying metric has been registered
    		// so that this latches onto the efficient implementation.
    		waitingMark.readOnlyObserver = fcmetrics.GetWaitingReadonlyConcurrency()
    		waitingMark.mutatingObserver = fcmetrics.GetWaitingMutatingConcurrency()
    	})
    
    	clock := &utilsclock.RealClock{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  7. staging/src/k8s.io/api/authorization/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
    - 11.9K bytes
    - Viewed (0)
  8. 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)
  9. staging/src/k8s.io/api/autoscaling/v2beta1/types_swagger_doc_generated.go

    */
    
    package v2beta1
    
    // 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: Mon Feb 27 23:13:24 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  10. 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)
Back to top