first attempt to add dkg metrics

Author: jbsv

contracts/evoting/mod.go

@@ -49,6 +49,13 @@ var (
 	},
 		[]string{"election"},
 	)
+
+	PromElectionDkgStatus = prometheus.NewGaugeVec(prometheus.GaugeOpts{
+		Name: "dvoting_dkg_status",
+		Help: "status of distributed key generator",
+	},
+		[]string{"election"},
+	)
 )
 
 const (

services/dkg/pedersen/mod.go

@@ -12,6 +12,7 @@ import (
 	"go.dedis.ch/dela"
 	"go.dedis.ch/dela/core/ordering"
 
+	"github.com/dedis/d-voting/contracts/evoting"
 	etypes "github.com/dedis/d-voting/contracts/evoting/types"
 
 	"github.com/dedis/d-voting/internal/tracing"
@@ -134,6 +135,8 @@ func (s *Pedersen) NewActor(electionIDBuf []byte, pool pool.Pool, txmngr txn.Man
 		status:      dkg.Status{Status: dkg.Initialized},
 	}
 
+	evoting.PromElectionDkgStatus.WithLabelValues(electionID).Set(float64(dkg.Initialized))
+
 	s.Lock()
 	defer s.Unlock()
 	s.actors[electionID] = a
@@ -169,6 +172,8 @@ func (a *Actor) setErr(err error, args map[string]interface{}) {
 		Err:    err,
 		Args:   args,
 	}
+
+	evoting.PromElectionDkgStatus.WithLabelValues(a.electionID).Set(float64(dkg.Failed))
 }
 
 // Setup implements dkg.Actor. It initializes the DKG protocol across all
@@ -297,6 +302,7 @@ func (a *Actor) Setup() (kyber.Point, error) {
 	}
 
 	a.status = dkg.Status{Status: dkg.Setup}
+	evoting.PromElectionDkgStatus.WithLabelValues(a.electionID).Set(float64(dkg.Setup))
 
 	return dkgPubKeys[0], nil
 }

services/dkg/pedersen/mod_test.go

@@ -14,10 +14,12 @@ import (
 	"go.dedis.ch/dela/core/validation"
 	"golang.org/x/xerrors"
 
+	"github.com/dedis/d-voting/contracts/evoting"
 	etypes "github.com/dedis/d-voting/contracts/evoting/types"
 	"github.com/dedis/d-voting/internal/testing/fake"
 	"github.com/dedis/d-voting/services/dkg"
 	"github.com/dedis/d-voting/services/dkg/pedersen/types"
+	"github.com/prometheus/client_golang/prometheus/testutil"
 	"github.com/stretchr/testify/require"
 	"go.dedis.ch/dela/core/ordering/cosipbft/authority"
 	"go.dedis.ch/dela/core/store/kv"
@@ -301,6 +303,8 @@ func TestPedersen_TwoListens(t *testing.T) {
 }
 
 func TestPedersen_Setup(t *testing.T) {
+	initMetrics()
+
 	electionID := "d3adbeef"
 
 	service := fake.NewService(electionID, etypes.Election{
@@ -325,6 +329,7 @@ func TestPedersen_Setup(t *testing.T) {
 
 	_, err := actor.Setup()
 	require.EqualError(t, err, "failed to get election: election does not exist: <nil>")
+	require.Equal(t, float64(dkg.Failed), testutil.ToFloat64(evoting.PromElectionDkgStatus))
 
 	actor.electionID = electionID
 
@@ -333,6 +338,7 @@ func TestPedersen_Setup(t *testing.T) {
 
 	_, err = actor.Setup()
 	require.EqualError(t, err, fake.Err("failed to stream"))
+	require.Equal(t, float64(dkg.Failed), testutil.ToFloat64(evoting.PromElectionDkgStatus))
 
 	// RPC is bogus 2
 	actor.rpc = fake.NewRPC()
@@ -396,6 +402,7 @@ func TestPedersen_Setup(t *testing.T) {
 	// We test that particular behaviour later.
 	_, err = actor.Setup()
 	require.NoError(t, err)
+	require.Equal(t, float64(dkg.Setup), testutil.ToFloat64(evoting.PromElectionDkgStatus))
 }
 
 func TestPedersen_GetPublicKey(t *testing.T) {
@@ -623,6 +630,10 @@ func TestPedersen_ComputePubshares_OK(t *testing.T) {
 // -----------------------------------------------------------------------------
 // Utility functions
 
+func initMetrics() {
+	evoting.PromElectionDkgStatus.Reset()
+}
+
 // actorsEqual checks that two actors hold the same data
 func requireActorsEqual(t require.TestingT, actor1, actor2 dkg.Actor) {
 	actor1Data, err := actor1.MarshalJSON()