From e46a1eb752dcde3ce4dd045772a0176b0ece601f Mon Sep 17 00:00:00 2001
From: jackgr <jackgr@google.com>
Date: Tue, 29 Mar 2016 13:56:44 -0700
Subject: [PATCH] Port replicatedservice template to chart format

---
 examples/charts/replicatedservice-v3.tgz      | Bin 0 -> 2847 bytes
 examples/charts/replicatedservice/Chart.yaml  |   7 +
 .../templates/replicatedservice.py            | 195 ++++++++++++++++++
 .../templates/replicatedservice.py.schema     |  91 ++++++++
 4 files changed, 293 insertions(+)
 create mode 100644 examples/charts/replicatedservice-v3.tgz
 create mode 100644 examples/charts/replicatedservice/Chart.yaml
 create mode 100644 examples/charts/replicatedservice/templates/replicatedservice.py
 create mode 100644 examples/charts/replicatedservice/templates/replicatedservice.py.schema

diff --git a/examples/charts/replicatedservice-v3.tgz b/examples/charts/replicatedservice-v3.tgz
new file mode 100644
index 0000000000000000000000000000000000000000..eefd10ae0d3bda3832c4403dba4890c00e9af08a
GIT binary patch
literal 2847
zcmV+)3*hu0iwFP>>-tsz1MM1XZ`;T*pZO~m2~gRnEX$500|J5~b)3Rz;slP7;$RrY
zid<QHrno#VsYFQq-#fD}E=5Xme1fmNa)3k@Ij^19&g?2<Y0N{Kvq-XR!9#ZVV&~BB
z_fLjH^5SH0d@_K~{?XCss88^@1#)yeIvEWI!+!sm^p6Ik;qePH+`TGwC}d7EP~}$|
z-rr^G@mO-Vk&ju2`}`k)tmgmI8O`$ElFs8@$pCwd27~qfe?2%c{vQpG`me$Nqf!6l
z1?lffflcs#?*D|&*_hO#Ac&X@GoI#LBxCYfWH}L2lFwKjmE>%m#_)hlGchOk#e`)E
z%b7e3F_L7kV3|~GUI*-ZN|T6X<A4w?`Aj`oPIwl<GnVApG8H_@$BwN$tcmQU%Rq)R
zHmBRrdKxYGqs{zZ3-$buL@0N=3H*HhACCHM{eKpy`+p|H{cZ!`3I0Dh8Mgj^4ygOT
zEU3GZ@l*bXUI6$1(NXLF=YUQAZ`x3wB4cy^cQhCbN9h0I$pB(t1pVLf@yW2?_J7X-
zFJHcV$EG}Cl2CH#9R9`jcFUBJ$&!Q_qd8CR$VB8bz_jn7cY}ZA^0XHOS2HfjTtr38
zG``{q9Drp^=tSlj4Y8plQ<0IZND^d7iR~kKLTK<$*FKUk2H&u(t2)Ja379q@kw++?
zR}^u~GOdJTlY%4Z9gBio+%f1_GhmzxL;!K1T9NR)7r?rMfX`FxY;o2Jf-h&6U(Zj^
zZm)j%e0F>K>BEP!)2s7O7vv4;nALWI%hRUUm!(>#PODB3KodPB|6mErz!vak%J242
zZT3Ci#|{{Duy1|q<LXXVS2w45I753GUBKRiyv^<;G9tvV9g{2DjGHGtAYepy!OHID
zIY~2-vMlFJBBx817g=JMy;b5V1Vu(Z(u7Z$%n3yme|h`y0|7sRB0aqT`2UrD9I6Gv
zj6iepjde0c?gT0fw%5_1#H;wZJSBgz3kis&d_#T!l@vu5GT9lE>zjwb%n9($u7@Ry
z>kdBa+-Op*=<Nzxxx5}k!Ct3|*wI0?Z`ezSnN7qF2k1KBR9eJ&XFpJD*VzNhhP6t)
zdK{B%f`l|f=T1bC1G<UPZOZy+Mpg1x(m62CJNq6hm7#CQn&{oA<C=im%fkH?y|Zwe
z$_B&NHVc)a@W$v^&z_)M2)bWIA0gVk<BGMq_8s!_-r-mGu2c#zEI0Lrru?fOL*Y$l
zan$MhZ|`{$;d7hkm6xUS$7QfoFy<_$5zXm}&}~a`I5C~D7*)2_;DdT#Yelz0z3-Dh
zRP>N33!8MnBBv6{@;B?mvEGwXO_BYZnx2xyEX+l=K~tMmPQjr3d{EBLZ;SL6aG}c6
z_%@zwh$)9<<GxESM56ffX#*==y$tfT9}PFx+Bop3;^zj-_6I?uztfl|Ay#W*_nTXu
zZmJ^=sj5x+{83sM^z+Y3m6F(1!)vb;-t=givLxCwOjYH{!iJ17S-6@kCIxqvC(Rq)
z?z3iPIgd{mL->STF)ao%uZO^O`TFVEQ6sbscY`|H4E1=6G>Wd7Wt(~2dsiz|U0H*L
zu#SV{1pB$C_F1xUEmD(W6;cx=)w;EniqD}tT;pE-uIAes4_8sQAR=tD!0%g*qjqFi
z)z>VqWQ_~hzD|UPEjSyQtRrqDT1EE1SN9Rs)O=w%DN?c!aRCj-Tog$zO)XwiyEUq`
zg<BWuEL^)&*u3=Xb{Y3K*L`@Pd45#VRV}~1c>-Ijna2Q|WwSP(G<wq!jg4_$X)AoD
z&|=G(DB_4r)V%Xs!3>I~vCW+RcHL2Aw<*xUUV|kLYV}^{5WC%j&VDb(jz8VQzjYf5
zRSxsS@Z6~d?N;ace%<cit)*5|ogo}vb(IaFW!sjB#hXa%D?NfZBPunXWDw^@yLA0P
zZSos}InDTj#|#EtaMODl%N+%@WMPr<e0i$nswI{l@WsNgnVG;+DY>C>fr$cJ7Byt5
zal024^K?&Bz)FKxq@0BHUPc&K!@Igv!fB-`1<ba0Lm*l1ECXOhiJ8(gGaE9>NB&UW
zxJ%YXbEA;bWSbWD;KRsQWBR|KJkfimv|=f+NSF3DZ6iByg__Oq^kN}6UXaB+xyPXz
zN&=FjDM=(kh?fM^|2E^{jGRN($DA$jt}ZIT5AX>M#DvG-RwEei+Vovq<ZjS<<a|mJ
zVV6sBg69jCbe(BEyLuLV>`{c(FQkdx<kTXj&_0T9xT?|$<7z@1l@5q@7+S>Y)Npzc
z@i4a%kgcJ{^Cf-jxS(;Njw9wYcgGm{JiRrT>)U_ho3izXm@cV)*wTa_4?2Ij<cZ92
z$k;0-bd`=KVX@NRvt^fPwa_XKvBzO9fPZtjw{LAyio6CgRf3SPOt2DR<qWEM?rRQu
zN>r2Mf)KTIhiuQ_ay#>?6S@O^1r2U5q&`PNF4CPKd63f#JY~tQ)Hk)1&19fQE<zEb
zDEp@t*Ly^SX=7n>z;`s4i>hkN)fidzzAUINV|_S!Se@>QEdP*b3mYE|_;_5Ai8IZ5
z1{Oshis`_CbTBEPa!y%Jz47)=vuUbnzEq)tt1SY!K8B|8^sJER=btU1ho<SQwpBTH
z2}okU1Z7ewv}!u}!%8iGV6NerNU$(dXeemL=_H2dI*(EjJwpzG4iL|0r6!&p5ZsdG
zO~D;=SqX0BQqqBR75%z;k{|kK936A`rz#Pi9N=f?!KDH6Fs&^XH~n?(xettlT|ma*
zLvyKLh1j|XFSVl8+Ny9WWmO5a4T!7E3a>oX?d*50vXyuG(f)(iwg9(3;m=5Z_WsZO
zpysD!Z2A4y@VI}B_kYKLG#I=-A^qdQ(df9n|9cML$y8vz<UEfdamyP(?|!E8Td;qt
z<l5DpA@bVEy&*E%;oYI?BsSe21{wRU;Lu=?g9D<Dje?+BhpXo}x+bA%#^wSo(8H!@
z+6$b@y&lJLP@TD$^Bk;fE?B^1fEM+F>ZQ_C#MtDn2{~{UE`_<X+{a4NcWdP(pqmcC
ztW}ZjW)0+-3T~wmJ9mujA6{Sb7)@4sy47CLH)GjOXqMpp27c??(O$KC+sevsQP*><
z_I6LwuM8)(sp*64t(-23Ib;=%jh4i7Cf8|9bOt=e5${BJk12)tzJiuHGSjn*&rM8z
zg)yYgtsDnopO2S4-D&ugG|T9+PPn!wa(qZbTUBOQ<3fpPf7W5F-e>uGPK1aVP3oGS
ztD7!VEzb(ph4rDXju(jqjmX4YW2s14xry5BkMqy#r>gR-=l5t@aw#J)u;*y<5x)AW
zF_E!4kJH{!L$Nh=ElQfaM>P3No#*+Ta)Tr535AEMRs*BF!+oWGWHHP0RE`f1!&nqi
z?@kEVEqbAtAG&29KobF<`X{z{0(YRhslUzQH%xDDsgRPR*^GU9<O>JSl5dQN1U54C
z)E$iQcu5CtPV#qL-m6{g;{6xQM<}ik929yuFd0zI=)#cFNS*e~n8XK6_MHCk?bFn^
zNKHa@ut=keN+xVHW8IXFb4NnM4(fYnry8d63Yk4oz<UTcxdaJw-HVvBw$#a0QaujI
zbY*hF9MHc~e~SDo5H=GsR~t3>6mkq~4;!Dfs-Um5jH+E%0`q5urYcDB=N+(Pv+uZ5
zfXAT~+aMFq20uY~G|TmqeVw(1+Rd#9Ef!N{Vs2$Xg>M`bLrDiJ62TL5F7cKbCh9-B
x18$*(7FuYbg%(<9p@kM&XrYA`T4<q#7FuYbg%(<9p@lyW{0Cz=NWTD3000}csq_E<

literal 0
HcmV?d00001

diff --git a/examples/charts/replicatedservice/Chart.yaml b/examples/charts/replicatedservice/Chart.yaml
new file mode 100644
index 000000000..869ebea4d
--- /dev/null
+++ b/examples/charts/replicatedservice/Chart.yaml
@@ -0,0 +1,7 @@
+name: replicatedservice
+description: Port of the replicatedservice template from kubernetes/charts
+version: 3
+expander:
+  name: Expandybird
+  entrypoint: templates/replicatedservice.py
+schema: templates/replicatedservice.py.schema
diff --git a/examples/charts/replicatedservice/templates/replicatedservice.py b/examples/charts/replicatedservice/templates/replicatedservice.py
new file mode 100644
index 000000000..7d20e3015
--- /dev/null
+++ b/examples/charts/replicatedservice/templates/replicatedservice.py
@@ -0,0 +1,195 @@
+"""Defines a ReplicatedService type by creating both a Service and an RC.
+
+This module creates a typical abstraction for running a service in a
+Kubernetes cluster, namely a replication controller and a service packaged
+together into a single unit.
+"""
+
+import yaml
+
+SERVICE_TYPE_COLLECTION = 'Service'
+RC_TYPE_COLLECTION = 'ReplicationController'
+
+
+def GenerateConfig(context):
+  """Generates a Replication Controller and a matching Service.
+
+  Args:
+    context: Template context. See schema for context properties
+
+  Returns:
+    A Container Manifest as a YAML string.
+  """
+  # YAML config that we're going to create for both RC & Service
+  config = {'resources': []}
+
+  name = context.env['name']
+  container_name = context.properties.get('container_name', name)
+  namespace = context.properties.get('namespace', 'default')
+
+  # Define things that the Service cares about
+  service_name = context.properties.get('service_name', name + '-service')
+  service_type = SERVICE_TYPE_COLLECTION
+
+  # Define things that the Replication Controller (rc) cares about
+  rc_name = context.properties.get('rc_name', name + '-rc')
+  rc_type = RC_TYPE_COLLECTION
+
+  service = {
+      'name': service_name,
+      'type': service_type,
+      'properties': {
+          'apiVersion': 'v1',
+          'kind': 'Service',
+          'namespace': namespace,
+          'metadata': {
+              'name': service_name,
+              'labels': GenerateLabels(context, service_name),
+          },
+          'spec': {
+              'ports': [GenerateServicePorts(context, container_name)],
+              'selector': GenerateLabels(context, name)
+          }
+      }
+  }
+  set_up_external_lb = context.properties.get('external_service', None)
+  if set_up_external_lb:
+    service['properties']['spec']['type'] = 'LoadBalancer'
+  cluster_ip = context.properties.get('cluster_ip', None)
+  if cluster_ip:
+    service['properties']['spec']['clusterIP'] = cluster_ip
+  config['resources'].append(service)
+
+  rc = {
+      'name': rc_name,
+      'type': rc_type,
+      'properties': {
+          'apiVersion': 'v1',
+          'kind': 'ReplicationController',
+          'namespace': namespace,
+          'metadata': {
+              'name': rc_name,
+              'labels': GenerateLabels(context, rc_name),
+          },
+          'spec': {
+              'replicas': context.properties['replicas'],
+              'selector': GenerateLabels(context, name),
+              'template': {
+                  'metadata': {
+                      'labels': GenerateLabels(context, name),
+                  },
+                  'spec': {
+                      'containers': [
+                          {
+                              'env': GenerateEnv(context),
+                              'name': container_name,
+                              'image': context.properties['image'],
+                              'ports': [
+                                  {
+                                      'name': container_name,
+                                      'containerPort': context.properties['container_port'],
+                                  }
+                              ],
+                          }
+                      ],
+                  }
+              }
+          }
+      }
+  }
+
+  # Set up volume mounts
+  if context.properties.get('volumes', None):
+    rc['properties']['spec']['template']['spec']['containers'][0]['volumeMounts'] = []
+    rc['properties']['spec']['template']['spec']['volumes'] = []
+    for volume in context.properties['volumes']:
+      # mountPath should be unique
+      volume_name = volume['mount_path'].replace('/', '-').lstrip('-') + '-storage'
+      rc['properties']['spec']['template']['spec']['containers'][0]['volumeMounts'].append(
+          {
+              'name': volume_name,
+              'mountPath': volume['mount_path']
+          }
+      )
+      del volume['mount_path']
+      volume['name'] = volume_name
+      rc['properties']['spec']['template']['spec']['volumes'].append(volume)
+
+  if context.properties.get('privileged', False):
+    rc['properties']['spec']['template']['spec']['containers'][0]['securityContext'] = {
+        'privileged': True
+    }
+
+  config['resources'].append(rc)
+  return yaml.dump(config)
+
+
+# Generates labels either from the context.properties['labels'] or generates
+# a default label 'name':name
+def GenerateLabels(context, name):
+  """Generates labels from context.properties['labels'] or creates default.
+
+  We make a deep copy of the context.properties['labels'] section to avoid
+  linking in the yaml document, which I believe reduces readability of the
+  expanded template. If no labels are given, generate a default 'name':name.
+
+  Args:
+    context: Template context, which can contain the following properties:
+             labels - Labels to generate
+
+  Returns:
+    A dict containing labels in a name:value format
+  """
+  tmp_labels = context.properties.get('labels', None)
+  ret_labels = {'name': name}
+  if isinstance(tmp_labels, dict):
+    for key, value in tmp_labels.iteritems():
+      ret_labels[key] = value
+  return ret_labels
+
+
+def GenerateServicePorts(context, name):
+  """Generates a ports section for a service.
+
+  Args:
+    context: Template context, which can contain the following properties:
+             service_port - Port to use for the service
+             target_port - Target port for the service
+             protocol - Protocol to use.
+
+  Returns:
+    A dict containing a port definition
+  """
+  container_port = context.properties['container_port']
+  target_port = context.properties.get('target_port', container_port)
+  service_port = context.properties.get('service_port', target_port)
+  protocol = context.properties.get('protocol')
+
+  ports = {}
+  if name:
+    ports['name'] = name
+  if service_port:
+    ports['port'] = service_port
+  if target_port:
+    ports['targetPort'] = target_port
+  if protocol:
+    ports['protocol'] = protocol
+
+  return ports
+
+def GenerateEnv(context):
+  """Generates environmental variables for a pod.
+
+  Args:
+    context: Template context, which can contain the following properties:
+             env - Environment variables to set.
+
+  Returns:
+    A list containing env variables in dict format {name: 'name', value: 'value'}
+  """
+  env = []
+  tmp_env = context.properties.get('env', [])
+  for entry in tmp_env:
+    if isinstance(entry, dict):
+      env.append({'name': entry.get('name'), 'value': entry.get('value')})
+  return env
diff --git a/examples/charts/replicatedservice/templates/replicatedservice.py.schema b/examples/charts/replicatedservice/templates/replicatedservice.py.schema
new file mode 100644
index 000000000..712ffd315
--- /dev/null
+++ b/examples/charts/replicatedservice/templates/replicatedservice.py.schema
@@ -0,0 +1,91 @@
+info:
+  title: Replicated Service
+  description: |
+    Defines a ReplicatedService type by creating both a Service and an RC.
+
+    This module creates a typical abstraction for running a service in a
+    Kubernetes cluster, namely a replication controller and a service packaged
+    together into a single unit.
+
+required:
+- image
+
+properties:
+  container_name:
+    type: string
+    description: Name to use for container. If omitted, name is used.
+  service_name:
+    type: string
+    description: Name to use for service. If omitted, name-service is used.
+  namespace:
+    type: string
+    description: Namespace to create resources in. If omitted, 'default' is
+      used.
+    default: default
+  protocol:
+    type: string
+    description: Protocol to use for the service.
+  service_port:
+    type: int
+    description: Port to use for the service.
+  target_port:
+    type: int
+    description: Target port to use for the service.
+  container_port:
+    type: int
+    description: Port to use for the container.
+  replicas:
+    type: int
+    description: Number of replicas to create in RC.
+  image:
+    type: string
+    description: Docker image to use for replicas.
+  labels:
+    type: object
+    description: Labels to apply.
+  env:
+    type: array
+    description: Environment variables to apply.
+    properties:
+      name:
+        type: string
+      value:
+        type: string
+  external_service:
+    type: boolean
+    description: If set to true, enable external load balancer.
+  cluster_ip:
+    type: string
+    description: IP to use for the service
+  privileged:
+    type: boolean
+    description: If set to true, enable privileged container
+  volumes:
+    type: array
+    description: Volumes to mount.
+    items:
+      type: object
+      properties:
+        mounth_path:
+          type: string
+          description: Path to mount volume
+        # See https://cloud.google.com/container-engine/docs/spec-schema?hl=en for possible volumes. Since we only use gcePersistentDisk and NFS in our examples we have only added these ones.
+        oneOf:
+          gcePersistentDisk:
+            pdName:
+              type: string
+              description: Persistent's disk name
+            fsType:
+              type: string
+              description: Filesystem type of the persistent disk
+          nfs:
+            server:
+              type: string
+              description: The hostname or IP address of the NFS server
+            path:
+              type: string
+              description: The path that is exported by the NFS server
+            readOnly:
+              type: boolean
+              description: Forces the NFS export to be mounted with read-only permissions
+