Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 44 for corev1informers (0.48 sec)

  1. pkg/controller/serviceaccount/legacy_serviceaccount_token_cleaner.go

    	minimumSinceLastUsed time.Duration
    }
    
    // NewLegacySATokenCleaner returns a new *NewLegacySATokenCleaner.
    func NewLegacySATokenCleaner(saInformer coreinformers.ServiceAccountInformer, secretInformer coreinformers.SecretInformer, podInformer coreinformers.PodInformer, client clientset.Interface, cl clock.Clock, options LegacySATokenCleanerOptions) (*LegacySATokenCleaner, error) {
    	if !(options.CleanUpPeriod > 0) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 27 03:52:06 UTC 2023
    - 10K bytes
    - Viewed (0)
  2. pkg/controller/bootstrap/tokencleaner_test.go

    	"k8s.io/apimachinery/pkg/runtime/schema"
    	"k8s.io/apimachinery/pkg/util/wait"
    	"k8s.io/client-go/informers"
    	coreinformers "k8s.io/client-go/informers/core/v1"
    	"k8s.io/client-go/kubernetes/fake"
    	core "k8s.io/client-go/testing"
    	api "k8s.io/kubernetes/pkg/apis/core"
    )
    
    func newTokenCleaner() (*TokenCleaner, *fake.Clientset, coreinformers.SecretInformer, error) {
    	options := DefaultTokenCleanerOptions()
    	cl := fake.NewSimpleClientset()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 14 00:05:53 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  3. pkg/controlplane/controller/systemnamespaces/system_namespaces_controller.go

    	"time"
    
    	v1 "k8s.io/api/core/v1"
    	"k8s.io/apimachinery/pkg/api/errors"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
    	"k8s.io/apimachinery/pkg/util/wait"
    	coreinformers "k8s.io/client-go/informers/core/v1"
    	"k8s.io/client-go/kubernetes"
    	listers "k8s.io/client-go/listers/core/v1"
    	"k8s.io/client-go/tools/cache"
    
    	"k8s.io/klog/v2"
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 12:19:56 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. pkg/controller/podgc/gc_controller.go

    	terminatedPodThreshold int
    	gcCheckPeriod          time.Duration
    	quarantineTime         time.Duration
    }
    
    func NewPodGC(ctx context.Context, kubeClient clientset.Interface, podInformer coreinformers.PodInformer,
    	nodeInformer coreinformers.NodeInformer, terminatedPodThreshold int) *PodGCController {
    	return NewPodGCInternal(ctx, kubeClient, podInformer, nodeInformer, terminatedPodThreshold, gcCheckPeriod, quarantineTime)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  5. pkg/controller/nodeipam/node_ipam_controller.go

    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    package nodeipam
    
    import (
    	"context"
    	"fmt"
    	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
    	coreinformers "k8s.io/client-go/informers/core/v1"
    	clientset "k8s.io/client-go/kubernetes"
    	v1core "k8s.io/client-go/kubernetes/typed/core/v1"
    	corelisters "k8s.io/client-go/listers/core/v1"
    	"k8s.io/client-go/tools/cache"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 16:18:38 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  6. pkg/controller/serviceaccount/serviceaccounts_controller.go

    			{ObjectMeta: metav1.ObjectMeta{Name: "default"}},
    		},
    	}
    }
    
    // NewServiceAccountsController returns a new *ServiceAccountsController.
    func NewServiceAccountsController(saInformer coreinformers.ServiceAccountInformer, nsInformer coreinformers.NamespaceInformer, cl clientset.Interface, options ServiceAccountsControllerOptions) (*ServiceAccountsController, error) {
    	e := &ServiceAccountsController{
    		client:                  cl,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  7. pkg/controller/volume/ephemeral/controller.go

    }
    
    // NewController creates an ephemeral volume controller.
    func NewController(
    	ctx context.Context,
    	kubeClient clientset.Interface,
    	podInformer coreinformers.PodInformer,
    	pvcInformer coreinformers.PersistentVolumeClaimInformer) (Controller, error) {
    
    	ec := &ephemeralController{
    		kubeClient: kubeClient,
    		podLister:  podInformer.Lister(),
    		podIndexer: podInformer.Informer().GetIndexer(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  8. pkg/controller/bootstrap/tokencleaner.go

    	v1 "k8s.io/api/core/v1"
    	apierrors "k8s.io/apimachinery/pkg/api/errors"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
    	"k8s.io/apimachinery/pkg/util/wait"
    	coreinformers "k8s.io/client-go/informers/core/v1"
    	clientset "k8s.io/client-go/kubernetes"
    	corelisters "k8s.io/client-go/listers/core/v1"
    	"k8s.io/client-go/tools/cache"
    	"k8s.io/client-go/util/workqueue"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  9. pkg/controller/volume/pvprotection/pv_protection_controller.go

    	v1 "k8s.io/api/core/v1"
    	apierrors "k8s.io/apimachinery/pkg/api/errors"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
    	"k8s.io/apimachinery/pkg/util/wait"
    	coreinformers "k8s.io/client-go/informers/core/v1"
    	clientset "k8s.io/client-go/kubernetes"
    	corelisters "k8s.io/client-go/listers/core/v1"
    	"k8s.io/client-go/tools/cache"
    	"k8s.io/client-go/util/workqueue"
    	"k8s.io/klog/v2"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  10. pkg/controller/volume/persistentvolume/pv_controller_base.go

    	VolumePlugins             []vol.VolumePlugin
    	VolumeInformer            coreinformers.PersistentVolumeInformer
    	ClaimInformer             coreinformers.PersistentVolumeClaimInformer
    	ClassInformer             storageinformers.StorageClassInformer
    	PodInformer               coreinformers.PodInformer
    	NodeInformer              coreinformers.NodeInformer
    	EnableDynamicProvisioning bool
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 29.5K bytes
    - Viewed (0)
Back to top