Skip to content
Snippets Groups Projects

Resolve "Implement gNMI subscription management"

Merged Fabian Seidl requested to merge 382-implement-gnmi-subscription-management into master
2 files
+ 26
8
Compare changes
  • Side-by-side
  • Inline
Files
2
@@ -27,8 +27,7 @@ func (s *SubManagementServer) ResetAllSubscriptions(ctx context.Context, request
s.networkElementWatchter.StopAndRemoveAllNetworkElementSubscriptions()
// Requires some rework of current way how paths/options are provided to the watcher.
s.networkElementWatchter.SubscribeToNetworkElements(subscriptions[0].Opts)
s.networkElementWatchter.SubscribeToNetworkElements(subscriptions)
return &subpb.ResetAllSubscriptionsResponse{
Timestamp: time.Now().UnixNano(),
@@ -42,7 +41,6 @@ func (s *SubManagementServer) GetAll(ctx context.Context, request *subpb.GetAllR
subInfosToReturn := make([]*subpb.Subscription, 0)
for _, info := range subInfos {
tmpPaths := make([]*subpb.Path, 0)
for _, path := range info.Opts.Paths {
tmpPaths = append(tmpPaths, &subpb.Path{
Loading