github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2026-01-13 19:44:29 +00:00
Code Issues Projects Releases Wiki Activity
3,330 Commits 35 Branches 1,532 Tags
e540ebe9940f6a170fb8a92d15d22c61dad04f32
Commit Graph

238 Commits

Author SHA1 Message Date
Michael Bolot
e540ebe994 Addresses the issue which caused #109115 
Kubernetes-commit: cbbb5f70a47644f9830073d9d0329bf247a328a1
 2022-03-29 12:35:13 -05:00
Wojciech Tyczyński
1cab68940f Add test for indexer with multiple values 
Kubernetes-commit: 56159f258ca380600b0bc08b2e99cbc745db3560
 2022-03-30 08:52:10 +02:00
Jian Li
6b59aa0b4a make comments of updateIndices optimization code more accurate 
Kubernetes-commit: 0eae1f3addbd044793dac89f9e097e5f4c6fb2aa
 2022-03-14 13:56:17 +08:00
Alexander Zielenski
54928eef9f modify SharedIndexInformer to use newInformer constructor which supports transformers 
avoids code duplication, allows transformer to be used with SharedIndexInformer

Kubernetes-commit: 754bf3b3d02c66d1dd030460b03dddd3d6c7196d
 2022-01-19 11:40:42 -08:00
Ismayil Mirzali
664b1a6c8c client-go: refactor: Fix styling issues (#107248) 
* client-go: Remove unreachable return

Due to the way the switch statement is done,
the return at the end of the function will neverbe reached.

Signed-off-by: Ismayil Mirzali <ismayilmirzeli@gmail.com>

* client-go: Refactor for clarity

Fixed one instance where the error message should be lowercase.
Made the fields in the struct literal more explicit

Signed-off-by: Ismayil Mirzali <ismayilmirzeli@gmail.com>

Kubernetes-commit: 75c0987de3cb9a0380873745f68dea2f0835a7a2
 2022-01-18 12:03:08 +02:00
Davanum Srinivas
3bf0eac274 OWNERS cleanup - Jan 2021 Week 1 
Signed-off-by: Davanum Srinivas <davanum@gmail.com>

Kubernetes-commit: 9682b7248fb69733c2a0ee53618856e87b067f16
 2022-01-03 10:59:47 -05:00
wq
3480737c9e fix typos in comment 
Kubernetes-commit: 3e2932179084fa322ba1bc53997d44e1d383db00
 2022-01-08 23:39:23 +09:00
astraw99
a8ff96d887 fix log typo 
Kubernetes-commit: abce7ab534d0c667dd1438ff24bb3130d17d3f6e
 2021-11-19 11:06:14 +08:00
Davanum Srinivas
73f2731e23 Cleanup OWNERS files (No Activity in the last year) 
Signed-off-by: Davanum Srinivas <davanum@gmail.com>

Kubernetes-commit: 497e9c1971c9e7d0193bc6d11503ec4ad527f1d5
 2021-12-10 15:18:50 -05:00
Davanum Srinivas
70f09c4943 Check in OWNERS modified by update-yamlfmt.sh 
Signed-off-by: Davanum Srinivas <davanum@gmail.com>

Kubernetes-commit: 9405e9b55ebcd461f161859a698b949ea3bde31d
 2021-12-09 21:31:26 -05:00
hyschumi
547d6c809a refactor: remove dup code 
Signed-off-by: hyschumi<msliudongsheng@gmail.com>

Kubernetes-commit: da5d0a72d9d2a0948e21b746a8c6951dc40c0ce9
 2021-11-04 21:11:53 +08:00
Antoni Zawodny
9af7db3c25 Add more info to the ListAndWatch trace 
Kubernetes-commit: 093aa210be67f45efb1005f273d8d68444156473
 2021-10-21 14:33:57 +02:00
astraw99
1816a40bbb fix word comment to common 
Kubernetes-commit: 3e31933471e015a860e1967acfe730bb35422f17
 2021-08-29 19:06:04 +08:00
wojtekt
c702a411d1 Create TransformingIndexerInformer 
Kubernetes-commit: 56ffb4e2b056622210bbf5ce845cf63ca18e85ce
 2021-09-23 09:09:59 +02:00
wojtekt
b100ecfc06 Create TransformingInformer 
TransformingInfomer is like a regular Informer, but allows for applying
custom transform functions on the objects received via list/watch API calls.

Kubernetes-commit: efd3490076c391823095b4c8bd6e847ae18eb012
 2020-09-29 15:06:33 +02:00
wojtekt
e61d0d5d52 Optimize index updating 
Kubernetes-commit: 75273a0689250f4861ea41405e6402c6191563a8
 2021-09-24 15:24:01 +02:00
wojtekt
463b3d12bb Optimize indexer 
Kubernetes-commit: 27c94a49c80202790e195dde3a258cc62110c1e5
 2021-09-24 14:46:56 +02:00
wojtekt
01243dd50e Migrate to k8s.io/utils/clock in client-go 
Kubernetes-commit: bb7dac443a2039f97c822f610e78d4b65482c56d
 2021-09-17 11:36:09 +02:00
kitianFresh
f0bcda0dce avoid sharedIndexInformer run more than once, avoid more cache and memory consume 
Kubernetes-commit: 305c13faca48d1a6ea4d263e262ebc8df0387c84
 2021-09-09 13:37:25 +08:00
Dingzhu Lurong
b86695770f Improve DeltaFIFO function 'ListKeys' 
In function ListKeys, it better to use ‘queue’ instead of 'items' to get all the keys.

Kubernetes-commit: f0ce8755287b1cad087b61abfcccd79c9f151828
 2021-09-02 14:02:54 +08:00
00255991
c209a2e2bc para 'resourceVersion' in DeltaFIFO.Replace is not used, so remove it 
Kubernetes-commit: 2949045ec47163485118c25c40907eb43c090fac
 2021-09-08 19:10:40 +08:00
astraw99
33e23edf09 fix sharedInformer doc 
Kubernetes-commit: 9d84ffafd06e6ca455aa279bd513758696e8e875
 2021-09-07 16:45:07 +08:00
astraw99
f100d86401 fix typo CRED to CRUD 
Kubernetes-commit: f8b82e189cfdc3aca7b9d789cc6f3131897f0ebc
 2021-08-22 21:19:30 +08:00
Antonio Ojea
c63d830a92 client-go: deltaFIFO trace slow handlers 
If the informers handlers are slow processing the objects, the deltaFIFO
blocks the queue and the streamWatchers can not add new elements to the
queue, creating contention and causing different problems, like high
memory usage.
The problem is not easy to identify from a user perspective, typically
you can use pprof to identify a high memory usage on the StreamWatchers
or some handler consuming most of the cpu time, but users should not
have to profile the golang binary in order to know that.

Metrics were disabled on the reflector because of memory leaks, also
monitoring the queue depth can't give a good signal, since it never goes high

However, we can trace slow handlers and inform users about the problem.

Kubernetes-commit: d38c2df2c4b945bcf1f81714fc6bfd01bbd0f538
 2021-07-26 16:00:31 +02:00
Patrick Ohly
67de95ce2f client-go: reduce log level of reflector again 
https://github.com/kubernetes/kubernetes/pull/87795 most likely
unintentionally increased the log level of "Starting reflector" and
"Stopping reflector", with the result that since Kubernetes 1.21
clients have printed that message by default. This is undesirable, we
should use the original level 3 again.

Kubernetes-commit: fd972934e4916879b04508686302659ce82cfa75
 2021-06-10 20:36:02 +02:00
刁浩 10284789
5b0c7191ef simplify returning boolean expression in staging/src/k8s.io/client-go/tools 
Signed-off-by: 刁浩 10284789 <diao.hao@zte.com.cn>

Kubernetes-commit: 9173414da6d1c70436b256d6068e3737a7434f6a
 2021-05-24 07:15:36 +00:00
kfu
6db26dd413 Fixes formatting and typos in client-go docs 
Kubernetes-commit: d0de4483d51c5811202f1731a835c75d8fc8b30e
 2021-04-27 21:28:23 +02:00
c00522440
ca138c86e8 Change time.Now().Sub(x) to time.Since(x) for cleanup 
Kubernetes-commit: 878548ceac9c109881c379911b8b0d8fce5ea68e
 2021-04-12 10:27:54 +08:00
scott
c7901fa3e4 modify the elements in the array directly without allocating a new array 
Kubernetes-commit: 238fce9357634502badbcc3704b0655cf8c378c3
 2021-01-12 19:58:21 +08:00
Iceber Gu
8269e41416 client-go/cache: fix the AddIfNotPresent method of the DeltaFIFO 
Signed-off-by: Iceber Gu <wei.cai-nat@daocloud.io>

Kubernetes-commit: c75bd4a535123f5032f78ffb246ed62b79617b44
 2021-04-01 13:44:16 +08:00
Iceber Gu
fc03592e80 client-go/cache: support errors.Unwrap for KeyError 
Signed-off-by: Iceber Gu <wei.cai-nat@daocloud.io>

Kubernetes-commit: 85fa121f84ee33bdc8d77e7a35d1f4d2c063c28f
 2021-04-02 10:17:57 +08:00
Monis Khan
7998e982ab Prune stale entries from OWNERS files 
Signed-off-by: Monis Khan <mok@vmware.com>

Kubernetes-commit: 91241eac9b7a7e62cc31e663147294bf6dc8f875
 2021-04-07 10:38:27 -04:00
wojtekt
03ebb2739b Handle 429 errors from watch requests in reflector library. 
Kubernetes-commit: a9daa46d470e87ed328688bebd9314cc5ac0fc4a
 2021-03-13 12:29:44 +01:00
Wang Yiping
aa707b1f81 Replace deprecated NewDeltaFIFO with NewDeltaFIFOWithOptions 
Kubernetes-commit: 8dc45c8e0ecdefa37df8c118f38fa0767c5c52b0
 2021-03-18 08:30:29 +08:00
Jordan Liggitt
21ee617309 Add test timeout to mutation detector test 
Kubernetes-commit: 877d889ac2c78b1c8c94dc2839351aad4136f908
 2021-03-06 18:16:42 -05:00
Jordan Liggitt
0693903770 Fix or remove tests that don't work in race mode 
Kubernetes-commit: 68bb8b827b3827cbee61d3fcc560738beba3e110
 2021-03-04 09:51:52 -05:00
Nikhita Raghunath
1d0cb03f5a *: remove nikhiljindal from OWNERS 
Kubernetes-commit: 6cef3a4e33c10c27bb301a1070ea3ff4cdad0c39
 2021-02-16 10:50:50 +05:30
Nikhita Raghunath
e8ab2528ca *: remove madhusudancs from reviewers 
Kubernetes-commit: 6b12c96a9b7fe4d7c03d0dfed447edd6b1055067
 2021-02-16 10:40:42 +05:30
Victor Timofei
53a09c71a4 Update the wording of the DeltaFIFO 
Kubernetes-commit: 3a107951f0bf16a022b70a667c98833e4ac1d540
 2020-12-24 16:33:04 +02:00
Victor Timofei
710a222444 Move Delta definitions to the top 
Kubernetes-commit: bcc1c9a387c898478ed47c629864418be89bf518
 2020-12-15 22:07:33 +02:00
Victor Timofei
09cf7147ab Update DeltaFIFO Documentation 
Kubernetes-commit: 1a4ed5ea57ac4d562311d2b2852dcc59b78725da
 2020-12-15 21:31:30 +02:00
pacoxu
8031d76bd6 fix index test: multi index check for empty list 
Signed-off-by: pacoxu <paco.xu@daocloud.io>

Kubernetes-commit: ae6360f6c732d554c332a0bc1b99808149d8376e
 2020-11-26 18:23:57 +08:00
Qing Ju
1d175299a2 Fixed a harmless bug where initialPopulationCount should be based on the key length not list size in DeltaFIFO#Replace() 
Kubernetes-commit: bc39672c0638426979feef95baeff39d170161eb
 2020-11-22 16:35:19 -08:00
wojtekt
866e6a7e3c Allow tracking resource version for reflector store 
Kubernetes-commit: 4af1328bb8a3b3eb2289bbbe624480548dd39cdc
 2020-08-31 15:58:16 +02:00
Maciej Borsz
a52faa7892 Add WatchListPageSize to cache.Config 
Currently there is no way to specify WatchListPageSize used by Controller. This PR adds a field that can be used to specify this.

Change-Id: I241454a45dd94d3ea65a91b297f530e217f843aa

Kubernetes-commit: 43f5afe1a1dd058a2564cd3b2f330fc2a401f607
 2020-08-31 12:52:45 +02:00
azush26
5f6a1b08cd modify the warning log format from %d to %v 
Kubernetes-commit: ac1168e0e922ccd32b0fcc3d3aecac8920cedbda
 2020-08-12 16:05:59 +09:00
Kevin Delgado
4d01b584c3 Add exp backoff for connection refused errors 
Currently when ListAndWatch() receives a connection refused error, it is
assumed to be due to the apiserver being transiently unresponsive. In
situations where a controller is running outside the k8s cluster it's
controlling, it is more common for the controller to lose connection
permanently to the apiserver and needs to exponentially backoff its
retry rather than continously spamming logs with Watch attempts that
will never succeed.

Kubernetes-commit: 1ff789f2bb9bf7fbb3df35977bc249c0dd019d31
 2020-08-25 19:15:21 +00:00
janeczku
47f16e33aa Fixed reflector not recovering from "Too large resource version" errors with API servers 1.17.0-1.18.5 
Kubernetes-commit: e1f4bfe1db8d3975bf626c2c8536dd8076aeb7d4
 2020-08-28 21:17:27 +02:00
gobomb
330cb14339 let panics propagate up when processLoop panic 
Kubernetes-commit: 19a3ca2c289b6f3dc8cd495e3db0d347b5a3b774
 2020-08-03 09:30:39 +00:00
Nikhita Raghunath
480d796592 apimachinery: remove inactive members from OWNERS 
Kubernetes-commit: db495ea9837cf840639a4e02085253fb341e12b5
 2020-07-11 19:28:24 +05:30