Add proper GCP config loader and refresher by mbohlool · Pull Request #22 · kubernetes-client/python-base · GitHub

This is based on #21. I added expiration mechanism as well as persisting config back so we don't need to refresh the token every time. The way it persisted back should be the same as kubectl.
Tests will fail for this PR unless kubernetes-client/python#302 is merged.

Thanks!

@gabrielgbim @pokoli This is a release blocker. Can you review it please.

Codecov Report

Merging #22 into master will decrease coverage by 1.05%.
The diff coverage is 87.61%.

@@            Coverage Diff             @@
##           master      #22      +/-   ##
==========================================
- Coverage   94.69%   93.64%   -1.06%     
==========================================
  Files           9       11       +2     
  Lines         698      803     +105     
==========================================
+ Hits          661      752      +91     
- Misses         37       51      +14

Impacted Files	Coverage Δ
config/dateutil_test.py	100% <100%> (ø)
config/kube_config.py	93.17% <77.77%> (-3.41%)	⬇️
config/dateutil.py	88.88% <88.88%> (ø)
config/kube_config_test.py	92.49% <92.3%> (-0.07%)	⬇️

Continue to review full report at Codecov.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update 00d2417...824c03c. Read the comment docs.

I don't think you need to store n as a variable.

Fixed.

Maybe better: "IF True config file will be updated when changed (e.g GCP token refresh)

Fixed!

Why is required a lambda function here?

to pass the config_file to _save_kube_config. If there is a better way to do it, I am open to it.

AFAIU it should work with:
config_persister = _save_kube_config

