Skip to content
Snippets Groups Projects
Commit 2019fbb6 authored by Malte Bauch's avatar Malte Bauch
Browse files

Internal key id representation is now uuid for key storage

parent 33426ec3
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
Showing
with 462 additions and 214 deletions
api/gen/proto/go/kmsintercom/kmsintercom.pb.go
+ 297
− 132
View file @ 2019fbb6
......@@ -196,6 +196,124 @@ func (x *SyncQkdBulkRequest) GetBulkId() []int64 {
return nil
}
type SyncKeyIdsForBulkRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
InterComAddr string `protobuf:"bytes,2,opt,name=interComAddr,proto3" json:"interComAddr,omitempty"`
BulkId int64 `protobuf:"varint,3,opt,name=bulkId,proto3" json:"bulkId,omitempty"`
KeyId []string `protobuf:"bytes,4,rep,name=keyId,proto3" json:"keyId,omitempty"`
}
func (x *SyncKeyIdsForBulkRequest) Reset() {
*x = SyncKeyIdsForBulkRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *SyncKeyIdsForBulkRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SyncKeyIdsForBulkRequest) ProtoMessage() {}
func (x *SyncKeyIdsForBulkRequest) ProtoReflect() protoreflect.Message {
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[3]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use SyncKeyIdsForBulkRequest.ProtoReflect.Descriptor instead.
func (*SyncKeyIdsForBulkRequest) Descriptor() ([]byte, []int) {
return file_kmsintercom_kmsintercom_proto_rawDescGZIP(), []int{3}
}
func (x *SyncKeyIdsForBulkRequest) GetTimestamp() int64 {
if x != nil {
return x.Timestamp
}
return 0
}
func (x *SyncKeyIdsForBulkRequest) GetInterComAddr() string {
if x != nil {
return x.InterComAddr
}
return ""
}
func (x *SyncKeyIdsForBulkRequest) GetBulkId() int64 {
if x != nil {
return x.BulkId
}
return 0
}
func (x *SyncKeyIdsForBulkRequest) GetKeyId() []string {
if x != nil {
return x.KeyId
}
return nil
}
type SyncKeyIdsForBulkResponse struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}
func (x *SyncKeyIdsForBulkResponse) Reset() {
*x = SyncKeyIdsForBulkResponse{}
if protoimpl.UnsafeEnabled {
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *SyncKeyIdsForBulkResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SyncKeyIdsForBulkResponse) ProtoMessage() {}
func (x *SyncKeyIdsForBulkResponse) ProtoReflect() protoreflect.Message {
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[4]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use SyncKeyIdsForBulkResponse.ProtoReflect.Descriptor instead.
func (*SyncKeyIdsForBulkResponse) Descriptor() ([]byte, []int) {
return file_kmsintercom_kmsintercom_proto_rawDescGZIP(), []int{4}
}
func (x *SyncKeyIdsForBulkResponse) GetTimestamp() int64 {
if x != nil {
return x.Timestamp
}
return 0
}
type SyncQkdBulkResponse struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
......@@ -208,7 +326,7 @@ type SyncQkdBulkResponse struct {
func (x *SyncQkdBulkResponse) Reset() {
*x = SyncQkdBulkResponse{}
if protoimpl.UnsafeEnabled {
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[3]
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
......@@ -221,7 +339,7 @@ func (x *SyncQkdBulkResponse) String() string {
func (*SyncQkdBulkResponse) ProtoMessage() {}
func (x *SyncQkdBulkResponse) ProtoReflect() protoreflect.Message {
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[3]
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[5]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
......@@ -234,7 +352,7 @@ func (x *SyncQkdBulkResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use SyncQkdBulkResponse.ProtoReflect.Descriptor instead.
func (*SyncQkdBulkResponse) Descriptor() ([]byte, []int) {
return file_kmsintercom_kmsintercom_proto_rawDescGZIP(), []int{3}
return file_kmsintercom_kmsintercom_proto_rawDescGZIP(), []int{5}
}
func (x *SyncQkdBulkResponse) GetTimestamp() int64 {
......@@ -259,13 +377,13 @@ type InterComTransportKeyNegotiationRequest struct {
Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
PathID string `protobuf:"bytes,2,opt,name=pathID,proto3" json:"pathID,omitempty"`
KeyToUse uint64 `protobuf:"varint,3,opt,name=keyToUse,proto3" json:"keyToUse,omitempty"`
KeyToUse string `protobuf:"bytes,3,opt,name=keyToUse,proto3" json:"keyToUse,omitempty"`
}
func (x *InterComTransportKeyNegotiationRequest) Reset() {
*x = InterComTransportKeyNegotiationRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[4]
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
......@@ -278,7 +396,7 @@ func (x *InterComTransportKeyNegotiationRequest) String() string {
func (*InterComTransportKeyNegotiationRequest) ProtoMessage() {}
func (x *InterComTransportKeyNegotiationRequest) ProtoReflect() protoreflect.Message {
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[4]
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[6]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
......@@ -291,7 +409,7 @@ func (x *InterComTransportKeyNegotiationRequest) ProtoReflect() protoreflect.Mes
// Deprecated: Use InterComTransportKeyNegotiationRequest.ProtoReflect.Descriptor instead.
func (*InterComTransportKeyNegotiationRequest) Descriptor() ([]byte, []int) {
return file_kmsintercom_kmsintercom_proto_rawDescGZIP(), []int{4}
return file_kmsintercom_kmsintercom_proto_rawDescGZIP(), []int{6}
}
func (x *InterComTransportKeyNegotiationRequest) GetTimestamp() int64 {
......@@ -308,11 +426,11 @@ func (x *InterComTransportKeyNegotiationRequest) GetPathID() string {
return ""
}
func (x *InterComTransportKeyNegotiationRequest) GetKeyToUse() uint64 {
func (x *InterComTransportKeyNegotiationRequest) GetKeyToUse() string {
if x != nil {
return x.KeyToUse
}
return 0
return ""
}
type InterComTransportKeyNegotiationResponse struct {
......@@ -326,7 +444,7 @@ type InterComTransportKeyNegotiationResponse struct {
func (x *InterComTransportKeyNegotiationResponse) Reset() {
*x = InterComTransportKeyNegotiationResponse{}
if protoimpl.UnsafeEnabled {
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[5]
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
......@@ -339,7 +457,7 @@ func (x *InterComTransportKeyNegotiationResponse) String() string {
func (*InterComTransportKeyNegotiationResponse) ProtoMessage() {}
func (x *InterComTransportKeyNegotiationResponse) ProtoReflect() protoreflect.Message {
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[5]
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[7]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
......@@ -352,7 +470,7 @@ func (x *InterComTransportKeyNegotiationResponse) ProtoReflect() protoreflect.Me
// Deprecated: Use InterComTransportKeyNegotiationResponse.ProtoReflect.Descriptor instead.
func (*InterComTransportKeyNegotiationResponse) Descriptor() ([]byte, []int) {
return file_kmsintercom_kmsintercom_proto_rawDescGZIP(), []int{5}
return file_kmsintercom_kmsintercom_proto_rawDescGZIP(), []int{7}
}
func (x *InterComTransportKeyNegotiationResponse) GetTimestamp() int64 {
......@@ -375,7 +493,7 @@ type KeyForwardingRequest struct {
func (x *KeyForwardingRequest) Reset() {
*x = KeyForwardingRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[6]
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[8]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
......@@ -388,7 +506,7 @@ func (x *KeyForwardingRequest) String() string {
func (*KeyForwardingRequest) ProtoMessage() {}
func (x *KeyForwardingRequest) ProtoReflect() protoreflect.Message {
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[6]
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[8]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
......@@ -401,7 +519,7 @@ func (x *KeyForwardingRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use KeyForwardingRequest.ProtoReflect.Descriptor instead.
func (*KeyForwardingRequest) Descriptor() ([]byte, []int) {
return file_kmsintercom_kmsintercom_proto_rawDescGZIP(), []int{6}
return file_kmsintercom_kmsintercom_proto_rawDescGZIP(), []int{8}
}
func (x *KeyForwardingRequest) GetTimestamp() int64 {
......@@ -436,7 +554,7 @@ type KeyForwardingResponse struct {
func (x *KeyForwardingResponse) Reset() {
*x = KeyForwardingResponse{}
if protoimpl.UnsafeEnabled {
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[7]
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[9]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
......@@ -449,7 +567,7 @@ func (x *KeyForwardingResponse) String() string {
func (*KeyForwardingResponse) ProtoMessage() {}
func (x *KeyForwardingResponse) ProtoReflect() protoreflect.Message {
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[7]
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[9]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
......@@ -462,7 +580,7 @@ func (x *KeyForwardingResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use KeyForwardingResponse.ProtoReflect.Descriptor instead.
func (*KeyForwardingResponse) Descriptor() ([]byte, []int) {
return file_kmsintercom_kmsintercom_proto_rawDescGZIP(), []int{7}
return file_kmsintercom_kmsintercom_proto_rawDescGZIP(), []int{9}
}
func (x *KeyForwardingResponse) GetTimestamp() int64 {
......@@ -485,7 +603,7 @@ type KeyIdNotificationRequest struct {
func (x *KeyIdNotificationRequest) Reset() {
*x = KeyIdNotificationRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[8]
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[10]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
......@@ -498,7 +616,7 @@ func (x *KeyIdNotificationRequest) String() string {
func (*KeyIdNotificationRequest) ProtoMessage() {}
func (x *KeyIdNotificationRequest) ProtoReflect() protoreflect.Message {
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[8]
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[10]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
......@@ -511,7 +629,7 @@ func (x *KeyIdNotificationRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use KeyIdNotificationRequest.ProtoReflect.Descriptor instead.
func (*KeyIdNotificationRequest) Descriptor() ([]byte, []int) {
return file_kmsintercom_kmsintercom_proto_rawDescGZIP(), []int{8}
return file_kmsintercom_kmsintercom_proto_rawDescGZIP(), []int{10}
}
func (x *KeyIdNotificationRequest) GetTimestamp() int64 {
......@@ -546,7 +664,7 @@ type KeyIdNotificationResponse struct {
func (x *KeyIdNotificationResponse) Reset() {
*x = KeyIdNotificationResponse{}
if protoimpl.UnsafeEnabled {
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[9]
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[11]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
......@@ -559,7 +677,7 @@ func (x *KeyIdNotificationResponse) String() string {
func (*KeyIdNotificationResponse) ProtoMessage() {}
func (x *KeyIdNotificationResponse) ProtoReflect() protoreflect.Message {
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[9]
mi := &file_kmsintercom_kmsintercom_proto_msgTypes[11]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
......@@ -572,7 +690,7 @@ func (x *KeyIdNotificationResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use KeyIdNotificationResponse.ProtoReflect.Descriptor instead.
func (*KeyIdNotificationResponse) Descriptor() ([]byte, []int) {
return file_kmsintercom_kmsintercom_proto_rawDescGZIP(), []int{9}
return file_kmsintercom_kmsintercom_proto_rawDescGZIP(), []int{11}
}
func (x *KeyIdNotificationResponse) GetTimestamp() int64 {
......@@ -606,90 +724,109 @@ var file_kmsintercom_kmsintercom_proto_rawDesc = []byte{
0x72, 0x43, 0x6f, 0x6d, 0x41, 0x64, 0x64, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c,
0x69, 0x6e, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6d, 0x41, 0x64, 0x64, 0x72, 0x12, 0x16, 0x0a, 0x06,
0x62, 0x75, 0x6c, 0x6b, 0x49, 0x64, 0x18, 0x03, 0x20, 0x03, 0x28, 0x03, 0x52, 0x06, 0x62, 0x75,
0x6c, 0x6b, 0x49, 0x64, 0x22, 0x4b, 0x0a, 0x13, 0x53, 0x79, 0x6e, 0x63, 0x51, 0x6b, 0x64, 0x42,
0x75, 0x6c, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x74,
0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09,
0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12, 0x16, 0x0a, 0x06, 0x62, 0x75, 0x6c,
0x6b, 0x49, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x62, 0x75, 0x6c, 0x6b, 0x49,
0x64, 0x22, 0x7a, 0x0a, 0x26, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6d, 0x54, 0x72, 0x61,
0x6e, 0x73, 0x70, 0x6f, 0x72, 0x74, 0x4b, 0x65, 0x79, 0x4e, 0x65, 0x67, 0x6f, 0x74, 0x69, 0x61,
0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1c, 0x0a, 0x09, 0x74,
0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09,
0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12, 0x16, 0x0a, 0x06, 0x70, 0x61, 0x74,
0x68, 0x49, 0x44, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x70, 0x61, 0x74, 0x68, 0x49,
0x44, 0x12, 0x1a, 0x0a, 0x08, 0x6b, 0x65, 0x79, 0x54, 0x6f, 0x55, 0x73, 0x65, 0x18, 0x03, 0x20,
0x01, 0x28, 0x04, 0x52, 0x08, 0x6b, 0x65, 0x79, 0x54, 0x6f, 0x55, 0x73, 0x65, 0x22, 0x47, 0x0a,
0x27, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6d, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x70, 0x6f,
0x72, 0x74, 0x4b, 0x65, 0x79, 0x4e, 0x65, 0x67, 0x6f, 0x74, 0x69, 0x61, 0x74, 0x69, 0x6f, 0x6e,
0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65,
0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d,
0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x22, 0x66, 0x0a, 0x14, 0x4b, 0x65, 0x79, 0x46, 0x6f, 0x72,
0x77, 0x61, 0x72, 0x64, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1c,
0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28,
0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12, 0x16, 0x0a, 0x06,
0x70, 0x61, 0x74, 0x68, 0x49, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x70, 0x61,
0x74, 0x68, 0x49, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x18,
0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x22, 0x35,
0x0a, 0x15, 0x4b, 0x65, 0x79, 0x46, 0x6f, 0x72, 0x77, 0x61, 0x72, 0x64, 0x69, 0x6e, 0x67, 0x52,
0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73,
0x74, 0x61, 0x6d, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65,
0x73, 0x74, 0x61, 0x6d, 0x70, 0x22, 0x74, 0x0a, 0x18, 0x4b, 0x65, 0x79, 0x49, 0x64, 0x4e, 0x6f,
0x74, 0x69, 0x66, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
0x6c, 0x6b, 0x49, 0x64, 0x22, 0x8a, 0x01, 0x0a, 0x18, 0x53, 0x79, 0x6e, 0x63, 0x4b, 0x65, 0x79,
0x49, 0x64, 0x73, 0x46, 0x6f, 0x72, 0x42, 0x75, 0x6c, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
0x74, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x01,
0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12,
0x22, 0x0a, 0x0c, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6d, 0x41, 0x64, 0x64, 0x72, 0x18,
0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6d, 0x41,
0x64, 0x64, 0x72, 0x12, 0x16, 0x0a, 0x06, 0x6b, 0x65, 0x79, 0x49, 0x64, 0x73, 0x18, 0x03, 0x20,
0x03, 0x28, 0x09, 0x52, 0x06, 0x6b, 0x65, 0x79, 0x49, 0x64, 0x73, 0x22, 0x39, 0x0a, 0x19, 0x4b,
0x65, 0x79, 0x49, 0x64, 0x4e, 0x6f, 0x74, 0x69, 0x66, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e,
0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65,
0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d,
0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x32, 0x9c, 0x04, 0x0a, 0x09, 0x4b, 0x6d, 0x73, 0x54, 0x61,
0x6c, 0x6b, 0x65, 0x72, 0x12, 0x6a, 0x0a, 0x14, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6d,
0x43, 0x61, 0x70, 0x61, 0x62, 0x69, 0x6c, 0x69, 0x74, 0x69, 0x65, 0x73, 0x12, 0x28, 0x2e, 0x6b,
0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x2e, 0x49, 0x6e, 0x74, 0x65, 0x72,
0x43, 0x6f, 0x6d, 0x43, 0x61, 0x70, 0x61, 0x62, 0x69, 0x6c, 0x69, 0x74, 0x69, 0x65, 0x73, 0x52,
0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x26, 0x2e, 0x6b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65,
0x72, 0x63, 0x6f, 0x6d, 0x2e, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6d, 0x43, 0x61, 0x70,
0x61, 0x62, 0x69, 0x6c, 0x69, 0x74, 0x69, 0x65, 0x73, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x22, 0x00,
0x12, 0x52, 0x0a, 0x0b, 0x53, 0x79, 0x6e, 0x63, 0x51, 0x6b, 0x64, 0x42, 0x75, 0x6c, 0x6b, 0x12,
0x1f, 0x2e, 0x6b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x2e, 0x53, 0x79,
0x6e, 0x63, 0x51, 0x6b, 0x64, 0x42, 0x75, 0x6c, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
0x1a, 0x20, 0x2e, 0x6b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x2e, 0x53,
0x79, 0x6e, 0x63, 0x51, 0x6b, 0x64, 0x42, 0x75, 0x6c, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
0x73, 0x65, 0x22, 0x00, 0x12, 0x8e, 0x01, 0x0a, 0x1f, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x43, 0x6f,
0x64, 0x64, 0x72, 0x12, 0x16, 0x0a, 0x06, 0x62, 0x75, 0x6c, 0x6b, 0x49, 0x64, 0x18, 0x03, 0x20,
0x01, 0x28, 0x03, 0x52, 0x06, 0x62, 0x75, 0x6c, 0x6b, 0x49, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x6b,
0x65, 0x79, 0x49, 0x64, 0x18, 0x04, 0x20, 0x03, 0x28, 0x09, 0x52, 0x05, 0x6b, 0x65, 0x79, 0x49,
0x64, 0x22, 0x39, 0x0a, 0x19, 0x53, 0x79, 0x6e, 0x63, 0x4b, 0x65, 0x79, 0x49, 0x64, 0x73, 0x46,
0x6f, 0x72, 0x42, 0x75, 0x6c, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1c,
0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28,
0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x22, 0x4b, 0x0a, 0x13,
0x53, 0x79, 0x6e, 0x63, 0x51, 0x6b, 0x64, 0x42, 0x75, 0x6c, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f,
0x6e, 0x73, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70,
0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d,
0x70, 0x12, 0x16, 0x0a, 0x06, 0x62, 0x75, 0x6c, 0x6b, 0x49, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28,
0x03, 0x52, 0x06, 0x62, 0x75, 0x6c, 0x6b, 0x49, 0x64, 0x22, 0x7a, 0x0a, 0x26, 0x49, 0x6e, 0x74,
0x65, 0x72, 0x43, 0x6f, 0x6d, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x70, 0x6f, 0x72, 0x74, 0x4b, 0x65,
0x79, 0x4e, 0x65, 0x67, 0x6f, 0x74, 0x69, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75,
0x65, 0x73, 0x74, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70,
0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d,
0x70, 0x12, 0x16, 0x0a, 0x06, 0x70, 0x61, 0x74, 0x68, 0x49, 0x44, 0x18, 0x02, 0x20, 0x01, 0x28,
0x09, 0x52, 0x06, 0x70, 0x61, 0x74, 0x68, 0x49, 0x44, 0x12, 0x1a, 0x0a, 0x08, 0x6b, 0x65, 0x79,
0x54, 0x6f, 0x55, 0x73, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x6b, 0x65, 0x79,
0x54, 0x6f, 0x55, 0x73, 0x65, 0x22, 0x47, 0x0a, 0x27, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x43, 0x6f,
0x6d, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x70, 0x6f, 0x72, 0x74, 0x4b, 0x65, 0x79, 0x4e, 0x65, 0x67,
0x6f, 0x74, 0x69, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x33, 0x2e, 0x6b, 0x6d, 0x73, 0x69, 0x6e,
0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x2e, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6d, 0x54,
0x6f, 0x74, 0x69, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x01, 0x20,
0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x22, 0x66,
0x0a, 0x14, 0x4b, 0x65, 0x79, 0x46, 0x6f, 0x72, 0x77, 0x61, 0x72, 0x64, 0x69, 0x6e, 0x67, 0x52,
0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74,
0x61, 0x6d, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73,
0x74, 0x61, 0x6d, 0x70, 0x12, 0x16, 0x0a, 0x06, 0x70, 0x61, 0x74, 0x68, 0x49, 0x64, 0x18, 0x02,
0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x70, 0x61, 0x74, 0x68, 0x49, 0x64, 0x12, 0x18, 0x0a, 0x07,
0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x70,
0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x22, 0x35, 0x0a, 0x15, 0x4b, 0x65, 0x79, 0x46, 0x6f, 0x72,
0x77, 0x61, 0x72, 0x64, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12,
0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x01, 0x20, 0x01,
0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x22, 0x74, 0x0a,
0x18, 0x4b, 0x65, 0x79, 0x49, 0x64, 0x4e, 0x6f, 0x74, 0x69, 0x66, 0x69, 0x63, 0x61, 0x74, 0x69,
0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d,
0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69,
0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12, 0x22, 0x0a, 0x0c, 0x69, 0x6e, 0x74, 0x65, 0x72,
0x43, 0x6f, 0x6d, 0x41, 0x64, 0x64, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x69,
0x6e, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6d, 0x41, 0x64, 0x64, 0x72, 0x12, 0x16, 0x0a, 0x06, 0x6b,
0x65, 0x79, 0x49, 0x64, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x52, 0x06, 0x6b, 0x65, 0x79,
0x49, 0x64, 0x73, 0x22, 0x39, 0x0a, 0x19, 0x4b, 0x65, 0x79, 0x49, 0x64, 0x4e, 0x6f, 0x74, 0x69,
0x66, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x01, 0x20,
0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x32, 0x82,
0x05, 0x0a, 0x09, 0x4b, 0x6d, 0x73, 0x54, 0x61, 0x6c, 0x6b, 0x65, 0x72, 0x12, 0x6a, 0x0a, 0x14,
0x49, 0x6e, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6d, 0x43, 0x61, 0x70, 0x61, 0x62, 0x69, 0x6c, 0x69,
0x74, 0x69, 0x65, 0x73, 0x12, 0x28, 0x2e, 0x6b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63,
0x6f, 0x6d, 0x2e, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6d, 0x43, 0x61, 0x70, 0x61, 0x62,
0x69, 0x6c, 0x69, 0x74, 0x69, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x26,
0x2e, 0x6b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x2e, 0x49, 0x6e, 0x74,
0x65, 0x72, 0x43, 0x6f, 0x6d, 0x43, 0x61, 0x70, 0x61, 0x62, 0x69, 0x6c, 0x69, 0x74, 0x69, 0x65,
0x73, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x22, 0x00, 0x12, 0x52, 0x0a, 0x0b, 0x53, 0x79, 0x6e, 0x63,
0x51, 0x6b, 0x64, 0x42, 0x75, 0x6c, 0x6b, 0x12, 0x1f, 0x2e, 0x6b, 0x6d, 0x73, 0x69, 0x6e, 0x74,
0x65, 0x72, 0x63, 0x6f, 0x6d, 0x2e, 0x53, 0x79, 0x6e, 0x63, 0x51, 0x6b, 0x64, 0x42, 0x75, 0x6c,
0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x20, 0x2e, 0x6b, 0x6d, 0x73, 0x69, 0x6e,
0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x2e, 0x53, 0x79, 0x6e, 0x63, 0x51, 0x6b, 0x64, 0x42, 0x75,
0x6c, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x64, 0x0a, 0x11,
0x53, 0x79, 0x6e, 0x63, 0x4b, 0x65, 0x79, 0x49, 0x64, 0x73, 0x46, 0x6f, 0x72, 0x42, 0x75, 0x6c,
0x6b, 0x12, 0x25, 0x2e, 0x6b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x2e,
0x53, 0x79, 0x6e, 0x63, 0x4b, 0x65, 0x79, 0x49, 0x64, 0x73, 0x46, 0x6f, 0x72, 0x42, 0x75, 0x6c,
0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x26, 0x2e, 0x6b, 0x6d, 0x73, 0x69, 0x6e,
0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x2e, 0x53, 0x79, 0x6e, 0x63, 0x4b, 0x65, 0x79, 0x49, 0x64,
0x73, 0x46, 0x6f, 0x72, 0x42, 0x75, 0x6c, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
0x22, 0x00, 0x12, 0x8e, 0x01, 0x0a, 0x1f, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6d, 0x54,
0x72, 0x61, 0x6e, 0x73, 0x70, 0x6f, 0x72, 0x74, 0x4b, 0x65, 0x79, 0x4e, 0x65, 0x67, 0x6f, 0x74,
0x69, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x34, 0x2e,
0x6b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x2e, 0x49, 0x6e, 0x74, 0x65,
0x72, 0x43, 0x6f, 0x6d, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x70, 0x6f, 0x72, 0x74, 0x4b, 0x65, 0x79,
0x4e, 0x65, 0x67, 0x6f, 0x74, 0x69, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f,
0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x58, 0x0a, 0x0d, 0x4b, 0x65, 0x79, 0x46, 0x6f, 0x72, 0x77,
0x61, 0x72, 0x64, 0x69, 0x6e, 0x67, 0x12, 0x21, 0x2e, 0x6b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65,
0x72, 0x63, 0x6f, 0x6d, 0x2e, 0x4b, 0x65, 0x79, 0x46, 0x6f, 0x72, 0x77, 0x61, 0x72, 0x64, 0x69,
0x6e, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x22, 0x2e, 0x6b, 0x6d, 0x73, 0x69,
0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x2e, 0x4b, 0x65, 0x79, 0x46, 0x6f, 0x72, 0x77, 0x61,
0x72, 0x64, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12,
0x64, 0x0a, 0x11, 0x4b, 0x65, 0x79, 0x49, 0x64, 0x4e, 0x6f, 0x74, 0x69, 0x66, 0x69, 0x63, 0x61,
0x74, 0x69, 0x6f, 0x6e, 0x12, 0x25, 0x2e, 0x6b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63,
0x6f, 0x6d, 0x2e, 0x4b, 0x65, 0x79, 0x49, 0x64, 0x4e, 0x6f, 0x74, 0x69, 0x66, 0x69, 0x63, 0x61,
0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x26, 0x2e, 0x6b, 0x6d,
0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x2e, 0x4b, 0x65, 0x79, 0x49, 0x64, 0x4e,
0x6f, 0x74, 0x69, 0x66, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f,
0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0xaf, 0x01, 0x0a, 0x0f, 0x63, 0x6f, 0x6d, 0x2e, 0x6b, 0x6d,
0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x42, 0x10, 0x4b, 0x6d, 0x73, 0x69, 0x6e,
0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x3e, 0x63,
0x6f, 0x64, 0x65, 0x2e, 0x66, 0x62, 0x69, 0x2e, 0x68, 0x2d, 0x64, 0x61, 0x2e, 0x64, 0x65, 0x2f,
0x64, 0x65, 0x6d, 0x6f, 0x71, 0x75, 0x61, 0x6e, 0x64, 0x74, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f,
0x2d, 0x6b, 0x6d, 0x73, 0x2f, 0x67, 0x65, 0x6e, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67,
0x6f, 0x2f, 0x6b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0xa2, 0x02, 0x03,
0x4b, 0x58, 0x58, 0xaa, 0x02, 0x0b, 0x4b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f,
0x6d, 0xca, 0x02, 0x0b, 0x4b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0xe2,
0x02, 0x17, 0x4b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x5c, 0x47, 0x50,
0x42, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xea, 0x02, 0x0b, 0x4b, 0x6d, 0x73, 0x69,
0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
0x69, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x33, 0x2e, 0x6b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65,
0x72, 0x63, 0x6f, 0x6d, 0x2e, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6d, 0x54, 0x72, 0x61,
0x6e, 0x73, 0x70, 0x6f, 0x72, 0x74, 0x4b, 0x65, 0x79, 0x4e, 0x65, 0x67, 0x6f, 0x74, 0x69, 0x61,
0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x34, 0x2e, 0x6b, 0x6d,
0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x2e, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x43,
0x6f, 0x6d, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x70, 0x6f, 0x72, 0x74, 0x4b, 0x65, 0x79, 0x4e, 0x65,
0x67, 0x6f, 0x74, 0x69, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
0x65, 0x22, 0x00, 0x12, 0x58, 0x0a, 0x0d, 0x4b, 0x65, 0x79, 0x46, 0x6f, 0x72, 0x77, 0x61, 0x72,
0x64, 0x69, 0x6e, 0x67, 0x12, 0x21, 0x2e, 0x6b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63,
0x6f, 0x6d, 0x2e, 0x4b, 0x65, 0x79, 0x46, 0x6f, 0x72, 0x77, 0x61, 0x72, 0x64, 0x69, 0x6e, 0x67,
0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x22, 0x2e, 0x6b, 0x6d, 0x73, 0x69, 0x6e, 0x74,
0x65, 0x72, 0x63, 0x6f, 0x6d, 0x2e, 0x4b, 0x65, 0x79, 0x46, 0x6f, 0x72, 0x77, 0x61, 0x72, 0x64,
0x69, 0x6e, 0x67, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x64, 0x0a,
0x11, 0x4b, 0x65, 0x79, 0x49, 0x64, 0x4e, 0x6f, 0x74, 0x69, 0x66, 0x69, 0x63, 0x61, 0x74, 0x69,
0x6f, 0x6e, 0x12, 0x25, 0x2e, 0x6b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d,
0x2e, 0x4b, 0x65, 0x79, 0x49, 0x64, 0x4e, 0x6f, 0x74, 0x69, 0x66, 0x69, 0x63, 0x61, 0x74, 0x69,
0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x26, 0x2e, 0x6b, 0x6d, 0x73, 0x69,
0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x2e, 0x4b, 0x65, 0x79, 0x49, 0x64, 0x4e, 0x6f, 0x74,
0x69, 0x66, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
0x65, 0x22, 0x00, 0x42, 0xaf, 0x01, 0x0a, 0x0f, 0x63, 0x6f, 0x6d, 0x2e, 0x6b, 0x6d, 0x73, 0x69,
0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x42, 0x10, 0x4b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65,
0x72, 0x63, 0x6f, 0x6d, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x3e, 0x63, 0x6f, 0x64,
0x65, 0x2e, 0x66, 0x62, 0x69, 0x2e, 0x68, 0x2d, 0x64, 0x61, 0x2e, 0x64, 0x65, 0x2f, 0x64, 0x65,
0x6d, 0x6f, 0x71, 0x75, 0x61, 0x6e, 0x64, 0x74, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2d, 0x6b,
0x6d, 0x73, 0x2f, 0x67, 0x65, 0x6e, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f,
0x6b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0xa2, 0x02, 0x03, 0x4b, 0x58,
0x58, 0xaa, 0x02, 0x0b, 0x4b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0xca,
0x02, 0x0b, 0x4b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0xe2, 0x02, 0x17,
0x4b, 0x6d, 0x73, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x6f, 0x6d, 0x5c, 0x47, 0x50, 0x42, 0x4d,
0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xea, 0x02, 0x0b, 0x4b, 0x6d, 0x73, 0x69, 0x6e, 0x74,
0x65, 0x72, 0x63, 0x6f, 0x6d, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (
......@@ -704,35 +841,39 @@ func file_kmsintercom_kmsintercom_proto_rawDescGZIP() []byte {
return file_kmsintercom_kmsintercom_proto_rawDescData
}
var file_kmsintercom_kmsintercom_proto_msgTypes = make([]protoimpl.MessageInfo, 10)
var file_kmsintercom_kmsintercom_proto_msgTypes = make([]protoimpl.MessageInfo, 12)
var file_kmsintercom_kmsintercom_proto_goTypes = []interface{}{
(*InterComCapabilitiesRequest)(nil), // 0: kmsintercom.InterComCapabilitiesRequest
(*InterComCapabilitiesReply)(nil), // 1: kmsintercom.InterComCapabilitiesReply
(*SyncQkdBulkRequest)(nil), // 2: kmsintercom.SyncQkdBulkRequest
(*SyncQkdBulkResponse)(nil), // 3: kmsintercom.SyncQkdBulkResponse
(*InterComTransportKeyNegotiationRequest)(nil), // 4: kmsintercom.InterComTransportKeyNegotiationRequest
(*InterComTransportKeyNegotiationResponse)(nil), // 5: kmsintercom.InterComTransportKeyNegotiationResponse
(*KeyForwardingRequest)(nil), // 6: kmsintercom.KeyForwardingRequest
(*KeyForwardingResponse)(nil), // 7: kmsintercom.KeyForwardingResponse
(*KeyIdNotificationRequest)(nil), // 8: kmsintercom.KeyIdNotificationRequest
(*KeyIdNotificationResponse)(nil), // 9: kmsintercom.KeyIdNotificationResponse
(*SyncKeyIdsForBulkRequest)(nil), // 3: kmsintercom.SyncKeyIdsForBulkRequest
(*SyncKeyIdsForBulkResponse)(nil), // 4: kmsintercom.SyncKeyIdsForBulkResponse
(*SyncQkdBulkResponse)(nil), // 5: kmsintercom.SyncQkdBulkResponse
(*InterComTransportKeyNegotiationRequest)(nil), // 6: kmsintercom.InterComTransportKeyNegotiationRequest
(*InterComTransportKeyNegotiationResponse)(nil), // 7: kmsintercom.InterComTransportKeyNegotiationResponse
(*KeyForwardingRequest)(nil), // 8: kmsintercom.KeyForwardingRequest
(*KeyForwardingResponse)(nil), // 9: kmsintercom.KeyForwardingResponse
(*KeyIdNotificationRequest)(nil), // 10: kmsintercom.KeyIdNotificationRequest
(*KeyIdNotificationResponse)(nil), // 11: kmsintercom.KeyIdNotificationResponse
}
var file_kmsintercom_kmsintercom_proto_depIdxs = []int32{
0, // 0: kmsintercom.KmsTalker.InterComCapabilities:input_type -> kmsintercom.InterComCapabilitiesRequest
2, // 1: kmsintercom.KmsTalker.SyncQkdBulk:input_type -> kmsintercom.SyncQkdBulkRequest
4, // 2: kmsintercom.KmsTalker.InterComTransportKeyNegotiation:input_type -> kmsintercom.InterComTransportKeyNegotiationRequest
6, // 3: kmsintercom.KmsTalker.KeyForwarding:input_type -> kmsintercom.KeyForwardingRequest
8, // 4: kmsintercom.KmsTalker.KeyIdNotification:input_type -> kmsintercom.KeyIdNotificationRequest
1, // 5: kmsintercom.KmsTalker.InterComCapabilities:output_type -> kmsintercom.InterComCapabilitiesReply
3, // 6: kmsintercom.KmsTalker.SyncQkdBulk:output_type -> kmsintercom.SyncQkdBulkResponse
5, // 7: kmsintercom.KmsTalker.InterComTransportKeyNegotiation:output_type -> kmsintercom.InterComTransportKeyNegotiationResponse
7, // 8: kmsintercom.KmsTalker.KeyForwarding:output_type -> kmsintercom.KeyForwardingResponse
9, // 9: kmsintercom.KmsTalker.KeyIdNotification:output_type -> kmsintercom.KeyIdNotificationResponse
5, // [5:10] is the sub-list for method output_type
0, // [0:5] is the sub-list for method input_type
0, // [0:0] is the sub-list for extension type_name
0, // [0:0] is the sub-list for extension extendee
0, // [0:0] is the sub-list for field type_name
0, // 0: kmsintercom.KmsTalker.InterComCapabilities:input_type -> kmsintercom.InterComCapabilitiesRequest
2, // 1: kmsintercom.KmsTalker.SyncQkdBulk:input_type -> kmsintercom.SyncQkdBulkRequest
3, // 2: kmsintercom.KmsTalker.SyncKeyIdsForBulk:input_type -> kmsintercom.SyncKeyIdsForBulkRequest
6, // 3: kmsintercom.KmsTalker.InterComTransportKeyNegotiation:input_type -> kmsintercom.InterComTransportKeyNegotiationRequest
8, // 4: kmsintercom.KmsTalker.KeyForwarding:input_type -> kmsintercom.KeyForwardingRequest
10, // 5: kmsintercom.KmsTalker.KeyIdNotification:input_type -> kmsintercom.KeyIdNotificationRequest
1, // 6: kmsintercom.KmsTalker.InterComCapabilities:output_type -> kmsintercom.InterComCapabilitiesReply
5, // 7: kmsintercom.KmsTalker.SyncQkdBulk:output_type -> kmsintercom.SyncQkdBulkResponse
4, // 8: kmsintercom.KmsTalker.SyncKeyIdsForBulk:output_type -> kmsintercom.SyncKeyIdsForBulkResponse
7, // 9: kmsintercom.KmsTalker.InterComTransportKeyNegotiation:output_type -> kmsintercom.InterComTransportKeyNegotiationResponse
9, // 10: kmsintercom.KmsTalker.KeyForwarding:output_type -> kmsintercom.KeyForwardingResponse
11, // 11: kmsintercom.KmsTalker.KeyIdNotification:output_type -> kmsintercom.KeyIdNotificationResponse
6, // [6:12] is the sub-list for method output_type
0, // [0:6] is the sub-list for method input_type
0, // [0:0] is the sub-list for extension type_name
0, // [0:0] is the sub-list for extension extendee
0, // [0:0] is the sub-list for field type_name
}
func init() { file_kmsintercom_kmsintercom_proto_init() }
......@@ -778,7 +919,7 @@ func file_kmsintercom_kmsintercom_proto_init() {
}
}
file_kmsintercom_kmsintercom_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*SyncQkdBulkResponse); i {
switch v := v.(*SyncKeyIdsForBulkRequest); i {
case 0:
return &v.state
case 1:
......@@ -790,7 +931,7 @@ func file_kmsintercom_kmsintercom_proto_init() {
}
}
file_kmsintercom_kmsintercom_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*InterComTransportKeyNegotiationRequest); i {
switch v := v.(*SyncKeyIdsForBulkResponse); i {
case 0:
return &v.state
case 1:
......@@ -802,7 +943,7 @@ func file_kmsintercom_kmsintercom_proto_init() {
}
}
file_kmsintercom_kmsintercom_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*InterComTransportKeyNegotiationResponse); i {
switch v := v.(*SyncQkdBulkResponse); i {
case 0:
return &v.state
case 1:
......@@ -814,7 +955,7 @@ func file_kmsintercom_kmsintercom_proto_init() {
}
}
file_kmsintercom_kmsintercom_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*KeyForwardingRequest); i {
switch v := v.(*InterComTransportKeyNegotiationRequest); i {
case 0:
return &v.state
case 1:
......@@ -826,7 +967,7 @@ func file_kmsintercom_kmsintercom_proto_init() {
}
}
file_kmsintercom_kmsintercom_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*KeyForwardingResponse); i {
switch v := v.(*InterComTransportKeyNegotiationResponse); i {
case 0:
return &v.state
case 1:
......@@ -838,7 +979,7 @@ func file_kmsintercom_kmsintercom_proto_init() {
}
}
file_kmsintercom_kmsintercom_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*KeyIdNotificationRequest); i {
switch v := v.(*KeyForwardingRequest); i {
case 0:
return &v.state
case 1:
......@@ -850,6 +991,30 @@ func file_kmsintercom_kmsintercom_proto_init() {
}
}
file_kmsintercom_kmsintercom_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*KeyForwardingResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_kmsintercom_kmsintercom_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*KeyIdNotificationRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_kmsintercom_kmsintercom_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*KeyIdNotificationResponse); i {
case 0:
return &v.state
......@@ -868,7 +1033,7 @@ func file_kmsintercom_kmsintercom_proto_init() {
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_kmsintercom_kmsintercom_proto_rawDesc,
NumEnums: 0,
NumMessages: 10,
NumMessages: 12,
NumExtensions: 0,
NumServices: 1,
},
......
api/gen/proto/go/kmsintercom/kmsintercom_grpc.pb.go
+ 37
− 0
View file @ 2019fbb6
......@@ -21,6 +21,7 @@ const _ = grpc.SupportPackageIsVersion7
const (
KmsTalker_InterComCapabilities_FullMethodName = "/kmsintercom.KmsTalker/InterComCapabilities"
KmsTalker_SyncQkdBulk_FullMethodName = "/kmsintercom.KmsTalker/SyncQkdBulk"
KmsTalker_SyncKeyIdsForBulk_FullMethodName = "/kmsintercom.KmsTalker/SyncKeyIdsForBulk"
KmsTalker_InterComTransportKeyNegotiation_FullMethodName = "/kmsintercom.KmsTalker/InterComTransportKeyNegotiation"
KmsTalker_KeyForwarding_FullMethodName = "/kmsintercom.KmsTalker/KeyForwarding"
KmsTalker_KeyIdNotification_FullMethodName = "/kmsintercom.KmsTalker/KeyIdNotification"
......@@ -32,6 +33,7 @@ const (
type KmsTalkerClient interface {
InterComCapabilities(ctx context.Context, in *InterComCapabilitiesRequest, opts ...grpc.CallOption) (*InterComCapabilitiesReply, error)
SyncQkdBulk(ctx context.Context, in *SyncQkdBulkRequest, opts ...grpc.CallOption) (*SyncQkdBulkResponse, error)
SyncKeyIdsForBulk(ctx context.Context, in *SyncKeyIdsForBulkRequest, opts ...grpc.CallOption) (*SyncKeyIdsForBulkResponse, error)
InterComTransportKeyNegotiation(ctx context.Context, in *InterComTransportKeyNegotiationRequest, opts ...grpc.CallOption) (*InterComTransportKeyNegotiationResponse, error)
KeyForwarding(ctx context.Context, in *KeyForwardingRequest, opts ...grpc.CallOption) (*KeyForwardingResponse, error)
// KeyIDNotification is used for ETSI GS QKD 014
......@@ -64,6 +66,15 @@ func (c *kmsTalkerClient) SyncQkdBulk(ctx context.Context, in *SyncQkdBulkReques
return out, nil
}
func (c *kmsTalkerClient) SyncKeyIdsForBulk(ctx context.Context, in *SyncKeyIdsForBulkRequest, opts ...grpc.CallOption) (*SyncKeyIdsForBulkResponse, error) {
out := new(SyncKeyIdsForBulkResponse)
err := c.cc.Invoke(ctx, KmsTalker_SyncKeyIdsForBulk_FullMethodName, in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *kmsTalkerClient) InterComTransportKeyNegotiation(ctx context.Context, in *InterComTransportKeyNegotiationRequest, opts ...grpc.CallOption) (*InterComTransportKeyNegotiationResponse, error) {
out := new(InterComTransportKeyNegotiationResponse)
err := c.cc.Invoke(ctx, KmsTalker_InterComTransportKeyNegotiation_FullMethodName, in, out, opts...)
......@@ -97,6 +108,7 @@ func (c *kmsTalkerClient) KeyIdNotification(ctx context.Context, in *KeyIdNotifi
type KmsTalkerServer interface {
InterComCapabilities(context.Context, *InterComCapabilitiesRequest) (*InterComCapabilitiesReply, error)
SyncQkdBulk(context.Context, *SyncQkdBulkRequest) (*SyncQkdBulkResponse, error)
SyncKeyIdsForBulk(context.Context, *SyncKeyIdsForBulkRequest) (*SyncKeyIdsForBulkResponse, error)
InterComTransportKeyNegotiation(context.Context, *InterComTransportKeyNegotiationRequest) (*InterComTransportKeyNegotiationResponse, error)
KeyForwarding(context.Context, *KeyForwardingRequest) (*KeyForwardingResponse, error)
// KeyIDNotification is used for ETSI GS QKD 014
......@@ -114,6 +126,9 @@ func (UnimplementedKmsTalkerServer) InterComCapabilities(context.Context, *Inter
func (UnimplementedKmsTalkerServer) SyncQkdBulk(context.Context, *SyncQkdBulkRequest) (*SyncQkdBulkResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method SyncQkdBulk not implemented")
}
func (UnimplementedKmsTalkerServer) SyncKeyIdsForBulk(context.Context, *SyncKeyIdsForBulkRequest) (*SyncKeyIdsForBulkResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method SyncKeyIdsForBulk not implemented")
}
func (UnimplementedKmsTalkerServer) InterComTransportKeyNegotiation(context.Context, *InterComTransportKeyNegotiationRequest) (*InterComTransportKeyNegotiationResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method InterComTransportKeyNegotiation not implemented")
}
......@@ -172,6 +187,24 @@ func _KmsTalker_SyncQkdBulk_Handler(srv interface{}, ctx context.Context, dec fu
return interceptor(ctx, in, info, handler)
}
func _KmsTalker_SyncKeyIdsForBulk_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(SyncKeyIdsForBulkRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(KmsTalkerServer).SyncKeyIdsForBulk(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: KmsTalker_SyncKeyIdsForBulk_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(KmsTalkerServer).SyncKeyIdsForBulk(ctx, req.(*SyncKeyIdsForBulkRequest))
}
return interceptor(ctx, in, info, handler)
}
func _KmsTalker_InterComTransportKeyNegotiation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(InterComTransportKeyNegotiationRequest)
if err := dec(in); err != nil {
......@@ -241,6 +274,10 @@ var KmsTalker_ServiceDesc = grpc.ServiceDesc{
MethodName: "SyncQkdBulk",
Handler: _KmsTalker_SyncQkdBulk_Handler,
},
{
MethodName: "SyncKeyIdsForBulk",
Handler: _KmsTalker_SyncKeyIdsForBulk_Handler,
},
{
MethodName: "InterComTransportKeyNegotiation",
Handler: _KmsTalker_InterComTransportKeyNegotiation_Handler,
......
api/kmsintercom/kmsintercom/kmsintercom.proto
+ 13
− 1
View file @ 2019fbb6
......@@ -6,6 +6,7 @@ package kmsintercom;
service KmsTalker {
rpc InterComCapabilities (InterComCapabilitiesRequest) returns (InterComCapabilitiesReply) {}
rpc SyncQkdBulk(SyncQkdBulkRequest) returns (SyncQkdBulkResponse) {}
rpc SyncKeyIdsForBulk(SyncKeyIdsForBulkRequest) returns (SyncKeyIdsForBulkResponse) {}
rpc InterComTransportKeyNegotiation(InterComTransportKeyNegotiationRequest) returns (InterComTransportKeyNegotiationResponse) {}
rpc KeyForwarding(KeyForwardingRequest) returns (KeyForwardingResponse) {}
// KeyIDNotification is used for ETSI GS QKD 014
......@@ -32,6 +33,17 @@ message SyncQkdBulkRequest {
//string bulkHash = 4;
}
message SyncKeyIdsForBulkRequest {
int64 timestamp = 1;
string interComAddr = 2;
int64 bulkId = 3;
repeated string keyId = 4;
}
message SyncKeyIdsForBulkResponse {
int64 timestamp = 1;
}
message SyncQkdBulkResponse {
int64 timestamp = 1;
int64 bulkId = 2;
......@@ -41,7 +53,7 @@ message SyncQkdBulkResponse {
message InterComTransportKeyNegotiationRequest {
int64 timestamp = 1;
string pathID = 2;
uint64 keyToUse = 3;
string keyToUse = 3;
}
message InterComTransportKeyNegotiationResponse {
......
kms/kms-keystore.go
+ 17
− 32
View file @ 2019fbb6
......@@ -4,9 +4,8 @@ import (
"fmt"
"sync"
"github.com/google/uuid"
log "github.com/sirupsen/logrus"
"code.fbi.h-da.de/danet/proto-kms/quantumlayer"
)
type Status int
......@@ -18,35 +17,28 @@ const (
USED
)
type kmsKS interface {
KeyChopper(bulkKey *quantumlayer.QuantumLayerBulkKey) (err error)
addKey(int64, [8]byte)
}
// holds a single ready to bit key, length can be configured
type kmsKSElement struct {
keyID uint64
keyID uuid.UUID
key []byte // a key
status Status
}
type kmsKeyStore struct {
keyStoreMutex sync.Mutex
keyStore map[uint64]*kmsKSElement
keyStore map[uuid.UUID]*kmsKSElement
keySingleSize uint // the size of a single key, given as unit of bits
indexCounter uint64
}
func NewKmsKeyStore(desiredkeySingleSizeLength uint) *kmsKeyStore {
return &kmsKeyStore{
// NOTE: could be useful to use something like a ordered map here
keyStore: make(map[uint64]*kmsKSElement),
keyStore: make(map[uuid.UUID]*kmsKSElement),
keySingleSize: desiredkeySingleSizeLength,
indexCounter: 0,
}
}
func (ks *kmsKeyStore) addKey(keyId uint64, keyToadd []byte) {
func (ks *kmsKeyStore) addKey(keyId uuid.UUID, keyToadd []byte) {
ks.keyStoreMutex.Lock()
defer ks.keyStoreMutex.Unlock()
......@@ -69,41 +61,34 @@ func (ks *kmsKeyStore) GetKey() (*kmsKSElement, error) {
ks.keyStoreMutex.Lock()
defer ks.keyStoreMutex.Unlock()
key, ok := ks.keyStore[ks.indexCounter]
if !ok {
return nil, fmt.Errorf("Could not find a key for id: %d", ks.indexCounter)
// TODO: if we want random here, then we have to take a different approach
for _, key := range ks.keyStore {
if key.status == AVAILABLE {
// change status of key to reserved
key.status = RESERVED
return key, nil
}
}
if key.status == AVAILABLE {
// change status of key to reserved
key.status = RESERVED
// increase index counter
ks.indexCounter = ks.indexCounter + 1
return key, nil
}
return nil, fmt.Errorf("Key with index: %d is already reserved.", ks.indexCounter)
return nil, fmt.Errorf("could not find a key to use")
}
func (ks *kmsKeyStore) GetKeyWithID(id uint64) (*kmsKSElement, error) {
func (ks *kmsKeyStore) GetKeyWithID(id uuid.UUID) (*kmsKSElement, error) {
ks.keyStoreMutex.Lock()
defer ks.keyStoreMutex.Unlock()
key, ok := ks.keyStore[id]
if !ok {
return nil, fmt.Errorf("Could not find a key for id: %d", ks.indexCounter)
return nil, fmt.Errorf("Could not find a key for id: %v", id)
}
if key.status == AVAILABLE {
// change status of key to reserved
key.status = RESERVED
// increase index counter
ks.indexCounter = ks.indexCounter + 1
return key, nil
}
return nil, fmt.Errorf("Key with index: %d is already reserved.", ks.indexCounter)
return nil, fmt.Errorf("Key with index: %v is already reserved.", id)
}
func (ks *kmsKeyStore) DeleteKey(keyId uint64) {
func (ks *kmsKeyStore) DeleteKey(keyId uuid.UUID) {
ks.keyStoreMutex.Lock()
delete(ks.keyStore, keyId)
ks.keyStoreMutex.Unlock()
......
kms/kmsetsi.go
+ 0
− 2
View file @ 2019fbb6
......@@ -25,7 +25,6 @@ var (
type etsiServer struct {
pb.UnimplementedKmsETSIServer
handlingEkms *EKMS
visitedKeys map[*kmsKSElement]bool
}
func (es *etsiServer) ETSICapabilities(ctx context.Context, in *pb.ETSICapabilitiesRequest) (capReply *pb.ETSICapabilitiesReply, err error) {
......@@ -181,7 +180,6 @@ func StartETSI(listenAddr string, callingKMS *EKMS) {
s := grpc.NewServer()
pb.RegisterKmsETSIServer(s, &etsiServer{
handlingEkms: callingKMS,
visitedKeys: make(map[*kmsKSElement]bool),
})
log.Infof("server listening at %v", lis.Addr())
if err := s.Serve(lis); err != nil {
......
kms/kmsintercom.go
+ 48
− 18
View file @ 2019fbb6
......@@ -104,19 +104,7 @@ func (s *kmsTalkerServer) SyncQkdBulk(ctx context.Context, in *pb.SyncQkdBulkReq
}
for _, bulkId := range in.BulkId {
rawBulkKeyIds := keysOfMap[int64](eqm.rawBulkKeys)
log.Info("PEER BULK KEYS: ", rawBulkKeyIds)
if bulk, ok := eqm.rawBulkKeys[bulkId]; ok {
eqm.keyStore = NewKmsKeyStore(256)
if err := eqm.KeyChopper(bulk); err != nil {
//TODO: proper error message
return nil, status.Errorf(codes.Internal, "chopping failed")
}
eqm.rawBulkKeysMutex.Lock()
delete(eqm.rawBulkKeys, bulkId)
eqm.rawBulkKeysMutex.Unlock()
if _, ok := eqm.rawBulkKeys[bulkId]; ok {
return &pb.SyncQkdBulkResponse{
Timestamp: time.Now().Unix(),
BulkId: bulkId,
......@@ -124,6 +112,41 @@ func (s *kmsTalkerServer) SyncQkdBulk(ctx context.Context, in *pb.SyncQkdBulkReq
}
}
return nil, status.Errorf(codes.Unimplemented, "method SyncQkdBulk not implemented")
}
func (s *kmsTalkerServer) SyncKeyIdsForBulk(ctx context.Context, in *pb.SyncKeyIdsForBulkRequest) (*pb.SyncKeyIdsForBulkResponse, error) {
peer, ok := s.eKMS.KmsPeers[in.GetInterComAddr()]
if !ok {
return nil, status.Errorf(codes.Internal, "For address: %s, no peer exists", in.GetInterComAddr())
}
eqm, ok := peer.servingQuantumModul.(*EmulatedQuantumModule)
if !ok {
return nil, status.Errorf(codes.Internal, "expected a emulated quantum module")
}
eqm.rawBulkKeysMutex.Lock()
bulk, ok := eqm.rawBulkKeys[in.GetBulkId()]
if !ok {
return nil, status.Errorf(codes.Internal, "bulk key with id: %d not found", in.GetBulkId())
}
eqm.rawBulkKeysMutex.Unlock()
eqm.keyStore = NewKmsKeyStore(256)
_, keyData, err := eqm.KeyChopper(bulk, in.GetKeyId())
if err != nil {
return nil, status.Errorf(codes.Internal, "%v", err)
}
for keyId, key := range keyData {
eqm.keyStore.addKey(keyId, key)
}
eqm.rawBulkKeysMutex.Lock()
delete(eqm.rawBulkKeys, in.GetBulkId())
eqm.rawBulkKeysMutex.Unlock()
// update the peer status to up
peer.peerStatus = KmsPeerUp
// Send notification about change
......@@ -131,17 +154,22 @@ func (s *kmsTalkerServer) SyncQkdBulk(ctx context.Context, in *pb.SyncQkdBulkReq
peer.externalNotifierKMSPeer <- peer.tcpSocketStr
}
return nil, status.Errorf(codes.Unimplemented, "method SyncQkdBulk not implemented")
return &pb.SyncKeyIdsForBulkResponse{
Timestamp: time.Now().Unix(),
}, nil
}
func (s *kmsTalkerServer) InterComTransportKeyNegotiation(ctx context.Context, in *pb.InterComTransportKeyNegotiationRequest) (capReply *pb.InterComTransportKeyNegotiationResponse, err error) {
// NOTE: For the current prototype it is assumed that a negotiation request
// is always valid. In the future an incoming negotiation request should
// also check for a suitable forwarding assignment from the controller.
keyID := in.KeyToUse
pathId, err := uuid.Parse(in.PathID)
keyID, err := uuid.Parse(in.GetKeyToUse())
if err != nil {
return nil, status.Errorf(codes.InvalidArgument, "")
return nil, status.Errorf(codes.InvalidArgument, "key with id: %s can not be parsed to uuid", in.GetKeyToUse())
}
pathId, err := uuid.Parse(in.GetPathID())
if err != nil {
return nil, status.Errorf(codes.InvalidArgument, "path id: %s can not be parsed to uuid", in.GetPathID())
}
route, ok := s.eKMS.routingTable[pathId]
......@@ -165,6 +193,8 @@ func (s *kmsTalkerServer) InterComTransportKeyNegotiation(ctx context.Context, i
// TODO: mutex
s.keyNegotiationMap[pathId] = key
quantumModuleKeyStore.DeleteKey(keyID)
return &pb.InterComTransportKeyNegotiationResponse{Timestamp: time.Now().Unix()}, nil
}
......@@ -200,7 +230,7 @@ func (s *kmsTalkerServer) KeyForwarding(ctx context.Context, in *pb.KeyForwardin
log.Infof("%s forwards payload to : %s", s.eKMS.kmsName, route.Next.tcpSocketStr)
go route.Next.SendPayload(decryptedPayload, pathId)
} else {
log.Infof("%s received the final payload: ", s.eKMS.kmsName, string(decryptedPayload))
log.Infof("%s received the final payload: %s", s.eKMS.kmsName, string(decryptedPayload))
}
//// NOTE: For demo purpose only
......
kms/kmspeers.go
+ 4
− 3
View file @ 2019fbb6
......@@ -96,7 +96,7 @@ func (ph *kmsPeer) TransportKeyNegotiation() error {
func (ph *kmsPeer) SendPayload(payload []byte, pathId uuid.UUID) error {
// NOTE: It should be assumed that there are keys available if we try to
// send.
if len(ph.servingQuantumModul.KeyStore().keyStore) <= int(ph.servingQuantumModul.KeyStore().indexCounter) {
if len(ph.servingQuantumModul.KeyStore().keyStore) == 0 {
log.Debug("Syncing bulk keys before sending the payload")
err := ph.SyncBulkKeys()
if err != nil {
......@@ -118,12 +118,13 @@ func (ph *kmsPeer) SendPayload(payload []byte, pathId uuid.UUID) error {
_, err = ph.peerClient.InterComTransportKeyNegotiation(ctx, &pbIC.InterComTransportKeyNegotiationRequest{
Timestamp: time.Now().Unix(),
PathID: pathId.String(),
KeyToUse: key.keyID,
KeyToUse: key.keyID.String(),
})
if err != nil {
return err
}
// TODO: delete key?
ph.servingQuantumModul.KeyStore().DeleteKey(key.keyID)
// TODO: would be better to update the index counter here (to keep it
// synchronized).
......
kms/module.go
+ 43
− 17
View file @ 2019fbb6
......@@ -25,8 +25,8 @@ type QuantumModule interface {
Initialize() error
// NOTE: Sync will be removed as soon as the emulated quantum module has been
// changed to push a constant byte stream.
Sync() error
KeyStore() *kmsKeyStore
Sync() error
Peer() *kmsPeer
SetPeer(*kmsPeer)
Address() net.Addr
......@@ -71,10 +71,6 @@ func (eqe *EmulatedQuantumModule) Address() net.Addr {
return eqe.QuantumElementLink.GetLocalQLPort()
}
func (eqe *EmulatedQuantumModule) KeyStore() *kmsKeyStore {
return eqe.keyStore
}
func (eqe *EmulatedQuantumModule) Sync() error {
rawBulkKeyIds := keysOfMap[int64](eqe.rawBulkKeys)
logrus.Info("Found the following bulk key ids for usage: ", rawBulkKeyIds)
......@@ -100,10 +96,25 @@ func (eqe *EmulatedQuantumModule) Sync() error {
// for now it is hardcoded.
eqe.keyStore = NewKmsKeyStore(256)
if err := eqe.KeyChopper(bulkKey); err != nil {
keyIds, keyData, err := eqe.KeyChopper(bulkKey, []string{})
if err != nil {
return err
}
_, err = eqe.peer.peerClient.SyncKeyIdsForBulk(ctx, &pbIC.SyncKeyIdsForBulkRequest{
Timestamp: time.Now().Unix(),
InterComAddr: eqe.peer.interComAddr,
BulkId: initialPeerSetupResponse.BulkId,
KeyId: keyIds,
})
if err != nil {
return err
}
for keyId, key := range keyData {
eqe.keyStore.addKey(keyId, key)
}
eqe.rawBulkKeysMutex.Lock()
delete(eqe.rawBulkKeys, initialPeerSetupResponse.BulkId)
eqe.rawBulkKeysMutex.Unlock()
......@@ -118,6 +129,10 @@ func (eqe *EmulatedQuantumModule) Sync() error {
return nil
}
func (eqe *EmulatedQuantumModule) KeyStore() *kmsKeyStore {
return eqe.keyStore
}
func (eqe *EmulatedQuantumModule) Peer() *kmsPeer {
return eqe.peer
}
......@@ -147,33 +162,44 @@ func (eqe *EmulatedQuantumModule) keyHandler() {
// Takes a bulk of keys and chops them in chopFactor keys each
// Any remainder is discarded
func (eqe *EmulatedQuantumModule) KeyChopper(bulkKey *quantumlayer.QuantumLayerBulkKey) error {
// If keyIds is empty, uuids are generated
func (eqe *EmulatedQuantumModule) KeyChopper(bulkKey *quantumlayer.QuantumLayerBulkKey, keyIds []string) ([]string, map[uuid.UUID][]byte, error) {
if eqe.keyStore.keySingleSize == 0 {
return errors.New("KeyChopper: no keySingleSize set")
return nil, nil, errors.New("KeyChopper: no keySingleSize set")
}
// TODO check if multiple of 8 (1 Byte)
if bulkKey.BulkKeyLength != len(*bulkKey.BulkKey) {
return errors.New("bulkKey length mismatch")
return nil, nil, errors.New("bulkKey length mismatch")
}
// reset indexCounter
eqe.keyStore.indexCounter = 0
var keyId uint64
keyId = 0
initialKeyIdsLen := len(keyIds)
// Let's chop!
keyData := make(map[uuid.UUID][]byte)
chopFactor := eqe.keyStore.keySingleSize >> 3
key := *bulkKey.BulkKey
counter := 0
for len(key) > int(chopFactor) {
var keyId uuid.UUID
var err error
if initialKeyIdsLen == 0 {
keyId = uuid.New()
keyIds = append(keyIds, keyId.String())
} else {
keyId, err = uuid.Parse(keyIds[counter])
if err != nil {
return nil, nil, fmt.Errorf("The provided ID: %s can not be parsed as UUID.", keyIds[counter])
}
counter++
}
tmpkey := key[:chopFactor]
eqe.keyStore.addKey(keyId, tmpkey)
keyId++
keyData[keyId] = tmpkey
// shorten the key storage
key = key[chopFactor:]
}
return nil
return keyIds, keyData, nil
}
type ETSI014HTTPQuantumModule struct {
......
kms/util.go
+ 3
− 9
View file @ 2019fbb6
......@@ -5,9 +5,9 @@ import (
"encoding/base64"
"fmt"
"net/http"
"strconv"
etsi14 "code.fbi.h-da.de/danet/ekms/api/go/rest/etsi/client"
"github.com/google/uuid"
)
func randomItemFromMap[T comparable, M any](m map[T]M) (M, error) {
......@@ -48,18 +48,12 @@ func addETSIKeysToKeystore(keyStore *kmsKeyStore, keyContainer []etsi14.KeyConta
if err != nil {
return err
}
// key id to uint
keyId := keyItem.GetKeyID()
keyIdUint, err := strconv.ParseUint(keyId, 10, 64)
keyId, err := uuid.Parse(keyItem.GetKeyID())
if err != nil {
return err
}
// add to keystore
keyStore.keyStoreMutex.Lock()
keyStore.addKey(keyIdUint, key)
keyStore.keyStoreMutex.Unlock()
keyStore.addKey(keyId, key)
}
return nil
}
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment