summaryrefslogtreecommitdiff
path: root/gen/zwdaemon
diff options
context:
space:
mode:
Diffstat (limited to 'gen/zwdaemon')
-rw-r--r--gen/zwdaemon/v1/daemon.pb.go1352
-rw-r--r--gen/zwdaemon/v1/daemon_grpc.pb.go463
2 files changed, 1815 insertions, 0 deletions
diff --git a/gen/zwdaemon/v1/daemon.pb.go b/gen/zwdaemon/v1/daemon.pb.go
new file mode 100644
index 0000000..68fb3c3
--- /dev/null
+++ b/gen/zwdaemon/v1/daemon.pb.go
@@ -0,0 +1,1352 @@
+// Code generated by protoc-gen-go. DO NOT EDIT.
+// versions:
+// protoc-gen-go v1.36.11
+// protoc (unknown)
+// source: zw/daemon/v1/daemon.proto
+
+package zwdaemonv1
+
+import (
+ protoreflect "google.golang.org/protobuf/reflect/protoreflect"
+ protoimpl "google.golang.org/protobuf/runtime/protoimpl"
+ reflect "reflect"
+ sync "sync"
+ unsafe "unsafe"
+)
+
+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)
+)
+
+type ZwErrorCode int32
+
+const (
+ ZwErrorCode_ZW_ERROR_CODE_UNSPECIFIED ZwErrorCode = 0
+ ZwErrorCode_ZW_ERROR_CODE_VAULT_SEALED ZwErrorCode = 1
+ ZwErrorCode_ZW_ERROR_CODE_VAULT_ALREADY_UNSEALED ZwErrorCode = 2
+ ZwErrorCode_ZW_ERROR_CODE_ENTRY_NOT_FOUND ZwErrorCode = 3
+ ZwErrorCode_ZW_ERROR_CODE_ENTRY_ALREADY_EXISTS ZwErrorCode = 4
+ ZwErrorCode_ZW_ERROR_CODE_AUTHENTICATION_OR_CORRUPTION ZwErrorCode = 5
+ ZwErrorCode_ZW_ERROR_CODE_INVALID_VAULT_FORMAT ZwErrorCode = 6
+ ZwErrorCode_ZW_ERROR_CODE_UNSUPPORTED_VAULT_VERSION ZwErrorCode = 7
+ ZwErrorCode_ZW_ERROR_CODE_UNSUPPORTED_PROTOCOL_VERSION ZwErrorCode = 8
+ ZwErrorCode_ZW_ERROR_CODE_PERMISSION_DENIED ZwErrorCode = 9
+ ZwErrorCode_ZW_ERROR_CODE_STORAGE_FULL ZwErrorCode = 10
+ ZwErrorCode_ZW_ERROR_CODE_COMMIT_FAILED ZwErrorCode = 11
+ ZwErrorCode_ZW_ERROR_CODE_INVALID_REQUEST ZwErrorCode = 12
+ ZwErrorCode_ZW_ERROR_CODE_INTERNAL ZwErrorCode = 13
+)
+
+// Enum value maps for ZwErrorCode.
+var (
+ ZwErrorCode_name = map[int32]string{
+ 0: "ZW_ERROR_CODE_UNSPECIFIED",
+ 1: "ZW_ERROR_CODE_VAULT_SEALED",
+ 2: "ZW_ERROR_CODE_VAULT_ALREADY_UNSEALED",
+ 3: "ZW_ERROR_CODE_ENTRY_NOT_FOUND",
+ 4: "ZW_ERROR_CODE_ENTRY_ALREADY_EXISTS",
+ 5: "ZW_ERROR_CODE_AUTHENTICATION_OR_CORRUPTION",
+ 6: "ZW_ERROR_CODE_INVALID_VAULT_FORMAT",
+ 7: "ZW_ERROR_CODE_UNSUPPORTED_VAULT_VERSION",
+ 8: "ZW_ERROR_CODE_UNSUPPORTED_PROTOCOL_VERSION",
+ 9: "ZW_ERROR_CODE_PERMISSION_DENIED",
+ 10: "ZW_ERROR_CODE_STORAGE_FULL",
+ 11: "ZW_ERROR_CODE_COMMIT_FAILED",
+ 12: "ZW_ERROR_CODE_INVALID_REQUEST",
+ 13: "ZW_ERROR_CODE_INTERNAL",
+ }
+ ZwErrorCode_value = map[string]int32{
+ "ZW_ERROR_CODE_UNSPECIFIED": 0,
+ "ZW_ERROR_CODE_VAULT_SEALED": 1,
+ "ZW_ERROR_CODE_VAULT_ALREADY_UNSEALED": 2,
+ "ZW_ERROR_CODE_ENTRY_NOT_FOUND": 3,
+ "ZW_ERROR_CODE_ENTRY_ALREADY_EXISTS": 4,
+ "ZW_ERROR_CODE_AUTHENTICATION_OR_CORRUPTION": 5,
+ "ZW_ERROR_CODE_INVALID_VAULT_FORMAT": 6,
+ "ZW_ERROR_CODE_UNSUPPORTED_VAULT_VERSION": 7,
+ "ZW_ERROR_CODE_UNSUPPORTED_PROTOCOL_VERSION": 8,
+ "ZW_ERROR_CODE_PERMISSION_DENIED": 9,
+ "ZW_ERROR_CODE_STORAGE_FULL": 10,
+ "ZW_ERROR_CODE_COMMIT_FAILED": 11,
+ "ZW_ERROR_CODE_INVALID_REQUEST": 12,
+ "ZW_ERROR_CODE_INTERNAL": 13,
+ }
+)
+
+func (x ZwErrorCode) Enum() *ZwErrorCode {
+ p := new(ZwErrorCode)
+ *p = x
+ return p
+}
+
+func (x ZwErrorCode) String() string {
+ return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
+}
+
+func (ZwErrorCode) Descriptor() protoreflect.EnumDescriptor {
+ return file_zw_daemon_v1_daemon_proto_enumTypes[0].Descriptor()
+}
+
+func (ZwErrorCode) Type() protoreflect.EnumType {
+ return &file_zw_daemon_v1_daemon_proto_enumTypes[0]
+}
+
+func (x ZwErrorCode) Number() protoreflect.EnumNumber {
+ return protoreflect.EnumNumber(x)
+}
+
+// Deprecated: Use ZwErrorCode.Descriptor instead.
+func (ZwErrorCode) EnumDescriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{0}
+}
+
+type GetServerInfoRequest struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *GetServerInfoRequest) Reset() {
+ *x = GetServerInfoRequest{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[0]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *GetServerInfoRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GetServerInfoRequest) ProtoMessage() {}
+
+func (x *GetServerInfoRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[0]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use GetServerInfoRequest.ProtoReflect.Descriptor instead.
+func (*GetServerInfoRequest) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{0}
+}
+
+type SealRequest struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *SealRequest) Reset() {
+ *x = SealRequest{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[1]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *SealRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*SealRequest) ProtoMessage() {}
+
+func (x *SealRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[1]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use SealRequest.ProtoReflect.Descriptor instead.
+func (*SealRequest) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{1}
+}
+
+type SealResponse struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *SealResponse) Reset() {
+ *x = SealResponse{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[2]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *SealResponse) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*SealResponse) ProtoMessage() {}
+
+func (x *SealResponse) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[2]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use SealResponse.ProtoReflect.Descriptor instead.
+func (*SealResponse) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{2}
+}
+
+type CreateResponse struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *CreateResponse) Reset() {
+ *x = CreateResponse{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[3]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *CreateResponse) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*CreateResponse) ProtoMessage() {}
+
+func (x *CreateResponse) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[3]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.
+func (*CreateResponse) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{3}
+}
+
+type UnsealResponse struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *UnsealResponse) Reset() {
+ *x = UnsealResponse{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[4]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *UnsealResponse) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*UnsealResponse) ProtoMessage() {}
+
+func (x *UnsealResponse) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[4]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use UnsealResponse.ProtoReflect.Descriptor instead.
+func (*UnsealResponse) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{4}
+}
+
+type CompactResponse struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *CompactResponse) Reset() {
+ *x = CompactResponse{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[5]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *CompactResponse) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*CompactResponse) ProtoMessage() {}
+
+func (x *CompactResponse) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[5]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use CompactResponse.ProtoReflect.Descriptor instead.
+func (*CompactResponse) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{5}
+}
+
+type CompactRequest struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *CompactRequest) Reset() {
+ *x = CompactRequest{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[6]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *CompactRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*CompactRequest) ProtoMessage() {}
+
+func (x *CompactRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[6]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use CompactRequest.ProtoReflect.Descriptor instead.
+func (*CompactRequest) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{6}
+}
+
+type AddFileResponse struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *AddFileResponse) Reset() {
+ *x = AddFileResponse{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[7]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *AddFileResponse) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*AddFileResponse) ProtoMessage() {}
+
+func (x *AddFileResponse) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[7]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use AddFileResponse.ProtoReflect.Descriptor instead.
+func (*AddFileResponse) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{7}
+}
+
+type DeleteFileResponse struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *DeleteFileResponse) Reset() {
+ *x = DeleteFileResponse{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[8]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *DeleteFileResponse) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*DeleteFileResponse) ProtoMessage() {}
+
+func (x *DeleteFileResponse) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[8]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use DeleteFileResponse.ProtoReflect.Descriptor instead.
+func (*DeleteFileResponse) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{8}
+}
+
+type GetServerInfoResponse struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ ApiMajor uint32 `protobuf:"varint,1,opt,name=api_major,json=apiMajor,proto3" json:"api_major,omitempty"`
+ ApiMinor uint32 `protobuf:"varint,2,opt,name=api_minor,json=apiMinor,proto3" json:"api_minor,omitempty"`
+ DaemonVersion string `protobuf:"bytes,3,opt,name=daemon_version,json=daemonVersion,proto3" json:"daemon_version,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *GetServerInfoResponse) Reset() {
+ *x = GetServerInfoResponse{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[9]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *GetServerInfoResponse) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GetServerInfoResponse) ProtoMessage() {}
+
+func (x *GetServerInfoResponse) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[9]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use GetServerInfoResponse.ProtoReflect.Descriptor instead.
+func (*GetServerInfoResponse) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{9}
+}
+
+func (x *GetServerInfoResponse) GetApiMajor() uint32 {
+ if x != nil {
+ return x.ApiMajor
+ }
+ return 0
+}
+
+func (x *GetServerInfoResponse) GetApiMinor() uint32 {
+ if x != nil {
+ return x.ApiMinor
+ }
+ return 0
+}
+
+func (x *GetServerInfoResponse) GetDaemonVersion() string {
+ if x != nil {
+ return x.DaemonVersion
+ }
+ return ""
+}
+
+type CreateRequest struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ VaultPath string `protobuf:"bytes,1,opt,name=vault_path,json=vaultPath,proto3" json:"vault_path,omitempty"`
+ Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *CreateRequest) Reset() {
+ *x = CreateRequest{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[10]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *CreateRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*CreateRequest) ProtoMessage() {}
+
+func (x *CreateRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[10]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.
+func (*CreateRequest) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{10}
+}
+
+func (x *CreateRequest) GetVaultPath() string {
+ if x != nil {
+ return x.VaultPath
+ }
+ return ""
+}
+
+func (x *CreateRequest) GetPassword() string {
+ if x != nil {
+ return x.Password
+ }
+ return ""
+}
+
+type UnsealRequest struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ VaultPath string `protobuf:"bytes,1,opt,name=vault_path,json=vaultPath,proto3" json:"vault_path,omitempty"`
+ Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *UnsealRequest) Reset() {
+ *x = UnsealRequest{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[11]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *UnsealRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*UnsealRequest) ProtoMessage() {}
+
+func (x *UnsealRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[11]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use UnsealRequest.ProtoReflect.Descriptor instead.
+func (*UnsealRequest) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{11}
+}
+
+func (x *UnsealRequest) GetVaultPath() string {
+ if x != nil {
+ return x.VaultPath
+ }
+ return ""
+}
+
+func (x *UnsealRequest) GetPassword() string {
+ if x != nil {
+ return x.Password
+ }
+ return ""
+}
+
+type ListFilesRequest struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ Prefix *string `protobuf:"bytes,1,opt,name=prefix,proto3,oneof" json:"prefix,omitempty"`
+ Contains *string `protobuf:"bytes,2,opt,name=contains,proto3,oneof" json:"contains,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *ListFilesRequest) Reset() {
+ *x = ListFilesRequest{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[12]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *ListFilesRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*ListFilesRequest) ProtoMessage() {}
+
+func (x *ListFilesRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[12]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use ListFilesRequest.ProtoReflect.Descriptor instead.
+func (*ListFilesRequest) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{12}
+}
+
+func (x *ListFilesRequest) GetPrefix() string {
+ if x != nil && x.Prefix != nil {
+ return *x.Prefix
+ }
+ return ""
+}
+
+func (x *ListFilesRequest) GetContains() string {
+ if x != nil && x.Contains != nil {
+ return *x.Contains
+ }
+ return ""
+}
+
+type ListFilesResponse struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ Files []*ListedFile `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *ListFilesResponse) Reset() {
+ *x = ListFilesResponse{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[13]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *ListFilesResponse) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*ListFilesResponse) ProtoMessage() {}
+
+func (x *ListFilesResponse) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[13]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use ListFilesResponse.ProtoReflect.Descriptor instead.
+func (*ListFilesResponse) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{13}
+}
+
+func (x *ListFilesResponse) GetFiles() []*ListedFile {
+ if x != nil {
+ return x.Files
+ }
+ return nil
+}
+
+type ListedFile struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ LogicalPath string `protobuf:"bytes,1,opt,name=logical_path,json=logicalPath,proto3" json:"logical_path,omitempty"`
+ Size uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *ListedFile) Reset() {
+ *x = ListedFile{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[14]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *ListedFile) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*ListedFile) ProtoMessage() {}
+
+func (x *ListedFile) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[14]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use ListedFile.ProtoReflect.Descriptor instead.
+func (*ListedFile) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{14}
+}
+
+func (x *ListedFile) GetLogicalPath() string {
+ if x != nil {
+ return x.LogicalPath
+ }
+ return ""
+}
+
+func (x *ListedFile) GetSize() uint64 {
+ if x != nil {
+ return x.Size
+ }
+ return 0
+}
+
+type GetFileRequest struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ LogicalPath string `protobuf:"bytes,1,opt,name=logical_path,json=logicalPath,proto3" json:"logical_path,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *GetFileRequest) Reset() {
+ *x = GetFileRequest{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[15]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *GetFileRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GetFileRequest) ProtoMessage() {}
+
+func (x *GetFileRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[15]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use GetFileRequest.ProtoReflect.Descriptor instead.
+func (*GetFileRequest) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{15}
+}
+
+func (x *GetFileRequest) GetLogicalPath() string {
+ if x != nil {
+ return x.LogicalPath
+ }
+ return ""
+}
+
+type GetFileRangeRequest struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ LogicalPath string `protobuf:"bytes,1,opt,name=logical_path,json=logicalPath,proto3" json:"logical_path,omitempty"`
+ Start uint64 `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
+ ExclusiveEnd uint64 `protobuf:"varint,3,opt,name=exclusive_end,json=exclusiveEnd,proto3" json:"exclusive_end,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *GetFileRangeRequest) Reset() {
+ *x = GetFileRangeRequest{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[16]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *GetFileRangeRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GetFileRangeRequest) ProtoMessage() {}
+
+func (x *GetFileRangeRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[16]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use GetFileRangeRequest.ProtoReflect.Descriptor instead.
+func (*GetFileRangeRequest) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{16}
+}
+
+func (x *GetFileRangeRequest) GetLogicalPath() string {
+ if x != nil {
+ return x.LogicalPath
+ }
+ return ""
+}
+
+func (x *GetFileRangeRequest) GetStart() uint64 {
+ if x != nil {
+ return x.Start
+ }
+ return 0
+}
+
+func (x *GetFileRangeRequest) GetExclusiveEnd() uint64 {
+ if x != nil {
+ return x.ExclusiveEnd
+ }
+ return 0
+}
+
+type GetFileResponse struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *GetFileResponse) Reset() {
+ *x = GetFileResponse{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[17]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *GetFileResponse) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GetFileResponse) ProtoMessage() {}
+
+func (x *GetFileResponse) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[17]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use GetFileResponse.ProtoReflect.Descriptor instead.
+func (*GetFileResponse) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{17}
+}
+
+func (x *GetFileResponse) GetData() []byte {
+ if x != nil {
+ return x.Data
+ }
+ return nil
+}
+
+type GetFileRangeResponse struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *GetFileRangeResponse) Reset() {
+ *x = GetFileRangeResponse{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[18]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *GetFileRangeResponse) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GetFileRangeResponse) ProtoMessage() {}
+
+func (x *GetFileRangeResponse) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[18]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use GetFileRangeResponse.ProtoReflect.Descriptor instead.
+func (*GetFileRangeResponse) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{18}
+}
+
+func (x *GetFileRangeResponse) GetData() []byte {
+ if x != nil {
+ return x.Data
+ }
+ return nil
+}
+
+type AddFileRequest struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ // Types that are valid to be assigned to Payload:
+ //
+ // *AddFileRequest_Header
+ // *AddFileRequest_Chunk
+ Payload isAddFileRequest_Payload `protobuf_oneof:"payload"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *AddFileRequest) Reset() {
+ *x = AddFileRequest{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[19]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *AddFileRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*AddFileRequest) ProtoMessage() {}
+
+func (x *AddFileRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[19]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use AddFileRequest.ProtoReflect.Descriptor instead.
+func (*AddFileRequest) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{19}
+}
+
+func (x *AddFileRequest) GetPayload() isAddFileRequest_Payload {
+ if x != nil {
+ return x.Payload
+ }
+ return nil
+}
+
+func (x *AddFileRequest) GetHeader() *AddFileHeader {
+ if x != nil {
+ if x, ok := x.Payload.(*AddFileRequest_Header); ok {
+ return x.Header
+ }
+ }
+ return nil
+}
+
+func (x *AddFileRequest) GetChunk() []byte {
+ if x != nil {
+ if x, ok := x.Payload.(*AddFileRequest_Chunk); ok {
+ return x.Chunk
+ }
+ }
+ return nil
+}
+
+type isAddFileRequest_Payload interface {
+ isAddFileRequest_Payload()
+}
+
+type AddFileRequest_Header struct {
+ Header *AddFileHeader `protobuf:"bytes,1,opt,name=header,proto3,oneof"`
+}
+
+type AddFileRequest_Chunk struct {
+ Chunk []byte `protobuf:"bytes,2,opt,name=chunk,proto3,oneof"`
+}
+
+func (*AddFileRequest_Header) isAddFileRequest_Payload() {}
+
+func (*AddFileRequest_Chunk) isAddFileRequest_Payload() {}
+
+type AddFileHeader struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ LogicalPath string `protobuf:"bytes,1,opt,name=logical_path,json=logicalPath,proto3" json:"logical_path,omitempty"`
+ SourceLen uint64 `protobuf:"varint,2,opt,name=source_len,json=sourceLen,proto3" json:"source_len,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *AddFileHeader) Reset() {
+ *x = AddFileHeader{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[20]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *AddFileHeader) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*AddFileHeader) ProtoMessage() {}
+
+func (x *AddFileHeader) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[20]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use AddFileHeader.ProtoReflect.Descriptor instead.
+func (*AddFileHeader) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{20}
+}
+
+func (x *AddFileHeader) GetLogicalPath() string {
+ if x != nil {
+ return x.LogicalPath
+ }
+ return ""
+}
+
+func (x *AddFileHeader) GetSourceLen() uint64 {
+ if x != nil {
+ return x.SourceLen
+ }
+ return 0
+}
+
+type DeleteFileRequest struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ LogicalPath string `protobuf:"bytes,1,opt,name=logical_path,json=logicalPath,proto3" json:"logical_path,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *DeleteFileRequest) Reset() {
+ *x = DeleteFileRequest{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[21]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *DeleteFileRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*DeleteFileRequest) ProtoMessage() {}
+
+func (x *DeleteFileRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[21]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use DeleteFileRequest.ProtoReflect.Descriptor instead.
+func (*DeleteFileRequest) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{21}
+}
+
+func (x *DeleteFileRequest) GetLogicalPath() string {
+ if x != nil {
+ return x.LogicalPath
+ }
+ return ""
+}
+
+type ZwErrorDetail struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ Code ZwErrorCode `protobuf:"varint,1,opt,name=code,proto3,enum=zw.daemon.v1.ZwErrorCode" json:"code,omitempty"`
+ Retryable bool `protobuf:"varint,2,opt,name=retryable,proto3" json:"retryable,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *ZwErrorDetail) Reset() {
+ *x = ZwErrorDetail{}
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[22]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *ZwErrorDetail) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*ZwErrorDetail) ProtoMessage() {}
+
+func (x *ZwErrorDetail) ProtoReflect() protoreflect.Message {
+ mi := &file_zw_daemon_v1_daemon_proto_msgTypes[22]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use ZwErrorDetail.ProtoReflect.Descriptor instead.
+func (*ZwErrorDetail) Descriptor() ([]byte, []int) {
+ return file_zw_daemon_v1_daemon_proto_rawDescGZIP(), []int{22}
+}
+
+func (x *ZwErrorDetail) GetCode() ZwErrorCode {
+ if x != nil {
+ return x.Code
+ }
+ return ZwErrorCode_ZW_ERROR_CODE_UNSPECIFIED
+}
+
+func (x *ZwErrorDetail) GetRetryable() bool {
+ if x != nil {
+ return x.Retryable
+ }
+ return false
+}
+
+var File_zw_daemon_v1_daemon_proto protoreflect.FileDescriptor
+
+const file_zw_daemon_v1_daemon_proto_rawDesc = "" +
+ "\n" +
+ "\x19zw/daemon/v1/daemon.proto\x12\fzw.daemon.v1\"\x16\n" +
+ "\x14GetServerInfoRequest\"\r\n" +
+ "\vSealRequest\"\x0e\n" +
+ "\fSealResponse\"\x10\n" +
+ "\x0eCreateResponse\"\x10\n" +
+ "\x0eUnsealResponse\"\x11\n" +
+ "\x0fCompactResponse\"\x10\n" +
+ "\x0eCompactRequest\"\x11\n" +
+ "\x0fAddFileResponse\"\x14\n" +
+ "\x12DeleteFileResponse\"x\n" +
+ "\x15GetServerInfoResponse\x12\x1b\n" +
+ "\tapi_major\x18\x01 \x01(\rR\bapiMajor\x12\x1b\n" +
+ "\tapi_minor\x18\x02 \x01(\rR\bapiMinor\x12%\n" +
+ "\x0edaemon_version\x18\x03 \x01(\tR\rdaemonVersion\"J\n" +
+ "\rCreateRequest\x12\x1d\n" +
+ "\n" +
+ "vault_path\x18\x01 \x01(\tR\tvaultPath\x12\x1a\n" +
+ "\bpassword\x18\x02 \x01(\tR\bpassword\"J\n" +
+ "\rUnsealRequest\x12\x1d\n" +
+ "\n" +
+ "vault_path\x18\x01 \x01(\tR\tvaultPath\x12\x1a\n" +
+ "\bpassword\x18\x02 \x01(\tR\bpassword\"h\n" +
+ "\x10ListFilesRequest\x12\x1b\n" +
+ "\x06prefix\x18\x01 \x01(\tH\x00R\x06prefix\x88\x01\x01\x12\x1f\n" +
+ "\bcontains\x18\x02 \x01(\tH\x01R\bcontains\x88\x01\x01B\t\n" +
+ "\a_prefixB\v\n" +
+ "\t_contains\"C\n" +
+ "\x11ListFilesResponse\x12.\n" +
+ "\x05files\x18\x01 \x03(\v2\x18.zw.daemon.v1.ListedFileR\x05files\"C\n" +
+ "\n" +
+ "ListedFile\x12!\n" +
+ "\flogical_path\x18\x01 \x01(\tR\vlogicalPath\x12\x12\n" +
+ "\x04size\x18\x02 \x01(\x04R\x04size\"3\n" +
+ "\x0eGetFileRequest\x12!\n" +
+ "\flogical_path\x18\x01 \x01(\tR\vlogicalPath\"s\n" +
+ "\x13GetFileRangeRequest\x12!\n" +
+ "\flogical_path\x18\x01 \x01(\tR\vlogicalPath\x12\x14\n" +
+ "\x05start\x18\x02 \x01(\x04R\x05start\x12#\n" +
+ "\rexclusive_end\x18\x03 \x01(\x04R\fexclusiveEnd\"%\n" +
+ "\x0fGetFileResponse\x12\x12\n" +
+ "\x04data\x18\x01 \x01(\fR\x04data\"*\n" +
+ "\x14GetFileRangeResponse\x12\x12\n" +
+ "\x04data\x18\x01 \x01(\fR\x04data\"j\n" +
+ "\x0eAddFileRequest\x125\n" +
+ "\x06header\x18\x01 \x01(\v2\x1b.zw.daemon.v1.AddFileHeaderH\x00R\x06header\x12\x16\n" +
+ "\x05chunk\x18\x02 \x01(\fH\x00R\x05chunkB\t\n" +
+ "\apayload\"Q\n" +
+ "\rAddFileHeader\x12!\n" +
+ "\flogical_path\x18\x01 \x01(\tR\vlogicalPath\x12\x1d\n" +
+ "\n" +
+ "source_len\x18\x02 \x01(\x04R\tsourceLen\"6\n" +
+ "\x11DeleteFileRequest\x12!\n" +
+ "\flogical_path\x18\x01 \x01(\tR\vlogicalPath\"\\\n" +
+ "\rZwErrorDetail\x12-\n" +
+ "\x04code\x18\x01 \x01(\x0e2\x19.zw.daemon.v1.ZwErrorCodeR\x04code\x12\x1c\n" +
+ "\tretryable\x18\x02 \x01(\bR\tretryable*\x9b\x04\n" +
+ "\vZwErrorCode\x12\x1d\n" +
+ "\x19ZW_ERROR_CODE_UNSPECIFIED\x10\x00\x12\x1e\n" +
+ "\x1aZW_ERROR_CODE_VAULT_SEALED\x10\x01\x12(\n" +
+ "$ZW_ERROR_CODE_VAULT_ALREADY_UNSEALED\x10\x02\x12!\n" +
+ "\x1dZW_ERROR_CODE_ENTRY_NOT_FOUND\x10\x03\x12&\n" +
+ "\"ZW_ERROR_CODE_ENTRY_ALREADY_EXISTS\x10\x04\x12.\n" +
+ "*ZW_ERROR_CODE_AUTHENTICATION_OR_CORRUPTION\x10\x05\x12&\n" +
+ "\"ZW_ERROR_CODE_INVALID_VAULT_FORMAT\x10\x06\x12+\n" +
+ "'ZW_ERROR_CODE_UNSUPPORTED_VAULT_VERSION\x10\a\x12.\n" +
+ "*ZW_ERROR_CODE_UNSUPPORTED_PROTOCOL_VERSION\x10\b\x12#\n" +
+ "\x1fZW_ERROR_CODE_PERMISSION_DENIED\x10\t\x12\x1e\n" +
+ "\x1aZW_ERROR_CODE_STORAGE_FULL\x10\n" +
+ "\x12\x1f\n" +
+ "\x1bZW_ERROR_CODE_COMMIT_FAILED\x10\v\x12!\n" +
+ "\x1dZW_ERROR_CODE_INVALID_REQUEST\x10\f\x12\x1a\n" +
+ "\x16ZW_ERROR_CODE_INTERNAL\x10\r2\x88\x06\n" +
+ "\x0fZwDaemonService\x12X\n" +
+ "\rGetServerInfo\x12\".zw.daemon.v1.GetServerInfoRequest\x1a#.zw.daemon.v1.GetServerInfoResponse\x12C\n" +
+ "\x06Create\x12\x1b.zw.daemon.v1.CreateRequest\x1a\x1c.zw.daemon.v1.CreateResponse\x12C\n" +
+ "\x06Unseal\x12\x1b.zw.daemon.v1.UnsealRequest\x1a\x1c.zw.daemon.v1.UnsealResponse\x12=\n" +
+ "\x04Seal\x12\x19.zw.daemon.v1.SealRequest\x1a\x1a.zw.daemon.v1.SealResponse\x12L\n" +
+ "\tListFiles\x12\x1e.zw.daemon.v1.ListFilesRequest\x1a\x1f.zw.daemon.v1.ListFilesResponse\x12H\n" +
+ "\aGetFile\x12\x1c.zw.daemon.v1.GetFileRequest\x1a\x1d.zw.daemon.v1.GetFileResponse0\x01\x12W\n" +
+ "\fGetFileRange\x12!.zw.daemon.v1.GetFileRangeRequest\x1a\".zw.daemon.v1.GetFileRangeResponse0\x01\x12H\n" +
+ "\aAddFile\x12\x1c.zw.daemon.v1.AddFileRequest\x1a\x1d.zw.daemon.v1.AddFileResponse(\x01\x12O\n" +
+ "\n" +
+ "DeleteFile\x12\x1f.zw.daemon.v1.DeleteFileRequest\x1a .zw.daemon.v1.DeleteFileResponse\x12F\n" +
+ "\aCompact\x12\x1c.zw.daemon.v1.CompactRequest\x1a\x1d.zw.daemon.v1.CompactResponseB5Z3git.pablu.de/pablu/zw-go/gen/zwdaemon/v1;zwdaemonv1b\x06proto3"
+
+var (
+ file_zw_daemon_v1_daemon_proto_rawDescOnce sync.Once
+ file_zw_daemon_v1_daemon_proto_rawDescData []byte
+)
+
+func file_zw_daemon_v1_daemon_proto_rawDescGZIP() []byte {
+ file_zw_daemon_v1_daemon_proto_rawDescOnce.Do(func() {
+ file_zw_daemon_v1_daemon_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_zw_daemon_v1_daemon_proto_rawDesc), len(file_zw_daemon_v1_daemon_proto_rawDesc)))
+ })
+ return file_zw_daemon_v1_daemon_proto_rawDescData
+}
+
+var file_zw_daemon_v1_daemon_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
+var file_zw_daemon_v1_daemon_proto_msgTypes = make([]protoimpl.MessageInfo, 23)
+var file_zw_daemon_v1_daemon_proto_goTypes = []any{
+ (ZwErrorCode)(0), // 0: zw.daemon.v1.ZwErrorCode
+ (*GetServerInfoRequest)(nil), // 1: zw.daemon.v1.GetServerInfoRequest
+ (*SealRequest)(nil), // 2: zw.daemon.v1.SealRequest
+ (*SealResponse)(nil), // 3: zw.daemon.v1.SealResponse
+ (*CreateResponse)(nil), // 4: zw.daemon.v1.CreateResponse
+ (*UnsealResponse)(nil), // 5: zw.daemon.v1.UnsealResponse
+ (*CompactResponse)(nil), // 6: zw.daemon.v1.CompactResponse
+ (*CompactRequest)(nil), // 7: zw.daemon.v1.CompactRequest
+ (*AddFileResponse)(nil), // 8: zw.daemon.v1.AddFileResponse
+ (*DeleteFileResponse)(nil), // 9: zw.daemon.v1.DeleteFileResponse
+ (*GetServerInfoResponse)(nil), // 10: zw.daemon.v1.GetServerInfoResponse
+ (*CreateRequest)(nil), // 11: zw.daemon.v1.CreateRequest
+ (*UnsealRequest)(nil), // 12: zw.daemon.v1.UnsealRequest
+ (*ListFilesRequest)(nil), // 13: zw.daemon.v1.ListFilesRequest
+ (*ListFilesResponse)(nil), // 14: zw.daemon.v1.ListFilesResponse
+ (*ListedFile)(nil), // 15: zw.daemon.v1.ListedFile
+ (*GetFileRequest)(nil), // 16: zw.daemon.v1.GetFileRequest
+ (*GetFileRangeRequest)(nil), // 17: zw.daemon.v1.GetFileRangeRequest
+ (*GetFileResponse)(nil), // 18: zw.daemon.v1.GetFileResponse
+ (*GetFileRangeResponse)(nil), // 19: zw.daemon.v1.GetFileRangeResponse
+ (*AddFileRequest)(nil), // 20: zw.daemon.v1.AddFileRequest
+ (*AddFileHeader)(nil), // 21: zw.daemon.v1.AddFileHeader
+ (*DeleteFileRequest)(nil), // 22: zw.daemon.v1.DeleteFileRequest
+ (*ZwErrorDetail)(nil), // 23: zw.daemon.v1.ZwErrorDetail
+}
+var file_zw_daemon_v1_daemon_proto_depIdxs = []int32{
+ 15, // 0: zw.daemon.v1.ListFilesResponse.files:type_name -> zw.daemon.v1.ListedFile
+ 21, // 1: zw.daemon.v1.AddFileRequest.header:type_name -> zw.daemon.v1.AddFileHeader
+ 0, // 2: zw.daemon.v1.ZwErrorDetail.code:type_name -> zw.daemon.v1.ZwErrorCode
+ 1, // 3: zw.daemon.v1.ZwDaemonService.GetServerInfo:input_type -> zw.daemon.v1.GetServerInfoRequest
+ 11, // 4: zw.daemon.v1.ZwDaemonService.Create:input_type -> zw.daemon.v1.CreateRequest
+ 12, // 5: zw.daemon.v1.ZwDaemonService.Unseal:input_type -> zw.daemon.v1.UnsealRequest
+ 2, // 6: zw.daemon.v1.ZwDaemonService.Seal:input_type -> zw.daemon.v1.SealRequest
+ 13, // 7: zw.daemon.v1.ZwDaemonService.ListFiles:input_type -> zw.daemon.v1.ListFilesRequest
+ 16, // 8: zw.daemon.v1.ZwDaemonService.GetFile:input_type -> zw.daemon.v1.GetFileRequest
+ 17, // 9: zw.daemon.v1.ZwDaemonService.GetFileRange:input_type -> zw.daemon.v1.GetFileRangeRequest
+ 20, // 10: zw.daemon.v1.ZwDaemonService.AddFile:input_type -> zw.daemon.v1.AddFileRequest
+ 22, // 11: zw.daemon.v1.ZwDaemonService.DeleteFile:input_type -> zw.daemon.v1.DeleteFileRequest
+ 7, // 12: zw.daemon.v1.ZwDaemonService.Compact:input_type -> zw.daemon.v1.CompactRequest
+ 10, // 13: zw.daemon.v1.ZwDaemonService.GetServerInfo:output_type -> zw.daemon.v1.GetServerInfoResponse
+ 4, // 14: zw.daemon.v1.ZwDaemonService.Create:output_type -> zw.daemon.v1.CreateResponse
+ 5, // 15: zw.daemon.v1.ZwDaemonService.Unseal:output_type -> zw.daemon.v1.UnsealResponse
+ 3, // 16: zw.daemon.v1.ZwDaemonService.Seal:output_type -> zw.daemon.v1.SealResponse
+ 14, // 17: zw.daemon.v1.ZwDaemonService.ListFiles:output_type -> zw.daemon.v1.ListFilesResponse
+ 18, // 18: zw.daemon.v1.ZwDaemonService.GetFile:output_type -> zw.daemon.v1.GetFileResponse
+ 19, // 19: zw.daemon.v1.ZwDaemonService.GetFileRange:output_type -> zw.daemon.v1.GetFileRangeResponse
+ 8, // 20: zw.daemon.v1.ZwDaemonService.AddFile:output_type -> zw.daemon.v1.AddFileResponse
+ 9, // 21: zw.daemon.v1.ZwDaemonService.DeleteFile:output_type -> zw.daemon.v1.DeleteFileResponse
+ 6, // 22: zw.daemon.v1.ZwDaemonService.Compact:output_type -> zw.daemon.v1.CompactResponse
+ 13, // [13:23] is the sub-list for method output_type
+ 3, // [3:13] is the sub-list for method input_type
+ 3, // [3:3] is the sub-list for extension type_name
+ 3, // [3:3] is the sub-list for extension extendee
+ 0, // [0:3] is the sub-list for field type_name
+}
+
+func init() { file_zw_daemon_v1_daemon_proto_init() }
+func file_zw_daemon_v1_daemon_proto_init() {
+ if File_zw_daemon_v1_daemon_proto != nil {
+ return
+ }
+ file_zw_daemon_v1_daemon_proto_msgTypes[12].OneofWrappers = []any{}
+ file_zw_daemon_v1_daemon_proto_msgTypes[19].OneofWrappers = []any{
+ (*AddFileRequest_Header)(nil),
+ (*AddFileRequest_Chunk)(nil),
+ }
+ type x struct{}
+ out := protoimpl.TypeBuilder{
+ File: protoimpl.DescBuilder{
+ GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
+ RawDescriptor: unsafe.Slice(unsafe.StringData(file_zw_daemon_v1_daemon_proto_rawDesc), len(file_zw_daemon_v1_daemon_proto_rawDesc)),
+ NumEnums: 1,
+ NumMessages: 23,
+ NumExtensions: 0,
+ NumServices: 1,
+ },
+ GoTypes: file_zw_daemon_v1_daemon_proto_goTypes,
+ DependencyIndexes: file_zw_daemon_v1_daemon_proto_depIdxs,
+ EnumInfos: file_zw_daemon_v1_daemon_proto_enumTypes,
+ MessageInfos: file_zw_daemon_v1_daemon_proto_msgTypes,
+ }.Build()
+ File_zw_daemon_v1_daemon_proto = out.File
+ file_zw_daemon_v1_daemon_proto_goTypes = nil
+ file_zw_daemon_v1_daemon_proto_depIdxs = nil
+}
diff --git a/gen/zwdaemon/v1/daemon_grpc.pb.go b/gen/zwdaemon/v1/daemon_grpc.pb.go
new file mode 100644
index 0000000..73b99bf
--- /dev/null
+++ b/gen/zwdaemon/v1/daemon_grpc.pb.go
@@ -0,0 +1,463 @@
+// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
+// versions:
+// - protoc-gen-go-grpc v1.6.2
+// - protoc (unknown)
+// source: zw/daemon/v1/daemon.proto
+
+package zwdaemonv1
+
+import (
+ context "context"
+ grpc "google.golang.org/grpc"
+ codes "google.golang.org/grpc/codes"
+ status "google.golang.org/grpc/status"
+)
+
+// This is a compile-time assertion to ensure that this generated file
+// is compatible with the grpc package it is being compiled against.
+// Requires gRPC-Go v1.64.0 or later.
+const _ = grpc.SupportPackageIsVersion9
+
+const (
+ ZwDaemonService_GetServerInfo_FullMethodName = "/zw.daemon.v1.ZwDaemonService/GetServerInfo"
+ ZwDaemonService_Create_FullMethodName = "/zw.daemon.v1.ZwDaemonService/Create"
+ ZwDaemonService_Unseal_FullMethodName = "/zw.daemon.v1.ZwDaemonService/Unseal"
+ ZwDaemonService_Seal_FullMethodName = "/zw.daemon.v1.ZwDaemonService/Seal"
+ ZwDaemonService_ListFiles_FullMethodName = "/zw.daemon.v1.ZwDaemonService/ListFiles"
+ ZwDaemonService_GetFile_FullMethodName = "/zw.daemon.v1.ZwDaemonService/GetFile"
+ ZwDaemonService_GetFileRange_FullMethodName = "/zw.daemon.v1.ZwDaemonService/GetFileRange"
+ ZwDaemonService_AddFile_FullMethodName = "/zw.daemon.v1.ZwDaemonService/AddFile"
+ ZwDaemonService_DeleteFile_FullMethodName = "/zw.daemon.v1.ZwDaemonService/DeleteFile"
+ ZwDaemonService_Compact_FullMethodName = "/zw.daemon.v1.ZwDaemonService/Compact"
+)
+
+// ZwDaemonServiceClient is the client API for ZwDaemonService service.
+//
+// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
+type ZwDaemonServiceClient interface {
+ GetServerInfo(ctx context.Context, in *GetServerInfoRequest, opts ...grpc.CallOption) (*GetServerInfoResponse, error)
+ Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
+ Unseal(ctx context.Context, in *UnsealRequest, opts ...grpc.CallOption) (*UnsealResponse, error)
+ Seal(ctx context.Context, in *SealRequest, opts ...grpc.CallOption) (*SealResponse, error)
+ ListFiles(ctx context.Context, in *ListFilesRequest, opts ...grpc.CallOption) (*ListFilesResponse, error)
+ GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetFileResponse], error)
+ GetFileRange(ctx context.Context, in *GetFileRangeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetFileRangeResponse], error)
+ AddFile(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[AddFileRequest, AddFileResponse], error)
+ DeleteFile(ctx context.Context, in *DeleteFileRequest, opts ...grpc.CallOption) (*DeleteFileResponse, error)
+ Compact(ctx context.Context, in *CompactRequest, opts ...grpc.CallOption) (*CompactResponse, error)
+}
+
+type zwDaemonServiceClient struct {
+ cc grpc.ClientConnInterface
+}
+
+func NewZwDaemonServiceClient(cc grpc.ClientConnInterface) ZwDaemonServiceClient {
+ return &zwDaemonServiceClient{cc}
+}
+
+func (c *zwDaemonServiceClient) GetServerInfo(ctx context.Context, in *GetServerInfoRequest, opts ...grpc.CallOption) (*GetServerInfoResponse, error) {
+ cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+ out := new(GetServerInfoResponse)
+ err := c.cc.Invoke(ctx, ZwDaemonService_GetServerInfo_FullMethodName, in, out, cOpts...)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *zwDaemonServiceClient) Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) {
+ cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+ out := new(CreateResponse)
+ err := c.cc.Invoke(ctx, ZwDaemonService_Create_FullMethodName, in, out, cOpts...)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *zwDaemonServiceClient) Unseal(ctx context.Context, in *UnsealRequest, opts ...grpc.CallOption) (*UnsealResponse, error) {
+ cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+ out := new(UnsealResponse)
+ err := c.cc.Invoke(ctx, ZwDaemonService_Unseal_FullMethodName, in, out, cOpts...)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *zwDaemonServiceClient) Seal(ctx context.Context, in *SealRequest, opts ...grpc.CallOption) (*SealResponse, error) {
+ cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+ out := new(SealResponse)
+ err := c.cc.Invoke(ctx, ZwDaemonService_Seal_FullMethodName, in, out, cOpts...)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *zwDaemonServiceClient) ListFiles(ctx context.Context, in *ListFilesRequest, opts ...grpc.CallOption) (*ListFilesResponse, error) {
+ cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+ out := new(ListFilesResponse)
+ err := c.cc.Invoke(ctx, ZwDaemonService_ListFiles_FullMethodName, in, out, cOpts...)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *zwDaemonServiceClient) GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetFileResponse], error) {
+ cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+ stream, err := c.cc.NewStream(ctx, &ZwDaemonService_ServiceDesc.Streams[0], ZwDaemonService_GetFile_FullMethodName, cOpts...)
+ if err != nil {
+ return nil, err
+ }
+ x := &grpc.GenericClientStream[GetFileRequest, GetFileResponse]{ClientStream: stream}
+ if err := x.ClientStream.SendMsg(in); err != nil {
+ return nil, err
+ }
+ if err := x.ClientStream.CloseSend(); err != nil {
+ return nil, err
+ }
+ return x, nil
+}
+
+// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
+type ZwDaemonService_GetFileClient = grpc.ServerStreamingClient[GetFileResponse]
+
+func (c *zwDaemonServiceClient) GetFileRange(ctx context.Context, in *GetFileRangeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetFileRangeResponse], error) {
+ cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+ stream, err := c.cc.NewStream(ctx, &ZwDaemonService_ServiceDesc.Streams[1], ZwDaemonService_GetFileRange_FullMethodName, cOpts...)
+ if err != nil {
+ return nil, err
+ }
+ x := &grpc.GenericClientStream[GetFileRangeRequest, GetFileRangeResponse]{ClientStream: stream}
+ if err := x.ClientStream.SendMsg(in); err != nil {
+ return nil, err
+ }
+ if err := x.ClientStream.CloseSend(); err != nil {
+ return nil, err
+ }
+ return x, nil
+}
+
+// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
+type ZwDaemonService_GetFileRangeClient = grpc.ServerStreamingClient[GetFileRangeResponse]
+
+func (c *zwDaemonServiceClient) AddFile(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[AddFileRequest, AddFileResponse], error) {
+ cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+ stream, err := c.cc.NewStream(ctx, &ZwDaemonService_ServiceDesc.Streams[2], ZwDaemonService_AddFile_FullMethodName, cOpts...)
+ if err != nil {
+ return nil, err
+ }
+ x := &grpc.GenericClientStream[AddFileRequest, AddFileResponse]{ClientStream: stream}
+ return x, nil
+}
+
+// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
+type ZwDaemonService_AddFileClient = grpc.ClientStreamingClient[AddFileRequest, AddFileResponse]
+
+func (c *zwDaemonServiceClient) DeleteFile(ctx context.Context, in *DeleteFileRequest, opts ...grpc.CallOption) (*DeleteFileResponse, error) {
+ cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+ out := new(DeleteFileResponse)
+ err := c.cc.Invoke(ctx, ZwDaemonService_DeleteFile_FullMethodName, in, out, cOpts...)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *zwDaemonServiceClient) Compact(ctx context.Context, in *CompactRequest, opts ...grpc.CallOption) (*CompactResponse, error) {
+ cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+ out := new(CompactResponse)
+ err := c.cc.Invoke(ctx, ZwDaemonService_Compact_FullMethodName, in, out, cOpts...)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+// ZwDaemonServiceServer is the server API for ZwDaemonService service.
+// All implementations must embed UnimplementedZwDaemonServiceServer
+// for forward compatibility.
+type ZwDaemonServiceServer interface {
+ GetServerInfo(context.Context, *GetServerInfoRequest) (*GetServerInfoResponse, error)
+ Create(context.Context, *CreateRequest) (*CreateResponse, error)
+ Unseal(context.Context, *UnsealRequest) (*UnsealResponse, error)
+ Seal(context.Context, *SealRequest) (*SealResponse, error)
+ ListFiles(context.Context, *ListFilesRequest) (*ListFilesResponse, error)
+ GetFile(*GetFileRequest, grpc.ServerStreamingServer[GetFileResponse]) error
+ GetFileRange(*GetFileRangeRequest, grpc.ServerStreamingServer[GetFileRangeResponse]) error
+ AddFile(grpc.ClientStreamingServer[AddFileRequest, AddFileResponse]) error
+ DeleteFile(context.Context, *DeleteFileRequest) (*DeleteFileResponse, error)
+ Compact(context.Context, *CompactRequest) (*CompactResponse, error)
+ mustEmbedUnimplementedZwDaemonServiceServer()
+}
+
+// UnimplementedZwDaemonServiceServer must be embedded to have
+// forward compatible implementations.
+//
+// NOTE: this should be embedded by value instead of pointer to avoid a nil
+// pointer dereference when methods are called.
+type UnimplementedZwDaemonServiceServer struct{}
+
+func (UnimplementedZwDaemonServiceServer) GetServerInfo(context.Context, *GetServerInfoRequest) (*GetServerInfoResponse, error) {
+ return nil, status.Error(codes.Unimplemented, "method GetServerInfo not implemented")
+}
+func (UnimplementedZwDaemonServiceServer) Create(context.Context, *CreateRequest) (*CreateResponse, error) {
+ return nil, status.Error(codes.Unimplemented, "method Create not implemented")
+}
+func (UnimplementedZwDaemonServiceServer) Unseal(context.Context, *UnsealRequest) (*UnsealResponse, error) {
+ return nil, status.Error(codes.Unimplemented, "method Unseal not implemented")
+}
+func (UnimplementedZwDaemonServiceServer) Seal(context.Context, *SealRequest) (*SealResponse, error) {
+ return nil, status.Error(codes.Unimplemented, "method Seal not implemented")
+}
+func (UnimplementedZwDaemonServiceServer) ListFiles(context.Context, *ListFilesRequest) (*ListFilesResponse, error) {
+ return nil, status.Error(codes.Unimplemented, "method ListFiles not implemented")
+}
+func (UnimplementedZwDaemonServiceServer) GetFile(*GetFileRequest, grpc.ServerStreamingServer[GetFileResponse]) error {
+ return status.Error(codes.Unimplemented, "method GetFile not implemented")
+}
+func (UnimplementedZwDaemonServiceServer) GetFileRange(*GetFileRangeRequest, grpc.ServerStreamingServer[GetFileRangeResponse]) error {
+ return status.Error(codes.Unimplemented, "method GetFileRange not implemented")
+}
+func (UnimplementedZwDaemonServiceServer) AddFile(grpc.ClientStreamingServer[AddFileRequest, AddFileResponse]) error {
+ return status.Error(codes.Unimplemented, "method AddFile not implemented")
+}
+func (UnimplementedZwDaemonServiceServer) DeleteFile(context.Context, *DeleteFileRequest) (*DeleteFileResponse, error) {
+ return nil, status.Error(codes.Unimplemented, "method DeleteFile not implemented")
+}
+func (UnimplementedZwDaemonServiceServer) Compact(context.Context, *CompactRequest) (*CompactResponse, error) {
+ return nil, status.Error(codes.Unimplemented, "method Compact not implemented")
+}
+func (UnimplementedZwDaemonServiceServer) mustEmbedUnimplementedZwDaemonServiceServer() {}
+func (UnimplementedZwDaemonServiceServer) testEmbeddedByValue() {}
+
+// UnsafeZwDaemonServiceServer may be embedded to opt out of forward compatibility for this service.
+// Use of this interface is not recommended, as added methods to ZwDaemonServiceServer will
+// result in compilation errors.
+type UnsafeZwDaemonServiceServer interface {
+ mustEmbedUnimplementedZwDaemonServiceServer()
+}
+
+func RegisterZwDaemonServiceServer(s grpc.ServiceRegistrar, srv ZwDaemonServiceServer) {
+ // If the following call panics, it indicates UnimplementedZwDaemonServiceServer 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.
+ if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
+ t.testEmbeddedByValue()
+ }
+ s.RegisterService(&ZwDaemonService_ServiceDesc, srv)
+}
+
+func _ZwDaemonService_GetServerInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+ in := new(GetServerInfoRequest)
+ if err := dec(in); err != nil {
+ return nil, err
+ }
+ if interceptor == nil {
+ return srv.(ZwDaemonServiceServer).GetServerInfo(ctx, in)
+ }
+ info := &grpc.UnaryServerInfo{
+ Server: srv,
+ FullMethod: ZwDaemonService_GetServerInfo_FullMethodName,
+ }
+ handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+ return srv.(ZwDaemonServiceServer).GetServerInfo(ctx, req.(*GetServerInfoRequest))
+ }
+ return interceptor(ctx, in, info, handler)
+}
+
+func _ZwDaemonService_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+ in := new(CreateRequest)
+ if err := dec(in); err != nil {
+ return nil, err
+ }
+ if interceptor == nil {
+ return srv.(ZwDaemonServiceServer).Create(ctx, in)
+ }
+ info := &grpc.UnaryServerInfo{
+ Server: srv,
+ FullMethod: ZwDaemonService_Create_FullMethodName,
+ }
+ handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+ return srv.(ZwDaemonServiceServer).Create(ctx, req.(*CreateRequest))
+ }
+ return interceptor(ctx, in, info, handler)
+}
+
+func _ZwDaemonService_Unseal_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+ in := new(UnsealRequest)
+ if err := dec(in); err != nil {
+ return nil, err
+ }
+ if interceptor == nil {
+ return srv.(ZwDaemonServiceServer).Unseal(ctx, in)
+ }
+ info := &grpc.UnaryServerInfo{
+ Server: srv,
+ FullMethod: ZwDaemonService_Unseal_FullMethodName,
+ }
+ handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+ return srv.(ZwDaemonServiceServer).Unseal(ctx, req.(*UnsealRequest))
+ }
+ return interceptor(ctx, in, info, handler)
+}
+
+func _ZwDaemonService_Seal_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+ in := new(SealRequest)
+ if err := dec(in); err != nil {
+ return nil, err
+ }
+ if interceptor == nil {
+ return srv.(ZwDaemonServiceServer).Seal(ctx, in)
+ }
+ info := &grpc.UnaryServerInfo{
+ Server: srv,
+ FullMethod: ZwDaemonService_Seal_FullMethodName,
+ }
+ handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+ return srv.(ZwDaemonServiceServer).Seal(ctx, req.(*SealRequest))
+ }
+ return interceptor(ctx, in, info, handler)
+}
+
+func _ZwDaemonService_ListFiles_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+ in := new(ListFilesRequest)
+ if err := dec(in); err != nil {
+ return nil, err
+ }
+ if interceptor == nil {
+ return srv.(ZwDaemonServiceServer).ListFiles(ctx, in)
+ }
+ info := &grpc.UnaryServerInfo{
+ Server: srv,
+ FullMethod: ZwDaemonService_ListFiles_FullMethodName,
+ }
+ handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+ return srv.(ZwDaemonServiceServer).ListFiles(ctx, req.(*ListFilesRequest))
+ }
+ return interceptor(ctx, in, info, handler)
+}
+
+func _ZwDaemonService_GetFile_Handler(srv interface{}, stream grpc.ServerStream) error {
+ m := new(GetFileRequest)
+ if err := stream.RecvMsg(m); err != nil {
+ return err
+ }
+ return srv.(ZwDaemonServiceServer).GetFile(m, &grpc.GenericServerStream[GetFileRequest, GetFileResponse]{ServerStream: stream})
+}
+
+// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
+type ZwDaemonService_GetFileServer = grpc.ServerStreamingServer[GetFileResponse]
+
+func _ZwDaemonService_GetFileRange_Handler(srv interface{}, stream grpc.ServerStream) error {
+ m := new(GetFileRangeRequest)
+ if err := stream.RecvMsg(m); err != nil {
+ return err
+ }
+ return srv.(ZwDaemonServiceServer).GetFileRange(m, &grpc.GenericServerStream[GetFileRangeRequest, GetFileRangeResponse]{ServerStream: stream})
+}
+
+// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
+type ZwDaemonService_GetFileRangeServer = grpc.ServerStreamingServer[GetFileRangeResponse]
+
+func _ZwDaemonService_AddFile_Handler(srv interface{}, stream grpc.ServerStream) error {
+ return srv.(ZwDaemonServiceServer).AddFile(&grpc.GenericServerStream[AddFileRequest, AddFileResponse]{ServerStream: stream})
+}
+
+// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
+type ZwDaemonService_AddFileServer = grpc.ClientStreamingServer[AddFileRequest, AddFileResponse]
+
+func _ZwDaemonService_DeleteFile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+ in := new(DeleteFileRequest)
+ if err := dec(in); err != nil {
+ return nil, err
+ }
+ if interceptor == nil {
+ return srv.(ZwDaemonServiceServer).DeleteFile(ctx, in)
+ }
+ info := &grpc.UnaryServerInfo{
+ Server: srv,
+ FullMethod: ZwDaemonService_DeleteFile_FullMethodName,
+ }
+ handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+ return srv.(ZwDaemonServiceServer).DeleteFile(ctx, req.(*DeleteFileRequest))
+ }
+ return interceptor(ctx, in, info, handler)
+}
+
+func _ZwDaemonService_Compact_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+ in := new(CompactRequest)
+ if err := dec(in); err != nil {
+ return nil, err
+ }
+ if interceptor == nil {
+ return srv.(ZwDaemonServiceServer).Compact(ctx, in)
+ }
+ info := &grpc.UnaryServerInfo{
+ Server: srv,
+ FullMethod: ZwDaemonService_Compact_FullMethodName,
+ }
+ handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+ return srv.(ZwDaemonServiceServer).Compact(ctx, req.(*CompactRequest))
+ }
+ return interceptor(ctx, in, info, handler)
+}
+
+// ZwDaemonService_ServiceDesc is the grpc.ServiceDesc for ZwDaemonService service.
+// It's only intended for direct use with grpc.RegisterService,
+// and not to be introspected or modified (even as a copy)
+var ZwDaemonService_ServiceDesc = grpc.ServiceDesc{
+ ServiceName: "zw.daemon.v1.ZwDaemonService",
+ HandlerType: (*ZwDaemonServiceServer)(nil),
+ Methods: []grpc.MethodDesc{
+ {
+ MethodName: "GetServerInfo",
+ Handler: _ZwDaemonService_GetServerInfo_Handler,
+ },
+ {
+ MethodName: "Create",
+ Handler: _ZwDaemonService_Create_Handler,
+ },
+ {
+ MethodName: "Unseal",
+ Handler: _ZwDaemonService_Unseal_Handler,
+ },
+ {
+ MethodName: "Seal",
+ Handler: _ZwDaemonService_Seal_Handler,
+ },
+ {
+ MethodName: "ListFiles",
+ Handler: _ZwDaemonService_ListFiles_Handler,
+ },
+ {
+ MethodName: "DeleteFile",
+ Handler: _ZwDaemonService_DeleteFile_Handler,
+ },
+ {
+ MethodName: "Compact",
+ Handler: _ZwDaemonService_Compact_Handler,
+ },
+ },
+ Streams: []grpc.StreamDesc{
+ {
+ StreamName: "GetFile",
+ Handler: _ZwDaemonService_GetFile_Handler,
+ ServerStreams: true,
+ },
+ {
+ StreamName: "GetFileRange",
+ Handler: _ZwDaemonService_GetFileRange_Handler,
+ ServerStreams: true,
+ },
+ {
+ StreamName: "AddFile",
+ Handler: _ZwDaemonService_AddFile_Handler,
+ ClientStreams: true,
+ },
+ },
+ Metadata: "zw/daemon/v1/daemon.proto",
+}
generated by cgit 1.3.1 (git 2.54.0) at 2026-10-12 20:28:52 +0000