From b05a327d4c59f98d19ebece3e8ba51b004b24833 Mon Sep 17 00:00:00 2001
From: Manuel Kieweg <mail@manuelkieweg.de>
Date: Thu, 11 Feb 2021 10:04:54 +0000
Subject: [PATCH] Fixed telemetry.go
---
cmd/gnmi-telemetry/telemetry.go | 29 ++++++++++++++---------------
1 file changed, 14 insertions(+), 15 deletions(-)
diff --git a/cmd/gnmi-telemetry/telemetry.go b/cmd/gnmi-telemetry/telemetry.go
index b89717f91..98650bd09 100644
--- a/cmd/gnmi-telemetry/telemetry.go
+++ b/cmd/gnmi-telemetry/telemetry.go
@@ -17,33 +17,32 @@ import (
func main() {
log.SetLevel(log.DebugLevel)
sbi := &nucleus.AristaOC{}
- transport := &nucleus.Gnmi{
- SetNode: sbi.SetNode(),
- RespChan: make(chan *gpb.SubscribeResponse),
- }
+
device := nucleus.Device{
GoStruct: sbi.Schema().Root,
SBI: sbi,
Config: nucleus.DeviceConfig{
- Uuid: uuid.New(),
- Address: "localhost:9339",
- Username: "admin",
- Password: "arista",
+ Uuid: uuid.New(),
},
- Transport: transport,
}
pnd := nucleus.NewPND("openconfig", "a simple openconfig PND", sbi)
if err := pnd.AddDevice(&device); err != nil {
log.Fatal(err)
}
+ transport := &nucleus.Gnmi{
+ SetNode: sbi.SetNode(),
+ RespChan: make(chan *gpb.SubscribeResponse),
+ }
cfg := &gnmi.Config{
- Addr: device.Config.Address,
- Password: device.Config.Password,
- Username: device.Config.Username,
+ Addr: "portainer.danet.fbi.h-da.de:6030",
+ Username: "admin",
+ Password: "arista",
+ Encoding: gpb.Encoding_JSON_IETF,
}
- ctx := gnmi.NewContext(context.Background(), cfg)
- ctx = context.WithValue(ctx, "config", cfg)
+ transport.SetConfig(cfg)
+
+ device.Transport = transport
paths := []string{"/interfaces/interface/name"}
@@ -61,7 +60,7 @@ func main() {
}
done := make(chan os.Signal, 1)
signal.Notify(done, syscall.SIGILL, syscall.SIGTERM)
- ctx = context.WithValue(ctx, "opts", opts)
+ ctx := context.WithValue(context.Background(), "opts", opts)
go func() {
if err := transport.Subscribe(ctx); err != nil {
log.Fatal(err)
--
GitLab