Add grafana dashboards.

Fix ports in agents and qed server.

balloon/balloon.go

@@ -28,6 +28,8 @@ import (
 	"github.com/bbva/qed/metrics"
 	"github.com/bbva/qed/storage"
 	"github.com/bbva/qed/util"
+
+	"github.com/prometheus/client_golang/prometheus"
 )
 
 var (
@@ -180,6 +182,11 @@ func (b *Balloon) RefreshVersion() error {
 
 func (b *Balloon) Add(event []byte) (*Snapshot, []*storage.Mutation, error) {
 
+	// Metrics
+	metrics.Qed_balloon_add_total.Inc()
+	timer := prometheus.NewTimer(metrics.Qed_balloon_add_duration_seconds)
+	defer timer.ObserveDuration()
+
 	// Activate metrics gathering
 	stats := metrics.Balloon
 
@@ -281,10 +288,22 @@ func (b Balloon) QueryDigestMembership(keyDigest hashing.Digest, version uint64)
 
 func (b Balloon) QueryMembership(event []byte, version uint64) (*MembershipProof, error) {
 	hasher := b.hasherF()
+
+	// Metrics
+	metrics.Qed_balloon_membership_total.Inc()
+	timer := prometheus.NewTimer(metrics.Qed_balloon_membership_duration_seconds)
+	defer timer.ObserveDuration()
+
 	return b.QueryDigestMembership(hasher.Do(event), version)
 }
 
 func (b Balloon) QueryConsistency(start, end uint64) (*IncrementalProof, error) {
+
+	// Metrics
+	metrics.Qed_balloon_incremental_total.Inc()
+	timer := prometheus.NewTimer(metrics.Qed_balloon_incremental_duration_seconds)
+	defer timer.ObserveDuration()
+
 	stats := metrics.Balloon
 	stats.AddFloat("QueryConsistency", 1)
 	var proof IncrementalProof

cmd/agent_auditor.go

@@ -41,11 +41,12 @@ func newAgentAuditorCommand(ctx cmdContext, config gossip.Config, agentPreRun fu
 			config = agentPreRun(config)
 
 			// Bindings
+			auditorConfig.MetricsAddr = config.BindAddr // TODO: make MetricsAddr configurable
 			auditorConfig.QEDUrls = v.GetStringSlice("agent.server_urls")
 			auditorConfig.PubUrls = v.GetStringSlice("agent.alert_urls")
+
 			markSliceStringRequired(auditorConfig.QEDUrls, "qedUrls")
 			markSliceStringRequired(auditorConfig.PubUrls, "pubUrls")
-
 		},
 		Run: func(cmd *cobra.Command, args []string) {
 

cmd/agent_monitor.go

@@ -41,11 +41,12 @@ func newAgentMonitorCommand(ctx cmdContext, config gossip.Config, agentPreRun fu
 			config = agentPreRun(config)
 
 			// Bindings
+			monitorConfig.MetricsAddr = config.BindAddr // TODO: make MetricsAddr configurable
 			monitorConfig.QEDUrls = v.GetStringSlice("agent.server_urls")
 			monitorConfig.PubUrls = v.GetStringSlice("agent.alert_urls")
+
 			markSliceStringRequired(monitorConfig.QEDUrls, "qedUrls")
 			markSliceStringRequired(monitorConfig.PubUrls, "pubUrls")
-
 		},
 		Run: func(cmd *cobra.Command, args []string) {
 

cmd/agent_publisher.go

@@ -26,7 +26,7 @@ import (
 
 func newAgentPublisherCommand(ctx cmdContext, config gossip.Config, agentPreRun func(gossip.Config) gossip.Config) *cobra.Command {
 
-	var endpoints []string
+	publisherConfig := publisher.DefaultConfig()
 
 	cmd := &cobra.Command{
 		Use:   "publisher",
@@ -41,14 +41,14 @@ func newAgentPublisherCommand(ctx cmdContext, config gossip.Config, agentPreRun
 			config = agentPreRun(config)
 
 			// Bindings
-			endpoints = v.GetStringSlice("agent.snapshots_store_urls")
-			markSliceStringRequired(endpoints, "pubUrls")
+			publisherConfig.MetricsAddr = config.BindAddr // TODO: make MetricsAddr configurable
+			publisherConfig.PubUrls = v.GetStringSlice("agent.snapshots_store_urls")
 
+			markSliceStringRequired(publisherConfig.PubUrls, "pubUrls")
 		},
 		Run: func(cmd *cobra.Command, args []string) {
 
 			config.Role = member.Publisher
-			publisherConfig := publisher.NewConfig(endpoints)
 
 			publisher, err := publisher.NewPublisher(*publisherConfig)
 			if err != nil {
@@ -72,7 +72,7 @@ func newAgentPublisherCommand(ctx cmdContext, config gossip.Config, agentPreRun
 	}
 
 	f := cmd.Flags()
-	f.StringSliceVarP(&endpoints, "pubUrls", "", []string{},
+	f.StringSliceVarP(&publisherConfig.PubUrls, "pubUrls", "", []string{},
 		"Comma-delimited list of end-publishers ([host]:port), through which an publisher can send requests")
 
 	// Lookups