refactor(ipc)!: make it consistent with the structure of ovm-win

cmd/ovm/main.go

@@ -88,7 +88,7 @@ func main() {
 		exit(1)
 	}
 
-	event.Notify(event.Initializing)
+	event.NotifyApp(event.Initializing)
 
 	ctx, cancel := context.WithCancel(context.Background())
 	g, ctx := errgroup.WithContext(ctx)
@@ -159,7 +159,7 @@ func ready(ctx context.Context, g *errgroup.Group, opt *cli.Context, log *logger
 			err = rerr
 		} else {
 			channel.NotifyVMReady()
-			event.Notify(event.VMReady)
+			event.NotifyApp(event.Ready)
 		}
 
 		if cerr := conn.Close(); cerr != nil {
@@ -174,7 +174,7 @@ func ready(ctx context.Context, g *errgroup.Group, opt *cli.Context, log *logger
 }
 
 func exit(exitCode int) {
-	event.Notify(event.Exit)
+	event.NotifyApp(event.Exit)
 	for _, clean := range cleans {
 		clean()
 	}

pkg/gvproxy/gvproxy.go

@@ -116,7 +116,7 @@ func Run(ctx context.Context, g *errgroup.Group, opt *cli.Context) error {
 	httpServe(ctx, g, ln, mux)
 
 	channel.NotifyGVProxyReady()
-	event.Notify(event.GVProxyReady)
+	event.NotifyApp(event.GVProxyReady)
 
 	g.Go(func() error {
 		select {

pkg/ipc/event/event.go

@@ -17,20 +17,26 @@ import (
 	"golang.org/x/sync/errgroup"
 )
 
-type Name string
-
-var (
-	Initializing     Name = "Initializing"
-	GVProxyReady     Name = "GVProxyReady"
-	IgnitionProgress Name = "IgnitionProgress"
-	IgnitionDone     Name = "IgnitionDone"
-	VMReady          Name = "VMReady"
-	Exit             Name = "Exit"
-	Error            Name = "Error"
+type key string
+
+const (
+	kApp   key = "app"
+	kError key = "error"
+)
+
+type app string
+
+const (
+	Initializing     app = "Initializing"
+	GVProxyReady     app = "GVProxyReady"
+	IgnitionProgress app = "IgnitionProgress"
+	IgnitionDone     app = "IgnitionDone"
+	Ready            app = "Ready"
+	Exit             app = "Exit"
 )
 
 type datum struct {
-	name    Name
+	name    key
 	message string
 }
 
@@ -91,7 +97,7 @@ func Subscribe(g *errgroup.Group) {
 				}
 			}
 
-			if datum.name == Exit {
+			if datum.message == string(Exit) {
 				e.channel.Close()
 				e = nil
 				return nil
@@ -102,13 +108,14 @@ func Subscribe(g *errgroup.Group) {
 	})
 }
 
-func Notify(name Name) {
+func NotifyApp(name app) {
 	if e == nil {
 		return
 	}
 
 	e.channel.In() <- &datum{
-		name: name,
+		name:    kApp,
+		message: string(name),
 	}
 }
 
@@ -118,7 +125,7 @@ func NotifyError(err error) {
 	}
 
 	e.channel.In() <- &datum{
-		name:    Error,
+		name:    kError,
 		message: err.Error(),
 	}
 }

pkg/vfkit/ignition.go

@@ -58,7 +58,7 @@ func ignition(ctx context.Context, g *errgroup.Group, opt *cli.Context, log *log
 			err = werr
 		} else {
 			log.Info("write ignition command success")
-			event.Notify(event.IgnitionDone)
+			event.NotifyApp(event.IgnitionDone)
 		}
 
 		if cerr := conn.Close(); cerr != nil {

pkg/vfkit/vfkit.go

@@ -104,7 +104,7 @@ func Run(ctx context.Context, g *errgroup.Group, opt *cli.Context) error {
 		return err
 	}
 
-	event.Notify(event.IgnitionProgress)
+	event.NotifyApp(event.IgnitionProgress)
 
 	if err := ignition(ctx, g, opt, log); err != nil {
 		log.Errorf("ignition failed: %v", err)