diff --git a/cmd/gnmi/gnmi.go b/cmd/gnmi/gnmi.go index e629fcc63d90c86d1a8c502ad91f5564e9e92415..d2be72c93fa8f7d98a0da753d9601d0d6ecf0418 100644 --- a/cmd/gnmi/gnmi.go +++ b/cmd/gnmi/gnmi.go @@ -29,16 +29,16 @@ func main() { transport := &nucleus.Gnmi{SetNode: sbi.SetNode()} cfg := &gnmi.Config{ - Addr: "localhost:9339", + Addr: "portainer.danet.fbi.h-da.de:6030", Username: "admin", Password: "arista", - Encoding: gpb.Encoding_PROTO, + Encoding: gpb.Encoding_JSON_IETF, } transport.SetConfig(cfg) device.Transport = transport - p := []string{"/interfaces/interface[name=en0]/state/name"} + p := []string{"/interfaces/interface[name=*]/state/name"} errors := 0 for _, path := range p { err := pnd.RequestAll(path) diff --git a/nucleus/gnmi_transport.go b/nucleus/gnmi_transport.go index 2c0ad0c0178cfa816a97a0e4f68852b50182cd7c..5d9dde72e3fc9a4beb7d9bcfdb18d079579aa058 100644 --- a/nucleus/gnmi_transport.go +++ b/nucleus/gnmi_transport.go @@ -115,6 +115,7 @@ func (g *Gnmi) Capabilities(ctx context.Context) (interface{}, error) { // Get calls GNMI get func (g *Gnmi) get(ctx context.Context, paths [][]string, origin string) (interface{}, error) { + ctx = gnmi.NewContext(ctx, g.config) ctx = context.WithValue(ctx, "config", g.config) req, err := gnmi.NewGetRequest(ctx, paths, origin) if err != nil { @@ -140,6 +141,7 @@ func (g *Gnmi) getWithRequest(ctx context.Context, req *gpb.GetRequest) (interfa // Set calls GNMI set func (g *Gnmi) set(ctx context.Context, setOps []*gnmi.Operation, exts ...*gnmi_ext.Extension) error { + ctx = gnmi.NewContext(ctx, g.config) client, err := gnmi.Dial(g.config) if err != nil { return err @@ -149,6 +151,7 @@ func (g *Gnmi) set(ctx context.Context, setOps []*gnmi.Operation, // Subscribe calls GNMI subscribe func (g *Gnmi) subscribe(ctx context.Context) error { + ctx = gnmi.NewContext(ctx, g.config) client, err := gnmi.Dial(g.config) if err != nil { return err