the key here is the config_file=config_file: part that passes the local variable config_file as one of the parameters.config_persisteraccepts one parameter,_save_kube_config` needs two.

Ok, I didn't understand at all the code.

Then you should probably use the partial function from functools standard library.

This will make the code clearer.

I inline'ed _save_kube_config. it should be cleaner. is it good or do you still suggest partial function?

Ok, now the usage it's much clearer.

maybe you can put a raise to ensure it's not called

Will fix this with some other tests.

Done.

What about https://pypi.python.org/pypi/rfc3339/5.2 (source code in https://bitbucket.org/henry/rfc3339/src)

looks like they only do one side of conversion? https://bitbucket.org/henry/rfc3339/issues/3/datetime-to-rfc-3339

I see a parse method but it is not exported.

Then probably it's worth to contribute one to the library :)

True. This is, however, a release blocker and I don't want to wait for that contribution to go through. I suggest we proceed with this and either contribute to the that one or even release the one I copied as a pypi package for all to use (I have a feeling by looking at the code that this one is better, but we can decide on that later).

I've looked at different options and decided to implement my own. Some options are too restrictive for our use and the others are too admissive. I've implemented a simple balanced one in dateutil.py.

Ok, as it's a release blocker I think the unique option we have is to include the code in the client.

For the record, I didn't copy code from any of those libraries. I've implemented it again by reading rfc. Of course my implementation can be influenced by those libraries, but I stick to the rules of rfc3339. None of the libraries I've checked were like that, they were either relaxer or stricter. Also our implementation forces a UTC timezone.

@pokoli I am going to add some tests for dateutil but this is basically ready for review and I already tested it for GKE. Please take another look. I would like to merge this as soon as possible to cut a new release.

We should probably need some test for the dateutil module.

AFAIU it should work with:
config_persister = _save_kube_config

Thanks for the review @pokoli I think I addressed all of your comments and tests are passing. Can you take a final look please?

Despite two minor issues its a LGTM

IF -> If

Why not directly raising the exception?

Why do you mean? I am passing this function as a function pointer to config loader and expect the function pointer (that suppose to update GCE token) never been called in the test. I was using lambda syntax to return a dummy token before, but you cannot raise exception in lambda syntax.

Ok, I didn't now that you can not raise inside lambda (always learning from codereview).

Forget about it.

@mbohlool for me you can merge once fixed.

mbohlool force-pushed the gce_config branch from a4d2b26 to 823f44e Compare July 21, 2017 21:55

mbohlool force-pushed the gce_config branch from 823f44e to b982d5e Compare July 22, 2017 00:59

mbohlool requested a review from pokoli July 22, 2017 01:00

mbohlool force-pushed the gce_config branch 2 times, most recently from f4da0c7 to 253d937 Compare July 23, 2017 10:15

pokoli reviewed Jul 24, 2017

View reviewed changes

mbohlool force-pushed the gce_config branch 2 times, most recently from 5d0b367 to 50f717d Compare July 25, 2017 03:54

pokoli reviewed Jul 25, 2017

View reviewed changes

mbohlool force-pushed the gce_config branch 3 times, most recently from c4b8c87 to bd507f4 Compare July 25, 2017 09:28

pokoli approved these changes Jul 25, 2017

View reviewed changes

Add proper GCP config loader and refresher

824c03c

mbohlool force-pushed the gce_config branch from bd507f4 to 824c03c Compare July 25, 2017 10:17

mbohlool mentioned this pull request Jul 25, 2017

Fixing get Google default credentials method #21

Closed

mbohlool merged commit ab3fc54 into kubernetes-client:master Jul 25, 2017

ofek mentioned this pull request Mar 18, 2019

Bug in rfc3339 implementation #123

Closed

                       from config file will be used.
                   :param client_configuration: The kubernetes.client.ConfigurationObject to
                       set configs to.
+                  :param persist_config: If True and config changed (e.g. GCP token refresh)

                           active_context="gcp",
                           client_configuration=actual,
-                          get_google_credentials=lambda: TEST_ANOTHER_DATA_BASE64) \
+                          get_google_credentials=lambda: "SHOULD NOT BE CALLED") \

                       from config file will be used.
                   :param client_configuration: The kubernetes.client.ConfigurationObject to
                       set configs to.
+                  :param persist_config: IF True, config file will be updated when changed

+              def _is_expired(expiry):
+                  tf = tf_from_timestamp(expiry)
+                  n = time.time()

+                  config_persister = None
+                  if persist_config:
+                      config_persister = lambda config_map, config_file=config_file: (

		@@ -0,0 +1 @@
		The (rfc3339.py)[rfc3339.py] file is copied from [this site](http://home.blarg.net/~steveha/pyfeed.html) because PyFeed is not available in PyPi. No newline at end of file

		return base64.encodestring(string.encode()).decode()


		def _raise_exception(st):

Add proper GCP config loader and refresher by mbohlool · Pull Request #22 · kubernetes-client/python-base · GitHub

Uh oh!

Add proper GCP config loader and refresher - #22

Add proper GCP config loader and refresher#22mbohlool merged 1 commit intokubernetes-client:masterkubernetes-client/python-base:masterfrom mbohlool:gce_configmbohlool/python-base:gce_configCopy head branch name to clipboard

Conversation

mbohlool commented Jul 21, 2017

Uh oh!

gabrielgbim commented Jul 21, 2017

Uh oh!

mbohlool commented Jul 22, 2017

Uh oh!

codecov-io commented Jul 23, 2017 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Codecov Report

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

mbohlool Jul 25, 2017 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

mbohlool Jul 25, 2017 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Choose a reason for hiding this comment

Uh oh!

mbohlool commented Jul 25, 2017

Uh oh!

pokoli left a comment

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

mbohlool commented Jul 25, 2017

Uh oh!

pokoli left a comment

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

mbohlool Jul 25, 2017 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Choose a reason for hiding this comment

Add proper GCP config loader and refresher#22
mbohlool merged 1 commit into
kubernetes-client:masterfrom
mbohlool:gce_config

codecov-io commented Jul 23, 2017 •
edited
Loading

mbohlool Jul 25, 2017 •
edited
Loading

mbohlool Jul 25, 2017 •
edited
Loading

mbohlool Jul 25, 2017 •
edited
Loading