From 44b49eebf7ca1bee11c9b7dc03deb3ab663e51fb Mon Sep 17 00:00:00 2001
From: beegiik <kbeegii@gmail.com>
Date: Wed, 8 Jan 2025 12:17:06 +0000
Subject: [PATCH 01/11] WIP

---
 cmd/legacy/daemon.go                          |  16 +++++++---
 pkg/hubble/common/mocks/mock_types.go         |   5 +++
 pkg/plugin/conntrack/conntrack_bpfel_x86.o    | Bin 0 -> 1912 bytes
 pkg/plugin/dropreason/kprobe_bpfel_x86.o      | Bin 0 -> 24384 bytes
 pkg/plugin/filter/filter_bpfel_x86.o          | Bin 0 -> 2144 bytes
 pkg/plugin/mock/plugin.go                     |  29 +++++++++---------
 .../packetforward/packetforward_bpfel_x86.o   | Bin 0 -> 4504 bytes
 .../packetparser/packetparser_bpfel_x86.o     | Bin 0 -> 55344 bytes
 8 files changed, 31 insertions(+), 19 deletions(-)
 create mode 100644 pkg/hubble/common/mocks/mock_types.go

diff --git a/cmd/legacy/daemon.go b/cmd/legacy/daemon.go
index 6e06ee73cc..47fdbf1e6e 100644
--- a/cmd/legacy/daemon.go
+++ b/cmd/legacy/daemon.go
@@ -104,11 +104,12 @@ func (d *Daemon) Start() error {
 	} else {
 		cfg, err = kcfg.GetConfig()
 		if err != nil {
-			panic(err)
+			fmt.Println("Falling back to standalone mode")
+			cfg = nil
 		}
 	}
 
