Aging plugin example, minor fixes

Author: fabianofranz

pkg/kubectl/cmd/cmd.go

@@ -283,7 +283,7 @@ func NewKubectlCommand(f cmdutil.Factory, in io.Reader, out, errOut io.Writer) *
 		{
 			Message: "Advanced Commands:",
 			Commands: []*cobra.Command{
-				NewCmdApply(f, out, err),
+				NewCmdApply(f, out, errOut),
 				NewCmdPatch(f, out),
 				NewCmdReplace(f, out),
 				NewCmdConvert(f, out),
@@ -307,7 +307,9 @@ func NewKubectlCommand(f cmdutil.Factory, in io.Reader, out, errOut io.Writer) *
 	if len(loadedPlugins) > 0 {
 		pluginCmds := []*cobra.Command{}
 
-		for _, plugin := range loadedPlugins {
+		for i := 0; i < len(loadedPlugins); i++ {
+			plugin := loadedPlugins[i]
+
 			pluginCmds = append(pluginCmds, &cobra.Command{
 				Use:     plugin.Use,
 				Short:   plugin.Short,

pkg/kubectl/plugins/examples/kubectl-aging

@@ -0,0 +1,83 @@
+#!/usr/bin/env ruby
+
+require 'json'
+require 'date'
+
+class Numeric
+  def duration
+    secs  = self.to_int
+    mins  = secs / 60
+    hours = mins / 60
+    days  = hours / 24
+    if days > 0
+      "#{days} day(s)"
+    elsif hours > 0
+      "#{hours} hour(s)"
+    elsif mins > 0
+      "#{mins} minute(s)"
+    elsif secs >= 0
+      "#{secs} second(s)"
+    end
+  end
+end
+
+if ARGV[0] == "metadata"
+  metadata = <<-META
+{
+  "use"    : "aging",
+  "short"  : "Aging shows pods by age",
+  "long"   : "Aging shows pods by age\\n\\nWhich shows pods by age which shows pods by age which shows pods by age which shows pods by age which shows pods by age which shows pods by age which shows pods by age which shows pods by age which shows pods by age which shows pods by age which shows pods by age which shows pods by age which shows pods by age which shows pods by age.",
+  "tunnel" : true
+}
+META
+  puts metadata
+else
+  api_host = ENV['KUBECTL_PLUGIN_API_HOST']
+  api_endpoint = "http://#{api_host}/api/v1/namespaces/myproject/pods"
+
+  pods_json = `curl -s #{api_endpoint}`
+  pods_parsed = JSON.parse(pods_json)
+
+  puts "I'm the magnificent aging plugin."
+  puts ""
+
+  data = Hash.new
+  max_name_length = 0
+  max_age = 0
+  min_age = 0
+
+  pods_parsed['items'].each { |pod|
+    name = pod['metadata']['name']
+    creation = pod['metadata']['creationTimestamp']
+
+    age = Time.now - DateTime.parse(creation).to_time
+    data[name] = age
+
+    if name.length > max_name_length
+      max_name_length = name.length
+    end
+    if age > max_age
+      max_age = age
+    end
+    if age < min_age
+      min_age = age
+    end
+
+  } 
+
+  data = data.sort_by{ |name, age| age }
+
+  if data.length
+    data.each { |name, age|
+      output = ""
+      output += name.rjust(max_name_length, ' ') + ": "
+      bar_size = (age*80/max_age).ceil 
+      bar_size.times{ output += "▒" }
+      output += " " + age.duration
+      puts output
+      puts ""
+    }
+  else
+    puts "No pods"
+  end
+end

pkg/kubectl/plugins/examples/kubectl-foo

@@ -6,16 +6,10 @@ if ARGV[0] == "metadata"
   "use"    : "foo",
   "short"  : "Foo plugin short description",
   "long"   : "Foo really LONG description\\n\\nCan take multi lines.",
-  "tunnel" : true
+  "tunnel" : false
 }
 META
   puts metadata
 else
-  api_host = ENV['KUBECTL_PLUGIN_API_HOST']
-  api_endpoint = "http://#{api_host}/api"
-
   puts "I'm the magnificent foo plugin."
-  puts ""
-  puts "I can use the API from #{api_host}:"
-  puts `curl -s #{api_endpoint}`
 end

pkg/kubectl/plugins/proxy.go

@@ -33,7 +33,7 @@ func ServePluginAPIProxy(clientConfig *restclient.Config) (net.Listener, error)
 		AcceptHosts: kubectl.MakeRegexpArrayOrDie(kubectl.DefaultHostAcceptRE),
 	}
 
-	server, err := kubectl.NewProxyServer("", "/api", "", filter, clientConfig)
+	server, err := kubectl.NewProxyServer("", "/", "", filter, clientConfig)
 	if err != nil {
 		return nil, err
 	}