Skip to content
Snippets Groups Projects

Draft: Akms ckms api implementation

Closed Neil-Jocelyn Schark requested to merge akms-ckms-api-implementation into master
2 files
+ 10
5
Compare changes
  • Side-by-side
  • Inline
Files
2
@@ -54,6 +54,8 @@ type Config struct {
Sync bool `yaml:"Sync"`
QuantumModule QuantumModule `yaml:"QuantumModule"`
} `yaml:"Peers"`
AkmsURL string `yaml:"AkmsURL"`
AkmsCkmsServerPort string `yaml:"AkmsCkmsServerPort"`
}
type QuantumModule struct {
@@ -126,8 +128,10 @@ func NewEkmsClient(bootInfo *Config) (myInfo *ekmsInfo) {
// TODO: return an error.
func emulatedKMS(config *Config, id uuid.UUID, peerChannel chan string) *kms.EKMS {
// Attach to eKMS
emuKMS := kms.NewEKMS(config.Name, id, os.Stdout, log.TraceLevel, false, config.InterComAddr)
akmsCkmsReceiverServer := akmsCkmsServer.NewAKMSReceiver("4567", emuKMS)
emuKMS := kms.NewEKMS(config.Name, id, os.Stdout, log.TraceLevel, false, config.InterComAddr, config.AkmsURL)
// Create AKMSReceiverServer object
akmsCkmsReceiverServer := akmsCkmsServer.NewAKMSReceiver(config.AkmsCkmsServerPort, emuKMS)
var qm kms.QuantumModule
var err error
@@ -172,8 +176,9 @@ func emulatedKMS(config *Config, id uuid.UUID, peerChannel chan string) *kms.EKM
// Start the SDN/management and key retrieval interface
go kms.StartETSI(config.GRPCAddr, emuKMS)
// Start the AKMSReceiverServer
// Start the akmsCkmsReceiverServer
go akmsCkmsReceiverServer.Serve()
return emuKMS
}
Loading