From 0be4bce96fa5144df68f06bbb3395f4e3c12581b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Andr=C3=A9=20Helberg?= <helberg.andre@gmail.com>
Date: Thu, 21 Jul 2022 12:21:17 +0200
Subject: [PATCH] Initial commit

---
 .gitignore                               |   2 +
 .tool-versions                           |   1 +
 Dockerfile                               |  12 +++
 README.md                                |   6 ++
 __pycache__/csi_pb2.cpython-310.pyc      | Bin 0 -> 31009 bytes
 __pycache__/csi_pb2_grpc.cpython-310.pyc | Bin 0 -> 15872 bytes
 bin/build.sh                             |   3 +
 bin/gen-protos.sh                        |   3 +
 bin/push.sh                              |   3 +
 gluster-dir-csi.nomad                    |  58 +++++++++++
 main.py                                  | 126 +++++++++++++++++++++++
 requirements.txt                         |   5 +
 test_part1.sh                            |   2 +
 13 files changed, 221 insertions(+)
 create mode 100644 .gitignore
 create mode 100644 .tool-versions
 create mode 100644 Dockerfile
 create mode 100644 README.md
 create mode 100644 __pycache__/csi_pb2.cpython-310.pyc
 create mode 100644 __pycache__/csi_pb2_grpc.cpython-310.pyc
 create mode 100755 bin/build.sh
 create mode 100755 bin/gen-protos.sh
 create mode 100755 bin/push.sh
 create mode 100644 gluster-dir-csi.nomad
 create mode 100644 main.py
 create mode 100644 requirements.txt
 create mode 100755 test_part1.sh

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..00219ef
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,2 @@
+csi_pb2.py
+csi_pb2_grpc.py
diff --git a/.tool-versions b/.tool-versions
new file mode 100644
index 0000000..85cfd4b
--- /dev/null
+++ b/.tool-versions
@@ -0,0 +1 @@
+python 3.10.5
diff --git a/Dockerfile b/Dockerfile
new file mode 100644
index 0000000..d653c02
--- /dev/null
+++ b/Dockerfile
@@ -0,0 +1,12 @@
+FROM python:3.10-slim-bullseye
+
+RUN apt-get update -yq && \
+    apt-get install -y --no-install-recommends glusterfs-client
+
+COPY requirements.txt /
+RUN pip install --upgrade pip
+RUN pip install -r /requirements.txt
+RUN pip3 install -r /requirements.txt
+COPY *.py /
+RUN mkdir /csi
+CMD python3 -u /main.py
diff --git a/README.md b/README.md
new file mode 100644
index 0000000..d98a68a
--- /dev/null
+++ b/README.md
@@ -0,0 +1,6 @@
+# Intro
+
+This is a super alpha implementation that supports the CSI spec for directories on a gluster volume.
+Each top level directory is treated as a volume.
+
+Currently tested on hashicorp nomad.
diff --git a/__pycache__/csi_pb2.cpython-310.pyc b/__pycache__/csi_pb2.cpython-310.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..e38a390561de09190b44288a07da7247f4d8a0bc
GIT binary patch
literal 31009
zcmeHw33wdUm2OL|wIs`O%Zn`U?R}GNdBGTCtfg%WYqJ)E3rt&5UE3{7YSAqj+YkbT
zY>;717$#v7m^fr5Bm|N`U?ybW2q6hsI{QXKGTA0WXOej@^Zs-0(pBBnlI?ll`@Z+S
zhd!VB>)dnBJ$J2pPu*(b)23Mg{P!d4I|HZs3Iac)8~1<JxY><=$+yoB1e|~!a0;Bl
z;ewGuJ6J$C2wY?rGcE!yu}c{j1DDz5j7xwmyP_Z<DjuwSC}2;6UMYB0_H<4!1Fp7b
zFfIoU*)@<YCfNsPI@Uu4_AIBuo-Jk#&2cK{2JBkg&E>mkxT|xj?0I}Q9e4AQwt(-d
zakmh6i}-E^?iS;23Ezcq7slOEzN^9AGN9$oOrRBvW&y1fD~DD&vw>DKZw}BJMzug|
z8O;S+C)Po(4ro22c|i4?Iv;2QqXj@487&0bBsM`~5l{o8#Xy@mbqUZGu?4ANpskFS
z0&U~eWk44(S`M^bY=_(mpo<x;1lqx970@Ltw;E_CqcuR6ic6uf7HAjq)&X6{Xg$zw
zu^XxNK#k1X0MsO!z$5>fnYR(Bh0!LUh={1vJ&efmUQTTQ+9&oQbu&;a^R@t8E-qIZ
z`<b^Dyf#MLfZ9bnQprjOBdVcJM&v;k%UuL?KpcSFcA#$2tu%TVkw!1eT@2L6Xa~?i
zaS(Es0A0aoC(xCgdMVH$M!SG)VJo?-n0Fa?SBtB`Bg==Gw;SjhMvXvGMomCR7&Qa+
zi+*Ud01YrN0yHQF!J~3GjL4qg)IC5)8SMo+#%LeVadBK}#F*C#-Vme9fli1MDs`B7
z`@tI#Bj8clMw!<J6c=$NH^#hn@UCUl0hAC4q*5Ct8IgbEjHneRSgsT3B%>~%>lhsX
zI>o3P=(ISktejy)R<376R&HRq9-vn->IJ%yQ6JE&865<=iP056H#52t=oUtYfL_DM
z2D+8eRY0$0bT!cH#OvSz)%fd~cNpjmjIIHCBcmwLZQ?dn8@Ds>2zYN2>xcf%=?A()
z)GKtSxCCebyt~AJ;@vH70U8AF9`Sm`yH}Jy_-1FOC>?ss(E_o;aUAhL;X^_DJ~8dV
zzZdsCRDhX`BxWfI!m|}#t)<0Epra22p?5#)-OqYt;r^k2FgE5Wy)|0Tek)7A)kxGT
ziM2-JZ7lINBQe+IN1ej!wKRJ=PjTxFcOB5N2a4d`18nU9<J|*8|LDSRH@VDLHa2J*
z_B&Yf9Y$h-lGtb@9%P9Jjl@DFK{d8W;RY?uo-S70&4#-P=s0`&5L<i5c=yoIKe_Nb
zO)g7Zxr7zoYV1+oOBHvU;cfwnaV}>$m$Sz5*`as2@WUpTWy;1y+J^mZ)_k{-Snl#;
zg~AtWX)f(b#ogiIu2S4f40k)w&;!M2t@m&q?=c>|XXw2y{5}_czwu+WvbR&)vp>LA
zK42u)C<&^YwF>Xj(&AE}6Wo&@VZBF8E{_a-(AZd~^e)qS_M<HQsF7Ij%B5c6MlCIN
z0}XR7A7Z@^nOr_J^kHLTgUg2QE6v766VM3Tc#Lg4W^6n*l<6NEm5mmyXMcpHKVov(
z<de%DEzK>bYiY0HMu0}S2R+W#9yfVEuJWd_|G2Bh8eF+-R=CyJ+XocqvOK}|o-p>F
z82YI3bc@S|u8;l3#^pe=K0d}aK4xru%vB#-m5ny7XMdcfKW=i_=E_BvyhBTKedy8L
z>EUXRx(v4+XpDRElbpws#-k@y%}^~p=^EKjx;(we<;Qjx);{%^eB3ikui<tBT}y2w
z4ge*%cAsKDo-%$sHS`HLc6o&q<ri7MSmocRt=mttrKe4;?QnT`iNaTCX|A=MihHHu
z9t28qFM5WpJ!5=%X6T<?_+Lyemns{Fv<>@{tocbJvCGGgtF*MRfyTKeo@KpfO)k%>
z9I3RIxoqgRK5T4U4K%?vKE*aZWo&%PRb#uAjcc@?{b`o|wDGi2NkomrXISDhMxsec
z95E7~Wr@!kiDs9lEea24Y0(dKl0E$#>wS*(sLy?F=<~)##AQSGVJOOVfTzC;!yN>=
zj$7^vZ21eu@)um={|m1A*rRees%_X`WX&%cKlUn#V@BdjEb%2HvCqfTn3fjDf#mrA
zGV6WW`1EDhsA^R<hP0mj6_);r$>nmNT!yu@IAL;mj`f~1xjg5}WxvaY?)Rg{#t6_U
zZkMmJjjtLTUmeQy^){Cc-7aIsM%?)EJllBQ*m&OMN4v6dt=6-@#?oIirR{L#qUYtL
zmgd&id5?RzdKQ{6+yu~Rp6y=XJYFy!y`biB>Ul4?`o{~d=R>FR<D|A{f1Ry--FVui
zB(5_O-(ZPv7>NT);*^p2CQE$NNOb#@_KcSHl=gZLSC{q%!#xcoOZy_{@uDg1i>}hX
z=ql}tuG01>KVGHn+23L--!h)|Dv2A7#J5@E+eV^KNxa%fe1|2zV<ZkLiJOeXcUj`Q
zM&b%3akG&~u|&#9T&W~(F%sWniSHSSLrUT`M&kP{@qHs<D~Vf;#1B~F2S(y5CGlD#
z@k5sQp^>;+NznYPXS&yGY4JKBIn(`!^?t;9)Zc#On&}QJ8*k8h_K#Wm$0nC+l*Aj2
z#7|h_Cq^Rb@<We|+qJZ~4M@&GKV`k28b5yO8kI+sjW=mM`)4fuGnSq;^mFG7_GrJr
z{_f|_^*}E%x&i2yA~^Ib=T#>P@2X0)i|IozKlp1=%UaWiegj;m@V^4jcj1K!{}%kk
z3jYo`tnlxFml1ZbuZ{k}!JanyN8r`KH-QpvVBElXGvm#SHx2!pbMxE)IJY1cBr(bF
z0DcYgZ#9_scMbi?d9C7Wtog5V@d*=u7w5H$aU<hK#?6eI88^9n(3o`hu*@Eo*~@q@
z<A_UMW0G%WnO2tB&v-xM%U$vslY9rubg)b(<4(q1jJp`OyL2@s-5!?dVVPdWy^ODb
z{OeUcXiV~lAag4yVVkkd_%Q1pW_%5F-=K6gCi%Nj=WkSejWz!^7oV`^>$V_y-4+h#
z<*<xkEEo^E%BV5fiLp$KWsbXKG$xs0mKkQ56D}EzNoI^?##koqlF^uCk}Q*CnQ_MB
zj3*dRFiyC1H74CNEOUlsu4jBb;~N;?!1%OFS7Xw>8GPMd8WaCD(7hFu@V&13*I4s)
zJriHoGvV7+yJ$@Ex3fRDv(4L#KW{=zC^PO}8v1wV@06~_e{}8;E26JBcY>y!yTnT1
zyFt^=Js91DR|DTG)&Rd5H0``atOdRgH0}JoSO<JRXxjM)u^#xXplRoA;ts}l06!q=
zf&URS?Yv#w$@os-cZdzZ4}zwhhr~wUe*#TA?-ZMW&w{3%cVTXM#d#Ps?YvuTX8va2
z_lPaP?*&ae?-N^r-w&F0J|MOMKLVO|J}52%eiStAd`N5u{xE3Tc}!dk{1MQ!^SIan
z`~+y)`KY)A_+y}H=i}lo#&-cfDRu%s1)6p~Aua`e8Z_-ZgZYQ>F5rI_mjV9^XxjOt
z*bV$FXxjOdXk^?7{Atky{25RxOEd6U(6sYe(E|KA(6sY;5dr=JD9P+$nLWVIh`qp1
zgQlG?ihaOe0!=$##=Jzh75FRSa^UAcNq0Z+S<tleRnZ3gJZReanrH`p0hDZZ06z^%
z_1p>kFevGE0iOj;J6{(EfWHBncD^aP8FvFegE@+Hdw}01dVwDXO*=1&KHzVGrk!t#
zgTUVbO*`KeR{*C#)6VzAmCU~q`1_c(UU7Z^ns$DOx$70@N1$ov$KopBpMa*FpNgx2
ze+Ei<9R_|FH0}IcTm$?I(6sZChywo-H0}IK907hAH0}Ia^aK9}H0}JW7y$k)XxjOm
zxSR3az`qxRz<&UxvOB<MK`Ac*{4i+R`J*@r{BNLX=TG7o@V|qmoma$h;4~=d#(>X)
zrky{FA>jW2O*?-PCxHJ7N;1PNGYtHnVg&eqfTo@QDMlHO0{>0Kf&UAX<i}WkESkQn
zzzK+Jqp#pvfGgb>iUi*WaizYHgzT3<NpGC>#(|#^6TnY{l1`C0$vVZj(tU}zj_*rx
zrTa2*ito#DrF%=9=KBg<DUUOp#~IG!dd}l|&f^Bo;|A8L6t7~PX}FS&Dsdy<Psf$+
ztHrDNeg>{|9}+k5eGRU3KU3Vy_p@-N``O|azMq3D-PekH)crktKNoW;)k__&ls-?~
z%J=herTYcqwS2!2SGr#$UdQ)~ai#ku;`MwV#+B}uihI@ly?nn+yn*kR<4Wl(#2fj3
zC9ZV8O5Dcxt8t~ezn$ylc1~L(-o$BZaV6Px;un0s9#^`r7ccSs23+ZWqxdD?Z^AY0
z+}MM4S5IJ7LqQ;LX3<_TDiZzU!dX0)h>yny<HL&wCXOBziN%9)N7TPeZ#P#Lq%21y
z2NSWe@puAv(=&I`v3PtKtkMyYO!glWB%2UNhsEG{EIvxI$<reP@!_b`Ki)skpCo}Q
zxB5T>IMc>s&>!y~8H<iFqw=~$|JayFB<Vi+yUl@sRX&)E)w7eK5`rf;)h#|2j~^Qr
z8<-2XH)IS;$+|_^5+)-hurOOdXDrjhv#ptX#dz27#Ie|D>*&#Vx43o!o`xSOux4c?
zB*)^TNfD~FibnfKL~X(1f>q_A*;ds_G3vw<(UT|*s-(7%`IlN{BmJYXqp(#QTpV0g
z(Xh5&ma5*@Y<;_uj*N~cPS<U)rg<2l3M+U*oK~4mvx-ml4^If0*N(#N1>uF(d}Ft{
zf2@BXHXIv|iKH%1r?ntYx++$^RXOO=Lr&y$t#(@0kg<F^{O+Jtoy`nwwo38h>||_E
zR!>F4;(Yq`JyLF8Ak<=2pNtPrjEJZ>HP%0BDzTzrRbK6btPs)i`vP@$7g(jrCfq0*
zKRqUWsA^cA*NT#_?}c#qfK^0S)O2ZI$NrAaD>|wJXx>nBXGd>$XIopOJK7WJKG@nE
zsV)dDvlbuhZ0l=}L>rr%BRxH>O|5OMy@#R@?&<ArZ0+dnsV=O$!J3}sXy_7;YwPp6
zmZc|MT<7PaWtDVxw6%7STkySe&mO)hY$}mig{!Q}u0(u5=&rECnx^hm)33IQ6A16g
z-c`|1S1-qm93dEX^-Y)q4pN5;|2k;ZG(&h?NC%b8tU<Bfs-nI$7#lwwP4tf*lO469
zVU{i~^&?8{ro_-ztLCKa0G=KwhmGlhGQ&&{3|(efWBmyXMZBR+))sjOnU9n8T}GM*
zS!fsa*1?1rPu3Q*w&`zv+C5T~RhxqMHx-0-ShKX>@zHTHIv!2NClcuUC71##8s_QJ
zD$k`%4~xM0y8gjI%&9RRsi-GRJh6lrfth4&sn<Ynd@Md3KX#gGTglXIvZiO3XNozZ
z4ny2sh$-ikpA}d&e!lOr%95k~W69(3ah{MW8rDow)cPJJD@%?6zr!k#^~Up;Ync0F
zRxf#4w{E#r<+T^8u`0AT(U>D=$hsv~rCTvH!z!0q8WA%*wpla1&8<eoLgOXP^c4+N
z-ZF-NSY%ZzhxNR98eO?~U^qT_Le<MMuTG}();E!qR7Z_KZ6rQ1I<6`tzgjy<8MW<J
zh3rJp5j@QCoFPA#=FPK_J6t<N>!w*1E)VK@tqPar&~&TxXfkT1&~mC{_Ah#Lxc^uZ
zUIy{#TV#b)oyxRhiTK1AJ5k;ge6XpY?vX;v%H$c^W)-oURGn3sxjnlM>oY3#<ZJk)
z0;`BX&dl7?+OfAS67A@0iA1mHZtab9V+x#S&2jU)BaJPXxiLc?sxA!GS+m>w+Im~1
zjyo+Fns3#*(v%HlwusESQYBQ0#i6h@*PW+Vx1^3LBecY-b<21xl(I+@8bviHRegA;
zHO)IuVy&TO2`4&mdR!#Amj$VHhGQeKamAzsNHF|{LaRhpEv->#V&&=Bt>+mOa@le*
zmNRN9rs?XGUc4;vb}BV0o287LO*bPK?=)D%{c+N1aJ^L{iyRvm7SVAv&#CFST4$=~
zzq&0}NOc!?&Qr{L;iy%kEx2aT&{C_Mt1}rJr=<cdcXDzhp)ss?MIs>_?)N@I;SsA$
zXAs(m$x$4W)3`LcFuNF7`$z$<I9ls@7*o#6_hVje5yN=y$;zNYVV&tS$+;hKG-zFO
zt&ait#ZN<aiyv|4{m8&_+G|)&rr|q-)<WtniTLoaNOVmM49Akkr}Q54&?p8z&DpYh
zZnkFV?rG*+HSOhJCsbQyw7iLr4xh#<p<q>6s5Se+zgaiY<UZzBQ0PF;fGOd6zW5w1
z=62`vt@8^U6dx?G7UeCidIa`b)5l~}MR{mrI*?uZk||3kE!3-)ri?I|$o`Jyo)3G<
zUjOL=YjMWmzES1b`FEoInbr?-TW!rPjlcQa_CMdo3NN*mOi~CnTK*EWmSDXd!=73V
zakFyBZ0Y=ldv8u}l%sy9F5#3`{bu$HT%Wi5tk2D`nA(x-)ooj*+2m?{+qoAicVfGs
zC&~YbMfWd*R(P_?QA2Yt;wACXqp`#Yo=b9py5(HzLyb%HL8(h?Jr&xKb8Ov9g;sec
zIhxa><P5O)LNYs#&L#V8{z?5xPv?^3xaER;%IaqqHl1ET&j>eKp|)63t>$&0hL_s?
zr=kMSN{n@G+G1M4A$pb=kBuI~BI$%sQKs<OLaWAOL-mdZt2ASP9{Xnf<|AFt({d<e
zS)-Vv-S+DS%r<Jge|#c|^>au~y9jryM>F|I+ktH+jDwEpAo!$WVHFK?OuO*X5}ivX
z%UwdhRV*EtV#5{MZk3=C;0AY8*HXr>O!BeN!}8%RRvj``iw}gsrg~=VpcQ)<+uwP<
zYO0c_@^^QZzZ-QmOkz}TciHc{!{<@`o6fuXWhsAKV1-a6W~ZUnl6mHQIr#Gr%Uzyf
zDF?9$4&-K&6OzfZACNoSoYnb-jJo$>@$7L#wI;fD|H=N?a6fHC^md7dUl2X7W~BdA
zY-D02dQ$F=lCd*7s5LJqT-G`|zHJNU@CgyR6q>Qo98FoC$uxOvgv0J7kMcS@vU`nt
zMUf+;N_Vkubk~FmGCfj-M9q5Rbofs}_b|vw$G8tB#s<|hXk~66&(Wyw?rKKB_THcs
z1VS{(9jsk<js|2v^!Y-+h-fV$I@sIyMxrf|wg@gVREyvM_V`_WO>M0``=Wgv8mZL6
zP_<Qwq+TW7QynDE-bin>xv{IU8R6aPB8nh*ZTECEcJ=J*?5!@w3|htdn$=TXLKd3a
zIy;OHrJ<RKn=2nE0Kt)oGA!n%MXu~>>}b)>mWLKw^WE-5l~$yMqZd8ZR%k9FP%;XQ
zxN}QuZ);~qb%hK!)L0gIuF6&^nUlpJrm={LioLtgnkB<xI^3prnYC8640GzSpo4BE
z2rTz%yEE%G`FJ+-fUn)$wRNb`GnvQ$uZfuZ8_9l{pJ&MPLMD`*=n)(d&s3Bebm5#h
zshPpFZ1}zct4!a}BbX+Z?BGsP1yD2lV81q?Ii)<b$(lAu-r(sQrFUVx<MoT__v$xt
z=#Z7PKR%5oe{>=#5PZQNIsA6K0FzsJ?Vj!cegW5ztF^OceP1KFt$p4*sak7xwrN@K
z^x&RJYXa@~1+A?@`Rh2V0w|_Xj(~pF%Y@Z>Ci8RUe?$52Km%o&R{d^E_Ug~f^S<(v
ztpC>Pwb{9J<+}>41(^p4zngQWT4{yO^HtHlOfAbvr9s#7q&eqSH{KEYgpy>$GVk){
zy!+@Ocht*UBdV?P#by^-b9jAiUWw`#L^2ds7JemY&F(;O3`^W&Q^x`K=SFhmFg5k(
zZ_6)$gIIVC7UFnej?GAa;uy}2jP;Knmy!Pqs#nbPS%b&CEYIUs&W0W_z3j-f48(2H
z9VCw>*+Z%K{5Jzs=i50hY@->TYt6|iiJJE=w`wV=Z<JbR>OPUD8TsiQo@dSVv86IP
zTO@N*VZ12^d3(OzXF?W~m!Gxs?|+z_-JMcS&c1`4o^!4f4yq%VxH6V*nYb~%(Jc!#
zXS!)AM-I(uB(MLu9d&<BM=fJpCI+3?*8go?RrR5)c2#|-#j2AXOa&CC>_k}&E4%3e
zYo4zamB|s=i?J(`<|!UvRs){bU-C2$@;E6scs!%Yg>0U2!t1T@DOrr{9Ay4@F<3l7
zr=~bWQqfSO=OXD%A0=IA+$4+xFBNV(D2~~{s(mZY3600c`-eGT5~TGx)^`q1)WOgS
z+>OS@d4X7!Iq2guS>K2B@EWU#uHLt=<yLXiq25Rj_Eb23(n_yjao{C<v84{YU_O;G
z9vVgc1EcZ82;87bF3X8H$~eS)Q;}xxnTd6WyJb7)+um;W-QF(H)lFR_XB!&+G`2Xt
zDR_tH+R~cPnXjzc%>KSWZf3W5HnS@xb%0dmHul4K!<~Ef2;116-p0KVY*ppeY-6#7
z%xvzWNTkz7xm(Df?*_4G>b+pG6q$#&t#W(W-r3jD8{OO8+1FJq-)EbR;!G<<6@!*>
zAD>HFH6E@S53Uz_a=^{EW+Jkpc9J*@h*PPfu%<ff`9*`mPZr8&qj#Z|_uZ)PV9#BT
z%2-XFqf2?_hX2M>Cz5%_$OVjvh){+46wSM~Ey2MgI(u=R8{cq)e4=~pt5(aiMs4^j
z_O7iC0?jzd73#32p$}vZQikU1&hKHXO=O)Jn^~!9;tqt4y3Sv^XM~VB9Ah-y$=bd-
z^p{7<<g?8x=F@PYnc83XVYxcf?w%ua;XuQ4<(8G%bA<LI&cjgvIe&)CsRuV#J7=oK
zn`nH3G51^aj4?Mi$Cx+K7#p_cWc>6zi$i99$|In&@QLbq40Q{WTf&-~F_!ffHIzAD
zXQJ_0B05L2dCqIhmFI+2m;a4f$e7A6qjNP8s>wu6QTJIDw4as@j&~!v|G1diu;~q+
zG`A&mQ|iWaMkiy*#muqfNi&u_)vrW!z}T<)vqW?*rp_|epCf7V#1RPDk9E8yWCpjF
zudSN{G1<v(lit`)#-x{@V=_D0n8f_#iGF0}Cl6a2G)2ftHTGf%`<Y(so;E{f>hVw4
zIrt1dw;5Oe9>kejlNH)QO)+8J;d~NxCMNRZE29cSZ@U^&#a0nLVL~|cL04B?A!HgX
zD?#V7NPCi#ZmP?+W>BJMZyGYE!*i0fWzXWvqwK05W!p0)d2M@=d~Ih*7{8Cmg-q5o
z6*6@%Js<Nq&{SvY-dD!taM&!MWV`YnCFCi%X><4frOx9+wumu*g;h=YySrA%(_Zcr
zT{WJD@d_Bjs%En01#it{C2I4Yn#qwdIbeb%*C9Yl%gnUsVrq+Kg7u_nOFK4MR{!wW
z@qWBkpBTZ&&pzND0lRaIg67HEvt_hP*|F2A&ZtCB^4q*6zKVEQOo%M)2Ft?N9?>Kp
zsKexyo#CFC7<RPIJ7tcWar~2=JW7dEDJeHEvZhHTb%+CPo1Is?{BlR<rWChYm0EH9
zc-+Al&())ZEH#r~QhvYTlb_mYc@>+A?I3Dopk$0bL)si$Rul-NT#b^-sqNTO7Rgj&
z%3VDvZ?RLJ!stZhW6JjvpOpXiJt^;pH>pWKt4U4%QB5l63z?MuMkST~Wk|~Nkw(h<
ziAKurql;Ab2LLJ0@&1(G+5J@3>G_oBn0(6jBz!98n0v~7cs%7kI-YVJ_)d9`FQ?RT
z<dn}5-jv?~-IO_0oAMrzP5GUEP5B-?O-*s?G&R*3$dun%#nhAs5mQs2@=Hy9#4mLY
zC&5yg!&)hy^F%4X^FgN7`It#cp1(;=az-XK*+H0;&-sy*-x&*cwdKtEyiIpkTaJXB
z&E2l##B@@0q9En};yRV*HEqhge@*$n@J!`-&zSOk$(ZtgDVLi3)tI}V`aN$`dEWJ;
z^1Td5<$V>9${*O5N?A)G*)Xh>m7*GCk~nT^vgoXI1kLPP_o(N2ifv{msr=kgPd$xd
zc`M_MM$;!KAic@gul!?yDWB+8$}hGhTf*CRvg)`cya}o#9Q3pK;})BPtf^9Z+|ehp
zg((Xm)#mQjuHMe>loh2fd?s)*DY`nCsKGb8i6cb%>FeF1#2mu4M2-+qT>M0FAh95u
zyNDQzz1-r&QerG4vfP^#OsvXgtj%WR<iU&_y^UVIVrkjmOIGHjBc#P83MRICEfgiT
z6XRkpHz>JBh^zE+3^jUHiexqAh-FzWPH+)?N@trmnC%J**}S3J(~&GjcD(#a76NTA
zu=U%{WDxg=*x5c`QgIq~W_JE>i|o9g6xsTd+Ce=qY`=qOcFy@B+jVTn_6h$cOQgr-
znBT7S<x@z1`3@p?gT!_ffZ&I%1F_vit|4-S$fHCaBXS6p5Nkrs#J)k~79uYaIY0@^
ziCje_M&tyMcM*9Hk$X_Ju}wq<h&V*vLgW<ujIAQlPNb8_7?CqXK1AdrL}rwO#7jYL
zAaWy-uM>HZNFk-pF9WF|)Jde9h>hO~kF6kbHIYvcd4|ZE3XuOKw4TssiF}^O4~YDj
zNPHSdg2>`3klzqmO6VmbzammG9i)m#=?oBy$R9%>w-fpkp)HsNViys)Y9`2ig#Lrb
zUx^$h-rYprOys&*AhU=hh@2sEY&OUck(ro3VzY^CC$fXc{Y2hI<c_%@e<Fn6lR=i4
zXJU5~`gk44Q$*54{zBx=c_8-?*@)2;Yanttk#-^*F?3>^i9Ac>J|dqX^38=H-y*UB
z^HZ#W$jT)ktBEubX(4h4k-LbzpU4M^e0?d%H;Me7$RCMp#Z(r%h)6GygG4?`<l{s(
zE(h66<TFIxO5}4y{)<S#3Xlav77@9Y$T*RYtpxcbp+^b*jnI>Xo+I)+ktWPru?UeH
zSA*O{<S`;o5P5VB-4c2A29R5bT-|^f{LiV<Xw-=hMx*xhtX)_F10i5nL^Hp9kO&f|
z+Qs4DXh;+hyDX~qfr(<Nm-(%RM2XbP`n?9bv_%~4pBNsuOQT4NIs=JP5?m=Afm=A<
zL3=iQ2+lVdPongsN?>&0XX5io(;2iR|L_9~my_`Fe8T#-8Q8Er1HW*K6<!P<!kiJ#
zo)|tHJ3{Jn8r!<|HAW*HeeKabt&ujIhwN)_igeo{oZt}r`vFNDp^MV5G$b$*1NH)!
z#=*w6zKBOJfk6qY%{{I7z#oS@d%dZZlv*n-$n4yi(m2Mi?#twM{1O1Yu=5CDJO}K#
zTA+7dXNxx-qudx!KQQ1Gp#SNBJxjGKf0b*BXU~e_MPOH3-`>`a){Z@$-H`)*k)B?A
zb~d}G3qMQ{v1g8=F>rLBzAw!fS>`VtZEx&o-2-zG`~bosdqGBu&cpH#9<)Y!be0SA
zC9AAwM5UWX_mDj|hoygE!CsP^Bwt1HA=w@rbhW2NySh8k?5fCB`c@Y;D$nUkH7&Kw
zj~nf3>~3twLE-KmS=1%IQnGU>k(ugfE&VzKlzKY*x|<{RQa^6goClUdOMHc-pUTdx
zEC);-N-0+zF3`qwlN^dRwRJY{mx5@tY>g<t%T>wqbCc!oS+wJYzFlPwK6f{E?2TZ8
zP-=AwXl<&4D^)j{8SU-t>TK)Wdx+}1wL8*|>aoiW*Pde_T6-_0nktpYwPhx{#g?c;
z+#aqPs7i5GmWZmYMf7VN>Zd!@*=dgvd)*WQ-dq}{l9tA~L+Hv_oL@&dxn(K|eeBy~
z7ai0T%^YO+7Os9u5pVIrlgTS*!%@thtt~iNuga=BoogQ0I<<^nw`n*Bwd`TK;T&{4
zgBHVc68}{p*PnwB)zzNX?)FHFz5Bex{fd6+`B})Wg_<aRB_JEb%*HdlOjWcceq7}e
zog(S$vFm(A<g_@?)kW~w@%Fd*{)sB*)sv-qJ*c4viT>h3&jL$*m^st-Os|kBbY`q5
z%h}H^ci+zuQD)rbQ;%uaH0&PeIjK<urSM3W&m;XX$dt^N?;V^g{FQTRU`~#l^1j?W
zgy4vrW^*0!<$E2OlcTIMn8p1@+cf<!?92AroSiLWYMeT@%cSIE;YZ7ng{~eYznt;*
z$F-BEdtGopD!j&&FLUHKH*_2;I~zXxmXqK+Z7<7X#p}$Pd{Q!J&x4>gS5|pEms8Zy
zF|W^cen}oR-^b;8R`W~pE$oW?;+{!)U4A*A0!!bsoKU{cQ{~D^l}qCJ{)tLenl+Oe
zAF0zLRGQ6BQ;L;p^6I07KXzrtW%)UlZIsPq;d)j|pYqK(v)SXE*#uKGcRBf6WX9|v
zo@Ht{4Hn(Iftg;W@?3TuZ*P}XwVdUBQoQ|C_AsxQvK^xLtXaE^g}F<5z1`_O)D^K;
z<fhBY<Q!<pA7weSeAbJPL+Ur!Xw8b%Ef%iJU1L9|{-~a$r5WzF!zs(wUVBmgx|KS3
z9jJa#5eLHf_Y~FZRXV?Em#Uit!ZZPUdbc=+1405nuFb!lm_XbnAfvYk$^<AB6G$Kc
z6L1A^5m*T%5J?Fn5JU+i5H(RTTm(k~iA?Yok&i$kOa$=`cjy*Ti9iCeh=2^QBJL1K
zAmk88tR=FJ$a*66L=b@p$e`vXLWo5K5}S!^A+nXoHX;`h$pl+>(CsBeb`rUi$Sxw6
z5!p?okw_DfW+E*_B1HBO*-K;}kyav?6WLFsjYvC@4kDdIx`-Sg(oLj?NH38-A_s|F
zLF7szhltojt|D?Zk;5Q%wR#zx+4h!4TU+of!FQdAuVmH;b}{z>I~48fiA0<6z|&#)
z9=pPIP{5v{n>V7v4t6!AyUzpImF_qFc9rT0>fN|KtzEd@vD;PZg_ce(i^k=l1iJ=D
z33MdHFst~WK&C)dd`cm6KOH}fhd1~c#tgR=L}e1=_H;K3KV<pdK;kIX8IiwUvY`*z
zCO7ntItj4>9exNu`<dJjA48Odf5vXZvEd2o;Om`OVm)46Y*4Q+>c>u}%67_E78C&v
zBtM0qQc<w7K>w8mEBUS}SQNAhiVFPyS%nr-{@?qnEGWcZ+25?<%EHP*!X<wzECJ`w
zRwZhPIWjd@uCml6{|BpvYxDv%biPyB%a-%Vziid17Ik@`HT+BDm+Hqm*OL3``tkDH
z%U7aI+qfl4{!lm*EyX3TDyZ_bmd@8LU*^+BTFzZVe!Ps&e#lQl^QQ73V^3?ieVIJf
zPs5LwYejpdubiiEAIj)vkj_JE>+AVh$=Ex8q&@JjtBk$L<m8;D=RtifDJ&^)|7pIy
zW~b?UO83LWn<`D)_LI}R?CWHCxn&7w-)r6fe?7k%C@YYEZY|Bz*U8ef%(-64mRGj2
MAaHZw=AwuH7p35n-v9sr

literal 0
HcmV?d00001

diff --git a/__pycache__/csi_pb2_grpc.cpython-310.pyc b/__pycache__/csi_pb2_grpc.cpython-310.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..4f564266b5af8910c4d6443137c5b84f39bcda9c
GIT binary patch
literal 15872
zcmdU0|8FG8RiAGjkLQa${xV*#*I#D$Zuic6yW<=QB#PkJ!?$;AxHX&e?EynzGM?)7
zju}t;s@s=aGe_X|l0e822q6TB(4Cb0;QYi-@GBBO@CSfU)QW@@en}K5zbsKCD-nF&
z>+b66neG|GtVEbm*Hpb%UGLLXuU@@+)nk@Q`2;@yp8wYFgRdnL|3L-)lR@DIF6$qW
zh(tXhk|Nbf)|333s;6H{h_uMOlMopr^DteXKzTxBQO<HXD<(zmokV>S^eK@CJ<s$U
z$^}tGxya=yluKe7<!LVG#f&K9z5?j8Vh;2<rWaA37YisaaJhtXMJ%Gc$mMBqPAuWR
z8PLy*Wzd(IUKXjH#Kwi=n_Hc>(Y341uBcjue8Z5{R;OuMhE;8uQX1Bw*%j^XUez|M
zhtjmo-J^Tgg>kRlHQXE8EyJpP51o<NZc(a#QYhTO^=Ju+kw7OU>M4<|r$tJn0V*Rh
z05RbdZwX*%+Yff^qutYw+-_SIi3AL@)o$95B+S;)0qQjEw%G-;11eP8-D-_NRqwSs
zMy*Bi{14?PaBbnTUP01J?qjg*<bG;DjWn}AAyV(Adx=JtIYgUePEK*An3Dk~&zyqd
z6vYIPXHRc!nO)14M=jfwwS2zneV&(l)<;!|h^_n0ZrA91wEBE?Pad{vTW-0gDxI!v
zwybvTjc03qXKcP?*mpWdd+qM6?mhD)RiBf_>qmxVH!x7`W~Y5@$a=*cBFkt9BOsq%
ziEnJHdDz@-ciMK_uuc~T>fMp%uCcvQatcS?rhL%g)X4!`qj9+VGtNQ?)hjL{XLiSj
z^s2dION^dV>8nVZWEoEWMQI**RZ5{M&WbAP7=00|F<h_RK%9QFQ{?CI+bDS@@16-R
zo}`?NWpwU2linbmB;+y_=JdwqU396niMb(-P1M~tTDG-m9vWTCJd!PAbFXt`*@nC>
z+VVPjh&q!xslh{h_`u0E8trb|ZZry{g=<JM*;F!%Z|*0ViT+&iC&v|k@M$L0{JXbL
zCa9@y^T22{oP48kV2Yy-<%^BR>qpIw$C+$2Fi{!}xdKW23|ex5XlW!lT#vGx$s~&@
zro~QO>uFSsp1NWJQy8{QOyV~ya+nZPPFXzwj0tRmlw>hmB-j5?o~|uikE%#|srM4@
zynH{Iq*6vCDQ8cJ<iq6K$&(Z}a(wQ#Vc$1JwQFMP9~^cJG6IIUc#^H>EW>WJOkp?~
z>ic?r2d3i4+5)9sy1RYr_MMk+-oCm0>dhDG1*$3xyV>qo&iuA%-wK+#DWxe-(vs|z
zGwDq?=!FS6Z`%ExSw^kPxVST?Q~6{rdA!#D{57SvG>c<9LOzLxB()~5P_jV@X`!3&
z;LW4>43VxOIldAvNuL2@NnC`WXO+ao0f{_+wl^jvskU6Fq)N#}N~n7zVV2a4_AvZd
z{6tTHaS4}2i*7EFN#;_yY%wc|9<t`7M3cBkXRLiBc49x-OYEoYG+A<_+5Jh8d^hdU
zbD&HyJs+YMKrb@A<kCgzYw5RAcH+Hhk?y75Pra4yCEuIrrSGu@iUgE8vklw3;3-4M
z%+}|X^$l$AM!N6Gk7xP}`$kzlg-3AKGz;5+);11UzZ+N@L<cj6JCH1gEK)K<$uuP;
zO1NidDK|$6_wfSdDoC95a9dVm&*;KLxBSMPrKS*yNWwj-)=7qDlRJ5xEakAw%n!n|
z>N9<9YC}w;>#UK8ew}I9Caqs+^dqRl<|UKLuuaUsCJyGZKg`T#l9~T1r{o85M+;Zz
zqdYQF3*Ax~nW@xN8s7}3$ic%RUkpa2J`u?!-;B8M)gtaCe~q}4A`P`DIywK@*gWym
zZ@<`L|ItH8c^WoS+eb8ONj=|7_27)a7130;m+GZ^6TM6?+nem=dQ<P0AR)Ca$xLtL
zTy-fLZysU@*$wJQYFY-$!79PZLGn)W@+y9utlgA*hV4w6hvYa}^?7fJYqX@nK3B72
z)yu7BrxT*&+E}VvN78T#@U;%1<rZ$QPk*Y3#q6Fb8`5Zs2hOAoH0F`*<e+U$(S)=<
zlSL}LgX<A#aIruuAJ&{?=Euj%nDiOQxbBlbix#L$X!-KGME)G|T2Jt7;GW<q!4u}g
zRHY9UO&vk>UqBL=>;Or~fR02og;rt^@q}bVG%MXH9EFHx?-A8tMAN=v)m#T9=jzt>
zi`)1>QiQd2iWWJ?EqB`YSs?BC1Kax{h`WQ!x`BjjZz`2ar;_@&_@h+$EVS~EB(*j$
zHOU93)+J@&=TF01wx!vDaU=i6bq$E;e<-h<_Sce++i7QaegdvWiQV~W<<8GACksxQ
zIkSp0$DB!U=9#mgI2GpPz*%I@ImKCG&J;N3nX{}o7nqX=XN5VdinGR?0yyi;sVdGz
z<`luX#GEG-=Sk+2z`4wvD~j_JbEd(0nmHSab5+d1vXmwD^69$o{RiW+xrM218?Tui
z?6)K>xskPAFgk``>-1_=Gis#o9PM`6)_u3d(`!TP-t8WSYG042{Tg;YFf|@TeWnIm
zDD8P(Zd<l1+lu7FJ)<^S*nN%w=hakur;8Eb+}_*iHV>`)rhOV!#qBy(r5e!+VfHIn
zryCJ9f(N|$<{{h#uXok9FW_$mSv-JSZ+qjJz-l`4`jC4&C3Z2Kg)qn6HL($MiaN`g
z*Y&~QY%PR|-kz(dQ=PQ{T}V&-Hr8YLUUTPSDmc}E(Wg~@+ZTt_@LE3~TgAB;uZO;X
zOT(&o5|-oZICGlr`fbjKXkH@)jp)p28m;aM(fqqKqTXE|+1GQw4XwKdY7BN)Ulpek
zo*90li~VG;rRgx;sf1^Zy1k$5-yWtr3!xe1-(BgWdN-FsWM?(d0e!Cdjc6JiW_ztI
zM&Ir%2Xyq6J1_k<FGTXZ2InJ~@*E7cw#xJ7ih=;2$7Q{ZWLVrGDi-m$X^3rTQ#Bmj
zkgH+zfsb+njL#AC5+ziM^)akB!PVXWAja4qs1Q>KSWJq%DBw3IilT(yDKRZ(@S7K9
zF^k`Vm=p8(Es6zE!EZ?{igWm#7E9therLq8xPafXSiyq2>dXbhvU8@;$60p#<e&W;
zE_cVT8AD%0O*g}1ZS~1Z|MpN(y5Sy6)N2s)9VP1OV8_)0QfO5eOX_bx;&+wQYk`QM
zFO|>Iw_=PX_Y;u$110x*gxvTgU@XB62>nkbShG{=fwg60EJ?eNaynF!w;Yg{HI^g;
zQWDq~xD#UdAoeXmW68Y_u~{WoTMAWQh8L`{g#8YL6^9B7FK=TB>q6L^5~g`g>d8XO
z;aIX>hpZ(fYa?PR1SEYi9ZRSUp=(O$l|X`ez<{Jy;_Z#us9m-sgDlBZN-|=SY>K1_
zE@`q!ng^0pRFb|(8b?X}E9t={0nygzV3nhd|G(hk0|Gw^n#&G;5gDbr1CddRdr*kU
zs^d8yS7g*{XBuIu8IG8iLy^>3(C3&wAEGaSUSaxTh<*<AC8nPb(U(EL!1R?6eHHXI
zrmu(SRnRXo{Zfej1n5sP{c?zY1@xzw{&a}G0s2*@KjYF72`+IY_?i|8zTOuJme<kE
z8>O-J;CR-H2?x5jQR6V5tU-d?K1cVqsmPJ6U!@$!l2`#hPDMJ{bXD<H%H5@emGajp
z_v@6fde$lTo0PDk{ubqan-W&pPg1T)2`ex8Sd!yotj71KxJL;qbenSfl(1@dD0e^!
zE4fLzLrPfPCFLwiHYxc4CC^gA+OMX7Q>9RG&=>yH41&d%q1o0KaOdz~aZ~{LanrK@
zl-cqE(r*CJfJdqV(q92)-6M?%Dz6U>NU!tD0&xN9b$)?>1JaQ#)9VDp%|&wQ<pSbP
zMRMt71LET4gn>Z#I=_HG+(IOmUPmA<USx>4mtIaFZYh#WFDnoiFFi!uOD`}GcP5g1
zL98&h9LZf3Ys{VH;C<D}2ikU~@V$yZKaVkwiT3hb<r&Izb%qo@D%#7d2$aK(_G<g0
zusc68@cc{hP}n*!6gCmDP{@=#jD!+$_eVmZ<tL_B*fKE`HczooXhr?9f^sPspV;ld
zNK`MxqhbTesMt!zq9SYh4Tb8-NL2mXg^{>!#^Yj3&A8ZH$KoQh{`U&kWewMm?Zil6
zFUAAoHG_fi!VwFM7MOolz_jp3P2X;eMDkKRl23x=E`&|W#Ui1#?OTyZ^zFz<B)^Pi
zVpN+~O70V0E@P3<vid!RBwC63w<{xY-HOM>OE%-;bvqUpt?#D_mlo~x43Qs%jy=>=
zR`Fx;VAx?`F#D(!KV0Np6jHub)WP&^cSiQiuf&64cZI<m3<X2J&58oEq)o5zc4#D)
zm*cURgn+TI!xTG8<XBx-ShUTjW*9@;rIDa+$Ae;zjX|;777L2pyXO=rExMqAQrju{
z90{C@+*17_SY!Lsnm?(WO8F_YY(l%O9Fp-)IL~?#`qN$yC$-co13oJTGI0Z!e^Q&<
z#+y@TIHUbn+{0&$kL|@uZtef{j8^0k&@H$pq$~c}8}-Mg+bPYx(DA5xZ&Ovdi&sKb
zrQpy}@k24qQ*{8S_<im~Z~&`nsEI|dxml;H11NQK5Fw#&tvOv9XaF_neYNe4744*O
zkpMuX-vQovg?m_dZh+|?Sh(kfGksiVi3p*d@=rg`M{vBekJ$m1+fJxQL+$i&^mall
zXW4D~P(Oe6Te=X*^Uq@<m<~Tfc$ECcSWrL9Yio|$3iBN9SA9JFhPVgA46m6oHKTLf
zr$fW~ak<|PKivRNf4V-V<HIBk@ms;0lnmXad3P5yV(b~!4vddQTcXE%Muih6R+qD$
zHPQLe9a_*XksYK`td(T6`p$m*vnH6Fd8bI-<;OnUw`0=4;eRMk*A}j`oE|+yz0cAU
zT|?%0MQ^;ug<vL+6=D4>n*V~5vo;_nG|R`5^hc2Nr6H0+Q+g~(6l(gal2na&rjVr=
zOV$@5>u;5;^#NI7gD{q;FG1ATm8jJLQM%C>OVD3H&^MK!!T#$rDPzg{DrEhglEr4x
zpG2(Zkmasr#YhK~rimmSmZV;iMqbj8Na`#}4<boIq>K4iU_69qYXO<T&^-e7RAV4u
zUj&h6vGpA!|K9`l2%P6QaK5Sq&etLX=Q(-C&OR=9@p017jdd+D&JA#6{14D~?r!pJ
z%JH6shw&XMeuferP=0~n52?sQ`+3U!F(o|6?^5nhDB<D$Q_B4rB|PwdPPs2r!Yc3;
z%KarJo0NQjlBjU@GKI7C$rS{$|ADlHf;^8qke&T@=BgK#{%bVf!WH_cur!^Y>Wf!I
zxU@1fEL|BImaYs9OIP?`ZWP3g3QJe`KX1g13QJe`KXAm23QJdphNUa~FFCrm$N}I*
zCqv`&KMVanK!?Uef>;?@1z8zqP%|?0OX~Z5sDK;#T_6ktYw^hK`*A!D)_umo6Cf4`
zO_U!i9PHRLj__JN63OqzBjIVsNO<nWBB422O8Y$$APKMKBa!stk?@RXBs}e7k&t;<
zQ%HCn@%kjZ){n&URy>w>!E#L%+niV|Uqro4g@yM3{#xd~E5<v&(Q&!oi-*Fdj=P2J
zT`Ux`i#HUMic;B-uQ0MtJ{=E)jVuFUOB)M>Eb_+{kYIfJeTk7+em@=yTX@F8W<C}R
zEeE>_3vamm@gZNs4S1Cz{S6LyJ;eS0Tc_i1aPN0%8TmRgKmBnn#GD8*-l(`p5B(Gp
z{H4zQrzHP_#mSnx^w&!MCnEp%i~s4v|0$3+=$<1==&+TeSG+l6$4b&l$E`<sXHM?t
w-9Jh`hZQejRgvHyX84a;IbB}PEtZ$cA1=R~d!_ub#HY)<<qzgQwD9bI13!m(SpWb4

literal 0
HcmV?d00001

diff --git a/bin/build.sh b/bin/build.sh
new file mode 100755
index 0000000..b2565c3
--- /dev/null
+++ b/bin/build.sh
@@ -0,0 +1,3 @@
+#!/usr/bin/env bash
+
+docker build -t ahelberg/gluster-dir-csi .
diff --git a/bin/gen-protos.sh b/bin/gen-protos.sh
new file mode 100755
index 0000000..b484485
--- /dev/null
+++ b/bin/gen-protos.sh
@@ -0,0 +1,3 @@
+#!/usr/bin/env bash
+
+python -m grpc_tools.protoc -Icsi-spec/  --python_out=. --grpc_python_out=. csi-spec/csi.proto
diff --git a/bin/push.sh b/bin/push.sh
new file mode 100755
index 0000000..516d449
--- /dev/null
+++ b/bin/push.sh
@@ -0,0 +1,3 @@
+#!/usr/bin/env bash
+
+docker push ahelberg/gluster-dir-csi 
diff --git a/gluster-dir-csi.nomad b/gluster-dir-csi.nomad
new file mode 100644
index 0000000..1c00525
--- /dev/null
+++ b/gluster-dir-csi.nomad
@@ -0,0 +1,58 @@
+job "gluster-dir-csi" {
+  type        = "system"
+  datacenters = ["dc1"]
+
+  group "csi" {
+
+    constraint {
+      operator = "distinct_hosts"
+      value    = "true"
+    }
+
+    # restart policy for failed portworx tasks
+    restart {
+      attempts = 3
+      delay    = "30s"
+      interval = "5m"
+      mode     = "fail"
+    }
+
+    # how to handle upgrades of portworx instances
+    update {
+      max_parallel     = 1
+      health_check     = "checks"
+      min_healthy_time = "10s"
+      healthy_deadline = "9m"
+      auto_revert      = true
+      canary           = 0
+      stagger          = "30s"
+    }
+
+    task "node" {
+      driver       = "docker"
+      kill_timeout = "120s"    # allow portworx 2 min to gracefully shut down
+      kill_signal  = "SIGTERM" # use SIGTERM to shut down the nodes
+
+      csi_plugin {
+        id        = "gluster-dir"
+        type      = "monolith"
+        mount_dir = "/csi"
+      }
+
+      # container config
+      config {
+        #image = "alpine"
+        #command = "tail"
+        #args = ["-f", "/dev/zero"]
+        image        = "ahelberg/gluster-dir-csi"
+        privileged = true
+      }
+
+      # resource config
+      resources {
+        cpu    = 1024
+        memory = 500
+      }
+    }
+  }
+}
diff --git a/main.py b/main.py
new file mode 100644
index 0000000..aebdd3a
--- /dev/null
+++ b/main.py
@@ -0,0 +1,126 @@
+from concurrent import futures
+
+import logging
+
+import socket
+import os
+
+import grpc
+import csi_pb2
+import csi_pb2_grpc
+
+import subprocess
+
+#csi_sock_full_path = "/Users/andre/Projects/opensource/gluster-dir-csi/csi.sock"
+csi_sock_full_path = "/csi/csi.sock"
+gluster_host = "10.0.114.218"
+gluster_volume = "vol_main"
+
+
+def unmount(path):
+    print("Unmounting", path)
+    return subprocess.run(["umount", path])
+
+def mount(volume, path):
+    print("Mounting", volume, "at", path)
+    p = subprocess.run(["mount","-t", "glusterfs", "%s:/%s/%s" % (gluster_host, gluster_volume, volume), path])
+    if p.returncode == 0:
+        return True
+
+    # Might be a stale mount, unmount and try again
+    if p.returncode == 32:
+        return True
+    return p
+
+
+class Identity(csi_pb2_grpc.Identity):
+
+    def GetPluginInfo(self, request, context):
+        return csi_pb2.GetPluginInfoResponse(name='gluster-dir-csi',vendor_version="1")
+
+    def Probe(self, request, context):
+        return csi_pb2.ProbeResponse()
+
+    def GetPluginCapabilities(self, request, context):
+        return csi_pb2.GetPluginCapabilitiesResponse(
+            capabilities=[
+                csi_pb2.PluginCapability(
+                    service=csi_pb2.PluginCapability.Service(type=csi_pb2.PluginCapability.Service.Type.CONTROLLER_SERVICE)
+                )
+            ])
+
+class Controller(csi_pb2_grpc.Controller):
+
+    def ControllerGetCapabilities(self, request, context):
+       return csi_pb2.ControllerGetCapabilitiesResponse(capabilities=[
+           csi_pb2.ControllerServiceCapability(rpc = csi_pb2.ControllerServiceCapability.RPC(type=csi_pb2.ControllerServiceCapability.RPC.Type.CREATE_DELETE_VOLUME)),
+       ])
+
+    def CreateVolume(self, request, context):
+      name = request.name
+      print("CreateVolume", name)
+      p = subprocess.run(["mkdir", "-p", "/mnt/main/%s" % name])
+      volume = csi_pb2.Volume(volume_id=name)
+      return csi_pb2.CreateVolumeResponse(volume=volume);
+
+class Node(csi_pb2_grpc.Node):
+
+    def NodeGetInfo(self, request, context):
+        node_id = os.getenv("HOSTNAME")
+        return csi_pb2.NodeGetInfoResponse(node_id=node_id)
+
+    def NodeGetCapabilities(self, request, context):
+        return csi_pb2.NodeGetCapabilitiesResponse(capabilities = [
+           csi_pb2.NodeServiceCapability(rpc= csi_pb2.NodeServiceCapability.RPC(type = csi_pb2.NodeServiceCapability.RPC.Type.STAGE_UNSTAGE_VOLUME))
+        ]);
+
+    def NodePublishVolume(self,request,context):
+        volume_id = request.volume_id
+        path = request.target_path
+        print("Node Publish Volume", path)
+        p = subprocess.run(["mkdir", "-p", path], check=True)
+        res = mount(volume_id, path)
+        if res is True:
+            return csi_pb2.NodePublishVolumeResponse();
+        print(res)
+
+    def NodeUnpublishVolume(self,request,context):
+        path = request.target_path
+        print("NodeUnpublishVolume", path)
+        p = subprocess.run(["umount", path])
+        return csi_pb2.NodeUnpublishVolumeResponse();
+
+    def NodeStageVolume(self, request, context):
+        volume_id = request.volume_id
+        path = request.staging_target_path
+        print("Node Stage Volume", path)
+        res = mount(volume_id, path)
+        if res is True:
+            return csi_pb2.NodeStageVolumeResponse()
+        print(res)
+
+    def NodeUnstageVolume(self, request, context):
+        path = request.staging_target_path
+        print("NodeUnstageVolume", path)
+        p = subprocess.run(["umount", path])
+        return csi_pb2.NodeUnstageVolumeResponse()
+
+
+def serve():
+    server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
+    csi_pb2_grpc.add_IdentityServicer_to_server(Identity(), server)
+    csi_pb2_grpc.add_ControllerServicer_to_server(Controller(), server)
+    csi_pb2_grpc.add_NodeServicer_to_server(Node(), server)
+
+    print("About to start listening on", csi_sock_full_path)
+    server.add_insecure_port(f'unix://%s' % csi_sock_full_path )
+    server.start()
+    print("Waiting for termination")
+    server.wait_for_termination()
+
+if __name__ == '__main__':
+    p = subprocess.run(["mkdir", "-p", "/mnt/main"])
+    p = subprocess.run(["mount", "-t", "glusterfs", "%s:/%s" % (gluster_host, gluster_volume), "/mnt/main"],check=True)
+
+    logging.basicConfig()
+    serve()
diff --git a/requirements.txt b/requirements.txt
new file mode 100644
index 0000000..5c38c41
--- /dev/null
+++ b/requirements.txt
@@ -0,0 +1,5 @@
+grpcio==1.47.0
+grpcio-tools==1.47.0
+protobuf==3.20.1
+googleapis-common-protos==1.53.0
+six==1.16.0
diff --git a/test_part1.sh b/test_part1.sh
new file mode 100755
index 0000000..7abb078
--- /dev/null
+++ b/test_part1.sh
@@ -0,0 +1,2 @@
+#!/usr/bin/env bash
+./build.sh && docker run --rm -ti --privileged -v "$PWD/docker-csi:/csi" ahelberg/gluster-dir-csi