- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for startInformer (0.32 sec)
-
pkg/kube/kclient/client.go
// handler is the actual handler. Note this does NOT have the filtering applied. handler cache.ResourceEventHandler } type informerClient[T controllers.Object] struct { informer cache.SharedIndexInformer startInformer func(stopCh <-chan struct{}) filter func(t any) bool handlerMu sync.RWMutex registeredHandlers []handlerRegistration } func (n *informerClient[T]) Get(name, namespace string) T {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 07:14:28 UTC 2024 - 13K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller_test.go
} func (f *fixture) runExpectError(ctx context.Context, deploymentName string, startInformers bool) { f.run_(ctx, deploymentName, startInformers, true) } func (f *fixture) run(ctx context.Context, deploymentName string) { f.run_(ctx, deploymentName, true, false) } func (f *fixture) run_(ctx context.Context, deploymentName string, startInformers bool, expectError bool) { c, informers, err := f.newController(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/admission_test.go
// support multiple types of params this function needs to be augmented // // PolicyTracker expects FakePolicyDefinition and FakePolicyBinding types // !TODO: refactor this test/framework to remove startInformers argument and // clean up the return args, and in general make it more accessible. func setupTestCommon( t *testing.T, compiler *fakeCompiler, matcher generic.PolicyMatcher, shouldStartInformers bool,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 25 01:39:01 UTC 2024 - 63.8K bytes - Viewed (0)