Add MIZU_GLOBAL_GOLANG_PATH environment variable

tap/passive_tapper.go

@@ -293,6 +293,15 @@ func startTlsTapper(extension *api.Extension, outputItems chan *api.OutputChanne
 		}
 	}
 
+	// A quick way to instrument Go `crypto/tls` using executable path - used for debuging and troubleshooting
+	//
+	if os.Getenv("MIZU_GLOBAL_GOLANG_PATH") != "" {
+		if err := tls.GlobalGolangTapPath(os.Getenv("MIZU_GLOBAL_GOLANG_PATH")); err != nil {
+			tlstapper.LogError(err)
+			return nil
+		}
+	}
+
 	var emitter api.Emitter = &api.Emitting{
 		AppStats:      &diagnose.AppStats,
 		OutputChannel: outputItems,

tap/tlstapper/tls_tapper.go

@@ -86,6 +86,10 @@ func (t *TlsTapper) GlobalGolangTap(procfs string, pid string) error {
 	return t.tapGolangPid(procfs, uint32(_pid), api.UNKNOWN_NAMESPACE)
 }
 
+func (t *TlsTapper) GlobalGolangTapPath(exePath string) error {
+	return t.tapGolangPath(exePath)
+}
+
 func (t *TlsTapper) AddSsllibPid(procfs string, pid uint32, namespace string) error {
 	sslLibrary, err := findSsllib(procfs, pid)
 
@@ -219,6 +223,18 @@ func (t *TlsTapper) tapGolangPid(procfs string, pid uint32, namespace string) er
 	return nil
 }
 
+func (t *TlsTapper) tapGolangPath(exePath string) error {
+	hooks := golangHooks{}
+
+	if err := hooks.installUprobes(&t.bpfObjects, exePath); err != nil {
+		return err
+	}
+
+	t.golangHooksStructs = append(t.golangHooksStructs, hooks)
+
+	return nil
+}
+
 func LogError(err error) {
 	var e *errors.Error
 	if errors.As(err, &e) {