Skip to content
Snippets Groups Projects

Resolve "Implement gNMI subscription management"

Merged Fabian Seidl requested to merge 382-implement-gnmi-subscription-management into master
1 file
+ 3
2
Compare changes
  • Side-by-side
  • Inline
@@ -23,11 +23,12 @@ func NewSubManagementServer(networkElementWatchter *nucleus.NetworkElementWatche
// ResetAllSubscriptions stops all running subscriptions and restarts them the same way they ran before.
func (s *SubManagementServer) ResetAllSubscriptions(ctx context.Context, request *subpb.ResetAllSubscriptionsRequest) (*subpb.ResetAllSubscriptionsResponse, error) {
subscriptions := s.networkElementWatchter.GetAllSubscriptionInformations()
s.networkElementWatchter.StopAndRemoveAllNetworkElementSubscriptions()
//TODO: first get all relevant sub information and then provide the options here.
// Requires some rework of current way how paths/options are provided to the watcher.
s.networkElementWatchter.SubscribeToNetworkElements(nil)
s.networkElementWatchter.SubscribeToNetworkElements(subscriptions[0].Opts)
return &subpb.ResetAllSubscriptionsResponse{
Timestamp: time.Now().UnixNano(),
Loading