diff --git a/kms/kmspeers.go b/kms/kmspeers.go index 67d2bdb61f4a33d33ee9aecc25230e1583758041..9a37de516d344f343d1420a6193393e96f213963 100644 --- a/kms/kmspeers.go +++ b/kms/kmspeers.go @@ -15,10 +15,10 @@ import ( type KmsPeerStatus int16 const ( - kmsPeerUp KmsPeerStatus = iota // peer was seen up lately - kmsPeerDown // peer not reachable anymore - kmsPeerPending // peer was added and has to be succesfully contacted once - kmsPeerUnknown // not known, not initialized + KmsPeerUp KmsPeerStatus = iota // peer was seen up lately + KmsPeerDown // peer not reachable anymore + KmsPeerPending // peer was added and has to be succesfully contacted once + KmsPeerUnknown // not known, not initialized ) type kmsPeerInfo interface { @@ -68,7 +68,7 @@ func (ph *kmsPeer) PeerHandler(kmsName string) { r, err := c.ETSICapabilities(ctx, &pb.ETSICapabilitiesRequest{MyKmsName: kmsName}) if err != nil { log.Printf("could not greet: %v", err) - ph.peerStatus = kmsPeerDown + ph.peerStatus = KmsPeerDown // Send notification about change if ph.externalNotifierKMSPeer != nil { ph.externalNotifierKMSPeer <- ph.tcpSocketStr @@ -76,7 +76,7 @@ func (ph *kmsPeer) PeerHandler(kmsName string) { return } // Works and peer moves to kmsPeerUp - ph.peerStatus = kmsPeerUp + ph.peerStatus = KmsPeerUp // Send notification about change if ph.externalNotifierKMSPeer != nil { @@ -94,7 +94,7 @@ func (ph *kmsPeer) PeerHandler(kmsName string) { _, err := c.ETSICapabilities(ctx, &pb.ETSICapabilitiesRequest{MyKmsName: kmsName}) if err != nil { log.Printf("could not greet: %v", err) - ph.peerStatus = kmsPeerDown + ph.peerStatus = KmsPeerDown // Send notification about change if ph.externalNotifierKMSPeer != nil { ph.externalNotifierKMSPeer <- ph.tcpSocketStr