Kris 209867a87c Add started state to the processor to protect against double starts ...

This prevents a race condition where the sharedIndexInformer was
causeing the processorListener's run and pop method to be started
twice. That violated the SharedInformer's interface guarantee of
sequential delivery and also caused panics on shutdown.

Kubernetes-commit: 8c8b5071cd0484d3c5a7cfbf1d49b81c0b8afe16

2018-02-13 11:33:21 -08:00

..

testing

Use buildozer to delete licenses() rules except under third_party/

2017-08-29 12:51:55 +00:00

BUILD

Enable paging for all list watchers

2017-09-03 13:49:07 +00:00

controller_test.go

run hack/update-staging-client-go, somehow we copied listers/<authn,authz,imagepolicy>

2017-06-28 00:06:44 +00:00

controller.go

Refactor Start functions into an object

2017-07-19 03:39:07 +00:00

delta_fifo_test.go

published by bot

2016-10-21 04:44:19 +00:00

delta_fifo.go

manually sync with k8s.io/kubernetest at 17375fc59fff39135af63bd1750bb07c36ef873b, k8s.io/apimachinery at d90aa2c8531f13b0ca734845934c10dcb6a56ca7

2017-02-23 12:27:32 -08:00

doc.go

published by bot

2016-10-21 04:44:19 +00:00

expiration_cache_fakes.go

Refactor move of client-go/util/clock to apimachinery

2017-05-21 17:20:29 +00:00

expiration_cache_test.go

Refactor move of client-go/util/clock to apimachinery

2017-05-21 17:20:29 +00:00

expiration_cache.go

Refactor move of client-go/util/clock to apimachinery

2017-05-21 17:20:29 +00:00

fake_custom_store.go

remove the top-level folders for versions

2016-10-19 14:34:19 -07:00

fifo_test.go

remove the top-level folders for versions

2016-10-19 14:34:19 -07:00

fifo.go

manually sync with k8s.io/kubernetest at 17375fc59fff39135af63bd1750bb07c36ef873b, k8s.io/apimachinery at d90aa2c8531f13b0ca734845934c10dcb6a56ca7

2017-02-23 12:27:32 -08:00

heap_test.go

Add a heap data store to client-go

2017-08-29 12:51:54 +00:00

heap.go

Add a heap data store to client-go

2017-08-29 12:51:54 +00:00

index_test.go

run hack/update-staging-client-go, somehow we copied listers/<authn,authz,imagepolicy>

2017-06-28 00:06:44 +00:00

index.go

add mutation cache filter

2017-05-17 17:20:30 +00:00

listers.go

published by bot

2017-01-24 15:19:42 +00:00

listwatch.go

Disable default paging in list watches

2017-09-09 21:30:07 +00:00

mutation_cache.go

Use glog.*f when a format string is passed

2017-07-16 03:58:42 +00:00

mutation_detector_test.go

run hack/update-staging-client-go, somehow we copied listers/<authn,authz,imagepolicy>

2017-06-28 00:06:44 +00:00

mutation_detector.go

Shared Informer Run blocks until all goroutines finish

2017-07-19 03:39:07 +00:00

OWNERS

Add ncdc to client-go/tools/cache OWNERS

2017-08-29 12:53:02 +00:00

processor_listener_test.go

Improve shared informer notification dispatching

2017-08-29 12:49:48 +00:00

reflector_metrics.go

add reflector metrics

2017-07-28 13:45:49 +00:00

reflector_test.go

Shared Informer Run blocks until all goroutines finish

2017-07-19 03:39:07 +00:00

reflector.go

rename metric reflector_xx_last_resource_version to reflector_last_resource_version{name="xx"}

2017-11-01 16:34:18 +08:00

shared_informer_test.go

Add a test case for the race in #59822

2018-02-13 11:32:36 -08:00

shared_informer.go

Add started state to the processor to protect against double starts

2018-02-13 11:33:21 -08:00

store_test.go

published by bot

2017-01-14 15:19:47 +00:00

store.go

add mutation cache filter

2017-05-17 17:20:30 +00:00

thread_safe_store.go

add mutation cache filter

2017-05-17 17:20:30 +00:00

undelta_store_test.go

remove the top-level folders for versions

2016-10-19 14:34:19 -07:00

undelta_store.go

remove the top-level folders for versions

2016-10-19 14:34:19 -07:00