Example Declarative Configuration for establishing BGP session using GoBGP

gnmi/fakedevice/fakedevice.go

@@ -52,7 +52,7 @@ func init() {
 
 // bootTimeTask is a task that updates the boot-time leaf with the current
 // time. It does not spawn any long-running threads.
-func bootTimeTask(_ gnmit.Queue, updateFn gnmit.UpdateFn, target string, remove func()) error {
+func bootTimeTask(_ func() *config.Device, _ gnmit.Queue, updateFn gnmit.UpdateFn, target string, remove func()) error {
 	defer remove()
 	pathBootTime, _, errs := ygot.ResolvePath(telemetrypath.DeviceRoot("").System().BootTime())
 	if errs != nil {
@@ -83,7 +83,7 @@ func bootTimeTask(_ gnmit.Queue, updateFn gnmit.UpdateFn, target string, remove
 
 // currentDateTimeTask updates the current-datetime leaf with the current time,
 // and spawns a thread that wakes up every second to update the leaf.
-func currentDateTimeTask(_ gnmit.Queue, updateFn gnmit.UpdateFn, target string, remove func()) error {
+func currentDateTimeTask(_ func() *config.Device, _ gnmit.Queue, updateFn gnmit.UpdateFn, target string, remove func()) error {
 	pathDatetime, _, err := ygot.ResolvePath(telemetrypath.DeviceRoot("").System().CurrentDatetime())
 	if err != nil {
 		return fmt.Errorf("currentDateTimeTask failed to initialize due to error: %v", err)
@@ -153,7 +153,7 @@ func toStatePath(configPath *gpb.Path) *gpb.Path {
 }
 
 // systemBaseTask handles most of the logic for the base systems feature profile.
-func systemBaseTask(queue gnmit.Queue, updateFn gnmit.UpdateFn, target string, remove func()) error {
+func systemBaseTask(_ func() *config.Device, queue gnmit.Queue, updateFn gnmit.UpdateFn, target string, remove func()) error {
 	hostnamePath, _, err := ygot.ResolvePath(configpath.DeviceRoot("").System().Hostname())
 	if err != nil {
 		log.Errorf("systemBaseTask failed to initialize due to error: %v", err)
@@ -253,7 +253,7 @@ func systemBaseTask(queue gnmit.Queue, updateFn gnmit.UpdateFn, target string, r
 // syslogTask is a meaningless test task that monitors updates to the
 // current-datetime leaf and writes updates to the syslog message leaf whenever
 // the current-datetime leaf is updated.
-func syslogTask(queue gnmit.Queue, updateFn gnmit.UpdateFn, target string, remove func()) error {
+func syslogTask(_ func() *config.Device, queue gnmit.Queue, updateFn gnmit.UpdateFn, target string, remove func()) error {
 	pathSystemMsg, _, err := ygot.ResolvePath(telemetrypath.DeviceRoot("").System().Messages().Message().Msg())
 	if err != nil {
 		log.Errorf("syslogTask failed to initialize due to error: %v", err)
@@ -361,6 +361,15 @@ func tasks(target string) []gnmit.Task {
 			Origin: "openconfig",
 			Target: target,
 		},
+	}, {
+		Run: goBgpTask,
+		Paths: []ygot.PathStruct{
+			configpath.DeviceRoot("").NetworkInstance("default").Protocol(config.PolicyTypes_INSTALL_PROTOCOL_TYPE_BGP, "BGP").Bgp(),
+		},
+		Prefix: &gpb.Path{
+			Origin: "openconfig",
+			Target: target,
+		},
 	}}
 }