gravitl/netmaker
1
1
Fork 0
mirror of https://github.com/gravitl/netmaker.git synced 2025-10-08 21:05:54 +08:00
Code Issues Projects Releases Packages Wiki Activity

pr comments

Browse source
This commit is contained in:
Abhishek Kondur 2023-01-06 21:27:40 +05:30
parent 2e7f9524e3
commit 023f29ee71
2 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
models/metrics.go
View file

@ -43,6 +43,7 @@ type IDandAddr struct {
// PeerMap - peer map for ids and addresses in metrics // PeerMap - peer map for ids and addresses in metrics
type PeerMap map[string]IDandAddr type PeerMap map[string]IDandAddr
// HostPeerMap - host peer map for ids and addresses
type HostPeerMap map[string]map[string]IDandAddr type HostPeerMap map[string]map[string]IDandAddr
// MetricsMap - map for holding multiple metrics in memory // MetricsMap - map for holding multiple metrics in memory

4
mq/publishers.go
View file

@ -14,7 +14,7 @@ import (
"github.com/gravitl/netmaker/serverctl" "github.com/gravitl/netmaker/serverctl"
) )
// PublishPeerUpdate --- deterines and publishes a peer update to all the peers of a node // PublishPeerUpdate --- determines and publishes a peer update to all the hosts
func PublishPeerUpdate(network string, publishToSelf bool) error { func PublishPeerUpdate(network string, publishToSelf bool) error {
if !servercfg.IsMessageQueueBackend() { if !servercfg.IsMessageQueueBackend() {
return nil return nil
@ -48,7 +48,7 @@ func PublishProxyPeerUpdate(node *models.Node) error {
return nil return nil
} }
// PublishSinglePeerUpdate --- determines and publishes a peer update to one node // PublishSingleHostUpdate --- determines and publishes a peer update to one host
func PublishSingleHostUpdate(host *models.Host) error { func PublishSingleHostUpdate(host *models.Host) error {
peerUpdate, err := logic.GetPeerUpdateForHost(host) peerUpdate, err := logic.GetPeerUpdateForHost(host)