NewGnmiTarget initializes notification dispatcher

examples/example01/cmd/start.go

@@ -39,7 +39,6 @@ import (
 	"code.fbi.h-da.de/danet/gnmi-target/examples/example01/handlers/system"
 	gnmitargetygot "code.fbi.h-da.de/danet/gnmi-target/examples/example01/model"
 	"code.fbi.h-da.de/danet/gnmi-target/handler"
-	not "code.fbi.h-da.de/danet/gnmi-target/internal/notifications"
 	"github.com/sirupsen/logrus"
 	"github.com/spf13/cobra"
 	"github.com/spf13/viper"
@@ -84,8 +83,6 @@ var startCmd = &cobra.Command{
 			logrus.Fatal(err)
 		}
 
-		changeDispatcher := not.NewDispatcher()
-
 		// The registered path handlers sorted by priority. If specific
 		// handlers should be able to process their workload before others,
 		// then they should be placed in the front of the slice.
@@ -99,7 +96,7 @@ var startCmd = &cobra.Command{
 			system.NewSystemHandler(),
 		}
 
-		gnmitTarget := gnmitarget.NewGnmiTarget(schema, &gnmitargetygot.Gnmitarget{}, gnmitargetygot.ΓModelData, gnmitargetygot.Unmarshal, gnmitargetygot.ΛEnum, changeDispatcher, handlers...)
+		gnmitTarget := gnmitarget.NewGnmiTarget(schema, &gnmitargetygot.Gnmitarget{}, gnmitargetygot.ΓModelData, gnmitargetygot.Unmarshal, gnmitargetygot.ΛEnum, handlers...)
 		if err := gnmitTarget.Start(viper.GetString("bindAddress"), viper.GetString("certFile"), viper.GetString("keyFile"), viper.GetString("caFile"), *insecure); err != nil {
 			logrus.Fatal(err)
 		}

go.mod

@@ -34,7 +34,6 @@ require (
 	github.com/sourcegraph/conc v0.3.0 // indirect
 	github.com/spf13/afero v1.11.0 // indirect
 	github.com/spf13/cast v1.6.0 // indirect
-	github.com/spf13/jwalterweatherman v1.1.0 // indirect
 	github.com/spf13/pflag v1.0.5 // indirect
 	github.com/subosito/gotenv v1.6.0 // indirect
 	github.com/tklauser/go-sysconf v0.3.11 // indirect

internal/gnmiserver/subscribe.go

@@ -42,7 +42,7 @@ func (s *Server) Subscribe(stream gnmi.GNMI_SubscribeServer) error {
 		}
 
 		// Print the path a subscription is requested for.
-		log.Infof("Received subscribe for gnmi path %s", path.String())
+		log.Infof("Received subscribe for gnmi path %s with mode %s", path.String(), subscriptions.GetMode().String())
 	}
 
 	subscribeMode = subscriptions.GetMode()

target.go

@@ -43,7 +43,6 @@ func NewGnmiTarget(
 	modeldata []*pbGNMI.ModelData,
 	unmarshalFn func(data []byte, destStruct ygot.GoStruct, opts ...ytypes.UnmarshalOpt) error,
 	ΛEnum map[string]map[int64]ygot.EnumDefinition,
-	changeDispatcher *not.Dispatcher,
 	yangHandlers ...handler.PathHandler,
 ) *GnmiTarget {
 	return &GnmiTarget{
@@ -52,7 +51,7 @@ func NewGnmiTarget(
 		modeldata:                 modeldata,
 		unmarshalFn:               unmarshalFn,
 		ΛEnum:                     ΛEnum,
-		YangModelChangeDispatcher: changeDispatcher,
+		YangModelChangeDispatcher: not.NewDispatcher(),
 		yangHandlers:              yangHandlers,
 	}
 }