Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 185 for Implementation (0.18 sec)

  1. pkg/kubelet/util/util_unsupported.go

    */
    
    package util
    
    import (
    	"fmt"
    	"time"
    )
    
    // LockAndCheckSubPath empty implementation
    func LockAndCheckSubPath(volumePath, subPath string) ([]uintptr, error) {
    	return []uintptr{}, nil
    }
    
    // UnlockPath empty implementation
    func UnlockPath(fileHandles []uintptr) {
    }
    
    // LocalEndpoint empty implementation
    func LocalEndpoint(path, file string) (string, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 08:58:18 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/doc.go

    // completes.
    //
    // The first two differences can easily be handled by straightforward
    // adaptation of the concept called "R(t)" in the original paper and
    // "virtual time" in the implementation outline. In that
    // implementation outline, the notation now() is used to mean reading
    // the virtual clock. In the original paper’s terms, "R(t)" is the
    // number of "rounds" that have been completed at real time t ---
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 08 12:33:30 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  3. pkg/kubelet/configmap/configmap_manager.go

    }
    
    // configMapManager keeps a cache of all configmaps necessary
    // for registered pods. Different implementation of the store
    // may result in different semantics for freshness of configmaps
    // (e.g. ttl-based implementation vs watch-based implementation).
    type configMapManager struct {
    	manager manager.Manager
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/cel/mutation/mock_test.go

    	"github.com/google/cel-go/common/types/ref"
    
    	"k8s.io/apiserver/pkg/cel/mutation/common"
    )
    
    // mockTypeResolver is a mock implementation of TypeResolver that
    // allows the object to contain any field.
    type mockTypeResolver struct {
    }
    
    // mockTypeRef is a mock implementation of TypeRef that
    // contains any field.
    type mockTypeRef struct {
    	objectType *types.Type
    	resolver   common.TypeResolver
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 24 00:01:35 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  5. pkg/util/coverage/fake_test_deps.go

    limitations under the License.
    */
    
    package coverage
    
    import (
    	"io"
    	"reflect"
    	"time"
    )
    
    // This is an implementation of testing.testDeps. It doesn't need to do anything, because
    // no tests are actually run. It does need a concrete implementation of at least ImportPath,
    // which is called unconditionally when running tests.
    //
    //nolint:unused // U1000 see comment above, we know it's unused normally.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 15:31:22 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/caching_authorizer.go

    	return &cachingAuthorizer{
    		authorizer: in,
    		decisions:  make(map[string]authzResult),
    	}
    }
    
    // The attribute accessors known to cache key construction. If this fails to compile, the cache
    // implementation may need to be updated.
    var _ authorizer.Attributes = (interface {
    	GetUser() user.Info
    	GetVerb() string
    	IsReadOnly() bool
    	GetNamespace() string
    	GetResource() string
    	GetSubresource() string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 12 18:58:24 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  7. pkg/kubelet/secret/secret_manager.go

    func (s *simpleSecretManager) UnregisterPod(pod *v1.Pod) {
    }
    
    // secretManager keeps a store with secrets necessary
    // for registered pods. Different implementations of the store
    // may result in different semantics for freshness of secrets
    // (e.g. ttl-based implementation vs watch-based implementation).
    type secretManager struct {
    	manager manager.Manager
    }
    
    func (s *secretManager) GetSecret(namespace, name string) (*v1.Secret, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  8. cmd/kubeadm/app/util/output/output.go

    	KubeTemplatePrintFlags *genericclioptions.KubeTemplatePrintFlags
    	// TextPrintFlags provides default flags necessary for kubeadm text printing.
    	TextPrintFlags TextPrintFlags
    	// TypeSetterPrinter is an implementation of ResourcePrinter that wraps another printer with types set on the objects
    	TypeSetterPrinter *printers.TypeSetterPrinter
    	// OutputFormat contains currently set output format
    	OutputFormat *string
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 19 08:22:45 UTC 2024
    - 8K bytes
    - Viewed (0)
  9. pkg/proxy/util/localdetector.go

    import (
    	netutils "k8s.io/utils/net"
    )
    
    // LocalTrafficDetector generates iptables or nftables rules to detect traffic from local pods.
    type LocalTrafficDetector interface {
    	// IsImplemented returns true if the implementation does something, false
    	// otherwise. You should not call the other methods if IsImplemented() returns
    	// false.
    	IsImplemented() bool
    
    	// IfLocal returns iptables arguments that will match traffic from a local pod.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 15:34:37 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  10. pkg/proxy/conntrack/cleanup_test.go

    	// We need to construct a proxy.ServicePortMap to pass to CleanStaleEntries.
    	// ServicePortMap is just map[string]proxy.ServicePort, but there are no public
    	// constructors for any implementation of proxy.ServicePort, so we have to either
    	// provide our own implementation of that interface, or else use a
    	// proxy.ServiceChangeTracker to construct them and fill in the map for us.
    
    	sct := proxy.NewServiceChangeTracker(nil, v1.IPv4Protocol, nil, nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jan 15 18:09:05 UTC 2024
    - 7.6K bytes
    - Viewed (0)
Back to top