-	fmt.Println("api server: ", cfg.Host)
+	fmt.Println("api server: ", getHost(cfg))
 
 	fmt.Println("init logger")
 	zl, err := log.SetupZapLogger(&log.LogOpts{
@@ -122,7 +123,7 @@ func (d *Daemon) Start() error {
 		EnableTelemetry:       daemonConfig.EnableTelemetry,
 	},
 		zap.String("version", buildinfo.Version),
-		zap.String("apiserver", cfg.Host),
+		zap.String("apiserver", getHost(cfg)),
 		zap.String("plugins", strings.Join(daemonConfig.EnabledPlugin, `,`)),
 		zap.String("data aggregation level", daemonConfig.DataAggregationLevel.String()),
 	)
@@ -151,7 +152,7 @@ func (d *Daemon) Start() error {
 		mainLogger.Info("telemetry enabled", zap.String("applicationInsightsID", buildinfo.ApplicationInsightsID))
 		tel, err = telemetry.NewAppInsightsTelemetryClient("retina-agent", map[string]string{
 			"version":   buildinfo.Version,
-			"apiserver": cfg.Host,
+			"apiserver": getHost(cfg),
 			"plugins":   strings.Join(daemonConfig.EnabledPlugin, `,`),
 		})
 		if err != nil {
@@ -323,3 +324,10 @@ func (d *Daemon) Start() error {
 	mainLogger.Info("Network observability exiting. Till next time!")
 	return nil
 }
+
+func getHost(cfg *rest.Config) string {
+	if cfg != nil {
+		return cfg.Host
+	}
+	return "running in standalone mode"
+}
diff --git a/pkg/hubble/common/mocks/mock_types.go b/pkg/hubble/common/mocks/mock_types.go
new file mode 100644
index 0000000000..aa2b561a19
--- /dev/null
+++ b/pkg/hubble/common/mocks/mock_types.go
@@ -0,0 +1,5 @@
+// Code generated by MockGen. DO NOT EDIT.
+// Source: decoder.go
+
+// Package mocks is a generated GoMock package.
+package mocks
diff --git a/pkg/plugin/conntrack/conntrack_bpfel_x86.o b/pkg/plugin/conntrack/conntrack_bpfel_x86.o
index e69de29bb2d1d6434b8b29ae775ad8c2e48c5391..b2adc2bab7291553f5f48aeb02930750f5b42b13 100644
GIT binary patch
literal 1912
zcmbtVzi-n(6n;qq7$}AEn*}1lfGQNVP*n(ZaEnr@QYEU=r3mS8oJ(WXv5kF6lZg&U
zEFd9P2D-2?bm9+yjh%^!iHU`+BYf|Cj#E=6p8DPU-n;kiJ>Olf&+02n<x+_<DbYUV
zR^}z@AIZ6`sZG|Qk$K!Gd-t<MmyP3fnTYW{FH|1GoH0uk@aoVco+5-3`;P;rl`IY(
zE#;$7R{+dc&Ol!WjsYxF0P`v^1MoUFaL@2n==;D);0dq{Kr9Qx15IgI?{R8dC!iZ<
zj{D=9PgC0(hwi0Z?=G)nq&xxg9DuKK6Z#d9_4(HDD)gS=HuPs8>+P%IZRj6{N6`Dg
zX`l~`V>2hAcYtf)5R3b}k@Bpk$`owuYlY8d9{emvLRJm8!5iS*-wx0>d>8yBIK(=K
z;Z4d*{GB#nq<kS`bnqN?)pV|W=^rualIeN!KD~z{^L+r}dtd{5;HRK>fREtkp+7Oe
zFG6$D7XUKB-^uhF2K@1M={v)kYmgTx5@KO(ZDB(^Tz*s+>l>?eA;?vtH!HT}fRfl1
zUPR4Av0^I<W2J3PqBv9`*67~3P2C{zHUrtLrptC`=5klk<}}3J&3$g$iMf;vR6HQr
z^IYYHflyvYlJB5mEV+hIebMyd1FkrAsn}_?JeQ}XPNtUcY$hU+66>TfBOa6GC3%AA
z23tY69grIaXv1;0L`N#8=_rR9Vd#@s<Z(EgPY#q!L@SK9owzC7u#2s1Xdk-v2gVa&
zL8*#ynRhf2TQfJC?~NY@n^hi24I)W=6g|i9O6oX$y<whADDr~9Lr5%@7dR+sK7nc-
zCrbE$4;Q{alj#-J0s1b0?eY&Bg5QX~Hx|{D>?^a}-&K6S*AY&$8ROikmZ(@c4d_8f
z>sb1=#q}k<;{Oe|kggxb!ZI`FajX~o>GjW@Y%}=H92I-i7~%Z=qr&e2=NEghO;EOf
z#^kr|fY`8#J#j#r2gr*;!GcNih{@h?onVHl`F?)uSh!El&FW|VtMHAj{0^aZfT2vA
d{9<oKdlnhyY7BFk{4$MB8!zWEvijNoz(2go^*R6m

literal 0
HcmV?d00001

diff --git a/pkg/plugin/dropreason/kprobe_bpfel_x86.o b/pkg/plugin/dropreason/kprobe_bpfel_x86.o
index e69de29bb2d1d6434b8b29ae775ad8c2e48c5391..a0098ede38482561f4961ac10fc98c79ff9e3792 100644
GIT binary patch
literal 24384
zcmeHP3vis*RlZtlWjS#i#j#z-d99N)ksUweSE{_+^)n7}Y~jeQlcxQ(-d$N+t#&uN
zD_e^D5S?_!5EulLP7M^Q&{Et|zzktxreUn1VQQGrc$h%V5Q^GKrygp+Eq$0ajQPHM
z&)L0uwTj)+bf%r&`2P2N=bZaG_uSX7fAhg@JGaMLT8xGk^F32X$~9)}opm~C$)vd%
zn&~C4UnG1UnG#6TOD<S^^7qL#W_HY&3l}e5TpSeoVaUijDg5UJ@0GR?GknA)=Hzxq
zupWlPOU~MQ()XOR>ELpQ{d&*7LA?u2yDeu_%A1Xp<lzp>HmTHHCyzP3tLHoZ;e^9+
z<K%3Q&9~&dZHMMN+{6xS&&f}?a%Rsm=6sX(J>Tl&v=2;I>;LGYk`*j$yVa(w_c*AN
zX$#HO*ShrNvo2+SzKimoM<FbS<+148v){Gt+}pCmT7c!S<f|9qfe_mF@RBL3e|X6m
zNl!~E<LuSPab|t2N86?Kjy~)3(@S2p`N^M$cnC3pn7*R9-}v@AeHr!&{bqDg4@!6a
zZ>;Y%+Ya%|F{^|}BzD-_)@E70KfTtZe)a=HY2v2yvh`tdbJ7)W7Pc+D?0l>z93Q`Z
zKMVdoZTzlr<9AZ#-vRhn0(Lkg>B87`)_&^ehh-f|FLCR_<=e+iyqVU6ndW<aJf{2a
zk22q<^?y;H?cenI;?~{6?{({r-_O_Kr~bUToONbey^G&?-kkhH+blDCwlU4-#mTah
zv)#VGhx>r9NB`d2ezVQEu<a(Bj;3s4!twutjDHs6kM7!ahxvc@#(zNUajQ+~Z^uFD
z`ug*A-|cVH{Pz;;{sFAN3E1(Fqzl{N$O!&CYUbCv-iP&FPCkDgENuIp-G448pI!IS
zJmx?A<WKsX^Htl<!%x0B=bO0sCtLo{&o{=r8RwgyIzNY#$LZ&CzW3+Hn|r=-e$MsP
z&a*e^JRdjzX#JgQ%};aKI-JTU9)7TQ^#eUS*^iHZqs1(i4xPK&7{<+VCjmRgHH>y;
z!jo2_2JP|L-ciWE5|QJNpn49W3?7+z+T#_2x3C1FTeXc@E;M<o5fR#{v%!+n%en&m
z%}&<NIv)@{wvqWH#I91x9rJ7Ll)g|JLsvDhn>8IBXtcYv3;ex^n(r~t>}L}3J&1D<
z#}G4!yje~n77%%7VWuaMke>woA@U&Vz(dOe8LOMS(WYWg=7}xj(}jk%+D1Em>@7&g
z5!KEUpml6N1DZBZApQj+LOaLgbCxtM$Ya<p39;)z{2e08BL7vy8xR@3iby(%coq?%
z{YE_g(~_oz<B)VT@06_x(6pgk1+0A*04EV?PhQ=|5NXdPh?9u&I$<79lfJE%0!wJH
z1M1NbyH%-R?6pxb=@Z+O5M7ShEr?0P>s^KOZUgPttv(BOtP_v*5W*jA|Lz5?^36gg
zpz|PTjzJP}kI+4!-z7SIpml7<Ku;i2pJ^I8DBqqNbD)=jK7n`;H0?i$DEFTB<)A+R
zK7utJ#=x2ckDC46n-Axo+E?2DcEmA6+W!v3NyMjIS@Z4$?MPeTk5twtq^y-*Ss-KT
zPd{uMxlT+X$~&leU7)p%NUx%u{uKnr<29uCH+L;)2{ERF_G#Mh5+-!pXs}VoH%}u)
zKJzi8Wc>*qbhwj9srNF{IMS~oZ9~cczFl_y3%vEf6NnoS{~H+p%n$IOeg79J+w?Zj
z5@Pp&n1ccrqL^c#uK|6p2p0;S1int_G0-;(JqdcL>Z9P>R3G#mst@{3)d#&=_0g8K
zst<aD>Vxi9ebD!+K8&zY^+9h^eb8G~AM{Suhf#K`KIlEF4|<>KgMOFlBYh7dLc=<O
zCSQeS7~1x3q<QFoH}^jBKtBwZodV79c9+=a4m>9X{{mBF`X2Ou5o8iH!yd#*l>2?~
zY4ar7&q2i;GGm}yg`NO?6==@SNze<0J`MUtp{GFK3Hlw-IS=|?(451dTQ&>*P0%}p
z{?;rL+b#6B!GDL)-vQkx^mjoI3Vi`(z8~~EQ6?SkY0#{T^zVue=vki<dRD7xIWBZ7
z=)V*?-fCi>7kW1MFA3ca`W2z)fPPizD?tB;&{u-KAoN_&7lpnG^i`Nh?C(6#Hwb+-
z=sQ5OogHZBCgFo_*(LNfpd+E@qiydMdI9(&LN5gUt3oe=&hH4l82nEQeI4k(5_$>f
zzZd#?&|en%2GHLU`bN;RFwkuCO`xw4`ex8K2%P}EOz5Sc*MX)FbfGT{`w)|$?*kvj
znm*9mK+|8xKtC+}3DA2$zYF|H(C-G#a!!M0cpPyGbie4^1qQr#BPQUR3|ym=pbL_>
z2lR)9?gRbXLYF}Q5op#m2KqVSkAwajp(jAUBJ^?4{|1_VH3|9~pd+Er3q1w?w?X%T
zZ!qS|k&sS;{vYu1&y0bN;ZT$UJpsBMbQbg^Xa=}%oPB0U+NUwsLT9VcOF(ZInhEq<
zsed#0n}mOx&`H6Yk&X$CB(_m#*gwuTErb3R;jIL%>#C}K0L0zkYh9Z>oku`#gFK1&
zxX@#uCB)e74EU(ao|D+l2Smtrl1>Un64SnE+X~QmP~=a52Hy{{4+>KK4?*W4;r%k`
z-9mp9G(tNM^&b}+Yohst(7Ql?+R?hMw*0xsxDP)sGA@a*nXHU7i7`B{z%32;Sq3oU
z9gZ}QNcsZuYu{c5?b{e_x3>9bkN-8$y~vxC{77Ovk1?QfyN{CAF$Zbe!g<QJc){{H
z?|eS(MSLFhJnAX)yu<Jv@DbXXkAZEZ{_EhYf6hi_q}kVNSuylgrsXdIpFYNLi$@cy
z&PwpLp0ysWI?yv)!RK6Mcmy>5*^qLCy%Py5#(Pgm`1?U01`V6p_CF0eEsEo!lM$>s
zzXd+)^g?V*0Buj1?z7k7&<Nh#{u$(1j1=VqGsw?~{Jk^CzkrJp^XF%f|1U0Sl=FPf
z0J@=lU&7!}UUK4T@;h+ppu9YT{27r~MUKS!Qx6FG10Au=UC`zo1dXyZ#733EaCL(2
z5WNx5)O!msQhUvOQgrDnH-O(J{A+~Yh4f~j6G-1GG`eS22%SK>%A?nK^etXphlJ0z
zFL!OS?zh3C@9}7pD^yJsZQ8SE)1%QN4?ean>V33lTNIh0ROzAYs411R{kf5RwqP=;
zY6_ae>(-j#LM3;gkj*4q=Hc!-Cq0lVo9bvOYX*_~U@AYHWl>RoK6Ri1Y9z`Qs^wg^
zVoJF}Ay+tH%GqkJkc#?q`D(UohO&^RD-rXsgiN_uifnn%8!i_j6v<YsxvO4hWuRED
zHso~mri;Vq-2TxjYD1R0*4MM-i-iLTKD2t)Q_iL;#X=-aXd=lTMB~x&RC+L5HI;HY
z%9Tu}Qe{F^VmpW}Q5oDH(Qu`5v08+krHkm9K_UB#MRa5{pJD;8358VEcD$6!RGNt2
zNR~>cvn8~EIdi2{CQ~-~VsUV|WL8zPBUQ6%^{Q2?ov~L(X|(OY>V^?ml{N_pm1=o7
zT}?PoNMJM)_a_e5q`Ce?=l)W^9Vu5sl+9;{I&W_%ZbjmDWL&n)yx$F_*tlvQ?CIUK
zdFQrh&t5#X?%CZ_<Luhh>lnRTdZI16ckSA?r8nBV>5&Jw7;-jk*|M$2XKdNI`;l#;
zK=s}|o3=a@ZQ8okm9lr&L%VjrbC(0@>Im&=y{Ke{OK|F}4mf*a#3a_juB|Z0!D23x
zn6BJu`O8t}iiDRTsyalkUBM}mkQ!Gc#G=lD63a`=tTm%(|1i8C9x{|2s${F3G}($o
z7xZ&aW{drurDe<RwVL3sLSZrwFdR~HU25CGnjx&wPRxnNA$+4jW0uBgAOq-%;F#ND
zT*K)n7OvcA=UU><`x9%NrYEu!kfPGcjWQ?dI)&^ZyCRIPawRkrP#3x~nirw{kpXIO
z!kPMmUeyYRrD0yonQ|6ORC&z?#Px{l5Z9XhC9@wsvt|uqmnq+E%H1Y4V$vffGh!+^
zlgXK4Id>oe534}BV%$ns!HQ66TyIRFKN`SPj4Ju!Av1`nw?DhOf!B2pDyGA1?%5ta
z)U#*z=53w6Ld}6HgK(Mt{={<Fv&O7xR^ikTF>&L>VOt8-WkxcZ^nMc+`qNdTE4y8(
zhEi#p4rIzUePTE}jOmdoVXZ!ZB{Yo{Gn<Ku{r&J#<B%y7p>FyuGNo*GFq<(0*;FR#
zFQ*QeQa^k;mCqN`CY7${4rU`PLRst|#X`lZWy_TaO~t|)MWw;2UF)?5#Rj`gv7C)E
z{j_1VoJwb5?5Hw4G=$2E#bQ((OpTiS`e-0k88DSYE<Kd%&qZ9TGo0_ajHxrw>Zl)s
zl`W)GrOI$VRYijwirD)!%En+04@pkfwuAXpA;SEq!0EM(KF{Sy7l%suEY_9EA;-vL
z-^e?%P{d|Yfbr}uku79k*eG2r^ykV$2B?yb3dKy;Zg{!U!3t_Cma^sQDBPluEfZFY
z>0(~D#39>83`oA1f+buU^&iS$)XIZ3Mt)tLS4~HiL0B)HPgN?p{!s%)imf_;j&Zli
z<jUD}6^89E7l&&6Og3E}Es+iVTp^Pk!N!(@>!WR))wx{1vDO!ZaL==3HJvk+Y}&TR
zbpiuesBnvn=qK3p9UEpjR4flRGU<|{rF}Qk@&`G+JT7YmOAOkb%H=V{&O1@aaF)xf
z8Lq$ujpvo+{Tu?5&sD0Xz%3Iae$ZrGj4J7Js+t}!<^6V~;I*JisWM#x15+$hf(2oq
zN+O@_#~edRwi7TE{Wg>3)KCYi!uyA?TEK=wmW(hn2CKQDY=kog4lPl{XZ^&&gN!?7
zrExT>z>aY6R3VL1kipPm8N&#YLOZhka5S{tZ9Gu0jvYmZYX0r!p1Kj|HMXNHj#q_L
zDHmbVz}YcI*cXR!e1lKX{mTbYCGA-*7KZ}Y6qqa7@zND1;_(q3LW}G|?~|@^6je;B
zS{%xyA+=iYjjns{+F<uStRwr;4(v{u&fBxq0XG-0`f&+V-;jOM?o+CgSnBq?fhyLV
z&TYLrqMqo%9vn$f^z@QxHY|!#E+{E-`X*g!x<%WACL6_4u-kUIy{^9ZfhSTYaT#!4
zi>e23%y4ZzfHO*ZxNN;jMV+;l;0&Gs7rH7-Y}}Ywx7HPSnfswV9Uy-Ndm$1&SJ;hb
z)2>HRQ*AfFW(A{H%^)5ybCW%*3qvk@)}C#>)3+^VuN{Qmk;>OMB?y2M8)2sUi9*|-
z!A_1<bf*10XulXIJYk7Fv4=&?4yoSxpm}+A>y&fakKC{-ChEcUT;~f|Sp#b}3Y(a+
zQQ?xtyx$s=n+$fbLF|9L59o0tWaGrKwqB(hx<IFPzNi$_gFJD#p|r;wM=sBn%PSJR
z(BP6#F1V3&ZVgFPs+KVdotCi-j33HNz3WWPPo+@bTZ1+SCJv<a4%gf@&~Qc;U($a2
z{bHA;W9k)`aIa|{5r@_6m+<zPvRnU@#>l+FTm*wA$Fy9gEp=A63nPSX#$k@*rfCl(
zQGY>wB;dkD*3~Umo84Z<6$y6{!g=6e-CG)tsBryCRj)s_rDfVdRgH0pqr87Tu6aec
zdU*{D+#%>-)5R;u{f5gI_Lp7T?fvqHUc{#N<o~^n%~+%w_Y$7gG(Swn)r&{(!P<FM
zt}qd95>2Evv({W@S_w^^Wf`}gX{x~xUaHR8#Ga|F#sQ6@d@hY!2~L9roCh;z)qWg>
zS7Fzv;PmDsTu^Zc1TtI^aIo3WyA0m5@jIG?ym$L7QpVo7c;F@6eRv7T_kK{Ry?0#)
z%y*{Uh@<$s3Pd*CkLPmaQ+xn;#Jxkc@*JLLJv<2fFYX<xl@H-L7cUJpe-ZfKJ^Tdl
zeeRv7)vw_B#~vOA<~v8Wb%E6|=9{GPQuszRH~}89hEBn2A;0Q<#`Fo!0k<4+eeA#+
z)wlAk>I*G~??#Eo5aTbkm@&bh0bcM*i$NAEKLvd4=@xTTFcKRk@MQk4BVP4ti~Syg
zcsX9y&Y5a4lOn$xc+uGwb4GA4@D1l$%#?>00k@+s%s&G8b+5OW4#6J*z6qnn@17|q
zz7DuE&`%2f9OQFaW2R5A?SFU7j;(vu>dN^|jCK6QS=Jv|?pJ{4yfn-GodNh$csC!P
znq~cha>YBO-TwgjoY!XAzsXRpxKHH#5G&pnv%d|Y{H?_J!}7Su9|pei@tBzi^p6F2
zQg8<P^D{AX%EKMNrv-li@<n)4u6F)Y;3fD=#FWU1uLM3XSlg#|e;M*P{^+cBRr_!b
zEJhv%_G3G6e0^)pZnob0TCJ~AZtG39*6e8O1@4mk2a&&HM{CWl#B+evu1^#9wATFd
zCE&$<tu;H{fH^lO(`vuPVSO4-Nco+R$Kgb32ld~xB3FI2gZi)9LH$?#PyJWzqW;?@
z{zXjx-52<y`k(smfXLN<M*{tE!Ro)q1*^Te_TZll?Duc5pT}EG0vzJc1J5~8x3kXc
zZjtM}Ry*5*@aPe_+F?Mj+My&^?Qm4E&eLOpwO=|8DnBi9?U&kJ+s`$$9Xbr`M=RFQ
z__@HpTH}rW)gEv3FW`ja-;4ZL&W+dnjpZ_EzlT|VN8GOYetlfK7dchij_*(pAMmhk
z)U$rx6SSi@Xa{ho=u1(xcC5r-pBCXmn|&gGKXCl<c+JmW0G^YH*Vf%H0xx)9ytZBt
zUk!Xr@_&Q+WAWO$tK&T>avg8AKiD>$!IS;b@z(Ls@xCB(9q)wrp^m5ey^go8yDHat
zpyRE6uJ+`f=&!?f0LM?)?QGZKGj+S#b@yDnwq7XK@wDsi`FPEb757O$be$^+w(Btd
z>NhU<O<9NMw$;`jyB>D5HLk<J=Y#g?`tvKa$AY%nI;{5L*<msAFmU{4;SZMa&bCJX
z>}qSAC+pi9=Lv8^^0OR<E<~2M0p-oPugxR{_YiMwGkt=!z7fICK)$%Qt#Mu6*EZw2
z{B^cBU$=|;>scuei4AHO^-r~n`e%puqx$Ei*5#hSf7L&AUG~>$o-0a${t?0I&pfmF
z{`(kk{78KqtpASJ?QZ?`lWmRu3*6wp$J!eG7q}1B;J7sP-xF`L|GrosC+okb0{;cp
zanknbI9dP2M{GJSY9F3$egFL;?KV}nn_XYe2L5}lZby5L08Xe~kTNv*@3#a0eZ6i+
zt*^m<=gw~Q-;UXD?7z3ouFdP8l>e%~>iX*YE6>FP;-9)6>w2sD<AMKnz-GMX(6t!&
zz3Z<5Gf>8Fww}e=mSG<v@#}*9`w;VO!r6?$zZdy@|9(XNMLEFu_atARdxPJuTi76k
zOSQ|tSNY{}uKML&Za@8dm|vc2&CE}HLOM;zZ;pA}><c94gl{lDe)y8=2Yl+x!udW7
zr>(v_w}-M>{JJFwU$gpc_Fm$PjtKvFQ12fIpX+EC-0i86`<&Hpx9fv1`CH+S`%Ix{
z)xNT76wZ?WM}W`$C0ov1LqGS!?+Jf#z^BeE_bU)z-TbxHpJ&&p27%QV$MXbVw)!2@
z?DnMa`#fEe9~FLcyTLJo@HwkLe}?wx8-RMI?_2!^)7tav!tblATI#dH58Lw@*lWJ$
zw*!*zW8hy?I}z8vIs7xxS3ULL4~c%4<WER?2h#bT-*!Wfp<ndJEHWk`=~GDOdwx49
z`k%J^cF{s2e7^IU@A(hccZOwB{)9#K@;?GR-}5W(?+m!YfsaGK1a0R7Qcj=n6Oz7w
zbiQ4g97E^LO4xZm{?nl4ylnOB<9I^q?ScL^<}IpTyW_>B-X4*tM?PltbtkRgojOI2
z#q#^L2@fv?os{~R5Ocp~U~(&>)}wd~JO;%l9IWB<9$pH1oQeoci2d@2Pa`s@e20S;
z(?_}j%)N(!`jnp`K+ydANO;)q&vNkn@`=X~8JLaO?+<a<AN32Z@5fz!Xs<l(a|~SJ
zX^W>k%<&xe@KWH9d3ZJOF%Ppp&v}^RJLzF-PY<txd<7x{>t~<W6Cfzw>Y&9uF7$eM
zHt39p@hZu1UNSI0XVp^#2*j-V83F`i&X!LSAP_G=e2xHtcroIO1PH`S5Y-=u+1|5=
z42mx}Si?GgDqqY@2#Pxctn*goI|8}-pUMXU`AC3|1o&uxj|KQdfKLVZOn}b@_(Fi&
z?fPHuZ^FYI&#nL`1I%@bf&Ha^Uw}&i9t-ezfF}ZcJiwCyJ{{nx0G|)A9{jYu_AceM
zKOqN0m3IX=8Q^^$roRsacqG6_0(>;U#{zsJz<h7X!1l4eGXXvu;0po9t6Up2|Kb35
z2Dm%GcqQAAe_wzH0?hjc0~5CQNPv$9_*j5X1o%{dr##H{<$QpxQ%e1m;}xF`R3lCV
zxGTWP0QUsAFTkY$j|F%<z!L#J;bE?irvi*uU^cM*l%Eaog#fq9QD5~J2e>o9Ne^>9
z?g?;TfJ*@$3ou@J*ueT(-b8?p2Y52Trvp3{;PV02A984YxVksgp9pYQfRh3432<M4
zO937W@OXfad6@g#i2$Dp@R<Og4e*5k>km=bf0n<v-FDy3KjO{+cL#V!fcFJ>AiyI5
zJ`&)g0X`Ps69GOI;3*Gt|L1Sr7}!5z`vZRucevjT)#Ql)cLg{Z;GO{Y1-KO8u>g+;
zcp|{Z13Vev(*d3e@c97i6-VvSaRrT1w@)I#T>(x8xF^5^9_D##B)~@kd^Etv0(>IC
zrviK?z-I$|A;9*3G9mqC`xbLiN1#23I|JMu;2i<p7vO;aj|BKgfG0f6^XTyaPX_pO
zfTsd{KEQfKW&c=yhrDZ3oCt7NfRh3432<M4O937W@OXeH0(?BclL0;*;Hdzg53pW@
zwZ9$m?ojax4|6NLFTgtkobfQ1()W3orhmr6+;2bYVeV%ydYJ3$D*=8jz^{9l>(>Gn
zioo{MUvCTW`T+0rFvowzs?}X<*KN4#ZOgjvynFr1H3q*u$<Oc^s1-H&Jd}L-;Ss6L
zz1vsuqnXB%g0JtK)D;$r@I6oMHx%}ppg_U$rhhTXZ;FCXx@P{&sIhU4h2bk@`*St#
z!%_KFnD@!hbRF;Wy(T62pIkK&*S<_`A`5=3CcmPSUwlpf$x>kWMyvRCZze&v+@Q?x
z^_AxXGil`W2Ztj5C=EX##E0hkZIym?g)c6vsr_bEWpv1<;xcCE=FQ#FT}<wB$vT&;
z>2hgzw805&vd$q0EnFY1r||A*9h0}YWW7t)x@3(@x}&vJS?7{9F6k1)^v4rYxHrnx
zsiDA;UI*>}c*&E<wYtXX21TA6Piy?7Py;~*Io8zl)`Q|!pR92lab&AY^}X0lfV|>r
z{thQL38c;H*Y^qCm#Ck=Id4|~38`P}Vf|dY!uq-PHmhIn=aZMHpW<fqpOX4}AZK9x
zv~gJfIq;g*Kf%T_T%!K7P-#~G;%zp!Nw~z;&$`3<hrnxEzueD8B)=w_UvUmZv--QG
ze&7B)5@~+r?*^|~{d)g9a*6&wG(-J6r2Zu2475MD=&=5;q5Nj`Psn}cQvUZ9WNy~~
zBTf3xEitVB)C~2X5k-A3kE}Lme#I}&Q2$Y>-}gV-T=T2_Z^NW))_*-OU#kBJ<Zssh
zvrYQXb4OVJ#Tojq=g$*toEJ2|vVJf_|1UJ@KhH6mU;BTn)E};){F^Ytq<z*OnqN74
z#C~D^ZaM!*F{*BDT>~I)Lj5c=%)dkOhxLVcSnBu7B(3?k-`XhAWktD9%rJgCwmXe6
zQRMvL|L0BXSNm-SFBl@5V|<NG%;VAzhuj*hG}DcU&HU$-)IT8xWc}A8POBg7pSAO1
o5u!1~S{RW1Pur=2u&w;Q7XPM&^KW-7eecJ7Y=hR%Gcd#d0a%;>KL7v#

literal 0
HcmV?d00001

diff --git a/pkg/plugin/filter/filter_bpfel_x86.o b/pkg/plugin/filter/filter_bpfel_x86.o
index e69de29bb2d1d6434b8b29ae775ad8c2e48c5391..bf6c879c816f34c58c39471bdebc664f91e53879 100644
GIT binary patch
literal 2144
zcmbtVJ8KkC6h6C&W;I4lREUwtfFM!ACL{>45H<^mh$-T$(89@NcQzR^nH^?lL*fI2
zAXwUnji6X*Wf{9ziG@GFA7CL^T4*7x-*@NU$?g~s@gv_ok9*F!=RS7wU}kPMpUa6s
zPJYOaWxOIU_w48;rIw@@k(HreEt*?MvLGu%Kb5`xie8bPyvWa1t2LM@`UrD$ZEOFQ
zwr}WOXcJEp@z3LnZ#fy%S?{n0c}lMZcfJdQHgnz3t<)4w3ECF=dqKT*69<n%elNsv
z5V73_NDJ%%iL)Se3mgN10%Oi8RsN{8AO3POSKyi#bsT$So<_dUXwumy<23SzjFyQ}
z7lS$U-8~L@12lQJpmU!k@HV&)+ytxO0q{K-fCoV)-GQLL1pOg>m^zHX)Pw9h0{aQb
zb9e><g`*grD^=7@V{hHBU?cv(0OT+f{HZPUCvn1F#S3Dw?dhvmr*GQVF5Q~3uiu=X
zv29s(!prW4gpphG)_pgSsuMeiY)(!{GiZ2Afm^kb<mS|lr?Tus5^sdAtRQ>M@tZD7
z*)`u;YCv1J-5`!Uw;`by1YWQtksEt~W7j-Cb|djZr&^6<v0nGZE_3wj^_6BQ#n@d(
zr<E|OFO7BN6f0tBG~%dPiLIn}3msS&th?!~SF=VI!<x;0lB%}ryQ?FoJIak(r;&K(
zjNF$ZA{!!n^Oim{o-;WIE`S8z(Hjuwt8fe>?~Fdab>c1f0UTZyRg1R42o&01z`lD)
zUD_v5F!vbBU(ls~Rh>b6cl-q{D7iC?LLF#}M>`59G4`k3O7b?~V{Zia#=U&ho1{*%
z9zmT`C6F-od}5~dLdFg=cApd@*H126Y31v)Mc#aJ7acd1J`LYrTebOa@GPZ>M-V%U
zkQ=K?vL33)T)8}MPw4gjS4^XT`k-YBo!1{VC*#-0mU<aRAHQ|&C~3poi<v7JMN8)L
zTT;@t5g&Q*0N)?M?_VA?`Nq$0IBR70@ESg1JQ3+=@{ObY8)tl!pSAIwi?%_xm3po~
z+pYi4yY$bqGV7cE55bo`Qx^ZEH?&Ek4cYbizhJlZzv{qwoy+s%cQ(8JBz#?StvbXe
gm|{xbf3~-*eF+(vBT_Zy_4@0&qPZipzWLw#8+^aPQ~&?~

literal 0
HcmV?d00001

diff --git a/pkg/plugin/mock/plugin.go b/pkg/plugin/mock/plugin.go
index 888d9267dd..403a472c3c 100644
--- a/pkg/plugin/mock/plugin.go
+++ b/pkg/plugin/mock/plugin.go
@@ -5,11 +5,11 @@
 //
 
 // Code generated by MockGen. DO NOT EDIT.
-// Source: github.com/microsoft/retina/pkg/plugin/ (interfaces: Plugin)
+// Source: github.com/microsoft/retina/pkg/plugin (interfaces: Plugin)
 //
 // Generated by this command:
 //
-//	mockgen -destination=mock/plugin.go -copyright_file=../lib/ignore_headers.txt -package=plugin github.com/microsoft/retina/pkg/plugin/ Plugin
+//	mockgen -destination=mock/plugin.go -copyright_file=../lib/ignore_headers.txt -package=plugin github.com/microsoft/retina/pkg/plugin Plugin
 //
 
 // Package plugin is a generated GoMock package.
@@ -27,7 +27,6 @@ import (
 type MockPlugin struct {
 	ctrl     *gomock.Controller
 	recorder *MockPluginMockRecorder
-	isgomock struct{}
 }
 
 // MockPluginMockRecorder is the mock recorder for MockPlugin.
@@ -48,31 +47,31 @@ func (m *MockPlugin) EXPECT() *MockPluginMockRecorder {
 }
 
 // Compile mocks base method.
-func (m *MockPlugin) Compile(ctx context.Context) error {
+func (m *MockPlugin) Compile(arg0 context.Context) error {
 	m.ctrl.T.Helper()
-	ret := m.ctrl.Call(m, "Compile", ctx)
+	ret := m.ctrl.Call(m, "Compile", arg0)
 	ret0, _ := ret[0].(error)
 	return ret0
 }
 
 // Compile indicates an expected call of Compile.
-func (mr *MockPluginMockRecorder) Compile(ctx any) *gomock.Call {
+func (mr *MockPluginMockRecorder) Compile(arg0 any) *gomock.Call {
 	mr.mock.ctrl.T.Helper()
-	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Compile", reflect.TypeOf((*MockPlugin)(nil).Compile), ctx)
+	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Compile", reflect.TypeOf((*MockPlugin)(nil).Compile), arg0)
 }
 
 // Generate mocks base method.
-func (m *MockPlugin) Generate(ctx context.Context) error {
+func (m *MockPlugin) Generate(arg0 context.Context) error {
 	m.ctrl.T.Helper()
-	ret := m.ctrl.Call(m, "Generate", ctx)
+	ret := m.ctrl.Call(m, "Generate", arg0)
 	ret0, _ := ret[0].(error)
 	return ret0
 }
 
 // Generate indicates an expected call of Generate.
-func (mr *MockPluginMockRecorder) Generate(ctx any) *gomock.Call {
+func (mr *MockPluginMockRecorder) Generate(arg0 any) *gomock.Call {
 	mr.mock.ctrl.T.Helper()
-	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Generate", reflect.TypeOf((*MockPlugin)(nil).Generate), ctx)
+	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Generate", reflect.TypeOf((*MockPlugin)(nil).Generate), arg0)
 }
 
 // Init mocks base method.
@@ -118,17 +117,17 @@ func (mr *MockPluginMockRecorder) SetupChannel(arg0 any) *gomock.Call {
 }
 
 // Start mocks base method.
-func (m *MockPlugin) Start(ctx context.Context) error {
+func (m *MockPlugin) Start(arg0 context.Context) error {
 	m.ctrl.T.Helper()
-	ret := m.ctrl.Call(m, "Start", ctx)
+	ret := m.ctrl.Call(m, "Start", arg0)
 	ret0, _ := ret[0].(error)
 	return ret0
 }
 
 // Start indicates an expected call of Start.
-func (mr *MockPluginMockRecorder) Start(ctx any) *gomock.Call {
+func (mr *MockPluginMockRecorder) Start(arg0 any) *gomock.Call {
 	mr.mock.ctrl.T.Helper()
-	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Start", reflect.TypeOf((*MockPlugin)(nil).Start), ctx)
+	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Start", reflect.TypeOf((*MockPlugin)(nil).Start), arg0)
 }
 
 // Stop mocks base method.
diff --git a/pkg/plugin/packetforward/packetforward_bpfel_x86.o b/pkg/plugin/packetforward/packetforward_bpfel_x86.o
index e69de29bb2d1d6434b8b29ae775ad8c2e48c5391..5f175500269f66b9fa5956441e65ccf97025395a 100644
GIT binary patch
literal 4504
zcmbtXU2I%O6+T|)$8HnHNeQG*sis9#Zjx^8HiSZ(vI%v56t}Tr2M7XPU$5`lH@^GR
zy?2vrL&PG%6O}+h(5H&1l>iAOct9kmQtJm$E5Sowkn&KZ@PaDfq3{AimCX0eobg^?
zEK7)^J@<UynKLtI&dko;{rc4OsnWoJco~p?N}qYJ$d^X?xME>Nb|dmu$@#<kwpp-$
zaL`)%Iga;V92^ryR1bZ)#(?mne2TpFnzK6*|KZx&+JVC4-$FB87iE_Xynguu+y54v
z^j{x)-}2%(Z@q5AWhc^kf0J=<xpal&a|zpJhwaeS`FHy9N8LExfgua_gpOYyb^Mm2
z@_n_>b;86ve|GNi(=*fR+S2^+uLE+xM=&So=QKC4604~x4bW}Ysn|j@clx)h!uU8q
zD<!uwi#POPUzHM9bH5`)!`>;fgJVCeybP<k&{Mh>kIxVw1(vA-b-N^TN-=#}h@suU
z7oZSZ&5DIK|7`|1g8K0<19MFk=oRQrXb<`l^d9Icv<HQZ@M!vefTg{7yb3iK`Zny3
zq5GhepF)WZ^p}b&u)kJ35Bs*_9_+h{Z^Hgj@ha?}72k#ZyJ9BsZ^Z`q9w_Ik&?=sX
zJqY~>{5{wQ)o)P5PbjVcmle+gKdHC}{EXt8z|SdO1wN<vF7Ou=^Mr7|{g}%DuPD9=
z+|d|=4gQAW3h>K{=Yc8wn)ZNy06+J375G(+;RgLkvEgPxc$O=`KUaSb_%<+P=srB&
zbhvm%?YU&FIIRu^#1*(2(odyei0wSDzXSM~^{hWi4=eOBe*n;P?So1W^<#FUTyh67
zJiqV3;<IZE_+B@ey%{kV+*WKp4*;^6=Xun{jeH!KL1W;sdjQ=7)=+c)2f-=qKkoYT
zc*|rCOWepL2u@tMaN<%hd-lsy!Q7>psUVP*s2gP6RwQR%IDKJib~ZRSbxEfBupVXY
zxGL3V2Lmj0vna(donuF((@5i`Mzm;>W@E`d#Ew%BuLV&9oe+t^<w}@zB56li+z5kK
zSY3&-TC;sMY%d0GYz~;N1Ph&7O_Hb~t(DAWR1e!L@?t0IL_s}lwc^H-wA#(AS#2hA
zB?%irs~x47%8{%ZdoN-T88_Q;*2Th?5S9jUEp9AE*Tmbb8aPLFL6*aGS>UK9VVcH^
zvKVHeePAVv(g<5|0B<d<$4M7UsW-DIh+9V`X;#C;qIKu7b>}f3*=n{k^;*c$x%N=9
zGz;r3xf-{lfJ<LWn?V{ar4Ga|MXdFcPxNceU92U|s{tyTO1gs2f}~9rHK@f&7PXa4
zN>D|ymLA_w@p6^tz-;I+o@VV%H8bm*U=Cr>N6mGa`0S(@NL(}Ha6R^{-x+iKxS2We
z`Eyfq!I|^3bBtx&4HG44v}O4Di*u*X<D|LaCu}zyCgZZ4#fr^wW9LFSp0>@Jo;xe%
zP_@&3-X2K=F0^Vq89~x)u5?;KltlIMN47d?N6aILKNoc$eOiXOtcTWz^NZj@;zpdg
zNy_%bW2%0FE~`SA{dyp5vft{H>$I@n(f^Vhvg~JY#GITt6`XkC5>n=*l=Y+^d)7{T
z`0%D}F89M5lfNO=<*<!&mBiJkkw#KRMN;vMS@U=ZLI0!)e^(e@DiFSFs1M*`nt(n7
z%=_~%!1!1>h$rtr`uP5&`~!HH7vwb;PyQ76$TwZA=fmJe<LA-7|7F~3IX((Lp&Z7_
zQ+TrfD~Lb%Gm$gOU8~59@?W9d;6=Txd>?M$9eAm?lz$R@>>ZJw@@ewlh<vxu{uAYw
z(LVfp_g?4xzXiYl4t^tQ`=8kVJrK09eRvz--}<#dv#lL#bQHN!3^dQVHuCRjJK&Zw
z=w5RhVo*}ZpsicJfxm_9YZ1BS<%T7L_V-HO|7nnYx$#G}AK!6%^*1l$4IhwM=-%8L
znC~bG_k+Uj{5{EfQar!Q!az_i+y1W{=gaK~8zF3Gp9+-XxgX#2dE44==YCUsd(W~y
z=YCUs`%TOG{1*kjTHx;%_}v2kpup`S;PdnOx_WN7$Xq+WcX?hZ@UIkjQs7@J@R89y
zQqH1lnUvd6Qa(9%s%(k99Jabr3vZutl3b|=;o@Q&zYg-Z46gAkT#$0wty`<J$n?pR
z6TzpPIqJ+4HV5~Tnsm$jzn@>l2zrDzjP-^d$X7Oa-I>a}SS~8hYF;XNlEd7$ynF{_
ztNwn!eV-u@)P5V5|D!6(y&2!-kWmMzzf<TMRsTg;&R?v-44n}Fy>#rq*U$TYv;Oni
z-}sJdi}}B({R?6CKMQ?dEOaQ=ua20_)_-P`_49u4!};~|zon)M)R#N@=am0b@=~0i
zV{SJ8vd-`8NXoe4{8R7^POmj#deC*bt%Wb{OCcTmUv{(Wf0+w|tlFnrBmeLC`46c7
EKhp6_`2YX_

literal 0
HcmV?d00001

diff --git a/pkg/plugin/packetparser/packetparser_bpfel_x86.o b/pkg/plugin/packetparser/packetparser_bpfel_x86.o
index e69de29bb2d1d6434b8b29ae775ad8c2e48c5391..dddcc7dd9b3644351016fdf1b31289c6df8f70c4 100644
GIT binary patch
literal 55344
zcmcJY3wT^tb?=X4$r(8>CB&d8B$>R&j_pXY;!F|}l*A4bNMd2jWT3!Ek;WcjTN-Pm
zWE_VgNT5?5#gs><TnaJ?Fr{3owketN0ahucLkky|hB6<IRv%D0Unv*06gs!1<o?&*
zYn@qI@<bNBciTs2|Mp({@!xBoea@V7MtZ}pd+%;-X$d5>1pgj1NK%7f>1&PnfQt?U
z8(}%x{qtuDpGKi5_M_c($0t8bsX=g7YY^0*efHTdQ|X(LM@c6+{b}ZX+!taB@AbRj
z<aIuB^7(#G?NK<^J?q*#)}7~lmiHOn5A#0B`$4y-_FqrsHw^gnM|#{o_lPeyGD5YJ
zo`g#ud2rD2vDd{tAGp`?$)j!;oYfHo=OMav)AwD%_>ptmeqYOXg9u_Lk2nm@Lcgy>
z^jLS))wA`AzjGNQ@ACGe-S_(Xi=8fg^sT<X$2P}Y`jOv6LkPLeuX8-w{bjd*dOeT-
z>ne`*_*b4|{EvRv*Sjz9^^U&P*Ejl0*0VAAg6rRrclrAEwY)k&*MgHdmmHk6E(mrY
zy7j7)F5&1${5Xui+~*(c9&-I3e>o-&!oluWc;4g3=V2t%cs_tVO@Z;3b2`AKV^1Y_
zUx6P8<EJUthV<vkr+S_%pFHzi`O#JK2Uf|SRr$H@gHHd*%c<8vFtUewhvUs-aO|ai
zevfW`wX+-T_VavvkjDkKG#(FNdl8r0i2c^Ke*A=Arrj<$3-w)v=+Te(`LK1U$7SgJ
zo0jEoarsAXbh}_<`(_t8`cd!C^U3K5Cx_h*`4_q)`y{8Ibyg6>k#%&A+dJz@XSnr%
zcifSkzFh95em;|4(s5+Y^VYT(I)i=f>sn|;jy&np_qDaOYyhA1@|-T>tz&-SXz07h
zl^<dKBint)>^OcK^EC>~(Obsc_<kGxaLnW09-Qs!Y0USr-~yzOJ{pm&*FEU+kA9fv
zInT>*o?k(#8uOgiHT)06?@yy13dbIq^Yh?@Umr%hi_Cs~814Rm<M9*z_&M0^?Z;2}
z<L6-ahh6@W6Mo&ubwBA?uM@@RSSL>UX%}pa(Ck6~9y#Red!wIcx$be#AM^Dd`KX__
zvd)gY$rTHZJa(>&jJy#8i9mBI_{;a-dRx>BJ=sSIIKKR_h4XV?+gsY)I&zKAf1o`G
z@E`N)F;|h*(H>mq439l>-1TeZgdd;L?gFzPztQfuJ03sb$LC<Tw;w;@$M0bGZ+cxP
zysljLdmQWb3THHKSGxW*{M&5&eErSGkIph!2j1u%a^~arh9=|p=!)@crU!>YaPmpl
zygRN2p!?_ve?IK;)7WR?XBUi-?Z%1{pN6v%*uNRu#n|M$e)NR*!_g1>@jgk55W>TJ
z+{tnL0D4LO-`M8;dh`kJ$D>bre;wPr;MzLYUH1Ez&inl>CAU9P^7HZJW3Kw(0n|@j
z-ned;OE|W<&gGZ<{*fB*7kOXh{VCp8+@AE%b%gjqU+0kilRPfxU+9_%u4(<ovww#4
z+#}y`<#TWSy4%z2r}cSsgRht72^Bs1M32kgxNcK`E~CFO{Pfpbv`#z?Bie6V*W&iX
z6dL8OaP_nYm%DV*P3zOfbzgM#THTH7D%Ri4`ny?wx7WXR-DRiy$O-R<T({Rfy5Y-b
zsK0~t`*|<N(dznJoPN<I=j~kgGp=1(w<JH;?T<@+d@sRY?ZFLh{KW29_j8ZWvF=}X
ze!TnH-}=R~&x*cWx1T3+olMt{8Em6mKiMsxC;zX<$*=1&UMJt^h9P(W?b3D7#uh$r
zZt(LW_tw94<EqE6gz*zS?QYekdG7r#^IzMS*`8Vo{qclvm#!aAcRefDLo_dGJlX?)
zo|Ef>^Y8NIWj&GWl9QZH^+Hl0*C$)obvhm4^}^os93Sz^1<pI?INsQPfiL$GUq7Aq
zsr{`7BEEcheY4(|-|p>lxA^(-G}<Nm@VaJQi?hRZjk}&b@)2(*{oL68{a?`a%#kO2
z`uTjFBl)6_uIEV4*0F#81+^IJ82YK>#&z3I9B*vz^g7%^=C5D8jvxE-p^hK<@;j+k
z_^0XhS<Tt)Yj5>B`1)*P+n0U+nOFG5_+#tn-~0CEx^(Y%eEXpvzU8>NAHLzshyDM$
zFTbiEPC2{ge)yv``r(VdAEIOE3%(!W_4DT)H}}KmeECqvXMFip{qVH2Tj_`Yu|_|9
z(zh@D-}?#Qe&~mfJ8tfWkNWaq|DW{bSM|e(oLzH2ylIVoc(3n==oosp??>o|cR6nE
zhj;k$p^mrt@~iscEzWMGA6~acKfK<zFa6(p%(ox<;i%*0ewgv)!~W-d`BnWe;q03G
z;pJ=e!<g@f=oos?_apSfu;b=_c(pGd>Ufnezp5YhIlGm9xOt6!xYxHY{ongi-+t(a
zgyZIZ*y+oM{lC+fU)2w{IlJb5h_2BO+kHPo$55~DN9cze95?sF^}c+lW0NnxsvoX)
zb}Ri5S)(5=@$F0h_g?JV5B=~0$IbolJYPQS{{_DMs(v`f*){jWkN<0J=jm485799c
z_<n?b_{D$G`L?+q{=?-r?x)lpuYMopC(drAAHL!Hf5zwOfAZ~1|M%8>`=K9x;JCRT
zzU#|}epvM7SM|fUoLzH2d~S_?_-o$}(J}N@-;dA_Uvb>r4`1@-LmhwN%ddJoeBRlu
z^utHj=!ZY??MwgnKJD8N{qV<*oBQDpeEG2dzwgVh>W7azyXJm)#~S@G=ldZ#hCb-~
z5&Gc+j+^_T=*x#X-sj7&>W6nZyOn;JS)(5czJ2Nc-naPnLq9z3xVax@efhBezv|1c
z>W8DwuDKsxy+%Jw`hJLxp~Jo(p&t%9ZtjNzzI>=7?aQy~hhb;8(hob==!XY<`_lit
z`+WPMAND$K?uXsJeAxf{eEC)VkZ^X*{c!yn{cyYQhv*o3k?%+7hg%#s_rnffKGf0g
z%dhH(8=T!rKRj=Zez?}RFa6(pwQoQ4!<CMk`{6QQKJ5Psefd@W@B(Mo+z<cp^R=C)
z&-MKf9YbgPeuRGLaNOJv?Y?}dW1TO*svmywb2|U8^uu?3|Ihe5{Zm&@ct2q8PaHSy
zYy6Aj=6?8*FCX^*hrax(e)xg2Ywm|Ht<ewP_WcO`@J-*3&<|C|&HeC<FCXgonlHbq
zAHL%3R{G%&*64>X`1Ym$dq3~n508fh$Ibol8DBo^|EGQVRsHbC&aSy1ifi=4@A-a+
zj-lW6{RsW=F~`mQ@PscP>Nw%cuj+>nIJ=d8m|deE-tF6${_lO4Z$I?II~_Oo!`poM
zu>ZgA%dhH($DLhsKO9)2A0F}j5FJB#-;dA_4>@k`hbdn^)RFb&SM|d|XSdQ1yVvN4
z2Yvg}|GmS${m>7ub==$!ukz)?{wIC;RsFEn*){jWjy3w>9^VhqG4vAOkI)ah95?sF
z9lm_1<Hf%Gs(!e|*{$@$Woz_9uWw)azxM{;e&~m-j+^^olP@3k|2kiORX<$m?3(+b
zeT{zT^8FAUL(lj92>o!8<K}+o^yNbx=lSxh`k}+wt@Oi>{?lD&obh=&@a;?g_x|EP
z>HOa~PygI;b3fEwe&c??&wTk+{qQf&uDKtc@jA}<`NKc@eu$2tfAIYX{qQ}<&HeEA
zzI^D1@A&eo`l0IVR{G&HYxKicef!e?y<hR|hsVQTId1NUzwqV5{{Oizzp5V=oLzH2
zJh4VUe9HGjbPPS^`w{x#4;?r6!zX?DP{${H`BnY!F=w~Z4{uweA3o^Ym;UelfNwwa
z!}}dK_rv>q`LO@*@#R<b!#kZ_b3aV2(GPF-{SX~PkNJLtet4tf=6-m+FCXeS=F6|@
zhliZqN<X}6jea=n+n4_DJ?PtKKRk^!$~`w6%((QEE1rv{efhBeqrUvAet503Ywm|T
zyp9w8xoCTk^!9DfckhjKwfX1fw1(pG^0Oz~DHa6hOTRgP>(CRf+(|G6dXDOzx6{ij
z2q&-hdwL(`yNK><`yFqu(&+*2Yx-e;a1zgVDO~<Mzo+Nmmm#{f*U!gX%)bvc8u9k+
z!Mk03)ZZ8RB2D{C`CEtHv7*0}KFa-V5B}LdPhRslylF+f&pi&0{*vP`<I3e?{=KHr
zh=0GMJ(zOoXFd*xR`mCD;~?+HycsVq(3@*r*l0dr=fZn=FYlF{i5<=NGqIzou$mn=
z|Nnirb7tgF^uBwBZg|Pyz0}x;e%Rv1g5tBdP@(Nhmk_zoN`0sI31~+%H5#IOEyo@6
zlumC$@}VVmNO7T+-V~vCzc5~H<mD(fdhdzCW^5FXV)Jj>1a2nqvbdryx|X^V8$yKI
z<YmUaW9ny+%WL&Vmy5e2k$gq{WG$4@dOrR1VVR9g3iP{;-iF<WP0GCrand<}?X}qG
zZRc5RW7ue3Enu6#=4LetJ%Tu;4<P;~>=DkR_h+O&L|b`@puA=M@NZI6a?rXFKaOKV
z+ig_-{n%s-PjEbneF+=A@j8I*4>&%E{im_f*bQS_z=jZc0e*bZMS~U^AF7u_EBWi|
z*f6GTG3@^io3!`O9FJm8V@2r$*e--9Y2#{+XOO;w<5|QLh<9V3$Mzb;Ux@uIwk+ZZ
z5t@24J}y3OI|hdD+US^l2jZ8KCBg}g4<P<Wh*Ljiv3-f-bBKQjafAr1z2Eb3_ulXT
zrTWksm6#cS*DCU8%xMg09`NgY!K)CbH;D(Z(LA8O&0-_pUyf}7+auV>_vGxK`L@ry
z!Xu?pXuaC+>E|-vL$8F^Yb9oET;s@t@7$cA{$0hk)Q@Yh4Pc}1Vj!G%9e((3xc#~0
zhbxgs<F*NV<ejq#aSp9p5Sd4M6!n)8|1{fD{^vN3yx=c5K7ja_IX;Z|H#t6w`1d$I
zhxii57ZCqH9A8Ad4I@B(p^lu(@hIY#a(n>sYdAiP_%_71!h9C-Ua?1gJH#GwSzm?`
zzk}0f5q~Mi=Mdk+@dd<R$?-+R$2d-&nZULUZAGy^%JDhuAHzm{j>2K@<oE#M@8|e1
zJCfG6S;U`2I?dk&#D9-%Xo5Y(@hIXHda(^4{#j0+<#Z$?#kWaSH<Fj9bF%@4rX9y{
z@I{pBp@NOjO6vjzu{i}Behu4aU~0XbW3V|FLlXQAY_7-t8`vZ59KL)Dkmr_M$={C-
z&|2_1-;r}}MEuL>EQ+<!+W0q!$FZmIO^#FlzK8hD*biglfFl0<LRGED_CwepL};B$
zBLU}u$LUx+h&Z*0&^F0&lxcgI<1`M(5U2V(u|3A|DB^G7IQ8M3Y(IcF&0(rDf$iN$
zzZH8Lx8Fvbt}}+QeTd_;h<^le1lPC!$#I$=pTZBkf9v}BS;VOi6u!W5>d%)Dr#hq9
zzQXYV#J`R>X&r`^Z*qJL@xSMI2Cn!X$Hx)>M~=S^@gH*hAmTsf_#wo9!tuk1|2xOA
zX0-e#$0reg7IErl7Mp0FMSML5lG2Z3D`0`6F{ZI?ri<1MvX5eudU_D2VCU5(Sd?g9
zz1U~3$Un;YcQncW8t31I{OkO6jGRYMtqX2G?Lw616HVGJ-tN4+5f>vwTkpXS4jW#I
z$PU=SzK!O>ZHUWxXeZ(rs$c-y`>|1c7~2Vs&thM~Mn0UwCg<gO#9xZCFT;KT+XINx
zTpK_q<XlSU%TFVX(gzVAXPYGAlZZoZFpPM3E=4?#bn;0j@@P&`e<(bTbc#o@y`AF&
zi2o+XhY>F#j&L4nL{-6uz}UM>rF$s{fqeZW(lL-O9rM}+^68Zvk6}+61?tDgRXs0p
zsebJL(6{HhxS-;}_{4OOO5L$%&mFH!?Y-w!yHZ219Nd*k1&2qnFH0W{vQz2(<M~7B
ziC}DGdIXj;+xvo<iQM>siS$_17oLeXQbsc)Q^EAnY&tlI(hrRsnn_btsr`pW4&)Ha
zr_vMCQ{(AekR6|x7@s&0Or@vCCq`2H#}7@Xr-ISx)I<F#Dw~@cO^s)RvD`H6h_aJY
z(~eyvJ2g2yNge9l(P%!GAsbXetsD)~4~>sbk55jdrpFJbgF_>zYbs5pQ`7m>*!a}4
zq$!^?JvFj_|M)0nr(NN|^*xnKr%{i$Q7K$%Jl80YnwdB_G5PRBFgiJbZj6i`OdU>7
zkGKJRaB}ickh+t8hPjQ*qtoeJYX9Wa!y{8;snN+9_~t>EhF%{!$|+e?n4Y$FlBz8+
zI6L|qgL7zd;y{#s$e4#ckOW^zc4R7-o=T-3!XV~?@$AUh7)EMx^59H1*fyQcPY2s>
z*tYEk@39+FqwvIm8<x3o+h`Ewkei;G8J&*$=@f-yqqjwmg}LMVqp=6G`%^SUd<&`c
zq4eR{wacp861^4$H*LZ<K~kyQ!PJ8@`}YSlC$k6PNt$ejN2U%2M`qG9X{riS>i}jh
z=Eo?;`JqE26DiE&9OQVI9vzodnnT&C@yV(2>7zIn4!|sz8s9%YF_z8;vY*CGbP1ym
z2APpuCP2a{W>ao_%pDe(ZDYa2NOnAhg#9Cj#}6IFh#sDtPGjo!W9UXl4!KyExFby5
zA(n1Zds9EralE;C6HMo(M-FF$hcO{jr20T^60;G9lZ%W$lEw_3e3%ZJT#!46{|^S}
zP<9eWC;IIr$>HUCy?>nCYfJ)mq@DxtV~3j!F;u!Gy8F((yY{@|j-h*Y-=7-Xeb4<v
zsk`^=zAv@w{+*6C-5PYjZ!=R9(V@Ficic6U+IRon!CiOV8caTj<DF(z04dYsqtS;Z
z$H$^vv!5WLW22j0TbR4?D9UXLI#O^rR)_Hk49DSIdOCJ(c1yHpOEd@Rllx=YP1JC9
z+jMFommbCRq6u}7j`-Ap^mGbG9OcBk5o%0NJ%m1BQE(#!d!*eO^xV=zmAJzVY3Re&
z+cDUbfd!_+b$Bx!!ZdI&i20OFv2ZaA53fzGu-Lj9ZqzlLX=$jU<AW-SUN36-cuG%a
zGGkMlqPIt-olSvH3o@y(bZ#2E+~myEXc`e&Dj!TkO3y8QzFr!piRsBqE{1|zZ)dYj
z(JO9??ixy@22=M8V(?e(f$iCNc16crQZSyuv6!C9Vd#VD$sD$6H=XI2nHo8en#4gp
zJ&koSlODw^cB{^q`-!<Ra~NI6L`dWG({szs<SKuHz+jGNx8Cl|-B3F>`m+Y-xk@PS
zCMxCzgL7n!z(_lxSNJt3CY5iBUVCk{k?3p1I^>M0S*aj;+ilT%1_$@-9@?E6x{Jo`
zmmWAfp3|c%2h^tp>|p2aT>3~rXBygL5$g@cXgsly1-YXW!4xJ$77G_Ff|;oUK^pU7
z^x-M2DHCIp4^vVqJ3WP7d*!qMVTjNSM%K+DH?%IF20`aj>y(Rw1f|`X5k+IJESitL
z=ta?<P0>d=1)ZUk-bM<#Mk#%b6m*nQwl`AHZA$5Hq@c%?a$_R}k|<?IBLxB}<t7~Y
zJ-5WM_4d*ann1nV(OYyeJTY&>xP^+-N2tUK6B^!$nZshnqfK)Mi;t?y8-!I;T{!;T
zf<|VU^vD?2Uo0-(5XT<*in`jzhrBU+5!NHW*74Dgd^*TB;Y{l0S<F?wc@w2$sp!SB
zAW7l!K(@}9Dxb{K3Ybfc&P<WxO&PYJmCofp`Y26>RSGR{2o0nTVsb&^=F^m=LCZZn
zK0TU=#>CXA>3FU__CePf_l=BCKL{Ni)TAH(%`{O@r;JV)+!?WUlaxl$_fh&y$9|j^
z3b6zCV#<5V=Nj^!wdm<3>t=#FHc#hpv5nD|RsB$GGZ}C1i*DZ3L}Q;jagrRAPLEEl
zt@I8qy~^D0NFU0jqjVN&wqEYriS=@3jAk^(cG&`i)W!ltd1~=-d4BQH3s3K@{^~Tm
zwv`LiFo7>lS6)@%0!m+3@Ua$tA|btWQ46!ixrh4aKBzSE!gCMue7un-A7e1oT#}a3
zM!wR=rI+W+$qSh->Pt3y>OS^FH~XER49zaB!|~v&YhM*P%9W=1OKK^gHGIBtpDfVv
z{Uh+Gx8}?hADLj~D%pDbiY#BytyhhcCynVcMN~0gN~Yide5{)}G$x<j{1vM2<`(Ll
zJLznR;(~MVj=NsAYbdqzo;|6d<T7DsaYug?AIo@_AD*0;OabY-kXrM{%CZlPu-voj
zj-9F9_usY4x3=~6Wd>Z7#*8Yy9jf&Q&M4N+SVQEpD+F3E{JHYlXbe{jsk`sFA16tQ
z?b$oD$t~^FEei4hX$&8Y@R4HK2PEZ1jA5w7UNBGL!yGQZ=`+HaOmSr{^BaTVoTO*;
zGP7{nJ2QPyEHhI_Kv-X6jxRG+2SZqA6H_@ZoSix{)_NeQ_IWJH0n6t<KCh_h|KFUY
zduWy}Z?&U?9G*>2?e`zSQ<F2(*_mno5llW9>rZL?NqtN7&cVA=cc<>!w`b2Td^Wpl
za3AW%M<x9^iR7p*XGSK*4y98Q>4$N1VPeAH@Q9%d2677w)vQ_Z$w|$ASo3xDwaYGp
zc@3chL=MyFwQiE{edYbK!mM0~sXOl0(dp-^U!PR-IPg(lYUrN(cJ1Cbgwy0cd^X+Q
zm%8tcWOOSX^U_pU@wU_5ufY^oYg@xs-R<%Be_$wb{NmBDUA_R^<`$gmX=PF!^kryJ
zR*WfKORVxKn^u)GEQb#x_wO2dVE3Mv$pE}Q8lH~Nybk$%zlN6GeSzj}pKiX;Wq_J5
z7_z%|-+%wEyWHJ|d+)h>7r8fe|L*&-MxK$2SKjV}-!K`@*k#SzZ+NgtH_x<>O{QUE
zi8+Irb-He%ecwmS(-o&+8U{JSwynsu!?VHw#p#?(_f}Tqt(?*7FqLD5mjIlq#o@Fn
zHM*o7=WnlS$1S&2$7X0M?RX{2?RDMZ!5mJC<+iHs(6muET{oZhvjc7@`HvTkS<>Vp
zK+C7);Fp?A)aM8G+%vSR`E|;c#xm4ovS=^yeN%HwW5opv7Bs$K*|+B<9NTr*E{@&x
zz@G3LhNSsx9o$-Sx6wUeA*0Kttx@F^x`@Is?AbNAd(Th`%Q)R|yjKs@>GiJg)fRtw
z#lol%g_Q%P+UC3aZnRXn=kUy`tI_G(Ty~OJ#W}tS)t%E<sr38f;Fr-aCFzWLYvUer
zdevLV-U4^m=pJvgd&M{#$(aPTXC~>vPSd;7I(wCRmz`_4;-+18^`2>W<pg#s?n&aY
zRw{L9d^C-l%($0Lk6;3S$Jsxk!83uz-6Xo<z5F(_e~1*w$0)K6AN%lqCEVx7MGt=B
zqc|Sg%;eHz!L|o;xnLVU!sP;Kn=TF;_xp)*lenvgK<}7E`I+CVv8Qbdet%5?+uQMQ
zk)9{^;2AOgyRaEQGuU=u`!OCe(sM`(Fc13t^IgXS`1uaScY^;x@lG&3d!)MK?x`>8
zMEsT5E=2=T<Pl4t=as|{V>|az{|uM-lh|4czE5Z4!D^Ns99LU{S?q|Pz}EWxmVn-o
zA+BIMcd5la(-l4&e2Vjbg#72%TY@U{xp<%9f}ghpi;6dZYs}XnzrU?Ds56g)dm_{+
z-`)qoXX6*Kbt+yDrr$|M?f(q<>tn4!)NqVBiuV+*dQq!;?o9T?>%sKwnYawTAkpfc
zKMS7?rf1N^&rtrot?oIr@Y&!j=l>Y_orA4GUhxL-ELi(vj`O9x66cFQDx4p|)8dQA
zT7y%je2p2y<N}6#nLj%*WYj+@e-_Hq@2(@>0p9R9#z*mbFow+KCy{^a@zx-&_$)An
zz~!G8!S84I0LDl0dEg}THp-vF_$WRPoMFBf`OjOxcqqOGTu{6TTvU81cuw(6;F987
z!DYoafbrk;m)g4rP*HpzxT^RL@S@^h0oN3#z;(rY!Sq4^jVINA7#vZ21WdmhQ1a8@
zsNy$(V~QUG(=jXd4}%93zYCmD{9bTU@vno26`u{xF#iYocL~I2nJ>kQmY3tjwOQt!
z;EPUSyqU+rmpz4dHxze)%gppEZ`Xer?{F~xDfoFyK|t?QQU8h8gBO{91il0Z<C5Z=
z!SvDw*}noWdz{zP640yR#7DvF;&@M&S>|`l<j0xc3HwXOT7m(^+rdfZe?|WJ(=EZU
z;&Z{Yu2Fk0#0ym&kG2GP!?VoWk^cfL+y%wm;Nyxrz(wZQ!2YuLv;-x^H-Z<K{|x!(
zKiT5eO=`ad?-ZSngZ~ugzZksn`<Rc+l3z3VOUzPV-Q-7TokZFQ)xU)GQt{c~9_Dva
zdzid&#pi(sn17G*&si5F6rTr9GXFX9&%S6~kO4n~_|LGlKiVE-nQy>LL>p(@gS_HS
zF#bFHmr?%X?Lk3tC-^w?0pz~`nMK7Hg6Eijjq=~#9+VVc2%cyD81gSdWo5<ZgDcE3
zzfLj#DeNypV@u5E;03;pC)<NM^QGX8p8#N;C%w0TubXcVB8o2qcQWUY-#ykAbTPjh
zyd90vd56mX1NeeWTM%Pz$6H319BK=Cn5BOM#y-J30Q<|HYzu}JUk}bGz6E@o`2(=;
z_(WSU$Nbme_U~i-m@mXdMD!Ca!Mx&&!E~OY{@zUa^O(<yF9uhbhmn8fQ<%?+F9BDX
z-$wamoc|SH0<JNC3i+3R2J405E-<~!MeR$V^BVEDV1F*06=Qb(`gwa0XTB6KY;DAE
zg&kma{)(&*5{fSa4>F6t=sf83qWt#Q`e2w@{FPxAe`T4af3wEEz%2fnQ%wFUDJFlN
zVitc@nWg?Zn2zr-V4Wv^H~PB{FZ0Hk-SyntaXf=b&l2*_i9-+b?Rd%id6BjttGEN4
zH})mw5!jy-TNlhLz7V{ixC2~eego{=qc~sUJV5Qc@w*!5L*~ySziSKDBgGxyIP*Ut
z|LOsp51F5jFA!Wo*K5pof-jHbdPMQ1;0*Ia$iMyDSihNn2)+{6uk*|YF2eEI*%p))
zcY>?TuK!Qs{Lk$AkBg5koL5NCyHNhRd7RG`cYu4CslV6ad>mJN1$cn@D=2^E7odmv
zr{K#!13ii_1!tH;J<OpVW|<FlX4n6F*9B3Wcf#=>#C%|mZ^ZcGVq#En2Y8tI2<2z6
zzB7LSeEFeuL0<8t;N#5Fzj<cqUsds482?4)Z==5M>2*Pk`69eHdIc_4mYC^RnqNp4
zD;R6)KXC^*!u%%iwV2<X%%22bQ-EHRA7}nMvY&^3<_-8_$TgpUev?1UEaRCqJO`%Z
z?G}`OA=amo;)}rx%yRuxRZQ1EOU!cpQ)iazp9s!FRKHx`bSb9mn;vGlzKJWQ>zf3#
zT;B{DPBP2&&9Gv+zR4=4>zh2Y=$%zedXF=U-Z{mjx6CYh7nnuwDQ3~TsF?KDnME&s
z>4?UMnDllsi{387QD)IgU&W*H#H6=JG3kvni{1gnq<4^6^bRW~y?JKQJIgG3k28zj
zImM*6%q)5r6qDXl%%Znyc#&E3))bT8x?<8xZ#V1t98pYqyO>39Ofl)D^BR>Gy$NQ~
zn`9Qf8O5Y`mRa-`6qDW}v*?{OTw)fz^NLAtSuyEdU>5&Y6qDX6v*@iUCcSjCMeB_)
zi{36~(Hm1tdIy+AZ$dHYO)`sKx~`)3gfq;dH>;TR&MGFo1!mEETrugLV-~&hib-#U
zS^Rs7S@bS4i{2&0q&I@=4(h+??Nm&9qs*c&X1Ir0^u`sF-T}p=H^D4=2NjdvVP?^r
zRZMyd%%b-=v*?{;7QOR|NpFQ&^qx{odKZ~RZ_V%$v*@iWCcP0{7twf9KI!db7QJ1H
zNpFl<^u`sF-a%&3n`9Qf8D`O&S4?`3GmGA$V$xe;7QOR^%gmy8K{4sAC?>t9m_=_@
zG3l)_i{83o(%XsaGJX7ZF^k?9v*?X0CcT5qqBp6S^k$evZ`N?0S@g~-CcVcMlinh;
z=$%tcdgqx%?}B2|TV)piE;5VWC1%k}U-+c)Att?D%%V4{nDq8Ai{7~50cO#gP)vFU
z6_eg1v*;aGOnS4-qIXs?=`Avg-Z^H`JI^e77Zj7;DzoTaR7`r8m_={hF#d2@czn|R
zBl?pva=en>F2$rb$}D<gib*eBr&D>+n@~)8hnYohhFSFHnMH3wG3lLS7QH3Kq_@m0
zdKU~=n8m-R6qDYnV$!?FEP88-NpGE5^wO6MML+3{GK=0Av*?X8i{6A{(mTv7dNYbi
zZ=PB7&KfQ-i{9gkN$;Fu(pzE{z4MAm?*g;vJ*AlR)|f@_60_(H@Hs?|SGphCshIS}
zm_=`oV$wUnEP4}$2bo20QZeZrR!n*`%%V4|nDovvi{9gkNpFc+^v*Mj-UVjy?<vKk
zx5g}bmlTs;`Vu>hm*|Zc?qn9dU5ZI>Ofl*0VHUk{#iTdEEP9iQNpF@}^yZmGZ-H6#
z78R4;d1ldDR!n*;%%b;{;VQG}T~thZYl=zl60_*7D<-{>iyOx)-T&`WOnQ5mMQ@y0
z^d^`^Z&ESo%`%JLykgQ@U>3c{4Hub3@0?=NJFl4ZmYGHGf@0Epidp=-sF?KDnME&s
znU&_B=<Q?{y-~%aH_j}22NaXuL1xjLG(5~KdNYbiZ&oqs%`=PMS;eIHIJ4-TQ%rix
z%%XRJS@fP_7QKs#NpGE5^al98ER7d2>Fs0|y<LW*%%V4@nDoXKlimSl(VI|AdXvne
zH=~&J&N7SM0<-9)?;7j%xulr%E-;JUiel1RWfr}QhHK2CcS$kntt%$I^vg)7KcY9H
znDllri{6-G(mTK`dK1i|H_0si%_t_lv&^EmpqTU)nMLoM;S#gxomWhH7Zj7;3bW`v
zrI_?CGK=0N#iTcaFTm4yiQZ0T(HmtJy*-LaZ-QC$4k{+S!_1;LV>rt!dh?1&@2q0d
zTVNKw#}$*_IcCv2ubA{!m__d?X3@LIEP9s|lV18IG;+Ms^Vd$rq&LbedSixrm_=_~
zG3iYxCcT5qqBp6S^k$evZ(cF!J<cq8i_D_8#4LKtib?M&X7O)TG3l)_i{2%}b!O2^
zzgUOHkC^mE6qDXgX3^WFnDoY&MQ>a&=^bPiy-8-#n_(8cdBvpnIJ4+2Dki-pX3;xu
zxXdhi7Zj7;Q;JD%m09#IDki;4%%V4l`tc(sy<N<rH_9w}dzeM<fMU{{WEQ={ib-#l
zS@h-&&oYbNf@0EpTrue_GK=0h#iVzhS@bR_CcRZ=(YwejdY70*Z*YYlFJjW$#VmTG
zib-z|v*?W*9$*%|3B{y0shIQ*GmGAgV$z#u7QF?<q<4;4^p==KZ<$&2Ruq%oMP|`k
zQ%rj6%%V5A(vO#Lgjw`<Dki;Mib-#jS@gyflioP9=uIdly~E6+H^VG?^UR{RpqTW|
zF^k@kV$xe?7JUnbE6k$zlw#7msF?KDm__fBV$vI2)i_@1^FpU$(i>wIy*<pLcYs;+
z4k{+S8D`O&RZMzknMH5G@Ns6*TU1PX=M<CP60_)?S4?^rn8m-R6qDW>v*=x77QMmM
zjpNmQ-d9X|W6YwrM=|LgU>3az!-LGCH>sHPW)zd&EVJm%D<-`KX3<+zOnT>;MQ@o|
z^j4U~zg5MgcZpf_))kZ9$TiE4*G|J-%%V4{nDoXJlinU?(HmDxdK1i|H>sHPW|>8A
zo>}x3m_=_<G3lLW7QJP~q_@H>{yk;5$}D;p6_eg2#iX~+EP8`${df|S-cDxG8&ynt
z<IJLWfLZhoGK=0}#iTdSEP7`ZliuUZqPJ*xj#>1U6qDY0#iX~)EP59dlipLzqIXd-
z>8&%1-rzbvUZS^?S@cE~lioP9=p9f@dIy<BZ_@BEv*^tzCcSyZq<5BC^cED8-XgQ;
zEh#3w3(TUo!Yq2L%%ZoZnDo*w(9)k5B8o|G7qjS%8jdlG-X6uIH?ElU4ls+}gksX0
zWEQ;{#iVzZS@af|MQ@Q=^p+Hp-UVjyZ$&Zbtul+=MZ+~_(YvIW^ah*!cv3#;jWCPe
zPQ|1*$}D<&6qDWrv*^XI3vm7ty~E6+H>;TR7MMlvamA!}j#>1U49_!*-m+rSyP%l#
zR+vTaDaE9Bky-REDJH#<&0e4A?P3<aQD)KGqnPw2m__fPV$wUzEP6ABv&^D5ubA`}
z6qDZL%%XP=Oz%s*7VC2dUOp}}zY!d(;Qd0y=Yp%upCkKc+T1U`r1BeZU-yat@3&s>
z>l+52e^GnTrT9|t0Q1L@f9?z0g9P*Uh@<U6hWV0<QT4amf?37qf(y*Qg8Yse-iKtC
z{x2{~|Er3r|BKAh|Hu~KU+I4*v-CfznEIb!{y5q{H`X2uGJlVF3*KjDmi`wMQ~!@M
zOaJM+JgtEbw60x&t+j;r)R08Hn;7q*(RX~b-F?KTj9qn|`|gjn`v}=B8N2#A_njbZ
z_j9tt`;5!l?eg3ML%7F%HwWDhI@*1IYuFKA$y{e1WA4K8aud@2l{o>v1^m={{6I)D
zf0a4Q{6pq0v`hBF3Gi)TX+O!lIYPDJyGYCl=2>PbKgax!oWH;<{aIv|{siz1wf94|
zk1{VY4>13f8LvM&d(oR^zPQ76&wY1->Ps_6FfLkO5BPTEi@pJ7(dTP9{m*p)I&T8K
z>rb<0*rXG#3tZ;1oZB(}t@xMWRGRA){?b*AcT-uXPYr_q4SOm<e$wFv=Wl%1#qAq8
z^j!qkACvCO<GVQLG;AsMW{e-%(>s(pe39Fw?^5XSQBJ3K)^+$Crx#5655yj8nhsc2
z5b)ifvvew6EoWWyj<gQvb9%+t(|0qd9$KSxxQWx3jQy{2f9RcK9UkKJr42eY2;Rr(
zWt09EPA{5zJ|*=V`@iM%l1YCB`@Lw=zsmj37{7dy>!Ejcb-;3l0RNiw|Hbz7&aVzH
z;PIq)admi>+Z{IPKjnJp-BKMM<aX(uR2}H|SyO-L-Ao<6$o0of`i*Sgg?IaO_%PcC
zCjA1or*{K&_*J&2cM5g*5sx#yTc^XT*q+|W)8S9qp59H<VH?}iJ8e4r4%^4@Zj%lh
z*uK-GA7y)bH%f;eur7M1N{9Q{p586e;qz=y?<DEa$M*DYjt(DUdwQowhx6G!j(0tD
zc$Dp<CVi08>D>?=KFfOPoe~|kusyw7p~G*pJ-w5mLxk<=-2@$G*q+{L&;ei5LcqKG
zbP`qJ<!s+$(#vd5&&GAQhVAK@x(@GQdwRC4Lkru}Gie>NY){W-b@&eJqG!4~>|}d-
zwyDFPusuB!)nOCc)3ZSx-pBTVNng+Q^lVLs9NW_~IUQcY>GW($ho@LCJ=4<RDz>L*
zJ31U^dwM3M!?WBUdN!g1zHWtp@5q_-Z?Qc+ThJlF_Vi3bhu>#=x;L-G3)#MC(%;7R
zbZ=V+T*e{b{BF_@usz)y*5MhpkDByb**>^RTjTE>usz+A)gj9EbZ=6Jcd$L()70U=
zczvdOdpf+1?dhJN4!3i9;u@WbzYW0S(__-R*}n7I<@UeE_H<85ho5o(>E4VEqij$2
zbaeO{+ta-b9bU}#bWcQwkFq`88_?l-Y)|(Tba)fnM>pwI|2=>5Z^Wd(mhI`YsSba|
z<3OKjb@&FiOP~F8xSY?kNppSj8|<%$NvH4JQ-A0)oDLIgKfFb!;_styI(??n;e(tm
z*OxkPU0^QKI1}IG(Pm+Mo%=2DA-V{C?zj;Bl#t=b2BcpQG%g-`IK6`Xh3a}(+;chG
zi=Cv?@=Nt3xxAd7f8y$C^k3|sa_JGaZu}1TMVH>VxDxxFuHD8(i^T4C>5YpMsZq)y
z+x-n0d`;K|;U&ZPT4|X72x1Yw4ka^Ux$YH?a6`n$u;qCO!+fMsASIM0{W?>o@4!)@
zX*!FIzT-xLIFD^eG4*d)vFnfGHy~f88<nU2^kbtSywjs&I%I|vPa{62cm{Dwqd?^!
z!d4(akot-qLoOLE8?G3x8m<|x8;+1D1Zkh<yXKhTxMBJnuI=e_xaN%Eyy1f3qT!O^
zvf+y1s^Oa9y5R^P+M#~KF~f1gbRR+MO&X^A2s%G+xL~+wxMa9&xMH|!xMsL+*k6At
z|GRa+!7;;e!wJJl!x_VQ!v(`d!zIII!xh6-!!^To!x3^kLg;_PF~f1g{<^GDK56nZ
zhVzCChUGp4CDT+bnf$Whis7o^n&G-(xvxUW)Ls{_=fb!x>4I?FaKdoXaK>=naKUiV
zaLI7laK&)daLsVtFusPrOdtKu1PY=TU&CL<_!|2%P8d!a&KS-cE*LHvE*UNxt{AQw
zt{JWymh-jf?c(#daLjPraKdoXaK>=naKUiVaLI7laK&)daLsVtuw0Lb-mb`U|Hcf<
zeM_;I`@_OXW1lgcH(W4WG+Z)VHe4}WHC!`XHyr6$uD8o@%y8Ur!f?`X#&F(n!En)V
z$#B_l#c<Vd&2ZgtL|yN>_0Mq3F#S#i3gT~leM#k$CO>01Z@6Gs?vG0SC6iw^TrpfV
zTr*rZ?Ec87($mHFPo@2s;ke<1;iTb=;k@C3;iBP^;j-b1;i}=9;kse^oemU4Z<pbi
zVY!bi_6d`pG%WYE#a=$|2p5cf(QwId*>J^h)o{&l-7x*mhh_Q=^Pf=;$0u&`>32Tp
z@=3!P!*c&T)Nk^OhD(OahAW1vhHHlFh9mqDSo+gtnE!loL%+#S7)~0_7|t6m7%mzv
z87>>H7_J(w8Lk_S@biOEzu}nSxZ#B1q~VO=yy1f3qT!O^vf+y1s^Oa9y5R`la0&Gr
zjv0;{P8g=&p`ee4jN!cDg5jd!lHs!9is7o^n&G<P2tVHm^&5^Err&{}^~v)gDW5d?
z8N+$Q1;a(dCBtRI6~k4-HN$no5q|z8{qHg?&$%Q&Zt@d`lZG>f^M(tCi-t>v%Z4k4
ztA=Za>xLuzJWcd<8K&P!p#2>;oG_d;Ouv&rm(Lq67%mzv87>>H7_J(w8Lk_ST(rD@
zU4~<Z<A&*X3TS=uyivw8WAgKc3x<n^ONPsaD~79vYliEFBmDeQ`rBnVW>}t^ihaW5
zCk<x|=M5JO7Y&yTmkn18R}I$;*9}Mbd93K^G8{8Z-|^S}P8d!a&KRce`0Mfo!$rd-
z!)3!2!&SpI!*#<Ee!d*)Hykq@H=Hm`-_h6l<oUJKpEvmh!$rd-!)3!2!&SpI!*#=v
zuI2shG8{7;H!RQLMPJh7XAI{J7Yr8-mkgH;R}5DT*9_MU%X<OR|1N&MFB~%*H=Hn>
zG@LP<H(W4WG+Z)VHe4}WHC!`XHyq*j6GU&9;h5pL;e_F&VfxOyJ|5(K2x+fi@{5K`
zhRcR4hO35ahU<nS{Jw?sr^|56aNKahu)NnH^<_+c-f+Qi(QwId*>J^h)o{&l-Ef58
z2a*2DdnUp$lOH#nFq|};F`PGCFkCcTGF&!XF<doVGh8<u;rClaZ<pbi;ke<1;iTb=
zVfqfaJ{}5&i-t>v%Z4k4tA=Za>xLuzzD}s$aLjPraKdoXu)HTE_2*4~!En)V$#B_l
z#c<Vd&2Zgtgx@EU{&g9a_m(6-Zt@d`lZG>f^M(tCi-t>v%Z4k4tA=Za>xLuI<@2%2
zaLjPraKdoXaK>=naKUiVaLI7laK&)daLsVtaO8@>1@Ui};h5pL;e_F&;f!H<?@Zb&
znEayQlHs!9is7o^n&G<P$dyLF;h1504^H}@F!@Qt8N+$Q1;a(dCBtRI6~k4-HN$no
zk*kb;!!g5g!wJJl!x_VQ!v(`d!zIII!xh6-!!^To!;!0ve#0@tal;A2Ny8b#dBX+6
zMZ+b-Wy2N2Rl_yIb;FTsjDEv0!*Rp%US%7qX~C8>`5D7`!v(`d!zIII!xh6-!!^To
z!;x!^e#0@tal;A2Ny8b#dBX+6MZ+b-Wy2N2Rl_yIb;FVCjDEv0!*Rn2!%4##!+FC6
z!}4CN%%_scFB`5Ht{Scxt{aZTjDEv0!*Rn2!}6Z4^gm<r^M(tCi-t>v%Z4k4tA=Za
z>xSihVCiqyrsd-iGaNUZFq|};F`PGCFkCcTGF&!XF<doVGh8=J-?^m_>NgxS95<XW
zoHU#<oHtxBTr^xVTsB-WTs2%XTsJK5WrzB&Up^i&!*Rn2!}9*O)R!^&dBX+6MZ+b-
zWy2N2Rl_yIb;FS@%k_2{jv0;{miNv@Z_?yv4Cf6O3>OWT43`a83|9@;4A%`uwi^A0
zV}|2~6NZz9Gluhq3x<n^ONPsaD~79vYliEFBioFA!!g5g!wJJl!x_VQ!v(`d!zIII
z!xh6-!!^To!;u?|e#0@tal;A2Ny8b#dBX+6MZ+b-Wy2N2Rl_yIb;FS!qu+4MaNKah
zaMEzbaNcmiaM5tdaM^IhaMf_laNTgE*XTDKGaNUZFq|};F`PGCFkCcTGF&!XF<doV
zGh8<u=`;Eb#|*~}Ck!VIXAI{J7Yr8-mkgH;R}5DT*9_MUN46XNhGT}~h7*R9hBJoq
zh6{#^hD(OahAW1vhHHlFhCBNk`qv>EH5^wwjr@e+VZ}4Z&l;w`!ApUz4<5o+H2joe
z`uzL_!_OH0zTtl}+;$@>L6GZ_iws|FxZm(j!$XG03{M+=-0*u0KWX?W!(TA`jN$Ja
z{x`#IJB)tAR~vq;<t;70)>3GBQ_HWnJl^u=mSEdd`p~xNbbi{$?i{*%8^Kh1dVFFe
z<^KS*`*YV*sq{nXiD~?qW|SDkpA*lG?;lT3rI!5#Ym=9r7|TwMPlSH}`?O{GuT(cH
zD%p*{5UpEG?H@lhot|p^5pVOSw$<OkUSYcYk7u)DuJ6#~<iVM&48!Q;#KiOz{(g0^
z?a-lz4yQ)O#-?)P2k`f?@pr)0-^-T2W}Ta!njU#D*p@qb*zIYIF|xtEci!2Ty6I-W
z-@*GEdEd|b?UEn&b~p0AkM}p-#N~P4$NOI1-?W4Cd4D7Cw+s91n{V{{?GoveNUucV
zVj__~iS$Zj`%P@qCy`!>?BJY!iENihpG0~k(to2gC6PXf^h%_^Uu-1OCy`!>Y?n4A
zvRxv566uvlf1lJRkv@s^N~FJ6Y$VbrkzR@P_lS)|`XtgTk(>KvusPBvDZLWG%Il`b
zc8T;!q*o$0iHSt|B+@I9{vBc?kv@s^N~Hfrv5`ohM0zFC-!C>2>61vWM7Fa@zeKi6
zq)#Hf66x=g`XtgPkzR@P_lk`~`XtgTk^UaBkw~9JdL<Iy?nko!CXU?5`|Z5%bNilD
zpSO$izMuEoCB4_@-^lxZ-uLk}rC)h}xu5%R@}u*w4dt)+l$+X@=g_%Q2g;_j^*Ryp
z0p@xB+$-4;iSVAvc3>M|mR<RMJ~qn<7h&IuP0Dw2`d;i$*ZvZ>%eURwx=~&db|Z4S
z_T#_hEu<Z4pU&;J{og>^>Duq&&%3L&|5lVgUHggCv`=Gf+rOzv`vYg#K3$fbuKna`
z+NZW{`?)6VXU?$w$tLY*PSgH|)3pCdZr{$~<J^7*`8r7dCGBoFkNjuL%l(RT#gO-8
ztHbXCs7_lx!k_nTdzQz!eO)KTrThp#H;{aqgF2*9{&fD!^Y{(2G0oreu}S+fuPM!H
zq9TWe=qJ8+&)039{4pSL+MkW>bnRET{YAb`r1mesX4~&U<LmBymZrfhwlI{w;-k_}
g$*_HW4H9Twuwjl4EQGFe{GQ4^j7{3-*YSe?3r$1Qz5oCK

literal 0
HcmV?d00001


From 2b3c782812d2f031705e416160c7bfdf9d8f412b Mon Sep 17 00:00:00 2001
From: beegiik <kbeegii@gmail.com>
Date: Wed, 8 Jan 2025 12:39:24 +0000
Subject: [PATCH 02/11] WIP 2

---
 cmd/legacy/daemon.go | 131 +++++++++++++++++++++++--------------------
 1 file changed, 71 insertions(+), 60 deletions(-)

diff --git a/cmd/legacy/daemon.go b/cmd/legacy/daemon.go
index 47fdbf1e6e..44d77cdb0e 100644
--- a/cmd/legacy/daemon.go
+++ b/cmd/legacy/daemon.go
@@ -104,7 +104,7 @@ func (d *Daemon) Start() error {
 	} else {
 		cfg, err = kcfg.GetConfig()
 		if err != nil {
-			fmt.Println("Falling back to standalone mode")
+			fmt.Println("KUBECONFIG not set. Falling back to standalone mode")
 			cfg = nil
 		}
 	}
@@ -209,36 +209,44 @@ func (d *Daemon) Start() error {
 		}
 	}
 
-	mgr, err := crmgr.New(cfg, mgrOption)
-	if err != nil {
-		mainLogger.Error("Unable to start manager", zap.Error(err))
-		return fmt.Errorf("creating controller-runtime manager: %w", err)
-	}
+	// Setup RetinaEndpoint controller.
+	// TODO(mainred): This is to temporarily create a cache and pubsub for RetinaEndpoint, need to refactor this.
+	ctx := ctrl.SetupSignalHandler()
+	ctrl.SetLogger(zapr.NewLogger(zl.Logger.Named("controller-runtime")))
 
-	//+kubebuilder:scaffold:builder
+	var cl *kubernetes.Clientset
+	var mgr crmgr.Manager
+	if cfg != nil {
+		mgr, err := crmgr.New(cfg, mgrOption)
+		if err != nil {
+			mainLogger.Error("Unable to start manager", zap.Error(err))
+			return fmt.Errorf("creating controller-runtime manager: %w", err)
+		}
 
-	if healthCheckErr := mgr.AddHealthzCheck("healthz", healthz.Ping); healthCheckErr != nil {
-		mainLogger.Fatal("Unable to set up health check", zap.Error(healthCheckErr))
-	}
-	if addReadyCheckErr := mgr.AddReadyzCheck("readyz", healthz.Ping); addReadyCheckErr != nil {
-		mainLogger.Fatal("Unable to set up ready check", zap.Error(addReadyCheckErr))
-	}
+		//+kubebuilder:scaffold:builder
+
+		if healthCheckErr := mgr.AddHealthzCheck("healthz", healthz.Ping); healthCheckErr != nil {
+			mainLogger.Fatal("Unable to set up health check", zap.Error(healthCheckErr))
+		}
+		if addReadyCheckErr := mgr.AddReadyzCheck("readyz", healthz.Ping); addReadyCheckErr != nil {
+			mainLogger.Fatal("Unable to set up ready check", zap.Error(addReadyCheckErr))
+		}
 
-	// k8s Client used for informers
-	cl := kubernetes.NewForConfigOrDie(mgr.GetConfig())
+		// k8s Client used for informers
+		cl := kubernetes.NewForConfigOrDie(mgr.GetConfig())
 
-	serverVersion, err := cl.Discovery().ServerVersion()
-	if err != nil {
-		mainLogger.Error("failed to get Kubernetes server version: ", zap.Error(err))
+		serverVersion, err := cl.Discovery().ServerVersion()
+		if err != nil {
+			mainLogger.Error("failed to get Kubernetes server version: ", zap.Error(err))
+		} else {
+			mainLogger.Infof("Kubernetes server version: %v", serverVersion)
+		}
 	} else {
-		mainLogger.Infof("Kubernetes server version: %v", serverVersion)
+		cl = nil
+		mgr = nil
+		mainLogger.Info("Running in standalone mode. Kubernetes components will be disabled.")
 	}
 
-	// Setup RetinaEndpoint controller.
-	// TODO(mainred): This is to temporarily create a cache and pubsub for RetinaEndpoint, need to refactor this.
-	ctx := ctrl.SetupSignalHandler()
-	ctrl.SetLogger(zapr.NewLogger(zl.Logger.Named("controller-runtime")))
-
 	if daemonConfig.EnablePodLevel {
 		pubSub := pubsub.New()
 		controllerCache := controllercache.New(pubSub)
@@ -252,48 +260,51 @@ func (d *Daemon) Start() error {
 		enrich.Run()
 		metricsModule := mm.InitModule(ctx, daemonConfig, pubSub, enrich, fm, controllerCache)
 
-		if !daemonConfig.RemoteContext {
-			mainLogger.Info("Initializing Pod controller")
-
-			podController := pc.New(mgr.GetClient(), controllerCache)
-			if err := podController.SetupWithManager(mgr); err != nil {
-				mainLogger.Fatal("unable to create PodController", zap.Error(err))
+		if cfg != nil {
+			if !daemonConfig.RemoteContext {
+				mainLogger.Info("Initializing Pod controller")
+
+				podController := pc.New(mgr.GetClient(), controllerCache)
+				if err := podController.SetupWithManager(mgr); err != nil {
+					mainLogger.Fatal("unable to create PodController", zap.Error(err))
+				}
+			} else if daemonConfig.EnableRetinaEndpoint {
+				mainLogger.Info("RetinaEndpoint is enabled")
+				mainLogger.Info("Initializing RetinaEndpoint controller")
+
+				retinaEndpointController := kec.New(mgr.GetClient(), controllerCache)
+				if err := retinaEndpointController.SetupWithManager(mgr); err != nil {
+					mainLogger.Fatal("unable to create retinaEndpointController", zap.Error(err))
+				}
 			}
-		} else if daemonConfig.EnableRetinaEndpoint {
-			mainLogger.Info("RetinaEndpoint is enabled")
-			mainLogger.Info("Initializing RetinaEndpoint controller")
 
-			retinaEndpointController := kec.New(mgr.GetClient(), controllerCache)
-			if err := retinaEndpointController.SetupWithManager(mgr); err != nil {
-				mainLogger.Fatal("unable to create retinaEndpointController", zap.Error(err))
+			mainLogger.Info("Initializing Node controller")
+			nodeController := nc.New(mgr.GetClient(), controllerCache)
+			if err := nodeController.SetupWithManager(mgr); err != nil {
+				mainLogger.Fatal("unable to create nodeController", zap.Error(err))
 			}
-		}
-
-		mainLogger.Info("Initializing Node controller")
-		nodeController := nc.New(mgr.GetClient(), controllerCache)
-		if err := nodeController.SetupWithManager(mgr); err != nil {
-			mainLogger.Fatal("unable to create nodeController", zap.Error(err))
-		}
-
-		mainLogger.Info("Initializing Service controller")
-		svcController := sc.New(mgr.GetClient(), controllerCache)
-		if err := svcController.SetupWithManager(mgr); err != nil {
-			mainLogger.Fatal("unable to create svcController", zap.Error(err))
-		}
 
-		if daemonConfig.EnableAnnotations {
-			mainLogger.Info("Initializing MetricsConfig namespaceController")
-			namespaceController := namespacecontroller.New(mgr.GetClient(), controllerCache, metricsModule)
-			if err := namespaceController.SetupWithManager(mgr); err != nil {
-				mainLogger.Fatal("unable to create namespaceController", zap.Error(err))
+			mainLogger.Info("Initializing Service controller")
+			svcController := sc.New(mgr.GetClient(), controllerCache)
+			if err := svcController.SetupWithManager(mgr); err != nil {
+				mainLogger.Fatal("unable to create svcController", zap.Error(err))
 			}
-			go namespaceController.Start(ctx)
-		} else {
-			mainLogger.Info("Initializing MetricsConfig controller")
-			metricsConfigController := mcc.New(mgr.GetClient(), mgr.GetScheme(), metricsModule)
-			if err := metricsConfigController.SetupWithManager(mgr); err != nil {
-				mainLogger.Fatal("unable to create metricsConfigController", zap.Error(err))
+
+			if daemonConfig.EnableAnnotations {
+				mainLogger.Info("Initializing MetricsConfig namespaceController")
+				namespaceController := namespacecontroller.New(mgr.GetClient(), controllerCache, metricsModule)
+				if err := namespaceController.SetupWithManager(mgr); err != nil {
+					mainLogger.Fatal("unable to create namespaceController", zap.Error(err))
+				}
+				go namespaceController.Start(ctx)
+			} else {
+				mainLogger.Info("Initializing MetricsConfig controller")
+				metricsConfigController := mcc.New(mgr.GetClient(), mgr.GetScheme(), metricsModule)
+				if err := metricsConfigController.SetupWithManager(mgr); err != nil {
+					mainLogger.Fatal("unable to create metricsConfigController", zap.Error(err))
+				}
 			}
+
 		}
 	}
 

From 43c6c8c424b1d0ec34f8e415c9dd01fb337005a0 Mon Sep 17 00:00:00 2001
From: beegiik <kbeegii@gmail.com>
Date: Wed, 8 Jan 2025 12:48:01 +0000
Subject: [PATCH 03/11] WIP 3

---
 cmd/legacy/daemon.go | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/cmd/legacy/daemon.go b/cmd/legacy/daemon.go
index 44d77cdb0e..848c008a8a 100644
--- a/cmd/legacy/daemon.go
+++ b/cmd/legacy/daemon.go
@@ -304,7 +304,6 @@ func (d *Daemon) Start() error {
 					mainLogger.Fatal("unable to create metricsConfigController", zap.Error(err))
 				}
 			}
-
 		}
 	}
 
@@ -328,8 +327,10 @@ func (d *Daemon) Start() error {
 	mainLogger.Info("Started controller manager")
 
 	// Start all registered controllers. This will block until container receives SIGTERM.
-	if err := mgr.Start(ctx); err != nil {
-		mainLogger.Fatal("unable to start manager", zap.Error(err))
+	if mgr != nil {
+		if err := mgr.Start(ctx); err != nil {
+			mainLogger.Fatal("unable to start manager", zap.Error(err))
+		}
 	}
 
 	mainLogger.Info("Network observability exiting. Till next time!")

From e077bd933a12559abcff9f04e2b7b663dd9f8e8b Mon Sep 17 00:00:00 2001
From: beegiik <kbeegii@gmail.com>
Date: Wed, 8 Jan 2025 13:05:45 +0000
Subject: [PATCH 04/11] WIP 4

---
 cmd/legacy/daemon.go | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/cmd/legacy/daemon.go b/cmd/legacy/daemon.go
index 848c008a8a..44a691720c 100644
--- a/cmd/legacy/daemon.go
+++ b/cmd/legacy/daemon.go
@@ -327,12 +327,13 @@ func (d *Daemon) Start() error {
 	mainLogger.Info("Started controller manager")
 
 	// Start all registered controllers. This will block until container receives SIGTERM.
-	if mgr != nil {
-		if err := mgr.Start(ctx); err != nil {
-			mainLogger.Fatal("unable to start manager", zap.Error(err))
-		}
+	if err := mgr.Start(ctx); err != nil {
+		mainLogger.Fatal("unable to start manager", zap.Error(err))
 	}
 
+	// Block the main thread until the context is canceled (e.g., SIGTERM).
+	<-ctx.Done()
+
 	mainLogger.Info("Network observability exiting. Till next time!")
 	return nil
 }

From 0b24052037f6ed18332a061176d65bf7b85ef13a Mon Sep 17 00:00:00 2001
From: beegiik <kbeegii@gmail.com>
Date: Thu, 9 Jan 2025 15:25:30 +0000
Subject: [PATCH 05/11] default config attempt

---
 cmd/legacy/daemon.go | 17 ++++++++++++++---
 1 file changed, 14 insertions(+), 3 deletions(-)

diff --git a/cmd/legacy/daemon.go b/cmd/legacy/daemon.go
index 44a691720c..70089a49dc 100644
--- a/cmd/legacy/daemon.go
+++ b/cmd/legacy/daemon.go
@@ -105,11 +105,11 @@ func (d *Daemon) Start() error {
 		cfg, err = kcfg.GetConfig()
 		if err != nil {
 			fmt.Println("KUBECONFIG not set. Falling back to standalone mode")
-			cfg = nil
+			cfg = loadStandaloneConfig()
 		}
 	}
 
-	fmt.Println("api server: ", getHost(cfg))
+	fmt.Println("api server: ", cfg.Host)
 
 	fmt.Println("init logger")
 	zl, err := log.SetupZapLogger(&log.LogOpts{
@@ -123,7 +123,7 @@ func (d *Daemon) Start() error {
 		EnableTelemetry:       daemonConfig.EnableTelemetry,
 	},
 		zap.String("version", buildinfo.Version),
-		zap.String("apiserver", getHost(cfg)),
+		zap.String("apiserver", cfg.Host),
 		zap.String("plugins", strings.Join(daemonConfig.EnabledPlugin, `,`)),
 		zap.String("data aggregation level", daemonConfig.DataAggregationLevel.String()),
 	)
@@ -338,6 +338,17 @@ func (d *Daemon) Start() error {
 	return nil
 }
 
+func loadStandaloneConfig() *rest.Config {
+	return &rest.Config{
+		Host:    "http://localhost:8080",
+		APIPath: "/api",
+		ContentConfig: rest.ContentConfig{
+			GroupVersion:         nil,
+			NegotiatedSerializer: nil,
+		},
+	}
+}
+
 func getHost(cfg *rest.Config) string {
 	if cfg != nil {
 		return cfg.Host

From fb5b03b2ba463ee148b042729eb9e4b6e5f1617d Mon Sep 17 00:00:00 2001
From: beegiik <kbeegii@gmail.com>
Date: Thu, 9 Jan 2025 15:43:35 +0000
Subject: [PATCH 06/11] updated empty config

---
 cmd/legacy/daemon.go | 51 ++++++++++++++++----------------------------
 1 file changed, 18 insertions(+), 33 deletions(-)

diff --git a/cmd/legacy/daemon.go b/cmd/legacy/daemon.go
index 70089a49dc..72a379d281 100644
--- a/cmd/legacy/daemon.go
+++ b/cmd/legacy/daemon.go
@@ -95,7 +95,8 @@ func (d *Daemon) Start() error {
 
 	fmt.Println("init client-go")
 	var cfg *rest.Config
-	if kubeconfig := os.Getenv("KUBECONFIG"); kubeconfig != "" {
+	var kubeconfig = os.Getenv("KUBECONFIG")
+	if kubeconfig != "" {
 		fmt.Println("KUBECONFIG set, using kubeconfig: ", kubeconfig)
 		cfg, err = clientcmd.BuildConfigFromFlags("", kubeconfig)
 		if err != nil {
@@ -152,7 +153,7 @@ func (d *Daemon) Start() error {
 		mainLogger.Info("telemetry enabled", zap.String("applicationInsightsID", buildinfo.ApplicationInsightsID))
 		tel, err = telemetry.NewAppInsightsTelemetryClient("retina-agent", map[string]string{
 			"version":   buildinfo.Version,
-			"apiserver": getHost(cfg),
+			"apiserver": cfg.Host,
 			"plugins":   strings.Join(daemonConfig.EnabledPlugin, `,`),
 		})
 		if err != nil {
@@ -214,37 +215,31 @@ func (d *Daemon) Start() error {
 	ctx := ctrl.SetupSignalHandler()
 	ctrl.SetLogger(zapr.NewLogger(zl.Logger.Named("controller-runtime")))
 
-	var cl *kubernetes.Clientset
-	var mgr crmgr.Manager
-	if cfg != nil {
-		mgr, err := crmgr.New(cfg, mgrOption)
-		if err != nil {
-			mainLogger.Error("Unable to start manager", zap.Error(err))
-			return fmt.Errorf("creating controller-runtime manager: %w", err)
-		}
+	mgr, err := crmgr.New(cfg, mgrOption)
+	if err != nil {
+		mainLogger.Error("Unable to start manager", zap.Error(err))
+		return fmt.Errorf("creating controller-runtime manager: %w", err)
+	}
 
-		//+kubebuilder:scaffold:builder
+	//+kubebuilder:scaffold:builder
 
-		if healthCheckErr := mgr.AddHealthzCheck("healthz", healthz.Ping); healthCheckErr != nil {
-			mainLogger.Fatal("Unable to set up health check", zap.Error(healthCheckErr))
-		}
-		if addReadyCheckErr := mgr.AddReadyzCheck("readyz", healthz.Ping); addReadyCheckErr != nil {
-			mainLogger.Fatal("Unable to set up ready check", zap.Error(addReadyCheckErr))
-		}
+	if healthCheckErr := mgr.AddHealthzCheck("healthz", healthz.Ping); healthCheckErr != nil {
+		mainLogger.Fatal("Unable to set up health check", zap.Error(healthCheckErr))
+	}
+	if addReadyCheckErr := mgr.AddReadyzCheck("readyz", healthz.Ping); addReadyCheckErr != nil {
+		mainLogger.Fatal("Unable to set up ready check", zap.Error(addReadyCheckErr))
+	}
 
-		// k8s Client used for informers
-		cl := kubernetes.NewForConfigOrDie(mgr.GetConfig())
+	// k8s Client used for informers
+	cl := kubernetes.NewForConfigOrDie(mgr.GetConfig())
 
+	if kubeconfig != "" {
 		serverVersion, err := cl.Discovery().ServerVersion()
 		if err != nil {
 			mainLogger.Error("failed to get Kubernetes server version: ", zap.Error(err))
 		} else {
 			mainLogger.Infof("Kubernetes server version: %v", serverVersion)
 		}
-	} else {
-		cl = nil
-		mgr = nil
-		mainLogger.Info("Running in standalone mode. Kubernetes components will be disabled.")
 	}
 
 	if daemonConfig.EnablePodLevel {
@@ -331,9 +326,6 @@ func (d *Daemon) Start() error {
 		mainLogger.Fatal("unable to start manager", zap.Error(err))
 	}
 
-	// Block the main thread until the context is canceled (e.g., SIGTERM).
-	<-ctx.Done()
-
 	mainLogger.Info("Network observability exiting. Till next time!")
 	return nil
 }
@@ -348,10 +340,3 @@ func loadStandaloneConfig() *rest.Config {
 		},
 	}
 }
-
-func getHost(cfg *rest.Config) string {
-	if cfg != nil {
-		return cfg.Host
-	}
-	return "running in standalone mode"
-}

From 151b0402cabf7f0c3d84ee726a5cde3edb9bed58 Mon Sep 17 00:00:00 2001
From: beegiik <kbeegii@gmail.com>
Date: Thu, 9 Jan 2025 17:14:40 +0000
Subject: [PATCH 07/11] add reading stateile logic

---
 pkg/enricher/enricher.go                |  21 +++++
 pkg/plugin/hnsstats/hnsstats_windows.go | 117 ++++++++++++++++++++++++
 pkg/plugin/hnsstats/types_windows.go    |  16 ++++
 pkg/utils/attr_utils.go                 |   5 +
 4 files changed, 159 insertions(+)

diff --git a/pkg/enricher/enricher.go b/pkg/enricher/enricher.go
index 98013cd2ca..86b193b3bd 100644
--- a/pkg/enricher/enricher.go
+++ b/pkg/enricher/enricher.go
@@ -14,6 +14,7 @@ import (
 	"github.com/microsoft/retina/pkg/common"
 	"github.com/microsoft/retina/pkg/controllers/cache"
 	"github.com/microsoft/retina/pkg/log"
+	"github.com/microsoft/retina/pkg/utils"
 	"go.uber.org/zap"
 )
 
@@ -186,6 +187,26 @@ func (e *Enricher) Write(ev *v1.Event) {
 	e.inputRing.Write(ev)
 }
 
+func (e *Enricher) GetWindowLabels(ip string) *utils.LabelsInfo {
+	obj := e.cache.GetObjByIP(ip)
+	if obj == nil {
+		e.l.Debug("No object found for IP", zap.String("ip", ip))
+		return nil
+	}
+
+	switch o := obj.(type) {
+	case *common.RetinaEndpoint:
+		return &utils.LabelsInfo{
+			Namespace: o.Namespace(),
+			PodName:   o.Name(),
+		}
+
+	default:
+		e.l.Debug("received unknown type from cache", zap.Any("obj", obj), zap.Any("type", reflect.TypeOf(obj)))
+		return nil
+	}
+}
+
 func (e *Enricher) ExportReader() *container.RingReader {
 	return container.NewRingReader(e.outputRing, e.outputRing.OldestWrite())
 }
diff --git a/pkg/plugin/hnsstats/hnsstats_windows.go b/pkg/plugin/hnsstats/hnsstats_windows.go
index a668dce4f9..994b9410e4 100644
--- a/pkg/plugin/hnsstats/hnsstats_windows.go
+++ b/pkg/plugin/hnsstats/hnsstats_windows.go
@@ -7,19 +7,27 @@ package hnsstats
 import (
 	"context"
 	"encoding/json"
+	"fmt"
+	"os"
 	"time"
 
 	"github.com/Microsoft/hcsshim"
 	"github.com/Microsoft/hcsshim/hcn"
 	v1 "github.com/cilium/cilium/pkg/hubble/api/v1"
 	kcfg "github.com/microsoft/retina/pkg/config"
+	"github.com/microsoft/retina/pkg/exporter"
 	"github.com/microsoft/retina/pkg/log"
 	"github.com/microsoft/retina/pkg/metrics"
 	"github.com/microsoft/retina/pkg/plugin/registry"
 	"github.com/microsoft/retina/pkg/utils"
+	"github.com/prometheus/client_golang/prometheus"
 	"go.uber.org/zap"
 )
 
+var (
+	AdvWindowsGauge *prometheus.GaugeVec
+)
+
 const (
 	initialize = iota + 1
 	start
@@ -85,6 +93,11 @@ func (h *hnsstats) Init() error {
 	}
 	h.endpointQuery.Filter = string(filter)
 
+	if h.cfg.EnablePodLevel {
+		h.l.Info("Creating advanced HNS stats metrics")
+		initializeAdvMetrics()
+	}
+
 	h.l.Info("Exiting hnsstats Init...")
 	return nil
 }
@@ -144,6 +157,7 @@ func pullHnsStats(ctx context.Context, h *hnsstats) error {
 						if vfpcounters, err := parseVfpPortCounters(countersRaw); err == nil {
 							// Attach VFP port counters
 							hnsStatsData.vfpCounters = vfpcounters
+							hnsStatsData.Port = portguid
 							h.l.Debug("Attached VFP port counters", zap.String(zapPortField, portguid))
 							// h.l.Info(vfpcounters.String())
 						} else {
@@ -154,6 +168,7 @@ func pullHnsStats(ctx context.Context, h *hnsstats) error {
 					}
 
 					notifyHnsStats(h, hnsStatsData)
+					getAdvancedMetricLabels(h, hnsStatsData)
 				}
 			}
 		}
@@ -208,12 +223,114 @@ func notifyHnsStats(h *hnsstats, stats *HnsStatsData) {
 	metrics.TCPFlagGauge.WithLabelValues(egressLabel, utils.RST).Set(float64(stats.vfpCounters.Out.TcpCounters.PacketCounters.RstPacketCount))
 }
 
+func getAdvancedMetricLabels(h *hnsstats, stats *HnsStatsData) {
+	if AdvWindowsGauge == nil {
+		h.l.Warn("Advanced windows metric is not initialized")
+		return
+	}
+	// if port is populated, vfp data exists
+	// labels := enricher.Instance().GetWindowLabels(stats.IPAddress)
+	labels, err := getStandaloneLabels(stats.IPAddress)
+
+	if err != nil {
+		AdvWindowsGauge.WithLabelValues(PacketsReceived, stats.IPAddress, stats.Port, labels.Namespace, labels.PodName).Set(float64(stats.hnscounters.PacketsReceived))
+		AdvWindowsGauge.WithLabelValues(PacketsSent, stats.IPAddress, stats.Port, labels.Namespace, labels.PodName).Set(float64(stats.hnscounters.PacketsSent))
+		h.l.Info("updating advanced HNS stats metric", zap.String(PodName, labels.PodName), zap.String(Namespace, labels.Namespace))
+	}
+}
+
 func (h *hnsstats) Start(ctx context.Context) error {
 	h.l.Info("Start hnsstats plugin...")
 	h.state = start
 	return pullHnsStats(ctx, h)
 }
 
+func cleanAdvMetrics() {
+	exporter.UnregisterMetric(exporter.AdvancedRegistry, metrics.ToPrometheusType(AdvWindowsGauge))
+}
+
+func initializeAdvMetrics() {
+	if AdvWindowsGauge != nil {
+		cleanAdvMetrics()
+	}
+	AdvWindowsGauge = exporter.CreatePrometheusGaugeVecForMetric(
+		exporter.AdvancedRegistry,
+		AdvHNSStatsName,
+		AdvHNSStatsDescription,
+		utils.Direction,
+		Ip,
+		Port,
+		Namespace,
+		PodName,
+		WorkloadKind,
+		WorkloadName,
+	)
+}
+
+type Endpoint struct {
+	ID           string   `json:"Id"`
+	IPAddresses  []IPInfo `json:"IPAddresses"`
+	PODName      string   `json:"PODName"`
+	PODNameSpace string   `json:"PODNameSpace"`
+}
+
+type IPInfo struct {
+	IP string `json:"IP"`
+}
+
+type Network struct {
+	ExternalInterfaces map[string]ExternalInterface `json:"ExternalInterfaces"`
+}
+
+type ExternalInterface struct {
+	Networks map[string]NetworkInfo `json:"Networks"`
+}
+
+type NetworkInfo struct {
+	Endpoints map[string]Endpoint `json:"Endpoints"`
+}
+
+func getStandaloneLabels(ip string) (*utils.LabelsInfo, error) {
+	file, err := os.Open("C:/k/azure-vnet.json")
+	if err != nil {
+		return &utils.LabelsInfo{
+			Namespace: "",
+			PodName:   "",
+		}, fmt.Errorf("failed to open file: %w", err)
+	}
+	defer file.Close()
+
+	// Decode JSON
+	var network Network
+	if err := json.NewDecoder(file).Decode(&network); err != nil {
+		return &utils.LabelsInfo{
+			Namespace: "",
+			PodName:   "",
+		}, fmt.Errorf("failed to decode JSON: %w", err)
+	}
+
+	// Search for the IP in Endpoints
+	for _, iface := range network.ExternalInterfaces {
+		for _, network := range iface.Networks {
+			for _, endpoint := range network.Endpoints {
+				for _, ipAddr := range endpoint.IPAddresses {
+					if ipAddr.IP == ip {
+						return &utils.LabelsInfo{
+							Namespace: endpoint.PODNameSpace,
+							PodName:   endpoint.PODName,
+						}, nil
+					}
+				}
+			}
+		}
+	}
+
+	return &utils.LabelsInfo{
+		Namespace: "",
+		PodName:   "",
+	}, fmt.Errorf("IP address not found")
+}
+
 func (d *hnsstats) Stop() error {
 	d.l.Info("Entered hnsstats Stop...")
 	if d.state != start {
diff --git a/pkg/plugin/hnsstats/types_windows.go b/pkg/plugin/hnsstats/types_windows.go
index ab8511d5d3..5eed46d257 100644
--- a/pkg/plugin/hnsstats/types_windows.go
+++ b/pkg/plugin/hnsstats/types_windows.go
@@ -10,6 +10,7 @@ import (
 	"github.com/Microsoft/hcsshim"
 	"github.com/Microsoft/hcsshim/hcn"
 	kcfg "github.com/microsoft/retina/pkg/config"
+	"github.com/microsoft/retina/pkg/enricher"
 	"github.com/microsoft/retina/pkg/log"
 	"go.opentelemetry.io/otel/attribute"
 	"go.opentelemetry.io/otel/metric"
@@ -20,6 +21,19 @@ import (
 const (
 	name          string = "hnsstats"
 	HnsStatsEvent string = "hnsstatscount"
+
+	// Advanced metric
+	AdvHNSStatsName        string = "adv_windows_hns_stats"
+	AdvHNSStatsDescription string = "Include many different metrics from packets sent/received to closed connections"
+
+	// Advanced metric labels
+	Ip           string = "ip"
+	Port         string = "port"
+	Namespace    string = "namespace"
+	PodName      string = "podname"
+	WorkloadKind string = "workload_kind"
+	WorkloadName string = "workload_name"
+
 	// From HNSStats API
 	PacketsReceived        string = "win_packets_recv_count"
 	PacketsSent            string = "win_packets_sent_count"
@@ -73,12 +87,14 @@ type hnsstats struct {
 	state         int
 	l             *log.ZapLogger
 	endpointQuery hcn.HostComputeQuery
+	enricher      enricher.EnricherInterface
 }
 
 type HnsStatsData struct {
 	hnscounters *hcsshim.HNSEndpointStats
 	IPAddress   string
 	vfpCounters *VfpPortStatsData
+	Port        string
 }
 
 // handles event signals such as incrementing a metric counter
diff --git a/pkg/utils/attr_utils.go b/pkg/utils/attr_utils.go
index 6826db74c9..4bac0a0d7c 100644
--- a/pkg/utils/attr_utils.go
+++ b/pkg/utils/attr_utils.go
@@ -87,6 +87,11 @@ var (
 	DNSResponseLabels = []string{"return_code", "query_type", "query", "response", "num_response"}
 )
 
+type LabelsInfo struct {
+	Namespace string
+	PodName   string
+}
+
 func GetPluginEventAttributes(attrs []attribute.KeyValue, pluginName, eventName, timestamp string) []attribute.KeyValue {
 	return append(attrs,
 		pluginKey.String(pluginName),

From 0d96602bec772799097c415742cdb503344eb0ee Mon Sep 17 00:00:00 2001
From: beegiik <kbeegii@gmail.com>
Date: Tue, 14 Jan 2025 11:31:18 +0000
Subject: [PATCH 08/11] WIP adding logs

---
 pkg/plugin/hnsstats/hnsstats_windows.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/pkg/plugin/hnsstats/hnsstats_windows.go b/pkg/plugin/hnsstats/hnsstats_windows.go
index 994b9410e4..ff595b63e3 100644
--- a/pkg/plugin/hnsstats/hnsstats_windows.go
+++ b/pkg/plugin/hnsstats/hnsstats_windows.go
@@ -230,7 +230,10 @@ func getAdvancedMetricLabels(h *hnsstats, stats *HnsStatsData) {
 	}
 	// if port is populated, vfp data exists
 	// labels := enricher.Instance().GetWindowLabels(stats.IPAddress)
+	h.l.Info("New standalone feature")
+
 	labels, err := getStandaloneLabels(stats.IPAddress)
+	h.l.Info("Reading fields from CNI state file", zap.String(Ip, stats.IPAddress), zap.String(PodName, labels.PodName), zap.String(Namespace, labels.Namespace))
 
 	if err != nil {
 		AdvWindowsGauge.WithLabelValues(PacketsReceived, stats.IPAddress, stats.Port, labels.Namespace, labels.PodName).Set(float64(stats.hnscounters.PacketsReceived))
@@ -262,8 +265,6 @@ func initializeAdvMetrics() {
 		Port,
 		Namespace,
 		PodName,
-		WorkloadKind,
-		WorkloadName,
 	)
 }
 
@@ -300,7 +301,6 @@ func getStandaloneLabels(ip string) (*utils.LabelsInfo, error) {
 	}
 	defer file.Close()
 
-	// Decode JSON
 	var network Network
 	if err := json.NewDecoder(file).Decode(&network); err != nil {
 		return &utils.LabelsInfo{

From da431ac36f1fb06e40c8febf208c16c3922a2eb4 Mon Sep 17 00:00:00 2001
From: beegiik <kbeegii@gmail.com>
Date: Tue, 14 Jan 2025 11:59:03 +0000
Subject: [PATCH 09/11] WIP more logging

---
 cmd/legacy/daemon.go                        | 2 ++
 pkg/managers/pluginmanager/pluginmanager.go | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/cmd/legacy/daemon.go b/cmd/legacy/daemon.go
index 72a379d281..fe6e17a07d 100644
--- a/cmd/legacy/daemon.go
+++ b/cmd/legacy/daemon.go
@@ -89,6 +89,8 @@ func (d *Daemon) Start() error {
 	}
 
 	daemonConfig, err := config.GetConfig(d.configFile)
+	fmt.Printf("config %+v\n", daemonConfig)
+
 	if err != nil {
 		panic(err)
 	}
diff --git a/pkg/managers/pluginmanager/pluginmanager.go b/pkg/managers/pluginmanager/pluginmanager.go
index 15d133382f..3e952e4344 100644
--- a/pkg/managers/pluginmanager/pluginmanager.go
+++ b/pkg/managers/pluginmanager/pluginmanager.go
@@ -59,6 +59,8 @@ func NewPluginManager(cfg *kcfg.Config, tel telemetry.Telemetry) (*PluginManager
 	}
 
 	for _, name := range cfg.EnabledPlugin {
+		fmt.Printf("Enabled plugins : %+v\n", name)
+
 		newPluginFn, ok := plugin.Get(name)
 		if !ok {
 			return nil, fmt.Errorf("plugin %s not found in registry", name)

From 84cc18b9839b22d759f7ef6d6e1958c2cb370e5d Mon Sep 17 00:00:00 2001
From: beegiik <kbeegii@gmail.com>
Date: Thu, 16 Jan 2025 11:43:31 +0000
Subject: [PATCH 10/11] troubleshooting windows command

---
 pkg/plugin/hnsstats/hnsstats_windows.go | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/pkg/plugin/hnsstats/hnsstats_windows.go b/pkg/plugin/hnsstats/hnsstats_windows.go
index ff595b63e3..a60309f992 100644
--- a/pkg/plugin/hnsstats/hnsstats_windows.go
+++ b/pkg/plugin/hnsstats/hnsstats_windows.go
@@ -93,10 +93,10 @@ func (h *hnsstats) Init() error {
 	}
 	h.endpointQuery.Filter = string(filter)
 
-	if h.cfg.EnablePodLevel {
-		h.l.Info("Creating advanced HNS stats metrics")
-		initializeAdvMetrics()
-	}
+	// if h.cfg.EnablePodLevel {
+	h.l.Info("Creating advanced HNS stats metrics")
+	initializeAdvMetrics()
+	// }
 
 	h.l.Info("Exiting hnsstats Init...")
 	return nil

From 8813eecf8c698e85504f3852242570136dbbe025 Mon Sep 17 00:00:00 2001
From: beegiik <kbeegii@gmail.com>
Date: Mon, 20 Jan 2025 10:01:47 +0000
Subject: [PATCH 11/11] winpod

---
 winpod.yaml | 31 +++++++++++++++++++++++++++++++
 1 file changed, 31 insertions(+)
 create mode 100644 winpod.yaml

diff --git a/winpod.yaml b/winpod.yaml
new file mode 100644
index 0000000000..1234d3db78
--- /dev/null
+++ b/winpod.yaml
@@ -0,0 +1,31 @@
+apiVersion: apps/v1
+kind: DaemonSet
+metadata:
+  name: privileged-daemonset
+  namespace: kube-system
+  labels:
+    app: privileged-daemonset
+spec:
+  selector:
+    matchLabels:
+      app: privileged-daemonset
+  template:
+    metadata:
+      labels:
+        app: privileged-daemonset
+    spec:
+      nodeSelector:
+        kubernetes.io/os: windows
+      securityContext:
+        windowsOptions:
+          hostProcess: true
+          runAsUserName: "NT AUTHORITY\\SYSTEM"
+      hostNetwork: true
+      containers:
+        - name: powershell
+          image: mcr.microsoft.com/powershell:lts-nanoserver-1809 # or lts-nanoserver-ltsc2022
+          command:
+            - powershell.exe
+            - -Command
+            - Start-Sleep -Seconds 2147483
+      terminationGracePeriodSeconds: 0