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

Merge branch 'provide-docker-containers' into 'main'

Add docker-compose

See merge request m.stiemerling/proto-kms!3
parents 1c236d5b 26645a7f
No related branches found
No related tags found
1 merge request!8Create a monorepo for ekms and quantumlayer
...@@ -23,9 +23,9 @@ import ( ...@@ -23,9 +23,9 @@ import (
) )
type QuantumPayloadElement struct { type QuantumPayloadElement struct {
BulkKeyId int64 // the unique ID of this bulk of keys BulkKeyId int64 `json:"bulk-key-id"` // the unique ID of this bulk of keys
BulkKeyLength int // the length, counted in bytes, of bulkKey BulkKeyLength int `json:"bulk-key-length"` // the length, counted in bytes, of bulkKey
BulkKey *[]byte // the bulk key BulkKey *[]byte `json:"bulk-key"` // the bulk key
} }
type QuantumlayerEmuPRNG struct { type QuantumlayerEmuPRNG struct {
...@@ -74,6 +74,7 @@ func (qlemuprng *QuantumlayerEmuPRNG) PowerOn(localQLAddress ...string) { ...@@ -74,6 +74,7 @@ func (qlemuprng *QuantumlayerEmuPRNG) PowerOn(localQLAddress ...string) {
udpAddrString = localQLAddress[0] udpAddrString = localQLAddress[0]
} }
log.Printf("localQLAddress is %s", localQLAddress[0]) log.Printf("localQLAddress is %s", localQLAddress[0])
// This reads random numbers from other Quantum end // This reads random numbers from other Quantum end
udpSrvPort, err := net.ResolveUDPAddr("udp", udpAddrString) udpSrvPort, err := net.ResolveUDPAddr("udp", udpAddrString)
if err != nil { if err != nil {
...@@ -178,7 +179,6 @@ func (qlemuprng *QuantumlayerEmuPRNG) AddPeer(addr net.UDPAddr) { ...@@ -178,7 +179,6 @@ func (qlemuprng *QuantumlayerEmuPRNG) AddPeer(addr net.UDPAddr) {
} }
} }
}(ctx) }(ctx)
} }
func (qlemuprng *QuantumlayerEmuPRNG) RemovePeer() { func (qlemuprng *QuantumlayerEmuPRNG) RemovePeer() {
...@@ -297,5 +297,4 @@ func (store *NumberStore) receiveNumbers(incoming chan QuantumPayloadElement) { ...@@ -297,5 +297,4 @@ func (store *NumberStore) receiveNumbers(incoming chan QuantumPayloadElement) {
store.mu.Unlock() store.mu.Unlock()
} }
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment