Skip to content
Snippets Groups Projects
Commit 810bf77f authored by Martin Stiemerling's avatar Martin Stiemerling :speech_balloon:
Browse files

Added Functions needed for KMS peer handling

parent c538ecf3
No related branches found
No related tags found
2 merge requests!9First working draft version,!6Added Functions needed for KMS peer handling
......@@ -12,20 +12,23 @@ import (
"google.golang.org/grpc/credentials/insecure"
)
type kmsPeerStatus int16
type KmsPeerStatus int16
const (
kmsPeerUp kmsPeerStatus = iota // peer was seen up lately
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 {
GetKmsPeerStatus() KmsPeerStatus
GetKmsPeerId() uuid.UUID
GetKmsPeerQkdiId() uint32
}
type kmsPeer struct {
peerStatus kmsPeerStatus
peerStatus KmsPeerStatus
servingQLE *QuantumElement
tcpSocket net.TCPAddr // the IP address and TCP port (aka socket) of the kms peer
tcpSocketStr string // string rep. of tcpSocket
......@@ -37,6 +40,7 @@ func NewKmsPeer(servQLE *QuantumElement) (peer kmsPeer) {
return kmsPeer{
peerStatus: kmsPeerUnknown,
servingQLE: servQLE,
id: uuid.New(),
}
}
......@@ -71,3 +75,15 @@ func (ph *kmsPeer) PeerHandler(kmsName string) {
log.Printf("Greeting: %s which is now in peerStatus %d", r.GetPeerKmsName(), ph.peerStatus)
}
func (ph *kmsPeer) GetKmsPeerStatus() KmsPeerStatus {
return ph.peerStatus
}
func (ph *kmsPeer) GetKmsPeerId() uuid.UUID {
return ph.id
}
func (ph *kmsPeer) GetKmsPeerQkdiId() uint32 {
return uint32(ph.servingQLE.qlID)
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment