Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 311 for destroy (0.11 sec)

  1. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/dryrun_test.go

    	sc.Codec = apitesting.TestStorageCodec(codecs, examplev1.SchemeGroupVersion)
    	s, destroy, err := factory.Create(*sc.ForResource(schema.GroupResource{Resource: "pods"}), nil, nil, "")
    	if err != nil {
    		t.Fatalf("Error creating storage: %v", err)
    	}
    	return DryRunnableStorage{Storage: s, Codec: sc.Codec}, func() {
    		destroy()
    		server.Terminate(t)
    	}
    }
    
    func UnstructuredOrDie(j string) *unstructured.Unstructured {
    Registered: 2024-06-15 01:39
    - Last Modified: 2023-08-24 09:23
    - 9.9K bytes
    - Viewed (0)
  2. pkg/registry/core/pod/rest/subresources.go

    // New returns an empty podProxyOptions object.
    func (r *ProxyREST) New() runtime.Object {
    	return &api.PodProxyOptions{}
    }
    
    // Destroy cleans up resources on shutdown.
    func (r *ProxyREST) Destroy() {
    	// Given that underlying store is shared with REST,
    	// we don't destroy it here explicitly.
    }
    
    // ConnectMethods returns the list of HTTP methods that can be proxied
    func (r *ProxyREST) ConnectMethods() []string {
    Registered: 2024-06-15 01:39
    - Last Modified: 2024-03-04 19:10
    - 9.2K bytes
    - Viewed (0)
  3. pkg/registry/core/service/allocator/interfaces.go

    	Allocate(int) (bool, error)
    	AllocateNext() (int, bool, error)
    	Release(int) error
    	ForEach(func(int))
    	Has(int) bool
    	Free() int
    
    	// Destroy shuts down all internal structures.
    	// Destroy needs to be implemented in thread-safe way and be prepared for being
    	// called more than once.
    	Destroy()
    }
    
    // Snapshottable is an Interface that can be snapshotted and restored. Snapshottable
    // should be threadsafe.
    Registered: 2024-06-15 01:39
    - Last Modified: 2023-05-22 10:35
    - 1.4K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/types.go

    	EnsureExists(*v1.Pod) error
    
    	// Exists returns true if the pod cgroup exists.
    	Exists(*v1.Pod) bool
    
    	// Destroy takes a pod Cgroup name as argument and destroys the pod's container.
    	Destroy(name CgroupName) error
    
    	// ReduceCPULimits reduces the CPU CFS values to the minimum amount of shares.
    	ReduceCPULimits(name CgroupName) error
    
    Registered: 2024-06-15 01:39
    - Last Modified: 2023-02-24 18:21
    - 5.4K bytes
    - Viewed (0)
  5. pkg/registry/certificates/certificates/storage/storage.go

    func (r *StatusREST) New() runtime.Object {
    	return &certificates.CertificateSigningRequest{}
    }
    
    // Destroy cleans up resources on shutdown.
    func (r *StatusREST) Destroy() {
    	// Given that underlying store is shared with REST,
    	// we don't destroy it here explicitly.
    }
    
    // Get retrieves the object from the storage. It is required to support Patch.
    Registered: 2024-06-15 01:39
    - Last Modified: 2022-11-18 09:21
    - 6.3K bytes
    - Viewed (0)
  6. pkg/registry/core/pod/storage/storage.go

    }
    
    // New creates a new binding resource
    func (r *BindingREST) New() runtime.Object {
    	return &api.Binding{}
    }
    
    // Destroy cleans up resources on shutdown.
    func (r *BindingREST) Destroy() {
    	// Given that underlying store is shared with REST,
    	// we don't destroy it here explicitly.
    }
    
    var _ = rest.NamedCreater(&BindingREST{})
    var _ = rest.SubresourceObjectMetaPreserver(&BindingREST{})
    
    Registered: 2024-06-15 01:39
    - Last Modified: 2023-03-20 14:29
    - 13.7K bytes
    - Viewed (0)
  7. pkg/registry/authorization/subjectaccessreview/rest.go

    func (r *REST) NamespaceScoped() bool {
    	return false
    }
    
    func (r *REST) New() runtime.Object {
    	return &authorizationapi.SubjectAccessReview{}
    }
    
    // Destroy cleans up resources on shutdown.
    func (r *REST) Destroy() {
    	// Given no underlying store, we don't destroy anything
    	// here explicitly.
    }
    
    var _ rest.SingularNameProvider = &REST{}
    
    func (r *REST) GetSingularName() string {
    	return "subjectaccessreview"
    }
    
    Registered: 2024-06-15 01:39
    - Last Modified: 2022-11-18 09:21
    - 2.7K bytes
    - Viewed (0)
  8. src/os/file_mutex_plan9.go

    // remaining reference, and the file has been marked to be closed,
    // then actually close it.
    func (file *file) decref() error {
    	if file.fdmu.Decref() {
    		return file.destroy()
    	}
    	return nil
    }
    
    // readLock adds a reference to the file and locks it for reading.
    // It returns an error if the file is already closed.
    func (file *file) readLock() error {
    	if !file.fdmu.ReadLock() {
    Registered: 2024-06-12 16:32
    - Last Modified: 2022-10-08 03:57
    - 1.8K bytes
    - Viewed (0)
  9. fess-crawler-lasta/src/main/java/org/codelibs/fess/crawler/container/LastaCrawlerContainer.java

        }
    
        @Override
        public boolean available() {
            return SingletonLaContainerFactory.hasContainer();
        }
    
        @Override
        public void destroy() {
            SingletonLaContainerFactory.destroy();
        }
    
    Registered: 2024-06-12 15:17
    - Last Modified: 2024-02-22 01:36
    - 1.2K bytes
    - Viewed (0)
  10. pkg/registry/core/node/rest/proxy.go

    // New returns an empty nodeProxyOptions object.
    func (r *ProxyREST) New() runtime.Object {
    	return &api.NodeProxyOptions{}
    }
    
    // Destroy cleans up resources on shutdown.
    func (r *ProxyREST) Destroy() {
    	// Given that underlying store is shared with REST,
    	// we don't destroy it here explicitly.
    }
    
    // ConnectMethods returns the list of HTTP methods that can be proxied
    func (r *ProxyREST) ConnectMethods() []string {
    Registered: 2024-06-15 01:39
    - Last Modified: 2022-04-19 13:59
    - 3.1K bytes
    - Viewed (0)
Back to top