diff --git a/dapps/valuetransfers/fpc.go b/dapps/valuetransfers/fpc.go
index cd5a17185c6b7c040c1dc5b0c0bfd66015fee650..bc42c949d59d6d9c240d487a257c51d0c2fcb8ec 100644
--- a/dapps/valuetransfers/fpc.go
+++ b/dapps/valuetransfers/fpc.go
@@ -7,7 +7,6 @@ import (
"strconv"
"sync"
- "github.com/golang/protobuf/proto"
"github.com/iotaledger/goshimmer/dapps/valuetransfers/packages/branchmanager"
"github.com/iotaledger/goshimmer/packages/metrics"
"github.com/iotaledger/goshimmer/packages/prng"
@@ -25,6 +24,7 @@ import (
"github.com/iotaledger/hive.go/logger"
flag "github.com/spf13/pflag"
"google.golang.org/grpc"
+ "google.golang.org/protobuf/proto"
)
const (
diff --git a/packages/gossip/manager.go b/packages/gossip/manager.go
index cc850539adeb46e666257daa2b6cc693025e76d5..2e4e84361b7cf29b3064c6228b7c5ca17a44b64e 100644
--- a/packages/gossip/manager.go
+++ b/packages/gossip/manager.go
@@ -6,7 +6,6 @@ import (
"runtime"
"sync"
- "github.com/golang/protobuf/proto"
"github.com/iotaledger/goshimmer/packages/binary/messagelayer/message"
pb "github.com/iotaledger/goshimmer/packages/gossip/proto"
"github.com/iotaledger/goshimmer/packages/gossip/server"
@@ -15,6 +14,7 @@ import (
"github.com/iotaledger/hive.go/identity"
"github.com/iotaledger/hive.go/logger"
"github.com/iotaledger/hive.go/workerpool"
+ "google.golang.org/protobuf/proto"
)
const (
diff --git a/packages/gossip/manager_test.go b/packages/gossip/manager_test.go
index 5ea5511378fad6daa361a12d13d7e2b8a628ab5d..be3b18289e64a17bb0fc6df67af7a2b1393cebdb 100644
--- a/packages/gossip/manager_test.go
+++ b/packages/gossip/manager_test.go
@@ -6,7 +6,6 @@ import (
"testing"
"time"
- "github.com/golang/protobuf/proto"
"github.com/iotaledger/goshimmer/packages/binary/messagelayer/message"
pb "github.com/iotaledger/goshimmer/packages/gossip/proto"
"github.com/iotaledger/goshimmer/packages/gossip/server"
@@ -18,6 +17,7 @@ import (
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/mock"
"github.com/stretchr/testify/require"
+ "google.golang.org/protobuf/proto"
)
const graceTime = 10 * time.Millisecond
diff --git a/packages/gossip/proto/message.pb.go b/packages/gossip/proto/message.pb.go
index e78ad3a77435b90b5fee57c316ad2ce941dd0f37..2e5a6a5c74ad978acdc8111b96bd08292835c9e6 100644
--- a/packages/gossip/proto/message.pb.go
+++ b/packages/gossip/proto/message.pb.go
@@ -1,123 +1,211 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
+// versions:
+// protoc-gen-go v1.25.0
+// protoc v3.12.3
// source: message.proto
package proto
import (
- fmt "fmt"
- math "math"
-
proto "github.com/golang/protobuf/proto"
+ protoreflect "google.golang.org/protobuf/reflect/protoreflect"
+ protoimpl "google.golang.org/protobuf/runtime/protoimpl"
+ reflect "reflect"
+ sync "sync"
)
-// Reference imports to suppress errors if they are not otherwise used.
-var _ = proto.Marshal
-var _ = fmt.Errorf
-var _ = math.Inf
+const (
+ // Verify that this generated code is sufficiently up-to-date.
+ _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
+ // Verify that runtime/protoimpl is sufficiently up-to-date.
+ _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
+)
-// This is a compile-time assertion to ensure that this generated file
-// is compatible with the proto package it is being compiled against.
-// A compilation error at this line likely means your copy of the
-// proto package needs to be updated.
-const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
+// This is a compile-time assertion that a sufficiently up-to-date version
+// of the legacy proto package is being used.
+const _ = proto.ProtoPackageIsVersion4
type Message struct {
- Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
-func (m *Message) Reset() { *m = Message{} }
-func (m *Message) String() string { return proto.CompactTextString(m) }
-func (*Message) ProtoMessage() {}
-func (*Message) Descriptor() ([]byte, []int) {
- return fileDescriptor_33c57e4bae7b9afd, []int{0}
+ Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}
-func (m *Message) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_Message.Unmarshal(m, b)
-}
-func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_Message.Marshal(b, m, deterministic)
-}
-func (m *Message) XXX_Merge(src proto.Message) {
- xxx_messageInfo_Message.Merge(m, src)
+func (x *Message) Reset() {
+ *x = Message{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_message_proto_msgTypes[0]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
}
-func (m *Message) XXX_Size() int {
- return xxx_messageInfo_Message.Size(m)
+
+func (x *Message) String() string {
+ return protoimpl.X.MessageStringOf(x)
}
-func (m *Message) XXX_DiscardUnknown() {
- xxx_messageInfo_Message.DiscardUnknown(m)
+
+func (*Message) ProtoMessage() {}
+
+func (x *Message) ProtoReflect() protoreflect.Message {
+ mi := &file_message_proto_msgTypes[0]
+ 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)
}
-var xxx_messageInfo_Message proto.InternalMessageInfo
+// Deprecated: Use Message.ProtoReflect.Descriptor instead.
+func (*Message) Descriptor() ([]byte, []int) {
+ return file_message_proto_rawDescGZIP(), []int{0}
+}
-func (m *Message) GetData() []byte {
- if m != nil {
- return m.Data
+func (x *Message) GetData() []byte {
+ if x != nil {
+ return x.Data
}
return nil
}
type MessageRequest struct {
- Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
-func (m *MessageRequest) Reset() { *m = MessageRequest{} }
-func (m *MessageRequest) String() string { return proto.CompactTextString(m) }
-func (*MessageRequest) ProtoMessage() {}
-func (*MessageRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_33c57e4bae7b9afd, []int{1}
+ Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}
-func (m *MessageRequest) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_MessageRequest.Unmarshal(m, b)
-}
-func (m *MessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_MessageRequest.Marshal(b, m, deterministic)
-}
-func (m *MessageRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_MessageRequest.Merge(m, src)
+func (x *MessageRequest) Reset() {
+ *x = MessageRequest{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_message_proto_msgTypes[1]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
}
-func (m *MessageRequest) XXX_Size() int {
- return xxx_messageInfo_MessageRequest.Size(m)
+
+func (x *MessageRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
}
-func (m *MessageRequest) XXX_DiscardUnknown() {
- xxx_messageInfo_MessageRequest.DiscardUnknown(m)
+
+func (*MessageRequest) ProtoMessage() {}
+
+func (x *MessageRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_message_proto_msgTypes[1]
+ 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)
}
-var xxx_messageInfo_MessageRequest proto.InternalMessageInfo
+// Deprecated: Use MessageRequest.ProtoReflect.Descriptor instead.
+func (*MessageRequest) Descriptor() ([]byte, []int) {
+ return file_message_proto_rawDescGZIP(), []int{1}
+}
-func (m *MessageRequest) GetId() []byte {
- if m != nil {
- return m.Id
+func (x *MessageRequest) GetId() []byte {
+ if x != nil {
+ return x.Id
}
return nil
}
-func init() {
- proto.RegisterType((*Message)(nil), "proto.Message")
- proto.RegisterType((*MessageRequest)(nil), "proto.MessageRequest")
+var File_message_proto protoreflect.FileDescriptor
+
+var file_message_proto_rawDesc = []byte{
+ 0x0a, 0x0d, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12,
+ 0x05, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x1d, 0x0a, 0x07, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67,
+ 0x65, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52,
+ 0x04, 0x64, 0x61, 0x74, 0x61, 0x22, 0x20, 0x0a, 0x0e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65,
+ 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20,
+ 0x01, 0x28, 0x0c, 0x52, 0x02, 0x69, 0x64, 0x42, 0x37, 0x5a, 0x35, 0x67, 0x69, 0x74, 0x68, 0x75,
+ 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x69, 0x6f, 0x74, 0x61, 0x6c, 0x65, 0x64, 0x67, 0x65, 0x72,
+ 0x2f, 0x67, 0x6f, 0x73, 0x68, 0x69, 0x6d, 0x6d, 0x65, 0x72, 0x2f, 0x70, 0x61, 0x63, 0x6b, 0x61,
+ 0x67, 0x65, 0x73, 0x2f, 0x67, 0x6f, 0x73, 0x73, 0x69, 0x70, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f,
+ 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+}
+
+var (
+ file_message_proto_rawDescOnce sync.Once
+ file_message_proto_rawDescData = file_message_proto_rawDesc
+)
+
+func file_message_proto_rawDescGZIP() []byte {
+ file_message_proto_rawDescOnce.Do(func() {
+ file_message_proto_rawDescData = protoimpl.X.CompressGZIP(file_message_proto_rawDescData)
+ })
+ return file_message_proto_rawDescData
}
-func init() {
- proto.RegisterFile("message.proto", fileDescriptor_33c57e4bae7b9afd)
+var file_message_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
+var file_message_proto_goTypes = []interface{}{
+ (*Message)(nil), // 0: proto.Message
+ (*MessageRequest)(nil), // 1: proto.MessageRequest
+}
+var file_message_proto_depIdxs = []int32{
+ 0, // [0:0] is the sub-list for method output_type
+ 0, // [0:0] 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
}
-var fileDescriptor_33c57e4bae7b9afd = []byte{
- // 147 bytes of a gzipped FileDescriptorProto
- 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0xe2, 0xcd, 0x4d, 0x2d, 0x2e,
- 0x4e, 0x4c, 0x4f, 0xd5, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0x62, 0x05, 0x53, 0x4a, 0xb2, 0x5c,
- 0xec, 0xbe, 0x10, 0x71, 0x21, 0x21, 0x2e, 0x96, 0x94, 0xc4, 0x92, 0x44, 0x09, 0x46, 0x05, 0x46,
- 0x0d, 0x9e, 0x20, 0x30, 0x5b, 0x49, 0x81, 0x8b, 0x0f, 0x2a, 0x1d, 0x94, 0x5a, 0x58, 0x9a, 0x5a,
- 0x5c, 0x22, 0xc4, 0xc7, 0xc5, 0x94, 0x99, 0x02, 0x55, 0xc3, 0x94, 0x99, 0xe2, 0x64, 0x1e, 0x65,
- 0x9a, 0x9e, 0x59, 0x92, 0x51, 0x9a, 0xa4, 0x97, 0x9c, 0x9f, 0xab, 0x9f, 0x99, 0x5f, 0x92, 0x98,
- 0x93, 0x9a, 0x92, 0x9e, 0x5a, 0xa4, 0x9f, 0x9e, 0x5f, 0x9c, 0x91, 0x99, 0x9b, 0x9b, 0x5a, 0xa4,
- 0x5f, 0x90, 0x98, 0x9c, 0x9d, 0x98, 0x9e, 0x5a, 0x0c, 0x12, 0x2a, 0xce, 0x2c, 0xd0, 0x07, 0xdb,
- 0x9c, 0xc4, 0x06, 0xa6, 0x8c, 0x01, 0x01, 0x00, 0x00, 0xff, 0xff, 0xc4, 0xb0, 0x39, 0x6d, 0x98,
- 0x00, 0x00, 0x00,
+func init() { file_message_proto_init() }
+func file_message_proto_init() {
+ if File_message_proto != nil {
+ return
+ }
+ if !protoimpl.UnsafeEnabled {
+ file_message_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
+ switch v := v.(*Message); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ file_message_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
+ switch v := v.(*MessageRequest); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ }
+ type x struct{}
+ out := protoimpl.TypeBuilder{
+ File: protoimpl.DescBuilder{
+ GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
+ RawDescriptor: file_message_proto_rawDesc,
+ NumEnums: 0,
+ NumMessages: 2,
+ NumExtensions: 0,
+ NumServices: 0,
+ },
+ GoTypes: file_message_proto_goTypes,
+ DependencyIndexes: file_message_proto_depIdxs,
+ MessageInfos: file_message_proto_msgTypes,
+ }.Build()
+ File_message_proto = out.File
+ file_message_proto_rawDesc = nil
+ file_message_proto_goTypes = nil
+ file_message_proto_depIdxs = nil
}
diff --git a/packages/gossip/proto/packet.go b/packages/gossip/proto/packet.go
index f905af818a0ea22d648c8804a6e07049d65d8d04..e80a7475daee85d01fd998e3ea189024ae101e7f 100644
--- a/packages/gossip/proto/packet.go
+++ b/packages/gossip/proto/packet.go
@@ -1,7 +1,7 @@
package proto
import (
- "github.com/golang/protobuf/proto"
+ "google.golang.org/protobuf/proto"
)
// PacketType is the type of packet type enum.
diff --git a/packages/gossip/server/handshake.go b/packages/gossip/server/handshake.go
index 86bef3f74ad82ab7aea532c1476661bf713ba4a1..c4adf26094b5ad16b826d2e0daab932be8de4c14 100644
--- a/packages/gossip/server/handshake.go
+++ b/packages/gossip/server/handshake.go
@@ -4,9 +4,9 @@ import (
"bytes"
"time"
- "github.com/golang/protobuf/proto"
pb "github.com/iotaledger/goshimmer/packages/gossip/server/proto"
"github.com/iotaledger/hive.go/autopeering/server"
+ "google.golang.org/protobuf/proto"
)
const (
diff --git a/packages/gossip/server/proto/handshake.pb.go b/packages/gossip/server/proto/handshake.pb.go
index c0e7307267baba8270206e24f17f7eebf41e85df..bfa00ba59bd48524c59f99cf766082c2715555d9 100644
--- a/packages/gossip/server/proto/handshake.pb.go
+++ b/packages/gossip/server/proto/handshake.pb.go
@@ -1,144 +1,236 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
-// source: server/proto/handshake.proto
+// versions:
+// protoc-gen-go v1.25.0
+// protoc v3.12.3
+// source: handshake.proto
package proto
import (
- fmt "fmt"
- math "math"
-
proto "github.com/golang/protobuf/proto"
+ protoreflect "google.golang.org/protobuf/reflect/protoreflect"
+ protoimpl "google.golang.org/protobuf/runtime/protoimpl"
+ reflect "reflect"
+ sync "sync"
)
-// Reference imports to suppress errors if they are not otherwise used.
-var _ = proto.Marshal
-var _ = fmt.Errorf
-var _ = math.Inf
+const (
+ // Verify that this generated code is sufficiently up-to-date.
+ _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
+ // Verify that runtime/protoimpl is sufficiently up-to-date.
+ _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
+)
-// This is a compile-time assertion to ensure that this generated file
-// is compatible with the proto package it is being compiled against.
-// A compilation error at this line likely means your copy of the
-// proto package needs to be updated.
-const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
+// This is a compile-time assertion that a sufficiently up-to-date version
+// of the legacy proto package is being used.
+const _ = proto.ProtoPackageIsVersion4
type HandshakeRequest struct {
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
+
// protocol version number
Version uint32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
// string form of the recipient address
To string `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
// unix time
- Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
+ Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}
-func (m *HandshakeRequest) Reset() { *m = HandshakeRequest{} }
-func (m *HandshakeRequest) String() string { return proto.CompactTextString(m) }
-func (*HandshakeRequest) ProtoMessage() {}
-func (*HandshakeRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_d7101ffe19b05443, []int{0}
+func (x *HandshakeRequest) Reset() {
+ *x = HandshakeRequest{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_handshake_proto_msgTypes[0]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
}
-func (m *HandshakeRequest) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_HandshakeRequest.Unmarshal(m, b)
+func (x *HandshakeRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
}
-func (m *HandshakeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_HandshakeRequest.Marshal(b, m, deterministic)
-}
-func (m *HandshakeRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_HandshakeRequest.Merge(m, src)
-}
-func (m *HandshakeRequest) XXX_Size() int {
- return xxx_messageInfo_HandshakeRequest.Size(m)
-}
-func (m *HandshakeRequest) XXX_DiscardUnknown() {
- xxx_messageInfo_HandshakeRequest.DiscardUnknown(m)
+
+func (*HandshakeRequest) ProtoMessage() {}
+
+func (x *HandshakeRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_handshake_proto_msgTypes[0]
+ 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)
}
-var xxx_messageInfo_HandshakeRequest proto.InternalMessageInfo
+// Deprecated: Use HandshakeRequest.ProtoReflect.Descriptor instead.
+func (*HandshakeRequest) Descriptor() ([]byte, []int) {
+ return file_handshake_proto_rawDescGZIP(), []int{0}
+}
-func (m *HandshakeRequest) GetVersion() uint32 {
- if m != nil {
- return m.Version
+func (x *HandshakeRequest) GetVersion() uint32 {
+ if x != nil {
+ return x.Version
}
return 0
}
-func (m *HandshakeRequest) GetTo() string {
- if m != nil {
- return m.To
+func (x *HandshakeRequest) GetTo() string {
+ if x != nil {
+ return x.To
}
return ""
}
-func (m *HandshakeRequest) GetTimestamp() int64 {
- if m != nil {
- return m.Timestamp
+func (x *HandshakeRequest) GetTimestamp() int64 {
+ if x != nil {
+ return x.Timestamp
}
return 0
}
type HandshakeResponse struct {
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
+
// hash of the ping packet
- ReqHash []byte `protobuf:"bytes,1,opt,name=req_hash,json=reqHash,proto3" json:"req_hash,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
+ ReqHash []byte `protobuf:"bytes,1,opt,name=req_hash,json=reqHash,proto3" json:"req_hash,omitempty"`
}
-func (m *HandshakeResponse) Reset() { *m = HandshakeResponse{} }
-func (m *HandshakeResponse) String() string { return proto.CompactTextString(m) }
-func (*HandshakeResponse) ProtoMessage() {}
-func (*HandshakeResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_d7101ffe19b05443, []int{1}
+func (x *HandshakeResponse) Reset() {
+ *x = HandshakeResponse{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_handshake_proto_msgTypes[1]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
}
-func (m *HandshakeResponse) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_HandshakeResponse.Unmarshal(m, b)
-}
-func (m *HandshakeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_HandshakeResponse.Marshal(b, m, deterministic)
+func (x *HandshakeResponse) String() string {
+ return protoimpl.X.MessageStringOf(x)
}
-func (m *HandshakeResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_HandshakeResponse.Merge(m, src)
-}
-func (m *HandshakeResponse) XXX_Size() int {
- return xxx_messageInfo_HandshakeResponse.Size(m)
-}
-func (m *HandshakeResponse) XXX_DiscardUnknown() {
- xxx_messageInfo_HandshakeResponse.DiscardUnknown(m)
+
+func (*HandshakeResponse) ProtoMessage() {}
+
+func (x *HandshakeResponse) ProtoReflect() protoreflect.Message {
+ mi := &file_handshake_proto_msgTypes[1]
+ 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)
}
-var xxx_messageInfo_HandshakeResponse proto.InternalMessageInfo
+// Deprecated: Use HandshakeResponse.ProtoReflect.Descriptor instead.
+func (*HandshakeResponse) Descriptor() ([]byte, []int) {
+ return file_handshake_proto_rawDescGZIP(), []int{1}
+}
-func (m *HandshakeResponse) GetReqHash() []byte {
- if m != nil {
- return m.ReqHash
+func (x *HandshakeResponse) GetReqHash() []byte {
+ if x != nil {
+ return x.ReqHash
}
return nil
}
-func init() {
- proto.RegisterType((*HandshakeRequest)(nil), "proto.HandshakeRequest")
- proto.RegisterType((*HandshakeResponse)(nil), "proto.HandshakeResponse")
-}
-
-func init() { proto.RegisterFile("server/proto/handshake.proto", fileDescriptor_d7101ffe19b05443) }
-
-var fileDescriptor_d7101ffe19b05443 = []byte{
- // 206 bytes of a gzipped FileDescriptorProto
- 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0x5c, 0x8f, 0x31, 0x4b, 0x83, 0x31,
- 0x10, 0x86, 0x69, 0x8b, 0xd6, 0x06, 0x15, 0xcd, 0xf4, 0x09, 0x82, 0xd2, 0xc9, 0xe9, 0xcb, 0xe0,
- 0x0f, 0x10, 0x9d, 0x3a, 0x67, 0xec, 0x22, 0xd7, 0xf6, 0x48, 0x42, 0x4d, 0x2e, 0xcd, 0x5d, 0xfd,
- 0xfd, 0x9e, 0x81, 0xa2, 0x74, 0x7a, 0xdf, 0xe7, 0x09, 0x79, 0x49, 0xcc, 0x93, 0x34, 0x28, 0x5c,
- 0xa9, 0x89, 0xab, 0x8d, 0x84, 0x5c, 0x84, 0xb2, 0xe3, 0x08, 0x7b, 0x1c, 0x3b, 0xdb, 0x8b, 0x1e,
- 0xcb, 0xb5, 0xb9, 0x5b, 0x9d, 0x4e, 0x3c, 0x1e, 0x8e, 0xc8, 0x62, 0x07, 0x33, 0xff, 0xc6, 0xc6,
- 0x89, 0xca, 0x30, 0x79, 0x9e, 0xbc, 0xdc, 0xf8, 0x13, 0xda, 0x5b, 0x33, 0x15, 0x1a, 0xa6, 0x2a,
- 0x17, 0x5e, 0x9b, 0x7d, 0x34, 0x0b, 0x49, 0x59, 0xef, 0x40, 0xae, 0xc3, 0x4c, 0xf5, 0xcc, 0xff,
- 0x89, 0xe5, 0x68, 0xee, 0xff, 0x6d, 0xeb, 0x63, 0x0a, 0xa3, 0x7d, 0x30, 0x57, 0x0d, 0x0f, 0x9f,
- 0x11, 0x38, 0xf6, 0xf5, 0x6b, 0x3f, 0x57, 0x5e, 0x29, 0x7e, 0xbc, 0xaf, 0xdf, 0x42, 0x92, 0x78,
- 0xdc, 0x8c, 0x5b, 0xca, 0x2e, 0x91, 0xc0, 0x17, 0xee, 0x02, 0x36, 0x17, 0x88, 0x63, 0xca, 0x59,
- 0x5b, 0x85, 0xed, 0x1e, 0x02, 0xf2, 0xaf, 0xe2, 0x54, 0xdd, 0xd9, 0x2f, 0x37, 0x97, 0x3d, 0x5e,
- 0x7f, 0x02, 0x00, 0x00, 0xff, 0xff, 0x51, 0x6a, 0x20, 0xf4, 0xff, 0x00, 0x00, 0x00,
+var File_handshake_proto protoreflect.FileDescriptor
+
+var file_handshake_proto_rawDesc = []byte{
+ 0x0a, 0x0f, 0x68, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74,
+ 0x6f, 0x12, 0x05, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x5a, 0x0a, 0x10, 0x48, 0x61, 0x6e, 0x64,
+ 0x73, 0x68, 0x61, 0x6b, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x07,
+ 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x07, 0x76,
+ 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x0e, 0x0a, 0x02, 0x74, 0x6f, 0x18, 0x02, 0x20, 0x01,
+ 0x28, 0x09, 0x52, 0x02, 0x74, 0x6f, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74,
+ 0x61, 0x6d, 0x70, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73,
+ 0x74, 0x61, 0x6d, 0x70, 0x22, 0x2e, 0x0a, 0x11, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b,
+ 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x19, 0x0a, 0x08, 0x72, 0x65, 0x71,
+ 0x5f, 0x68, 0x61, 0x73, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x07, 0x72, 0x65, 0x71,
+ 0x48, 0x61, 0x73, 0x68, 0x42, 0x41, 0x5a, 0x3f, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63,
+ 0x6f, 0x6d, 0x2f, 0x69, 0x6f, 0x74, 0x61, 0x6c, 0x65, 0x64, 0x67, 0x65, 0x72, 0x2f, 0x67, 0x6f,
+ 0x73, 0x68, 0x69, 0x6d, 0x6d, 0x65, 0x72, 0x2f, 0x70, 0x61, 0x63, 0x6b, 0x61, 0x67, 0x65, 0x73,
+ 0x2f, 0x67, 0x6f, 0x73, 0x73, 0x69, 0x70, 0x2f, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x70, 0x6f, 0x72,
+ 0x74, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+}
+
+var (
+ file_handshake_proto_rawDescOnce sync.Once
+ file_handshake_proto_rawDescData = file_handshake_proto_rawDesc
+)
+
+func file_handshake_proto_rawDescGZIP() []byte {
+ file_handshake_proto_rawDescOnce.Do(func() {
+ file_handshake_proto_rawDescData = protoimpl.X.CompressGZIP(file_handshake_proto_rawDescData)
+ })
+ return file_handshake_proto_rawDescData
+}
+
+var file_handshake_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
+var file_handshake_proto_goTypes = []interface{}{
+ (*HandshakeRequest)(nil), // 0: proto.HandshakeRequest
+ (*HandshakeResponse)(nil), // 1: proto.HandshakeResponse
+}
+var file_handshake_proto_depIdxs = []int32{
+ 0, // [0:0] is the sub-list for method output_type
+ 0, // [0:0] 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_handshake_proto_init() }
+func file_handshake_proto_init() {
+ if File_handshake_proto != nil {
+ return
+ }
+ if !protoimpl.UnsafeEnabled {
+ file_handshake_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
+ switch v := v.(*HandshakeRequest); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ file_handshake_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
+ switch v := v.(*HandshakeResponse); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ }
+ type x struct{}
+ out := protoimpl.TypeBuilder{
+ File: protoimpl.DescBuilder{
+ GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
+ RawDescriptor: file_handshake_proto_rawDesc,
+ NumEnums: 0,
+ NumMessages: 2,
+ NumExtensions: 0,
+ NumServices: 0,
+ },
+ GoTypes: file_handshake_proto_goTypes,
+ DependencyIndexes: file_handshake_proto_depIdxs,
+ MessageInfos: file_handshake_proto_msgTypes,
+ }.Build()
+ File_handshake_proto = out.File
+ file_handshake_proto_rawDesc = nil
+ file_handshake_proto_goTypes = nil
+ file_handshake_proto_depIdxs = nil
}
diff --git a/packages/vote/net/query.pb.go b/packages/vote/net/query.pb.go
index 30a964a05b939b3ecc5e2e974c70eda9a745458e..bc5d14e7728f4a3dc19af50b1a03ea91f2854886 100644
--- a/packages/vote/net/query.pb.go
+++ b/packages/vote/net/query.pb.go
@@ -1,4 +1,7 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
+// versions:
+// protoc-gen-go v1.25.0
+// protoc v3.12.3
// source: query.proto
package net
@@ -10,7 +13,11 @@ import (
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
+ protoreflect "google.golang.org/protobuf/reflect/protoreflect"
+ protoimpl "google.golang.org/protobuf/runtime/protoimpl"
math "math"
+ reflect "reflect"
+ sync "sync"
)
// Reference imports to suppress errors if they are not otherwise used.
@@ -18,111 +25,203 @@ var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
-// This is a compile-time assertion to ensure that this generated file
-// is compatible with the proto package it is being compiled against.
-// A compilation error at this line likely means your copy of the
-// proto package needs to be updated.
-const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
+const (
+ // Verify that this generated code is sufficiently up-to-date.
+ _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
+ // Verify that runtime/protoimpl is sufficiently up-to-date.
+ _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
+)
+
+// This is a compile-time assertion that a sufficiently up-to-date version
+// of the legacy proto package is being used.
+const _ = proto.ProtoPackageIsVersion4
type QueryRequest struct {
- Id []string `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
-func (m *QueryRequest) Reset() { *m = QueryRequest{} }
-func (m *QueryRequest) String() string { return proto.CompactTextString(m) }
-func (*QueryRequest) ProtoMessage() {}
-func (*QueryRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_5c6ac9b241082464, []int{0}
+ Id []string `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"`
}
-func (m *QueryRequest) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_QueryRequest.Unmarshal(m, b)
-}
-func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_QueryRequest.Marshal(b, m, deterministic)
-}
-func (m *QueryRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_QueryRequest.Merge(m, src)
+func (x *QueryRequest) Reset() {
+ *x = QueryRequest{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_query_proto_msgTypes[0]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
}
-func (m *QueryRequest) XXX_Size() int {
- return xxx_messageInfo_QueryRequest.Size(m)
+
+func (x *QueryRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
}
-func (m *QueryRequest) XXX_DiscardUnknown() {
- xxx_messageInfo_QueryRequest.DiscardUnknown(m)
+
+func (*QueryRequest) ProtoMessage() {}
+
+func (x *QueryRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_query_proto_msgTypes[0]
+ 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)
}
-var xxx_messageInfo_QueryRequest proto.InternalMessageInfo
+// Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.
+func (*QueryRequest) Descriptor() ([]byte, []int) {
+ return file_query_proto_rawDescGZIP(), []int{0}
+}
-func (m *QueryRequest) GetId() []string {
- if m != nil {
- return m.Id
+func (x *QueryRequest) GetId() []string {
+ if x != nil {
+ return x.Id
}
return nil
}
type QueryReply struct {
- Opinion []int32 `protobuf:"varint,1,rep,packed,name=opinion,proto3" json:"opinion,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
-func (m *QueryReply) Reset() { *m = QueryReply{} }
-func (m *QueryReply) String() string { return proto.CompactTextString(m) }
-func (*QueryReply) ProtoMessage() {}
-func (*QueryReply) Descriptor() ([]byte, []int) {
- return fileDescriptor_5c6ac9b241082464, []int{1}
+ Opinion []int32 `protobuf:"varint,1,rep,packed,name=opinion,proto3" json:"opinion,omitempty"`
}
-func (m *QueryReply) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_QueryReply.Unmarshal(m, b)
-}
-func (m *QueryReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_QueryReply.Marshal(b, m, deterministic)
-}
-func (m *QueryReply) XXX_Merge(src proto.Message) {
- xxx_messageInfo_QueryReply.Merge(m, src)
+func (x *QueryReply) Reset() {
+ *x = QueryReply{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_query_proto_msgTypes[1]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
}
-func (m *QueryReply) XXX_Size() int {
- return xxx_messageInfo_QueryReply.Size(m)
+
+func (x *QueryReply) String() string {
+ return protoimpl.X.MessageStringOf(x)
}
-func (m *QueryReply) XXX_DiscardUnknown() {
- xxx_messageInfo_QueryReply.DiscardUnknown(m)
+
+func (*QueryReply) ProtoMessage() {}
+
+func (x *QueryReply) ProtoReflect() protoreflect.Message {
+ mi := &file_query_proto_msgTypes[1]
+ 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)
}
-var xxx_messageInfo_QueryReply proto.InternalMessageInfo
+// Deprecated: Use QueryReply.ProtoReflect.Descriptor instead.
+func (*QueryReply) Descriptor() ([]byte, []int) {
+ return file_query_proto_rawDescGZIP(), []int{1}
+}
-func (m *QueryReply) GetOpinion() []int32 {
- if m != nil {
- return m.Opinion
+func (x *QueryReply) GetOpinion() []int32 {
+ if x != nil {
+ return x.Opinion
}
return nil
}
-func init() {
- proto.RegisterType((*QueryRequest)(nil), "net.QueryRequest")
- proto.RegisterType((*QueryReply)(nil), "net.QueryReply")
+var File_query_proto protoreflect.FileDescriptor
+
+var file_query_proto_rawDesc = []byte{
+ 0x0a, 0x0b, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x03, 0x6e,
+ 0x65, 0x74, 0x22, 0x1e, 0x0a, 0x0c, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65,
+ 0x73, 0x74, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x02,
+ 0x69, 0x64, 0x22, 0x26, 0x0a, 0x0a, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x70, 0x6c, 0x79,
+ 0x12, 0x18, 0x0a, 0x07, 0x6f, 0x70, 0x69, 0x6e, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x03, 0x28,
+ 0x05, 0x52, 0x07, 0x6f, 0x70, 0x69, 0x6e, 0x69, 0x6f, 0x6e, 0x32, 0x3d, 0x0a, 0x0a, 0x56, 0x6f,
+ 0x74, 0x65, 0x72, 0x51, 0x75, 0x65, 0x72, 0x79, 0x12, 0x2f, 0x0a, 0x07, 0x4f, 0x70, 0x69, 0x6e,
+ 0x69, 0x6f, 0x6e, 0x12, 0x11, 0x2e, 0x6e, 0x65, 0x74, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52,
+ 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x6e, 0x65, 0x74, 0x2e, 0x51, 0x75, 0x65,
+ 0x72, 0x79, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x22, 0x00, 0x42, 0x07, 0x5a, 0x05, 0x2e, 0x3b, 0x6e,
+ 0x65, 0x74, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
-func init() {
- proto.RegisterFile("query.proto", fileDescriptor_5c6ac9b241082464)
+var (
+ file_query_proto_rawDescOnce sync.Once
+ file_query_proto_rawDescData = file_query_proto_rawDesc
+)
+
+func file_query_proto_rawDescGZIP() []byte {
+ file_query_proto_rawDescOnce.Do(func() {
+ file_query_proto_rawDescData = protoimpl.X.CompressGZIP(file_query_proto_rawDescData)
+ })
+ return file_query_proto_rawDescData
+}
+
+var file_query_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
+var file_query_proto_goTypes = []interface{}{
+ (*QueryRequest)(nil), // 0: net.QueryRequest
+ (*QueryReply)(nil), // 1: net.QueryReply
+}
+var file_query_proto_depIdxs = []int32{
+ 0, // 0: net.VoterQuery.Opinion:input_type -> net.QueryRequest
+ 1, // 1: net.VoterQuery.Opinion:output_type -> net.QueryReply
+ 1, // [1:2] is the sub-list for method output_type
+ 0, // [0:1] 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
}
-var fileDescriptor_5c6ac9b241082464 = []byte{
- // 148 bytes of a gzipped FileDescriptorProto
- 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0xe2, 0x2e, 0x2c, 0x4d, 0x2d,
- 0xaa, 0xd4, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0x62, 0xce, 0x4b, 0x2d, 0x51, 0x92, 0xe3, 0xe2,
- 0x09, 0x04, 0x89, 0x05, 0xa5, 0x16, 0x96, 0xa6, 0x16, 0x97, 0x08, 0xf1, 0x71, 0x31, 0x65, 0xa6,
- 0x48, 0x30, 0x2a, 0x30, 0x6b, 0x70, 0x06, 0x31, 0x65, 0xa6, 0x28, 0xa9, 0x71, 0x71, 0x41, 0xe5,
- 0x0b, 0x72, 0x2a, 0x85, 0x24, 0xb8, 0xd8, 0xf3, 0x0b, 0x32, 0xf3, 0x32, 0xf3, 0xf3, 0xc0, 0x4a,
- 0x58, 0x83, 0x60, 0x5c, 0x23, 0x5b, 0x2e, 0xae, 0xb0, 0xfc, 0x92, 0xd4, 0x22, 0xb0, 0x62, 0x21,
- 0x7d, 0x2e, 0x76, 0x7f, 0x88, 0x84, 0x90, 0xa0, 0x5e, 0x5e, 0x6a, 0x89, 0x1e, 0xb2, 0x1d, 0x52,
- 0xfc, 0xc8, 0x42, 0x05, 0x39, 0x95, 0x4a, 0x0c, 0x4e, 0xec, 0x51, 0xac, 0x7a, 0xd6, 0x79, 0xa9,
- 0x25, 0x49, 0x6c, 0x60, 0xb7, 0x19, 0x03, 0x02, 0x00, 0x00, 0xff, 0xff, 0xb4, 0x93, 0xeb, 0x61,
- 0xaa, 0x00, 0x00, 0x00,
+func init() { file_query_proto_init() }
+func file_query_proto_init() {
+ if File_query_proto != nil {
+ return
+ }
+ if !protoimpl.UnsafeEnabled {
+ file_query_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
+ switch v := v.(*QueryRequest); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ file_query_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
+ switch v := v.(*QueryReply); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ }
+ type x struct{}
+ out := protoimpl.TypeBuilder{
+ File: protoimpl.DescBuilder{
+ GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
+ RawDescriptor: file_query_proto_rawDesc,
+ NumEnums: 0,
+ NumMessages: 2,
+ NumExtensions: 0,
+ NumServices: 1,
+ },
+ GoTypes: file_query_proto_goTypes,
+ DependencyIndexes: file_query_proto_depIdxs,
+ MessageInfos: file_query_proto_msgTypes,
+ }.Build()
+ File_query_proto = out.File
+ file_query_proto_rawDesc = nil
+ file_query_proto_goTypes = nil
+ file_query_proto_depIdxs = nil
}
// Reference imports to suppress errors if they are not otherwise used.
diff --git a/packages/vote/net/server.go b/packages/vote/net/server.go
index e91aba982440201ea5f9fb2bb40b9f58e581ddd4..c925134154daa8991d740b6c23b28606b4eb2996 100644
--- a/packages/vote/net/server.go
+++ b/packages/vote/net/server.go
@@ -4,11 +4,11 @@ import (
"context"
"net"
- "github.com/golang/protobuf/proto"
"github.com/iotaledger/goshimmer/packages/metrics"
"github.com/iotaledger/goshimmer/packages/vote"
"github.com/iotaledger/hive.go/events"
"google.golang.org/grpc"
+ "google.golang.org/protobuf/proto"
)
// OpinionRetriever retrieves the opinion for the given ID.