Versions in this module Expand all Collapse all v0 v0.0.1 Feb 23, 2024 Changes in this version + type Dispatcher struct + func NewDispatcher() *Dispatcher + func (b *Dispatcher) AddSubscriber(streamRequestor gnmi.GNMI_SubscribeServer) *Subscriber + func (b *Dispatcher) Broadcast(msg *gnmi.Notification, topics []string) + func (b *Dispatcher) GetSubscribers(topic string) int + func (b *Dispatcher) Publish(stringPath string, msg *gnmi.Notification) + func (b *Dispatcher) RemoveSubscriber(s *Subscriber) + func (b *Dispatcher) Subscribe(s *Subscriber, topic string) + func (b *Dispatcher) Unsubscribe(s *Subscriber, topic string) + type InfoChangeMessage struct + func NewInfoChangeMessage(msg *gnmi.Notification, yangPath string) *InfoChangeMessage + func (m *InfoChangeMessage) GetMessageBody() *gnmi.Notification + func (m *InfoChangeMessage) GetYangPath() string + type Subscriber struct + func CreateNewSubscriber(streamRequestor gnmi.GNMI_SubscribeServer) (string, *Subscriber) + func (s *Subscriber) AddTopic(topic string) + func (s *Subscriber) Destruct() + func (s *Subscriber) GetTopics() []string + func (s *Subscriber) GetstreamRequestor() gnmi.GNMI_SubscribeServer + func (s *Subscriber) Listen() + func (s *Subscriber) RemoveTopic(topic string) + func (s *Subscriber) ReturnListenChannel() (pubChannel chan *InfoChangeMessage) + func (s *Subscriber) Signal(msg *InfoChangeMessage) + type Subscribers map[string]*Subscriber