From e8662c2427601ec7ad7f5a23ed3b1c33d55a671f Mon Sep 17 00:00:00 2001 From: Christian Schwarz Date: Tue, 20 Jan 2026 21:57:25 +0000 Subject: [PATCH] `make generate` after updates --- internal/replication/logic/pdu/pdu.pb.go | 947 ++++++------------ internal/replication/logic/pdu/pdu_grpc.pb.go | 18 +- .../example/pdu/grpcauth.pb.go | 92 +- .../example/pdu/grpcauth_grpc.pb.go | 6 +- 4 files changed, 320 insertions(+), 743 deletions(-) diff --git a/internal/replication/logic/pdu/pdu.pb.go b/internal/replication/logic/pdu/pdu.pb.go index 867bf4b..09654d3 100644 --- a/internal/replication/logic/pdu/pdu.pb.go +++ b/internal/replication/logic/pdu/pdu.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.2 +// protoc-gen-go v1.36.11 // protoc v5.28.0 // source: pdu.proto @@ -11,6 +11,7 @@ import ( protoimpl "google.golang.org/protobuf/runtime/protoimpl" reflect "reflect" sync "sync" + unsafe "unsafe" ) const ( @@ -119,18 +120,16 @@ func (FilesystemVersion_VersionType) EnumDescriptor() ([]byte, []int) { } type ListFilesystemReq struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *ListFilesystemReq) Reset() { *x = ListFilesystemReq{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[0] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ListFilesystemReq) String() string { @@ -141,7 +140,7 @@ func (*ListFilesystemReq) ProtoMessage() {} func (x *ListFilesystemReq) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[0] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -157,20 +156,17 @@ func (*ListFilesystemReq) Descriptor() ([]byte, []int) { } type ListFilesystemRes struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Filesystems []*Filesystem `protobuf:"bytes,1,rep,name=Filesystems,proto3" json:"Filesystems,omitempty"` unknownFields protoimpl.UnknownFields - - Filesystems []*Filesystem `protobuf:"bytes,1,rep,name=Filesystems,proto3" json:"Filesystems,omitempty"` + sizeCache protoimpl.SizeCache } func (x *ListFilesystemRes) Reset() { *x = ListFilesystemRes{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[1] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ListFilesystemRes) String() string { @@ -181,7 +177,7 @@ func (*ListFilesystemRes) ProtoMessage() {} func (x *ListFilesystemRes) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[1] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -204,22 +200,19 @@ func (x *ListFilesystemRes) GetFilesystems() []*Filesystem { } type Filesystem struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Path string `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"` + ResumeToken string `protobuf:"bytes,2,opt,name=ResumeToken,proto3" json:"ResumeToken,omitempty"` + IsPlaceholder bool `protobuf:"varint,3,opt,name=IsPlaceholder,proto3" json:"IsPlaceholder,omitempty"` unknownFields protoimpl.UnknownFields - - Path string `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"` - ResumeToken string `protobuf:"bytes,2,opt,name=ResumeToken,proto3" json:"ResumeToken,omitempty"` - IsPlaceholder bool `protobuf:"varint,3,opt,name=IsPlaceholder,proto3" json:"IsPlaceholder,omitempty"` + sizeCache protoimpl.SizeCache } func (x *Filesystem) Reset() { *x = Filesystem{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[2] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *Filesystem) String() string { @@ -230,7 +223,7 @@ func (*Filesystem) ProtoMessage() {} func (x *Filesystem) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[2] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -267,20 +260,17 @@ func (x *Filesystem) GetIsPlaceholder() bool { } type ListFilesystemVersionsReq struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"` unknownFields protoimpl.UnknownFields - - Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"` + sizeCache protoimpl.SizeCache } func (x *ListFilesystemVersionsReq) Reset() { *x = ListFilesystemVersionsReq{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[3] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[3] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ListFilesystemVersionsReq) String() string { @@ -291,7 +281,7 @@ func (*ListFilesystemVersionsReq) ProtoMessage() {} func (x *ListFilesystemVersionsReq) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[3] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -314,20 +304,17 @@ func (x *ListFilesystemVersionsReq) GetFilesystem() string { } type ListFilesystemVersionsRes struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Versions []*FilesystemVersion `protobuf:"bytes,1,rep,name=Versions,proto3" json:"Versions,omitempty"` unknownFields protoimpl.UnknownFields - - Versions []*FilesystemVersion `protobuf:"bytes,1,rep,name=Versions,proto3" json:"Versions,omitempty"` + sizeCache protoimpl.SizeCache } func (x *ListFilesystemVersionsRes) Reset() { *x = ListFilesystemVersionsRes{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[4] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[4] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ListFilesystemVersionsRes) String() string { @@ -338,7 +325,7 @@ func (*ListFilesystemVersionsRes) ProtoMessage() {} func (x *ListFilesystemVersionsRes) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[4] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -361,24 +348,21 @@ func (x *ListFilesystemVersionsRes) GetVersions() []*FilesystemVersion { } type FilesystemVersion struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Type FilesystemVersion_VersionType `protobuf:"varint,1,opt,name=Type,proto3,enum=FilesystemVersion_VersionType" json:"Type,omitempty"` + Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"` + Guid uint64 `protobuf:"varint,3,opt,name=Guid,proto3" json:"Guid,omitempty"` + CreateTXG uint64 `protobuf:"varint,4,opt,name=CreateTXG,proto3" json:"CreateTXG,omitempty"` + Creation string `protobuf:"bytes,5,opt,name=Creation,proto3" json:"Creation,omitempty"` // RFC 3339 unknownFields protoimpl.UnknownFields - - Type FilesystemVersion_VersionType `protobuf:"varint,1,opt,name=Type,proto3,enum=FilesystemVersion_VersionType" json:"Type,omitempty"` - Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"` - Guid uint64 `protobuf:"varint,3,opt,name=Guid,proto3" json:"Guid,omitempty"` - CreateTXG uint64 `protobuf:"varint,4,opt,name=CreateTXG,proto3" json:"CreateTXG,omitempty"` - Creation string `protobuf:"bytes,5,opt,name=Creation,proto3" json:"Creation,omitempty"` // RFC 3339 + sizeCache protoimpl.SizeCache } func (x *FilesystemVersion) Reset() { *x = FilesystemVersion{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[5] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[5] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *FilesystemVersion) String() string { @@ -389,7 +373,7 @@ func (*FilesystemVersion) ProtoMessage() {} func (x *FilesystemVersion) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[5] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -440,11 +424,8 @@ func (x *FilesystemVersion) GetCreation() string { } type SendReq struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"` // May be empty / null to request a full transfer of To From *FilesystemVersion `protobuf:"bytes,2,opt,name=From,proto3" json:"From,omitempty"` To *FilesystemVersion `protobuf:"bytes,3,opt,name=To,proto3" json:"To,omitempty"` @@ -456,15 +437,15 @@ type SendReq struct { // encoded in the ResumeToken. Otherwise, the Sender MUST return an error. ResumeToken string `protobuf:"bytes,4,opt,name=ResumeToken,proto3" json:"ResumeToken,omitempty"` ReplicationConfig *ReplicationConfig `protobuf:"bytes,6,opt,name=ReplicationConfig,proto3" json:"ReplicationConfig,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *SendReq) Reset() { *x = SendReq{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[6] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[6] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *SendReq) String() string { @@ -475,7 +456,7 @@ func (*SendReq) ProtoMessage() {} func (x *SendReq) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[6] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -526,20 +507,17 @@ func (x *SendReq) GetReplicationConfig() *ReplicationConfig { } type ReplicationConfig struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Protection *ReplicationConfigProtection `protobuf:"bytes,1,opt,name=protection,proto3" json:"protection,omitempty"` unknownFields protoimpl.UnknownFields - - Protection *ReplicationConfigProtection `protobuf:"bytes,1,opt,name=protection,proto3" json:"protection,omitempty"` + sizeCache protoimpl.SizeCache } func (x *ReplicationConfig) Reset() { *x = ReplicationConfig{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[7] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[7] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ReplicationConfig) String() string { @@ -550,7 +528,7 @@ func (*ReplicationConfig) ProtoMessage() {} func (x *ReplicationConfig) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[7] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -573,21 +551,18 @@ func (x *ReplicationConfig) GetProtection() *ReplicationConfigProtection { } type ReplicationConfigProtection struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Initial ReplicationGuaranteeKind `protobuf:"varint,1,opt,name=Initial,proto3,enum=ReplicationGuaranteeKind" json:"Initial,omitempty"` + Incremental ReplicationGuaranteeKind `protobuf:"varint,2,opt,name=Incremental,proto3,enum=ReplicationGuaranteeKind" json:"Incremental,omitempty"` unknownFields protoimpl.UnknownFields - - Initial ReplicationGuaranteeKind `protobuf:"varint,1,opt,name=Initial,proto3,enum=ReplicationGuaranteeKind" json:"Initial,omitempty"` - Incremental ReplicationGuaranteeKind `protobuf:"varint,2,opt,name=Incremental,proto3,enum=ReplicationGuaranteeKind" json:"Incremental,omitempty"` + sizeCache protoimpl.SizeCache } func (x *ReplicationConfigProtection) Reset() { *x = ReplicationConfigProtection{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[8] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[8] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ReplicationConfigProtection) String() string { @@ -598,7 +573,7 @@ func (*ReplicationConfigProtection) ProtoMessage() {} func (x *ReplicationConfigProtection) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[8] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -628,21 +603,18 @@ func (x *ReplicationConfigProtection) GetIncremental() ReplicationGuaranteeKind } type Property struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` + Value string `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"` unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` - Value string `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"` + sizeCache protoimpl.SizeCache } func (x *Property) Reset() { *x = Property{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[9] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[9] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *Property) String() string { @@ -653,7 +625,7 @@ func (*Property) ProtoMessage() {} func (x *Property) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[9] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -683,25 +655,22 @@ func (x *Property) GetValue() string { } type SendRes struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // Whether the resume token provided in the request has been used or not. // If the SendReq.ResumeToken == "", this field MUST be false. UsedResumeToken bool `protobuf:"varint,1,opt,name=UsedResumeToken,proto3" json:"UsedResumeToken,omitempty"` // Expected stream size determined by dry run, not exact. // 0 indicates that for the given SendReq, no size estimate could be made. - ExpectedSize uint64 `protobuf:"varint,2,opt,name=ExpectedSize,proto3" json:"ExpectedSize,omitempty"` + ExpectedSize uint64 `protobuf:"varint,2,opt,name=ExpectedSize,proto3" json:"ExpectedSize,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *SendRes) Reset() { *x = SendRes{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[10] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[10] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *SendRes) String() string { @@ -712,7 +681,7 @@ func (*SendRes) ProtoMessage() {} func (x *SendRes) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[10] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -742,20 +711,17 @@ func (x *SendRes) GetExpectedSize() uint64 { } type SendCompletedReq struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + OriginalReq *SendReq `protobuf:"bytes,2,opt,name=OriginalReq,proto3" json:"OriginalReq,omitempty"` unknownFields protoimpl.UnknownFields - - OriginalReq *SendReq `protobuf:"bytes,2,opt,name=OriginalReq,proto3" json:"OriginalReq,omitempty"` + sizeCache protoimpl.SizeCache } func (x *SendCompletedReq) Reset() { *x = SendCompletedReq{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[11] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[11] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *SendCompletedReq) String() string { @@ -766,7 +732,7 @@ func (*SendCompletedReq) ProtoMessage() {} func (x *SendCompletedReq) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[11] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -789,18 +755,16 @@ func (x *SendCompletedReq) GetOriginalReq() *SendReq { } type SendCompletedRes struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *SendCompletedRes) Reset() { *x = SendCompletedRes{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[12] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[12] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *SendCompletedRes) String() string { @@ -811,7 +775,7 @@ func (*SendCompletedRes) ProtoMessage() {} func (x *SendCompletedRes) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[12] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -827,25 +791,22 @@ func (*SendCompletedRes) Descriptor() ([]byte, []int) { } type ReceiveReq struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"` - To *FilesystemVersion `protobuf:"bytes,2,opt,name=To,proto3" json:"To,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"` + To *FilesystemVersion `protobuf:"bytes,2,opt,name=To,proto3" json:"To,omitempty"` // If true, the receiver should clear the resume token before performing the // zfs recv of the stream in the request ClearResumeToken bool `protobuf:"varint,3,opt,name=ClearResumeToken,proto3" json:"ClearResumeToken,omitempty"` ReplicationConfig *ReplicationConfig `protobuf:"bytes,4,opt,name=ReplicationConfig,proto3" json:"ReplicationConfig,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *ReceiveReq) Reset() { *x = ReceiveReq{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[13] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[13] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ReceiveReq) String() string { @@ -856,7 +817,7 @@ func (*ReceiveReq) ProtoMessage() {} func (x *ReceiveReq) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[13] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -900,18 +861,16 @@ func (x *ReceiveReq) GetReplicationConfig() *ReplicationConfig { } type ReceiveRes struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *ReceiveRes) Reset() { *x = ReceiveRes{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[14] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[14] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ReceiveRes) String() string { @@ -922,7 +881,7 @@ func (*ReceiveRes) ProtoMessage() {} func (x *ReceiveRes) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[14] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -938,22 +897,19 @@ func (*ReceiveRes) Descriptor() ([]byte, []int) { } type DestroySnapshotsReq struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"` // Path to filesystem, snapshot or bookmark to be destroyed - Snapshots []*FilesystemVersion `protobuf:"bytes,2,rep,name=Snapshots,proto3" json:"Snapshots,omitempty"` + Snapshots []*FilesystemVersion `protobuf:"bytes,2,rep,name=Snapshots,proto3" json:"Snapshots,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *DestroySnapshotsReq) Reset() { *x = DestroySnapshotsReq{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[15] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[15] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *DestroySnapshotsReq) String() string { @@ -964,7 +920,7 @@ func (*DestroySnapshotsReq) ProtoMessage() {} func (x *DestroySnapshotsReq) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[15] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -994,21 +950,18 @@ func (x *DestroySnapshotsReq) GetSnapshots() []*FilesystemVersion { } type DestroySnapshotRes struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Snapshot *FilesystemVersion `protobuf:"bytes,1,opt,name=Snapshot,proto3" json:"Snapshot,omitempty"` + Error string `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"` unknownFields protoimpl.UnknownFields - - Snapshot *FilesystemVersion `protobuf:"bytes,1,opt,name=Snapshot,proto3" json:"Snapshot,omitempty"` - Error string `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"` + sizeCache protoimpl.SizeCache } func (x *DestroySnapshotRes) Reset() { *x = DestroySnapshotRes{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[16] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[16] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *DestroySnapshotRes) String() string { @@ -1019,7 +972,7 @@ func (*DestroySnapshotRes) ProtoMessage() {} func (x *DestroySnapshotRes) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[16] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -1049,20 +1002,17 @@ func (x *DestroySnapshotRes) GetError() string { } type DestroySnapshotsRes struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Results []*DestroySnapshotRes `protobuf:"bytes,1,rep,name=Results,proto3" json:"Results,omitempty"` unknownFields protoimpl.UnknownFields - - Results []*DestroySnapshotRes `protobuf:"bytes,1,rep,name=Results,proto3" json:"Results,omitempty"` + sizeCache protoimpl.SizeCache } func (x *DestroySnapshotsRes) Reset() { *x = DestroySnapshotsRes{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[17] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[17] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *DestroySnapshotsRes) String() string { @@ -1073,7 +1023,7 @@ func (*DestroySnapshotsRes) ProtoMessage() {} func (x *DestroySnapshotsRes) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[17] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -1096,20 +1046,17 @@ func (x *DestroySnapshotsRes) GetResults() []*DestroySnapshotRes { } type ReplicationCursorReq struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"` unknownFields protoimpl.UnknownFields - - Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"` + sizeCache protoimpl.SizeCache } func (x *ReplicationCursorReq) Reset() { *x = ReplicationCursorReq{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[18] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[18] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ReplicationCursorReq) String() string { @@ -1120,7 +1067,7 @@ func (*ReplicationCursorReq) ProtoMessage() {} func (x *ReplicationCursorReq) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[18] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -1143,24 +1090,21 @@ func (x *ReplicationCursorReq) GetFilesystem() string { } type ReplicationCursorRes struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - // Types that are assignable to Result: + state protoimpl.MessageState `protogen:"open.v1"` + // Types that are valid to be assigned to Result: // // *ReplicationCursorRes_Guid // *ReplicationCursorRes_Notexist - Result isReplicationCursorRes_Result `protobuf_oneof:"Result"` + Result isReplicationCursorRes_Result `protobuf_oneof:"Result"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *ReplicationCursorRes) Reset() { *x = ReplicationCursorRes{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[19] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[19] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *ReplicationCursorRes) String() string { @@ -1171,7 +1115,7 @@ func (*ReplicationCursorRes) ProtoMessage() {} func (x *ReplicationCursorRes) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[19] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -1186,23 +1130,27 @@ func (*ReplicationCursorRes) Descriptor() ([]byte, []int) { return file_pdu_proto_rawDescGZIP(), []int{19} } -func (m *ReplicationCursorRes) GetResult() isReplicationCursorRes_Result { - if m != nil { - return m.Result +func (x *ReplicationCursorRes) GetResult() isReplicationCursorRes_Result { + if x != nil { + return x.Result } return nil } func (x *ReplicationCursorRes) GetGuid() uint64 { - if x, ok := x.GetResult().(*ReplicationCursorRes_Guid); ok { - return x.Guid + if x != nil { + if x, ok := x.Result.(*ReplicationCursorRes_Guid); ok { + return x.Guid + } } return 0 } func (x *ReplicationCursorRes) GetNotexist() bool { - if x, ok := x.GetResult().(*ReplicationCursorRes_Notexist); ok { - return x.Notexist + if x != nil { + if x, ok := x.Result.(*ReplicationCursorRes_Notexist); ok { + return x.Notexist + } } return false } @@ -1224,20 +1172,17 @@ func (*ReplicationCursorRes_Guid) isReplicationCursorRes_Result() {} func (*ReplicationCursorRes_Notexist) isReplicationCursorRes_Result() {} type PingReq struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Message string `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"` unknownFields protoimpl.UnknownFields - - Message string `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"` + sizeCache protoimpl.SizeCache } func (x *PingReq) Reset() { *x = PingReq{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[20] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[20] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PingReq) String() string { @@ -1248,7 +1193,7 @@ func (*PingReq) ProtoMessage() {} func (x *PingReq) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[20] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -1271,21 +1216,18 @@ func (x *PingReq) GetMessage() string { } type PingRes struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // Echo must be PingReq.Message - Echo string `protobuf:"bytes,1,opt,name=Echo,proto3" json:"Echo,omitempty"` + Echo string `protobuf:"bytes,1,opt,name=Echo,proto3" json:"Echo,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *PingRes) Reset() { *x = PingRes{} - if protoimpl.UnsafeEnabled { - mi := &file_pdu_proto_msgTypes[21] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_pdu_proto_msgTypes[21] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *PingRes) String() string { @@ -1296,7 +1238,7 @@ func (*PingRes) ProtoMessage() {} func (x *PingRes) ProtoReflect() protoreflect.Message { mi := &file_pdu_proto_msgTypes[21] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -1320,172 +1262,110 @@ func (x *PingRes) GetEcho() string { var File_pdu_proto protoreflect.FileDescriptor -var file_pdu_proto_rawDesc = []byte{ - 0x0a, 0x09, 0x70, 0x64, 0x75, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x13, 0x0a, 0x11, 0x4c, - 0x69, 0x73, 0x74, 0x46, 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x52, 0x65, 0x71, - 0x22, 0x42, 0x0a, 0x11, 0x4c, 0x69, 0x73, 0x74, 0x46, 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, - 0x65, 0x6d, 0x52, 0x65, 0x73, 0x12, 0x2d, 0x0a, 0x0b, 0x46, 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, - 0x74, 0x65, 0x6d, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0b, 0x2e, 0x46, 0x69, 0x6c, - 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x52, 0x0b, 0x46, 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, - 0x74, 0x65, 0x6d, 0x73, 0x22, 0x68, 0x0a, 0x0a, 0x46, 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, - 0x65, 0x6d, 0x12, 0x12, 0x0a, 0x04, 0x50, 0x61, 0x74, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, - 0x52, 0x04, 0x50, 0x61, 0x74, 0x68, 0x12, 0x20, 0x0a, 0x0b, 0x52, 0x65, 0x73, 0x75, 0x6d, 0x65, - 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x52, 0x65, 0x73, - 0x75, 0x6d, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x24, 0x0a, 0x0d, 0x49, 0x73, 0x50, 0x6c, - 0x61, 0x63, 0x65, 0x68, 0x6f, 0x6c, 0x64, 0x65, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 0x52, - 0x0d, 0x49, 0x73, 0x50, 0x6c, 0x61, 0x63, 0x65, 0x68, 0x6f, 0x6c, 0x64, 0x65, 0x72, 0x22, 0x3b, - 0x0a, 0x19, 0x4c, 0x69, 0x73, 0x74, 0x46, 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, - 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x12, 0x1e, 0x0a, 0x0a, 0x46, - 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, - 0x0a, 0x46, 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x22, 0x4b, 0x0a, 0x19, 0x4c, - 0x69, 0x73, 0x74, 0x46, 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x56, 0x65, 0x72, - 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x73, 0x12, 0x2e, 0x0a, 0x08, 0x56, 0x65, 0x72, 0x73, - 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x46, 0x69, 0x6c, - 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x08, - 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x22, 0xd4, 0x01, 0x0a, 0x11, 0x46, 0x69, 0x6c, - 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x32, - 0x0a, 0x04, 0x54, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1e, 0x2e, 0x46, - 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, - 0x2e, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70, 0x65, 0x52, 0x04, 0x54, 0x79, - 0x70, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, - 0x52, 0x04, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x47, 0x75, 0x69, 0x64, 0x18, 0x03, - 0x20, 0x01, 0x28, 0x04, 0x52, 0x04, 0x47, 0x75, 0x69, 0x64, 0x12, 0x1c, 0x0a, 0x09, 0x43, 0x72, - 0x65, 0x61, 0x74, 0x65, 0x54, 0x58, 0x47, 0x18, 0x04, 0x20, 0x01, 0x28, 0x04, 0x52, 0x09, 0x43, - 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x58, 0x47, 0x12, 0x1a, 0x0a, 0x08, 0x43, 0x72, 0x65, 0x61, - 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x43, 0x72, 0x65, 0x61, - 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x29, 0x0a, 0x0b, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x54, - 0x79, 0x70, 0x65, 0x12, 0x0c, 0x0a, 0x08, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x10, - 0x00, 0x12, 0x0c, 0x0a, 0x08, 0x42, 0x6f, 0x6f, 0x6b, 0x6d, 0x61, 0x72, 0x6b, 0x10, 0x01, 0x22, - 0xd9, 0x01, 0x0a, 0x07, 0x53, 0x65, 0x6e, 0x64, 0x52, 0x65, 0x71, 0x12, 0x1e, 0x0a, 0x0a, 0x46, - 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, - 0x0a, 0x46, 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x12, 0x26, 0x0a, 0x04, 0x46, - 0x72, 0x6f, 0x6d, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x46, 0x69, 0x6c, 0x65, - 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x04, 0x46, - 0x72, 0x6f, 0x6d, 0x12, 0x22, 0x0a, 0x02, 0x54, 0x6f, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, - 0x12, 0x2e, 0x46, 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x56, 0x65, 0x72, 0x73, - 0x69, 0x6f, 0x6e, 0x52, 0x02, 0x54, 0x6f, 0x12, 0x20, 0x0a, 0x0b, 0x52, 0x65, 0x73, 0x75, 0x6d, - 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x52, 0x65, - 0x73, 0x75, 0x6d, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x40, 0x0a, 0x11, 0x52, 0x65, 0x70, - 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x06, - 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, - 0x6f, 0x6e, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x11, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, - 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x22, 0x51, 0x0a, 0x11, 0x52, - 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, - 0x12, 0x3c, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x74, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, - 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, - 0x6f, 0x6e, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x50, 0x72, 0x6f, 0x74, 0x65, 0x63, 0x74, 0x69, - 0x6f, 0x6e, 0x52, 0x0a, 0x70, 0x72, 0x6f, 0x74, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x8f, - 0x01, 0x0a, 0x1b, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x6f, - 0x6e, 0x66, 0x69, 0x67, 0x50, 0x72, 0x6f, 0x74, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x33, - 0x0a, 0x07, 0x49, 0x6e, 0x69, 0x74, 0x69, 0x61, 0x6c, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, - 0x19, 0x2e, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x47, 0x75, 0x61, - 0x72, 0x61, 0x6e, 0x74, 0x65, 0x65, 0x4b, 0x69, 0x6e, 0x64, 0x52, 0x07, 0x49, 0x6e, 0x69, 0x74, - 0x69, 0x61, 0x6c, 0x12, 0x3b, 0x0a, 0x0b, 0x49, 0x6e, 0x63, 0x72, 0x65, 0x6d, 0x65, 0x6e, 0x74, - 0x61, 0x6c, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x19, 0x2e, 0x52, 0x65, 0x70, 0x6c, 0x69, - 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x47, 0x75, 0x61, 0x72, 0x61, 0x6e, 0x74, 0x65, 0x65, 0x4b, - 0x69, 0x6e, 0x64, 0x52, 0x0b, 0x49, 0x6e, 0x63, 0x72, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x61, 0x6c, - 0x22, 0x34, 0x0a, 0x08, 0x50, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x79, 0x12, 0x12, 0x0a, 0x04, - 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x4e, 0x61, 0x6d, 0x65, - 0x12, 0x14, 0x0a, 0x05, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, - 0x05, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x57, 0x0a, 0x07, 0x53, 0x65, 0x6e, 0x64, 0x52, 0x65, - 0x73, 0x12, 0x28, 0x0a, 0x0f, 0x55, 0x73, 0x65, 0x64, 0x52, 0x65, 0x73, 0x75, 0x6d, 0x65, 0x54, - 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0f, 0x55, 0x73, 0x65, 0x64, - 0x52, 0x65, 0x73, 0x75, 0x6d, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x22, 0x0a, 0x0c, 0x45, - 0x78, 0x70, 0x65, 0x63, 0x74, 0x65, 0x64, 0x53, 0x69, 0x7a, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, - 0x04, 0x52, 0x0c, 0x45, 0x78, 0x70, 0x65, 0x63, 0x74, 0x65, 0x64, 0x53, 0x69, 0x7a, 0x65, 0x22, - 0x3e, 0x0a, 0x10, 0x53, 0x65, 0x6e, 0x64, 0x43, 0x6f, 0x6d, 0x70, 0x6c, 0x65, 0x74, 0x65, 0x64, - 0x52, 0x65, 0x71, 0x12, 0x2a, 0x0a, 0x0b, 0x4f, 0x72, 0x69, 0x67, 0x69, 0x6e, 0x61, 0x6c, 0x52, - 0x65, 0x71, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x08, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x52, - 0x65, 0x71, 0x52, 0x0b, 0x4f, 0x72, 0x69, 0x67, 0x69, 0x6e, 0x61, 0x6c, 0x52, 0x65, 0x71, 0x22, - 0x12, 0x0a, 0x10, 0x53, 0x65, 0x6e, 0x64, 0x43, 0x6f, 0x6d, 0x70, 0x6c, 0x65, 0x74, 0x65, 0x64, - 0x52, 0x65, 0x73, 0x22, 0xbe, 0x01, 0x0a, 0x0a, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x52, - 0x65, 0x71, 0x12, 0x1e, 0x0a, 0x0a, 0x46, 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, - 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x46, 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, - 0x65, 0x6d, 0x12, 0x22, 0x0a, 0x02, 0x54, 0x6f, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, - 0x2e, 0x46, 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x56, 0x65, 0x72, 0x73, 0x69, - 0x6f, 0x6e, 0x52, 0x02, 0x54, 0x6f, 0x12, 0x2a, 0x0a, 0x10, 0x43, 0x6c, 0x65, 0x61, 0x72, 0x52, - 0x65, 0x73, 0x75, 0x6d, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, - 0x52, 0x10, 0x43, 0x6c, 0x65, 0x61, 0x72, 0x52, 0x65, 0x73, 0x75, 0x6d, 0x65, 0x54, 0x6f, 0x6b, - 0x65, 0x6e, 0x12, 0x40, 0x0a, 0x11, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, - 0x6e, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, - 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x6f, 0x6e, 0x66, 0x69, - 0x67, 0x52, 0x11, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x6f, - 0x6e, 0x66, 0x69, 0x67, 0x22, 0x0c, 0x0a, 0x0a, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x52, - 0x65, 0x73, 0x22, 0x67, 0x0a, 0x13, 0x44, 0x65, 0x73, 0x74, 0x72, 0x6f, 0x79, 0x53, 0x6e, 0x61, - 0x70, 0x73, 0x68, 0x6f, 0x74, 0x73, 0x52, 0x65, 0x71, 0x12, 0x1e, 0x0a, 0x0a, 0x46, 0x69, 0x6c, - 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x46, - 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x12, 0x30, 0x0a, 0x09, 0x53, 0x6e, 0x61, - 0x70, 0x73, 0x68, 0x6f, 0x74, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x46, - 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, - 0x52, 0x09, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x73, 0x22, 0x5a, 0x0a, 0x12, 0x44, - 0x65, 0x73, 0x74, 0x72, 0x6f, 0x79, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x52, 0x65, - 0x73, 0x12, 0x2e, 0x0a, 0x08, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x18, 0x01, 0x20, - 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x46, 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, - 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x08, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, - 0x74, 0x12, 0x14, 0x0a, 0x05, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, - 0x52, 0x05, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x22, 0x44, 0x0a, 0x13, 0x44, 0x65, 0x73, 0x74, 0x72, - 0x6f, 0x79, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x73, 0x52, 0x65, 0x73, 0x12, 0x2d, - 0x0a, 0x07, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, - 0x13, 0x2e, 0x44, 0x65, 0x73, 0x74, 0x72, 0x6f, 0x79, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, - 0x74, 0x52, 0x65, 0x73, 0x52, 0x07, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x22, 0x36, 0x0a, - 0x14, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x75, 0x72, 0x73, - 0x6f, 0x72, 0x52, 0x65, 0x71, 0x12, 0x1e, 0x0a, 0x0a, 0x46, 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, - 0x74, 0x65, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x46, 0x69, 0x6c, 0x65, 0x73, - 0x79, 0x73, 0x74, 0x65, 0x6d, 0x22, 0x54, 0x0a, 0x14, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, - 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x75, 0x72, 0x73, 0x6f, 0x72, 0x52, 0x65, 0x73, 0x12, 0x14, 0x0a, - 0x04, 0x47, 0x75, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x48, 0x00, 0x52, 0x04, 0x47, - 0x75, 0x69, 0x64, 0x12, 0x1c, 0x0a, 0x08, 0x4e, 0x6f, 0x74, 0x65, 0x78, 0x69, 0x73, 0x74, 0x18, - 0x02, 0x20, 0x01, 0x28, 0x08, 0x48, 0x00, 0x52, 0x08, 0x4e, 0x6f, 0x74, 0x65, 0x78, 0x69, 0x73, - 0x74, 0x42, 0x08, 0x0a, 0x06, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x22, 0x23, 0x0a, 0x07, 0x50, - 0x69, 0x6e, 0x67, 0x52, 0x65, 0x71, 0x12, 0x18, 0x0a, 0x07, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, - 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, - 0x22, 0x1d, 0x0a, 0x07, 0x50, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x73, 0x12, 0x12, 0x0a, 0x04, 0x45, - 0x63, 0x68, 0x6f, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x45, 0x63, 0x68, 0x6f, 0x2a, - 0x86, 0x01, 0x0a, 0x18, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x47, - 0x75, 0x61, 0x72, 0x61, 0x6e, 0x74, 0x65, 0x65, 0x4b, 0x69, 0x6e, 0x64, 0x12, 0x14, 0x0a, 0x10, - 0x47, 0x75, 0x61, 0x72, 0x61, 0x6e, 0x74, 0x65, 0x65, 0x49, 0x6e, 0x76, 0x61, 0x6c, 0x69, 0x64, - 0x10, 0x00, 0x12, 0x19, 0x0a, 0x15, 0x47, 0x75, 0x61, 0x72, 0x61, 0x6e, 0x74, 0x65, 0x65, 0x52, - 0x65, 0x73, 0x75, 0x6d, 0x61, 0x62, 0x69, 0x6c, 0x69, 0x74, 0x79, 0x10, 0x01, 0x12, 0x23, 0x0a, - 0x1f, 0x47, 0x75, 0x61, 0x72, 0x61, 0x6e, 0x74, 0x65, 0x65, 0x49, 0x6e, 0x63, 0x72, 0x65, 0x6d, - 0x65, 0x6e, 0x74, 0x61, 0x6c, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, - 0x10, 0x02, 0x12, 0x14, 0x0a, 0x10, 0x47, 0x75, 0x61, 0x72, 0x61, 0x6e, 0x74, 0x65, 0x65, 0x4e, - 0x6f, 0x74, 0x68, 0x69, 0x6e, 0x67, 0x10, 0x03, 0x32, 0x8f, 0x03, 0x0a, 0x0b, 0x52, 0x65, 0x70, - 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x1a, 0x0a, 0x04, 0x50, 0x69, 0x6e, 0x67, - 0x12, 0x08, 0x2e, 0x50, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x71, 0x1a, 0x08, 0x2e, 0x50, 0x69, 0x6e, - 0x67, 0x52, 0x65, 0x73, 0x12, 0x39, 0x0a, 0x0f, 0x4c, 0x69, 0x73, 0x74, 0x46, 0x69, 0x6c, 0x65, - 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x73, 0x12, 0x12, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x46, 0x69, - 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x52, 0x65, 0x71, 0x1a, 0x12, 0x2e, 0x4c, 0x69, - 0x73, 0x74, 0x46, 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x52, 0x65, 0x73, 0x12, - 0x50, 0x0a, 0x16, 0x4c, 0x69, 0x73, 0x74, 0x46, 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, - 0x6d, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x1a, 0x2e, 0x4c, 0x69, 0x73, 0x74, - 0x46, 0x69, 0x6c, 0x65, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, - 0x6e, 0x73, 0x52, 0x65, 0x71, 0x1a, 0x1a, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x46, 0x69, 0x6c, 0x65, - 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, - 0x73, 0x12, 0x3e, 0x0a, 0x10, 0x44, 0x65, 0x73, 0x74, 0x72, 0x6f, 0x79, 0x53, 0x6e, 0x61, 0x70, - 0x73, 0x68, 0x6f, 0x74, 0x73, 0x12, 0x14, 0x2e, 0x44, 0x65, 0x73, 0x74, 0x72, 0x6f, 0x79, 0x53, - 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x73, 0x52, 0x65, 0x71, 0x1a, 0x14, 0x2e, 0x44, 0x65, - 0x73, 0x74, 0x72, 0x6f, 0x79, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x73, 0x52, 0x65, - 0x73, 0x12, 0x41, 0x0a, 0x11, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, - 0x43, 0x75, 0x72, 0x73, 0x6f, 0x72, 0x12, 0x15, 0x2e, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, - 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x75, 0x72, 0x73, 0x6f, 0x72, 0x52, 0x65, 0x71, 0x1a, 0x15, 0x2e, - 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x75, 0x72, 0x73, 0x6f, - 0x72, 0x52, 0x65, 0x73, 0x12, 0x1d, 0x0a, 0x07, 0x53, 0x65, 0x6e, 0x64, 0x44, 0x72, 0x79, 0x12, - 0x08, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x52, 0x65, 0x71, 0x1a, 0x08, 0x2e, 0x53, 0x65, 0x6e, 0x64, - 0x52, 0x65, 0x73, 0x12, 0x35, 0x0a, 0x0d, 0x53, 0x65, 0x6e, 0x64, 0x43, 0x6f, 0x6d, 0x70, 0x6c, - 0x65, 0x74, 0x65, 0x64, 0x12, 0x11, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x43, 0x6f, 0x6d, 0x70, 0x6c, - 0x65, 0x74, 0x65, 0x64, 0x52, 0x65, 0x71, 0x1a, 0x11, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x43, 0x6f, - 0x6d, 0x70, 0x6c, 0x65, 0x74, 0x65, 0x64, 0x52, 0x65, 0x73, 0x42, 0x07, 0x5a, 0x05, 0x2e, 0x3b, - 0x70, 0x64, 0x75, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, -} +const file_pdu_proto_rawDesc = "" + + "\n" + + "\tpdu.proto\"\x13\n" + + "\x11ListFilesystemReq\"B\n" + + "\x11ListFilesystemRes\x12-\n" + + "\vFilesystems\x18\x01 \x03(\v2\v.FilesystemR\vFilesystems\"h\n" + + "\n" + + "Filesystem\x12\x12\n" + + "\x04Path\x18\x01 \x01(\tR\x04Path\x12 \n" + + "\vResumeToken\x18\x02 \x01(\tR\vResumeToken\x12$\n" + + "\rIsPlaceholder\x18\x03 \x01(\bR\rIsPlaceholder\";\n" + + "\x19ListFilesystemVersionsReq\x12\x1e\n" + + "\n" + + "Filesystem\x18\x01 \x01(\tR\n" + + "Filesystem\"K\n" + + "\x19ListFilesystemVersionsRes\x12.\n" + + "\bVersions\x18\x01 \x03(\v2\x12.FilesystemVersionR\bVersions\"\xd4\x01\n" + + "\x11FilesystemVersion\x122\n" + + "\x04Type\x18\x01 \x01(\x0e2\x1e.FilesystemVersion.VersionTypeR\x04Type\x12\x12\n" + + "\x04Name\x18\x02 \x01(\tR\x04Name\x12\x12\n" + + "\x04Guid\x18\x03 \x01(\x04R\x04Guid\x12\x1c\n" + + "\tCreateTXG\x18\x04 \x01(\x04R\tCreateTXG\x12\x1a\n" + + "\bCreation\x18\x05 \x01(\tR\bCreation\")\n" + + "\vVersionType\x12\f\n" + + "\bSnapshot\x10\x00\x12\f\n" + + "\bBookmark\x10\x01\"\xd9\x01\n" + + "\aSendReq\x12\x1e\n" + + "\n" + + "Filesystem\x18\x01 \x01(\tR\n" + + "Filesystem\x12&\n" + + "\x04From\x18\x02 \x01(\v2\x12.FilesystemVersionR\x04From\x12\"\n" + + "\x02To\x18\x03 \x01(\v2\x12.FilesystemVersionR\x02To\x12 \n" + + "\vResumeToken\x18\x04 \x01(\tR\vResumeToken\x12@\n" + + "\x11ReplicationConfig\x18\x06 \x01(\v2\x12.ReplicationConfigR\x11ReplicationConfig\"Q\n" + + "\x11ReplicationConfig\x12<\n" + + "\n" + + "protection\x18\x01 \x01(\v2\x1c.ReplicationConfigProtectionR\n" + + "protection\"\x8f\x01\n" + + "\x1bReplicationConfigProtection\x123\n" + + "\aInitial\x18\x01 \x01(\x0e2\x19.ReplicationGuaranteeKindR\aInitial\x12;\n" + + "\vIncremental\x18\x02 \x01(\x0e2\x19.ReplicationGuaranteeKindR\vIncremental\"4\n" + + "\bProperty\x12\x12\n" + + "\x04Name\x18\x01 \x01(\tR\x04Name\x12\x14\n" + + "\x05Value\x18\x02 \x01(\tR\x05Value\"W\n" + + "\aSendRes\x12(\n" + + "\x0fUsedResumeToken\x18\x01 \x01(\bR\x0fUsedResumeToken\x12\"\n" + + "\fExpectedSize\x18\x02 \x01(\x04R\fExpectedSize\">\n" + + "\x10SendCompletedReq\x12*\n" + + "\vOriginalReq\x18\x02 \x01(\v2\b.SendReqR\vOriginalReq\"\x12\n" + + "\x10SendCompletedRes\"\xbe\x01\n" + + "\n" + + "ReceiveReq\x12\x1e\n" + + "\n" + + "Filesystem\x18\x01 \x01(\tR\n" + + "Filesystem\x12\"\n" + + "\x02To\x18\x02 \x01(\v2\x12.FilesystemVersionR\x02To\x12*\n" + + "\x10ClearResumeToken\x18\x03 \x01(\bR\x10ClearResumeToken\x12@\n" + + "\x11ReplicationConfig\x18\x04 \x01(\v2\x12.ReplicationConfigR\x11ReplicationConfig\"\f\n" + + "\n" + + "ReceiveRes\"g\n" + + "\x13DestroySnapshotsReq\x12\x1e\n" + + "\n" + + "Filesystem\x18\x01 \x01(\tR\n" + + "Filesystem\x120\n" + + "\tSnapshots\x18\x02 \x03(\v2\x12.FilesystemVersionR\tSnapshots\"Z\n" + + "\x12DestroySnapshotRes\x12.\n" + + "\bSnapshot\x18\x01 \x01(\v2\x12.FilesystemVersionR\bSnapshot\x12\x14\n" + + "\x05Error\x18\x02 \x01(\tR\x05Error\"D\n" + + "\x13DestroySnapshotsRes\x12-\n" + + "\aResults\x18\x01 \x03(\v2\x13.DestroySnapshotResR\aResults\"6\n" + + "\x14ReplicationCursorReq\x12\x1e\n" + + "\n" + + "Filesystem\x18\x01 \x01(\tR\n" + + "Filesystem\"T\n" + + "\x14ReplicationCursorRes\x12\x14\n" + + "\x04Guid\x18\x01 \x01(\x04H\x00R\x04Guid\x12\x1c\n" + + "\bNotexist\x18\x02 \x01(\bH\x00R\bNotexistB\b\n" + + "\x06Result\"#\n" + + "\aPingReq\x12\x18\n" + + "\aMessage\x18\x01 \x01(\tR\aMessage\"\x1d\n" + + "\aPingRes\x12\x12\n" + + "\x04Echo\x18\x01 \x01(\tR\x04Echo*\x86\x01\n" + + "\x18ReplicationGuaranteeKind\x12\x14\n" + + "\x10GuaranteeInvalid\x10\x00\x12\x19\n" + + "\x15GuaranteeResumability\x10\x01\x12#\n" + + "\x1fGuaranteeIncrementalReplication\x10\x02\x12\x14\n" + + "\x10GuaranteeNothing\x10\x032\x8f\x03\n" + + "\vReplication\x12\x1a\n" + + "\x04Ping\x12\b.PingReq\x1a\b.PingRes\x129\n" + + "\x0fListFilesystems\x12\x12.ListFilesystemReq\x1a\x12.ListFilesystemRes\x12P\n" + + "\x16ListFilesystemVersions\x12\x1a.ListFilesystemVersionsReq\x1a\x1a.ListFilesystemVersionsRes\x12>\n" + + "\x10DestroySnapshots\x12\x14.DestroySnapshotsReq\x1a\x14.DestroySnapshotsRes\x12A\n" + + "\x11ReplicationCursor\x12\x15.ReplicationCursorReq\x1a\x15.ReplicationCursorRes\x12\x1d\n" + + "\aSendDry\x12\b.SendReq\x1a\b.SendRes\x125\n" + + "\rSendCompleted\x12\x11.SendCompletedReq\x1a\x11.SendCompletedResB\aZ\x05.;pdub\x06proto3" var ( file_pdu_proto_rawDescOnce sync.Once - file_pdu_proto_rawDescData = file_pdu_proto_rawDesc + file_pdu_proto_rawDescData []byte ) func file_pdu_proto_rawDescGZIP() []byte { file_pdu_proto_rawDescOnce.Do(func() { - file_pdu_proto_rawDescData = protoimpl.X.CompressGZIP(file_pdu_proto_rawDescData) + file_pdu_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_pdu_proto_rawDesc), len(file_pdu_proto_rawDesc))) }) return file_pdu_proto_rawDescData } @@ -1560,272 +1440,6 @@ func file_pdu_proto_init() { if File_pdu_proto != nil { return } - if !protoimpl.UnsafeEnabled { - file_pdu_proto_msgTypes[0].Exporter = func(v any, i int) any { - switch v := v.(*ListFilesystemReq); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[1].Exporter = func(v any, i int) any { - switch v := v.(*ListFilesystemRes); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[2].Exporter = func(v any, i int) any { - switch v := v.(*Filesystem); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[3].Exporter = func(v any, i int) any { - switch v := v.(*ListFilesystemVersionsReq); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[4].Exporter = func(v any, i int) any { - switch v := v.(*ListFilesystemVersionsRes); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[5].Exporter = func(v any, i int) any { - switch v := v.(*FilesystemVersion); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[6].Exporter = func(v any, i int) any { - switch v := v.(*SendReq); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[7].Exporter = func(v any, i int) any { - switch v := v.(*ReplicationConfig); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[8].Exporter = func(v any, i int) any { - switch v := v.(*ReplicationConfigProtection); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[9].Exporter = func(v any, i int) any { - switch v := v.(*Property); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[10].Exporter = func(v any, i int) any { - switch v := v.(*SendRes); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[11].Exporter = func(v any, i int) any { - switch v := v.(*SendCompletedReq); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[12].Exporter = func(v any, i int) any { - switch v := v.(*SendCompletedRes); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[13].Exporter = func(v any, i int) any { - switch v := v.(*ReceiveReq); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[14].Exporter = func(v any, i int) any { - switch v := v.(*ReceiveRes); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[15].Exporter = func(v any, i int) any { - switch v := v.(*DestroySnapshotsReq); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[16].Exporter = func(v any, i int) any { - switch v := v.(*DestroySnapshotRes); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[17].Exporter = func(v any, i int) any { - switch v := v.(*DestroySnapshotsRes); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[18].Exporter = func(v any, i int) any { - switch v := v.(*ReplicationCursorReq); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[19].Exporter = func(v any, i int) any { - switch v := v.(*ReplicationCursorRes); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[20].Exporter = func(v any, i int) any { - switch v := v.(*PingReq); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_pdu_proto_msgTypes[21].Exporter = func(v any, i int) any { - switch v := v.(*PingRes); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - } file_pdu_proto_msgTypes[19].OneofWrappers = []any{ (*ReplicationCursorRes_Guid)(nil), (*ReplicationCursorRes_Notexist)(nil), @@ -1834,7 +1448,7 @@ func file_pdu_proto_init() { out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: file_pdu_proto_rawDesc, + RawDescriptor: unsafe.Slice(unsafe.StringData(file_pdu_proto_rawDesc), len(file_pdu_proto_rawDesc)), NumEnums: 2, NumMessages: 22, NumExtensions: 0, @@ -1846,7 +1460,6 @@ func file_pdu_proto_init() { MessageInfos: file_pdu_proto_msgTypes, }.Build() File_pdu_proto = out.File - file_pdu_proto_rawDesc = nil file_pdu_proto_goTypes = nil file_pdu_proto_depIdxs = nil } diff --git a/internal/replication/logic/pdu/pdu_grpc.pb.go b/internal/replication/logic/pdu/pdu_grpc.pb.go index 9c8608c..3935b37 100644 --- a/internal/replication/logic/pdu/pdu_grpc.pb.go +++ b/internal/replication/logic/pdu/pdu_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.5.1 +// - protoc-gen-go-grpc v1.6.0 // - protoc v5.28.0 // source: pdu.proto @@ -141,25 +141,25 @@ type ReplicationServer interface { type UnimplementedReplicationServer struct{} func (UnimplementedReplicationServer) Ping(context.Context, *PingReq) (*PingRes, error) { - return nil, status.Errorf(codes.Unimplemented, "method Ping not implemented") + return nil, status.Error(codes.Unimplemented, "method Ping not implemented") } func (UnimplementedReplicationServer) ListFilesystems(context.Context, *ListFilesystemReq) (*ListFilesystemRes, error) { - return nil, status.Errorf(codes.Unimplemented, "method ListFilesystems not implemented") + return nil, status.Error(codes.Unimplemented, "method ListFilesystems not implemented") } func (UnimplementedReplicationServer) ListFilesystemVersions(context.Context, *ListFilesystemVersionsReq) (*ListFilesystemVersionsRes, error) { - return nil, status.Errorf(codes.Unimplemented, "method ListFilesystemVersions not implemented") + return nil, status.Error(codes.Unimplemented, "method ListFilesystemVersions not implemented") } func (UnimplementedReplicationServer) DestroySnapshots(context.Context, *DestroySnapshotsReq) (*DestroySnapshotsRes, error) { - return nil, status.Errorf(codes.Unimplemented, "method DestroySnapshots not implemented") + return nil, status.Error(codes.Unimplemented, "method DestroySnapshots not implemented") } func (UnimplementedReplicationServer) ReplicationCursor(context.Context, *ReplicationCursorReq) (*ReplicationCursorRes, error) { - return nil, status.Errorf(codes.Unimplemented, "method ReplicationCursor not implemented") + return nil, status.Error(codes.Unimplemented, "method ReplicationCursor not implemented") } func (UnimplementedReplicationServer) SendDry(context.Context, *SendReq) (*SendRes, error) { - return nil, status.Errorf(codes.Unimplemented, "method SendDry not implemented") + return nil, status.Error(codes.Unimplemented, "method SendDry not implemented") } func (UnimplementedReplicationServer) SendCompleted(context.Context, *SendCompletedReq) (*SendCompletedRes, error) { - return nil, status.Errorf(codes.Unimplemented, "method SendCompleted not implemented") + return nil, status.Error(codes.Unimplemented, "method SendCompleted not implemented") } func (UnimplementedReplicationServer) mustEmbedUnimplementedReplicationServer() {} func (UnimplementedReplicationServer) testEmbeddedByValue() {} @@ -172,7 +172,7 @@ type UnsafeReplicationServer interface { } func RegisterReplicationServer(s grpc.ServiceRegistrar, srv ReplicationServer) { - // If the following call pancis, it indicates UnimplementedReplicationServer was + // If the following call panics, it indicates UnimplementedReplicationServer was // embedded by pointer and is nil. This will cause panics if an // unimplemented method is ever invoked, so we test this at initialization // time to prevent it from happening at runtime later due to I/O. diff --git a/internal/rpc/grpcclientidentity/example/pdu/grpcauth.pb.go b/internal/rpc/grpcclientidentity/example/pdu/grpcauth.pb.go index 0688f35..a99f754 100644 --- a/internal/rpc/grpcclientidentity/example/pdu/grpcauth.pb.go +++ b/internal/rpc/grpcclientidentity/example/pdu/grpcauth.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.2 +// protoc-gen-go v1.36.11 // protoc v5.28.0 // source: grpcauth.proto @@ -11,6 +11,7 @@ import ( protoimpl "google.golang.org/protobuf/runtime/protoimpl" reflect "reflect" sync "sync" + unsafe "unsafe" ) const ( @@ -21,20 +22,17 @@ const ( ) type GreetRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` + sizeCache protoimpl.SizeCache } func (x *GreetRequest) Reset() { *x = GreetRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_grpcauth_proto_msgTypes[0] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_grpcauth_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *GreetRequest) String() string { @@ -45,7 +43,7 @@ func (*GreetRequest) ProtoMessage() {} func (x *GreetRequest) ProtoReflect() protoreflect.Message { mi := &file_grpcauth_proto_msgTypes[0] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -68,20 +66,17 @@ func (x *GreetRequest) GetName() string { } type GreetResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` unknownFields protoimpl.UnknownFields - - Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` + sizeCache protoimpl.SizeCache } func (x *GreetResponse) Reset() { *x = GreetResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_grpcauth_proto_msgTypes[1] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_grpcauth_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *GreetResponse) String() string { @@ -92,7 +87,7 @@ func (*GreetResponse) ProtoMessage() {} func (x *GreetResponse) ProtoReflect() protoreflect.Message { mi := &file_grpcauth_proto_msgTypes[1] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -116,28 +111,24 @@ func (x *GreetResponse) GetMsg() string { var File_grpcauth_proto protoreflect.FileDescriptor -var file_grpcauth_proto_rawDesc = []byte{ - 0x0a, 0x0e, 0x67, 0x72, 0x70, 0x63, 0x61, 0x75, 0x74, 0x68, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, - 0x12, 0x03, 0x70, 0x64, 0x75, 0x22, 0x22, 0x0a, 0x0c, 0x47, 0x72, 0x65, 0x65, 0x74, 0x52, 0x65, - 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, - 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x21, 0x0a, 0x0d, 0x47, 0x72, 0x65, - 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x6d, 0x73, - 0x67, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6d, 0x73, 0x67, 0x32, 0x3b, 0x0a, 0x07, - 0x47, 0x72, 0x65, 0x65, 0x74, 0x65, 0x72, 0x12, 0x30, 0x0a, 0x05, 0x47, 0x72, 0x65, 0x65, 0x74, - 0x12, 0x11, 0x2e, 0x70, 0x64, 0x75, 0x2e, 0x47, 0x72, 0x65, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, - 0x65, 0x73, 0x74, 0x1a, 0x12, 0x2e, 0x70, 0x64, 0x75, 0x2e, 0x47, 0x72, 0x65, 0x65, 0x74, 0x52, - 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x07, 0x5a, 0x05, 0x2e, 0x3b, 0x70, - 0x64, 0x75, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, -} +const file_grpcauth_proto_rawDesc = "" + + "\n" + + "\x0egrpcauth.proto\x12\x03pdu\"\"\n" + + "\fGreetRequest\x12\x12\n" + + "\x04name\x18\x01 \x01(\tR\x04name\"!\n" + + "\rGreetResponse\x12\x10\n" + + "\x03msg\x18\x01 \x01(\tR\x03msg2;\n" + + "\aGreeter\x120\n" + + "\x05Greet\x12\x11.pdu.GreetRequest\x1a\x12.pdu.GreetResponse\"\x00B\aZ\x05.;pdub\x06proto3" var ( file_grpcauth_proto_rawDescOnce sync.Once - file_grpcauth_proto_rawDescData = file_grpcauth_proto_rawDesc + file_grpcauth_proto_rawDescData []byte ) func file_grpcauth_proto_rawDescGZIP() []byte { file_grpcauth_proto_rawDescOnce.Do(func() { - file_grpcauth_proto_rawDescData = protoimpl.X.CompressGZIP(file_grpcauth_proto_rawDescData) + file_grpcauth_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_grpcauth_proto_rawDesc), len(file_grpcauth_proto_rawDesc))) }) return file_grpcauth_proto_rawDescData } @@ -162,37 +153,11 @@ func file_grpcauth_proto_init() { if File_grpcauth_proto != nil { return } - if !protoimpl.UnsafeEnabled { - file_grpcauth_proto_msgTypes[0].Exporter = func(v any, i int) any { - switch v := v.(*GreetRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_grpcauth_proto_msgTypes[1].Exporter = func(v any, i int) any { - switch v := v.(*GreetResponse); 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_grpcauth_proto_rawDesc, + RawDescriptor: unsafe.Slice(unsafe.StringData(file_grpcauth_proto_rawDesc), len(file_grpcauth_proto_rawDesc)), NumEnums: 0, NumMessages: 2, NumExtensions: 0, @@ -203,7 +168,6 @@ func file_grpcauth_proto_init() { MessageInfos: file_grpcauth_proto_msgTypes, }.Build() File_grpcauth_proto = out.File - file_grpcauth_proto_rawDesc = nil file_grpcauth_proto_goTypes = nil file_grpcauth_proto_depIdxs = nil } diff --git a/internal/rpc/grpcclientidentity/example/pdu/grpcauth_grpc.pb.go b/internal/rpc/grpcclientidentity/example/pdu/grpcauth_grpc.pb.go index 2a98433..2990e2d 100644 --- a/internal/rpc/grpcclientidentity/example/pdu/grpcauth_grpc.pb.go +++ b/internal/rpc/grpcclientidentity/example/pdu/grpcauth_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.5.1 +// - protoc-gen-go-grpc v1.6.0 // - protoc v5.28.0 // source: grpcauth.proto @@ -63,7 +63,7 @@ type GreeterServer interface { type UnimplementedGreeterServer struct{} func (UnimplementedGreeterServer) Greet(context.Context, *GreetRequest) (*GreetResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method Greet not implemented") + return nil, status.Error(codes.Unimplemented, "method Greet not implemented") } func (UnimplementedGreeterServer) mustEmbedUnimplementedGreeterServer() {} func (UnimplementedGreeterServer) testEmbeddedByValue() {} @@ -76,7 +76,7 @@ type UnsafeGreeterServer interface { } func RegisterGreeterServer(s grpc.ServiceRegistrar, srv GreeterServer) { - // If the following call pancis, it indicates UnimplementedGreeterServer was + // If the following call panics, it indicates UnimplementedGreeterServer was // embedded by pointer and is nil. This will cause panics if an // unimplemented method is ever invoked, so we test this at initialization // time to prevent it from happening at runtime later due to I/O.