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

Changed to demoquandt git and fixed two remains.

parent 4f3488d3
No related branches found
No related tags found
1 merge request!9First working draft version
module code.fbi.h-da.de/demoquandt/emulated-kms module code.fbi.h-da.de/demoquandt/proto-kms
go 1.20 go 1.20
require github.com/google/uuid v1.3.0 require (
github.com/google/uuid v1.3.0
google.golang.org/grpc v1.56.1
google.golang.org/protobuf v1.31.0
)
require ( require (
github.com/fullstorydev/grpcurl v1.8.7 // indirect
github.com/golang/protobuf v1.5.3 // indirect github.com/golang/protobuf v1.5.3 // indirect
github.com/jhump/protoreflect v1.12.0 // indirect
golang.org/x/net v0.9.0 // indirect golang.org/x/net v0.9.0 // indirect
golang.org/x/sys v0.7.0 // indirect golang.org/x/sys v0.7.0 // indirect
golang.org/x/text v0.9.0 // indirect golang.org/x/text v0.9.0 // indirect
google.golang.org/genproto v0.0.0-20230410155749-daa745c078e1 // indirect google.golang.org/genproto v0.0.0-20230410155749-daa745c078e1 // indirect
google.golang.org/grpc v1.56.1 // indirect
google.golang.org/protobuf v1.30.0 // indirect
) )
This diff is collapsed.
...@@ -6,7 +6,7 @@ import ( ...@@ -6,7 +6,7 @@ import (
"log" "log"
"sync" "sync"
"code.fbi.h-da.de/m.stiemerling/proto-kms/quantumlayer" "code.fbi.h-da.de/demoquandt/proto-kms/quantumlayer"
) )
type kmsKS interface { type kmsKS interface {
......
...@@ -11,9 +11,9 @@ import ( ...@@ -11,9 +11,9 @@ import (
"sync" "sync"
"time" "time"
pbETSI "code.fbi.h-da.de/m.stiemerling/proto-kms/kmsetsiproto" pbETSI "code.fbi.h-da.de/demoquandt/proto-kms/kmsetsiproto"
pbIC "code.fbi.h-da.de/m.stiemerling/proto-kms/kmsintercomproto" pbIC "code.fbi.h-da.de/demoquandt/proto-kms/kmsintercomproto"
"code.fbi.h-da.de/m.stiemerling/proto-kms/quantumlayer" "code.fbi.h-da.de/demoquandt/proto-kms/quantumlayer"
"github.com/google/uuid" "github.com/google/uuid"
) )
......
...@@ -8,7 +8,7 @@ import ( ...@@ -8,7 +8,7 @@ import (
"log" "log"
"net" "net"
pb "code.fbi.h-da.de/m.stiemerling/proto-kms/kmsetsiproto" pb "code.fbi.h-da.de/demoquandt/proto-kms/kmsetsiproto"
"google.golang.org/grpc" "google.golang.org/grpc"
) )
......
...@@ -7,7 +7,7 @@ import ( ...@@ -7,7 +7,7 @@ import (
"log" "log"
"net" "net"
pb "code.fbi.h-da.de/m.stiemerling/proto-kms/kmsintercomproto" pb "code.fbi.h-da.de/demoquandt/proto-kms/kmsintercomproto"
"google.golang.org/grpc" "google.golang.org/grpc"
) )
......
...@@ -6,7 +6,7 @@ import ( ...@@ -6,7 +6,7 @@ import (
"net" "net"
"time" "time"
pb "code.fbi.h-da.de/m.stiemerling/proto-kms/kmsetsiproto" pb "code.fbi.h-da.de/demoquandt/proto-kms/kmsetsiproto"
"github.com/google/uuid" "github.com/google/uuid"
"google.golang.org/grpc" "google.golang.org/grpc"
"google.golang.org/grpc/credentials/insecure" "google.golang.org/grpc/credentials/insecure"
...@@ -39,7 +39,7 @@ type kmsPeer struct { ...@@ -39,7 +39,7 @@ type kmsPeer struct {
func NewKmsPeer(servQLE *QuantumElement, in chan string) (peer kmsPeer) { func NewKmsPeer(servQLE *QuantumElement, in chan string) (peer kmsPeer) {
return kmsPeer{ return kmsPeer{
peerStatus: kmsPeerUnknown, peerStatus: KmsPeerUnknown,
servingQLE: servQLE, servingQLE: servQLE,
id: uuid.New(), id: uuid.New(),
externalNotifierKMSPeer: in, externalNotifierKMSPeer: in,
...@@ -55,7 +55,7 @@ func (ph *kmsPeer) PeerHandler(kmsName string) { ...@@ -55,7 +55,7 @@ func (ph *kmsPeer) PeerHandler(kmsName string) {
newPeerConn, err := grpc.Dial(ph.tcpSocketStr, grpc.WithTransportCredentials(insecure.NewCredentials())) newPeerConn, err := grpc.Dial(ph.tcpSocketStr, grpc.WithTransportCredentials(insecure.NewCredentials()))
if err != nil { if err != nil {
log.Printf("did not connect: %v", err) log.Printf("did not connect: %v", err)
ph.peerStatus = kmsPeerDown ph.peerStatus = KmsPeerDown
return return
} }
defer newPeerConn.Close() defer newPeerConn.Close()
......
syntax = "proto3"; syntax = "proto3";
option go_package = "code.fbi.h-da.de/m.stiemerling/proto-kms/kmsetsiproto"; option go_package = "code.fbi.h-da.de/demoquandt/proto-kms/kmsetsiproto";
package kmsetsiproto; package kmsetsiproto;
......
syntax = "proto3"; syntax = "proto3";
option go_package = "code.fbi.h-da.de/m.stiemerling/proto-kms/kmsintercomproto"; option go_package = "code.fbi.h-da.de/demoquandt/proto-kms/kmsintercomproto";
package kmsintercomproto; package kmsintercomproto;
......
...@@ -10,7 +10,7 @@ import ( ...@@ -10,7 +10,7 @@ import (
"testing" "testing"
"time" "time"
"code.fbi.h-da.de/m.stiemerling/proto-kms/kms" "code.fbi.h-da.de/demoquandt/proto-kms/kms"
"github.com/google/uuid" "github.com/google/uuid"
) )
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment