Fix Kuber.get: Handle non-namespaced and all-namespaced queries (#59)

* Fix Kuber.get: Handle non-namespaced and all-namespaced queries

* Fix

* Fix

* Update version in Project.toml

Author: nkottary

Project.toml

@@ -4,7 +4,7 @@ authors = ["Tanmay Mohapatra <[email protected]>"]
 keywords = ["kubernetes", "client"]
 license = "MIT"
 desc = "Julia Kubernetes Client"
-version = "0.7.2"
+version = "0.7.3"
 
 [deps]
 Dates = "ade2ca70-3891-5945-98fb-dc099432e06a"

src/simpleapi.jl

@@ -143,17 +143,20 @@ function get(ctx::Union{KuberContext,KuberWatchContext}, O::Symbol, name::String
         max_tries::Integer=retries(ctx),
         watch=isa(ctx, KuberWatchContext),
         resource_version=nothing,
+        namespace::Union{String,Nothing}=_kubectx(ctx).namespace,
         kwargs...)
     apictx = _get_apictx(ctx, O, apiversion; max_tries=max_tries)
+    namespaced = (namespace !== nothing) && !isempty(namespace)
+    allnamespaces = namespaced && (namespace == "*")
 
     eventstream = isa(ctx, KuberWatchContext) ? ctx.stream : nothing
     result = nothing
     args = Any[name]
     _O_ = to_snake_case(string(O))
-    if (apicall = _api_function(ctx, "read_$(_O_)")) !== nothing
+    if namespaced && !allnamespaces && (apicall = _api_function(ctx, "read_namespaced_$(_O_)")) !== nothing
+        push!(args, namespace)
+    elseif (apicall = _api_function(ctx, "read_$(_O_)")) !== nothing
         # nothing
-    elseif (apicall = _api_function(ctx, "read_namespaced_$(_O_)")) !== nothing
-        push!(args, _kubectx(ctx).namespace)
     else
         throw(ArgumentError("No API functions could be located using $O"))
     end
@@ -189,17 +192,22 @@ function get(ctx::Union{KuberContext,KuberWatchContext}, O::Symbol;
         resource_version=nothing,
         kwargs...)
     apictx = _get_apictx(ctx, O, apiversion; max_tries=max_tries)
+    namespaced = (namespace !== nothing) && !isempty(namespace)
+    allnamespaces = namespaced && (namespace == "*")
 
     eventstream = isa(ctx, KuberWatchContext) ? ctx.stream : nothing
     result = nothing
     args = Any[]
     _O_ = to_snake_case(string(O))
     apiname = "list_$(_O_)"
-    namespace === nothing && (apiname *= "_for_all_namespaces")
-    if (apicall = _api_function(ctx, apiname)) !== nothing
-        # nothing
-    elseif (apicall = _api_function(ctx, "list_namespaced_$(_O_)")) !== nothing
+    if allnamespaces && (apicall = _api_function(ctx, apiname * "_for_all_namespaces")) !== nothing
+        #nothing
+    elseif namespaced && (apicall = _api_function(ctx, "list_namespaced_$(_O_)")) !== nothing
         push!(args, namespace)
+    elseif (apicall = _api_function(ctx, apiname)) !== nothing
+        #nothing
+    elseif (apicall = _api_function(ctx, apiname * "_for_all_namespaces")) !== nothing
+        #nothing
     else
         throw(ArgumentError("No API functions could be located using $O"))
     end