From 42f41d05c6ee486da3beb8a489192077765e8c3a Mon Sep 17 00:00:00 2001 From: UnicodingUnicorn <7555ic@gmail.com> Date: Wed, 13 Feb 2019 23:03:12 +0800 Subject: [PATCH] Extended pipeline protobufs + extra documentation + gitignore --- .gitignore | 202 ++++++++++++++++++++++++++++++++ README.md | 76 ++++++++++-- data_request.proto | 9 ++ bite.pb.go => go/bite.pb.go | 0 client.pb.go => go/client.pb.go | 0 go/data_request.pb.go | 94 +++++++++++++++ go/response.pb.go | 95 +++++++++++++++ go/scan_request.pb.go | 103 ++++++++++++++++ go/store.pb.go | 85 ++++++++++++++ response.proto | 10 ++ scan_request.proto | 10 ++ store.proto | 9 ++ 12 files changed, 685 insertions(+), 8 deletions(-) create mode 100644 .gitignore create mode 100644 data_request.proto rename bite.pb.go => go/bite.pb.go (100%) rename client.pb.go => go/client.pb.go (100%) create mode 100644 go/data_request.pb.go create mode 100644 go/response.pb.go create mode 100644 go/scan_request.pb.go create mode 100644 go/store.pb.go create mode 100644 response.proto create mode 100644 scan_request.proto create mode 100644 store.proto diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..a7ca0e2 --- /dev/null +++ b/.gitignore @@ -0,0 +1,202 @@ +# autogen.sh-generated files +Makefile.in +src/Makefile.in +config.guess +config.h.in +config.sub +configure +depcomp +install-sh +ltmain.sh +missing + +aclocal.m4 +m4/libtool.m4 +m4/ltoptions.m4 +m4/ltsugar.m4 +m4/ltversion.m4 +m4/lt~obsolete.m4 +autom4te.cache + +# downloaded files +/gmock + +# in-tree configure-generated files +Makefile +src/Makefile +/config.h +config.log +config.status + +libtool +protobuf-lite.pc +protobuf.pc +.deps +stamp-h1 + +# in-tree build products +*.o +*.lo +*.la +src/.libs +*.so + +.dirstamp + +any_test.pb.* +map*unittest.pb.* +unittest*.pb.* +cpp_test*.pb.* +src/google/protobuf/util/**/*.pb.cc +src/google/protobuf/util/**/*.pb.h + +*.pyc +*.egg-info +*_pb2.py +python/**/*.egg +python/.eggs/ +python/.tox +python/build/ + +src/js_embed +src/protoc +src/unittest_proto_middleman + +# vim generated +*.swp + +# Generated test scaffolding +src/no_warning_test.cc +src/no-warning-test +src/protobuf*-test +src/test_plugin +src/testzip.* +src/zcg*zip +ar-lib + +test-driver +compile + +src/**/*.log +src/**/*.trs + +# JavaBuild output. +java/core/target +java/util/target +javanano/target +java/.idea +java/**/*.iml + +# Windows native output. +cmake/build +build_msvc + +# NuGet packages: we want the repository configuration, but not the +# packages themselves. +/csharp/src/packages/*/ + +# OS X's Finder creates these for state about opened windows/etc. +**/.DS_Store + +# Cocoapods artifacts +# Podfile.lock and the workspace file are tracked, to ease deleting them. That's +# needed to trigger "pod install" to rerun the preinstall commands. +Pods/ + +# Comformance test output +conformance/.libs/ +conformance/com/ +conformance/conformance-cpp +conformance/conformance-csharp +conformance/conformance-java +conformance/conformance-objc +conformance/conformance-test-runner +conformance/conformance.pb.cc +conformance/conformance.pb.h +conformance/Conformance.pbobjc.h +conformance/Conformance.pbobjc.m +conformance/conformance_pb.js +conformance/conformance_pb.rb +conformance/failing_tests.txt +conformance/google/ +conformance/google-protobuf/ +conformance/javac_middleman +conformance/lite/ +conformance/nonexistent_tests.txt +conformance/protoc_middleman +conformance/succeeding_tests.txt +conformance/Conformance/ +conformance/GPBMetadata/ +conformance/Google/ +conformance/Protobuf_test_messages/ +conformance/conformance-php +conformance/conformance-php-c +conformance/*.class + +# php test output +composer.lock +php/tests/generated/ +php/tests/old_protoc +php/tests/protobuf/ +php/ext/google/protobuf/.libs/ +php/ext/google/protobuf/Makefile.fragments +php/ext/google/protobuf/Makefile.global +php/ext/google/protobuf/Makefile.objects +php/ext/google/protobuf/acinclude.m4 +php/ext/google/protobuf/build/ +php/ext/google/protobuf/config.h +php/ext/google/protobuf/config.h.in~ +php/ext/google/protobuf/config.nice +php/ext/google/protobuf/configure.ac +php/ext/google/protobuf/configure.in +php/ext/google/protobuf/mkinstalldirs +php/ext/google/protobuf/run-tests.php +vendor/ + +# JavaScript artifacts +js/commonjs_out/ +js/compatibility_tests/v3.0.0/commonjs_out* +js/compatibility_tests/v3.0.0/protoc +js/compatibility_tests/v3.0.0/testproto_libs1.js +js/compatibility_tests/v3.0.0/testproto_libs1_new.js +js/compatibility_tests/v3.0.0/testproto_libs2.js +js/compatibility_tests/v3.0.0/testproto_libs2_new.js +js/deps.js +js/google-protobuf.js +js/google/ +js/node_modules/ +js/testproto_libs1.js +js/testproto_libs2.js + +# Ignore the bazel symlinks +/bazel-* + +# ruby test output +ruby/lib/ +ruby/tests/basic_test_pb.rb +ruby/tests/basic_test_proto2_pb.rb +ruby/tests/generated_code_pb.rb +ruby/tests/test_import_pb.rb +ruby/tests/test_ruby_package_pb.rb +ruby/tests/generated_code_proto2_pb.rb +ruby/tests/test_import_proto2_pb.rb +ruby/tests/test_ruby_package_proto2_pb.rb +ruby/Gemfile.lock +ruby/compatibility_tests/v3.0.0/protoc +ruby/compatibility_tests/v3.0.0/tests/generated_code_pb.rb +ruby/compatibility_tests/v3.0.0/tests/test_import_pb.rb + +# IntelliJ CLion Config files and build output +cmake/.idea +cmake/cmake-build-debug/ + +# Common build subdirectories. +./.build/ +./_build/ + +# Visual Studio 2017 +.vs + +# IntelliJ +.idea +*.iml diff --git a/README.md b/README.md index 70984ab..f60ed24 100644 --- a/README.md +++ b/README.md @@ -2,12 +2,72 @@ Definitions of [protobufs](https://developers.google.com/protocol-buffers) used in Beep backend. -### Bite (bite.proto) +## Client (client.proto) -```proto -message Bite { - bytes key = 1; - uint64 start = 2; - bytes data = 3; -} -``` +Defines a user client (user + device). Intended to be populated from auth token and convey the user through the pipeline. + +| Field | Type | Description | +| ----- | ---- | ----------- | +| key | string | User's ID. (Unique to user) | +| client | string | User's device's ID. (Unique to user's device) | + +--- + +## Bite (bite.proto) + +A chunk of raw data. Doesn't necessarily have to be raw audio, could be text too in the case of ```backend-transcription```. + +| Field | Type | Description | +| ----- | ---- | ----------- | +| key | string | Bite's key | +| client | uint64 | Bite's start time in Unix Epoch | +| data | bytes | Bite's raw audio data | +| client | Client | Client who submitted the Bite | + +--- + +## Store (store.proto) + +A request to store a Bite in ```backend-store```. + +| Field | Type | Description | +| ----- | ---- | ----------- | +| type | string | Type of data to be stored. E.g. ```bite``` or ```transcription``` | +| bite | Bite | Bite to be stored | + +--- + +## DataRequest + +A request to get data from ```backend-store```. See more details in its README. + +| Field | Type | Description | +| ----- | ---- | ----------- | +| key | string | The target key. | +| start | uint64 | The target data's start time in Unix Epoch time | +| type | string | The target data's type. E.g. ```bite``` or ```transcription``` | + +--- + +## ScanRequest + +A request to scan data from ```backend-store```. See more details in its README. + +| Field | Type | Description | +| ----- | ---- | ----------- | +| key | string | The target key. | +| from | uint64 | Time to start scanning from in Unix Epoch time | +| to | uint64 | Time to scan to in Unix Epoch Time | +| type | string | The target data's type. E.g. ```bite``` or ```transcription``` | + +--- + +## Response + +A response, roughly follows the basics of a HTTP response (status code and message). Client can be left blank, usually when NATS is Requested from a HTTP request. + +| Field | Type | Description | +| ----- | ---- | ----------- | +| code | uint32 | HTTP status code of response | +| message | string | Body of response. | +| client | Client | Client to respond to. | diff --git a/data_request.proto b/data_request.proto new file mode 100644 index 0000000..74e704e --- /dev/null +++ b/data_request.proto @@ -0,0 +1,9 @@ +syntax = "proto3"; +package main; + +message DataRequest { + string key = 1; + uint64 start = 2; + + string type = 3; +} diff --git a/bite.pb.go b/go/bite.pb.go similarity index 100% rename from bite.pb.go rename to go/bite.pb.go diff --git a/client.pb.go b/go/client.pb.go similarity index 100% rename from client.pb.go rename to go/client.pb.go diff --git a/go/data_request.pb.go b/go/data_request.pb.go new file mode 100644 index 0000000..858132e --- /dev/null +++ b/go/data_request.pb.go @@ -0,0 +1,94 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// source: store/data_request.proto + +package main + +import ( + fmt "fmt" + proto "github.com/golang/protobuf/proto" + math "math" +) + +// Reference imports to suppress errors if they are not otherwise used. +var _ = proto.Marshal +var _ = fmt.Errorf +var _ = math.Inf + +// This is a compile-time assertion to ensure that this generated file +// is compatible with the proto package it is being compiled against. +// A compilation error at this line likely means your copy of the +// proto package needs to be updated. +const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package + +type DataRequest struct { + Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` + Start uint64 `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"` + Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *DataRequest) Reset() { *m = DataRequest{} } +func (m *DataRequest) String() string { return proto.CompactTextString(m) } +func (*DataRequest) ProtoMessage() {} +func (*DataRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_1c7f2c7bfa43f02c, []int{0} +} + +func (m *DataRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_DataRequest.Unmarshal(m, b) +} +func (m *DataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_DataRequest.Marshal(b, m, deterministic) +} +func (m *DataRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_DataRequest.Merge(m, src) +} +func (m *DataRequest) XXX_Size() int { + return xxx_messageInfo_DataRequest.Size(m) +} +func (m *DataRequest) XXX_DiscardUnknown() { + xxx_messageInfo_DataRequest.DiscardUnknown(m) +} + +var xxx_messageInfo_DataRequest proto.InternalMessageInfo + +func (m *DataRequest) GetKey() string { + if m != nil { + return m.Key + } + return "" +} + +func (m *DataRequest) GetStart() uint64 { + if m != nil { + return m.Start + } + return 0 +} + +func (m *DataRequest) GetType() string { + if m != nil { + return m.Type + } + return "" +} + +func init() { + proto.RegisterType((*DataRequest)(nil), "main.DataRequest") +} + +func init() { proto.RegisterFile("store/data_request.proto", fileDescriptor_1c7f2c7bfa43f02c) } + +var fileDescriptor_1c7f2c7bfa43f02c = []byte{ + // 119 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x92, 0x28, 0x2e, 0xc9, 0x2f, + 0x4a, 0xd5, 0x4f, 0x49, 0x2c, 0x49, 0x8c, 0x2f, 0x4a, 0x2d, 0x2c, 0x4d, 0x2d, 0x2e, 0xd1, 0x2b, + 0x28, 0xca, 0x2f, 0xc9, 0x17, 0x62, 0xc9, 0x4d, 0xcc, 0xcc, 0x53, 0xf2, 0xe4, 0xe2, 0x76, 0x49, + 0x2c, 0x49, 0x0c, 0x82, 0x48, 0x09, 0x09, 0x70, 0x31, 0x67, 0xa7, 0x56, 0x4a, 0x30, 0x2a, 0x30, + 0x6a, 0x70, 0x06, 0x81, 0x98, 0x42, 0x22, 0x5c, 0xac, 0xc5, 0x25, 0x89, 0x45, 0x25, 0x12, 0x4c, + 0x0a, 0x8c, 0x1a, 0x2c, 0x41, 0x10, 0x8e, 0x90, 0x10, 0x17, 0x4b, 0x49, 0x65, 0x41, 0xaa, 0x04, + 0x33, 0x58, 0x21, 0x98, 0x9d, 0xc4, 0x06, 0x36, 0xd7, 0x18, 0x10, 0x00, 0x00, 0xff, 0xff, 0x70, + 0x54, 0xb9, 0xcc, 0x73, 0x00, 0x00, 0x00, +} diff --git a/go/response.pb.go b/go/response.pb.go new file mode 100644 index 0000000..3797a39 --- /dev/null +++ b/go/response.pb.go @@ -0,0 +1,95 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// source: response.proto + +package main + +import ( + fmt "fmt" + proto "github.com/golang/protobuf/proto" + math "math" +) + +// Reference imports to suppress errors if they are not otherwise used. +var _ = proto.Marshal +var _ = fmt.Errorf +var _ = math.Inf + +// This is a compile-time assertion to ensure that this generated file +// is compatible with the proto package it is being compiled against. +// A compilation error at this line likely means your copy of the +// proto package needs to be updated. +const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package + +type Response struct { + Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` + Message []byte `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` + Client *Client `protobuf:"bytes,3,opt,name=client,proto3" json:"client,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *Response) Reset() { *m = Response{} } +func (m *Response) String() string { return proto.CompactTextString(m) } +func (*Response) ProtoMessage() {} +func (*Response) Descriptor() ([]byte, []int) { + return fileDescriptor_0fbc901015fa5021, []int{0} +} + +func (m *Response) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_Response.Unmarshal(m, b) +} +func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_Response.Marshal(b, m, deterministic) +} +func (m *Response) XXX_Merge(src proto.Message) { + xxx_messageInfo_Response.Merge(m, src) +} +func (m *Response) XXX_Size() int { + return xxx_messageInfo_Response.Size(m) +} +func (m *Response) XXX_DiscardUnknown() { + xxx_messageInfo_Response.DiscardUnknown(m) +} + +var xxx_messageInfo_Response proto.InternalMessageInfo + +func (m *Response) GetCode() uint32 { + if m != nil { + return m.Code + } + return 0 +} + +func (m *Response) GetMessage() []byte { + if m != nil { + return m.Message + } + return nil +} + +func (m *Response) GetClient() *Client { + if m != nil { + return m.Client + } + return nil +} + +func init() { + proto.RegisterType((*Response)(nil), "main.Response") +} + +func init() { proto.RegisterFile("response.proto", fileDescriptor_0fbc901015fa5021) } + +var fileDescriptor_0fbc901015fa5021 = []byte{ + // 129 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0xe2, 0x2b, 0x4a, 0x2d, 0x2e, + 0xc8, 0xcf, 0x2b, 0x4e, 0xd5, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0x62, 0xc9, 0x4d, 0xcc, 0xcc, + 0x93, 0xe2, 0x49, 0xce, 0xc9, 0x4c, 0xcd, 0x2b, 0x81, 0x88, 0x29, 0xc5, 0x71, 0x71, 0x04, 0x41, + 0x55, 0x09, 0x09, 0x71, 0xb1, 0x24, 0xe7, 0xa7, 0xa4, 0x4a, 0x30, 0x2a, 0x30, 0x6a, 0xf0, 0x06, + 0x81, 0xd9, 0x42, 0x12, 0x5c, 0xec, 0xb9, 0xa9, 0xc5, 0xc5, 0x89, 0xe9, 0xa9, 0x12, 0x4c, 0x0a, + 0x8c, 0x1a, 0x3c, 0x41, 0x30, 0xae, 0x90, 0x0a, 0x17, 0x1b, 0xc4, 0x24, 0x09, 0x66, 0x05, 0x46, + 0x0d, 0x6e, 0x23, 0x1e, 0x3d, 0x90, 0xf1, 0x7a, 0xce, 0x60, 0xb1, 0x20, 0xa8, 0x5c, 0x12, 0x1b, + 0xd8, 0x1a, 0x63, 0x40, 0x00, 0x00, 0x00, 0xff, 0xff, 0x14, 0x8c, 0xe3, 0xa3, 0x8c, 0x00, 0x00, + 0x00, +} diff --git a/go/scan_request.pb.go b/go/scan_request.pb.go new file mode 100644 index 0000000..681c08e --- /dev/null +++ b/go/scan_request.pb.go @@ -0,0 +1,103 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// source: store/scan_request.proto + +package main + +import ( + fmt "fmt" + proto "github.com/golang/protobuf/proto" + math "math" +) + +// Reference imports to suppress errors if they are not otherwise used. +var _ = proto.Marshal +var _ = fmt.Errorf +var _ = math.Inf + +// This is a compile-time assertion to ensure that this generated file +// is compatible with the proto package it is being compiled against. +// A compilation error at this line likely means your copy of the +// proto package needs to be updated. +const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package + +type ScanRequest struct { + Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` + From uint64 `protobuf:"varint,2,opt,name=from,proto3" json:"from,omitempty"` + To uint64 `protobuf:"varint,3,opt,name=to,proto3" json:"to,omitempty"` + Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ScanRequest) Reset() { *m = ScanRequest{} } +func (m *ScanRequest) String() string { return proto.CompactTextString(m) } +func (*ScanRequest) ProtoMessage() {} +func (*ScanRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_812dc305bd560f72, []int{0} +} + +func (m *ScanRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ScanRequest.Unmarshal(m, b) +} +func (m *ScanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ScanRequest.Marshal(b, m, deterministic) +} +func (m *ScanRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_ScanRequest.Merge(m, src) +} +func (m *ScanRequest) XXX_Size() int { + return xxx_messageInfo_ScanRequest.Size(m) +} +func (m *ScanRequest) XXX_DiscardUnknown() { + xxx_messageInfo_ScanRequest.DiscardUnknown(m) +} + +var xxx_messageInfo_ScanRequest proto.InternalMessageInfo + +func (m *ScanRequest) GetKey() string { + if m != nil { + return m.Key + } + return "" +} + +func (m *ScanRequest) GetFrom() uint64 { + if m != nil { + return m.From + } + return 0 +} + +func (m *ScanRequest) GetTo() uint64 { + if m != nil { + return m.To + } + return 0 +} + +func (m *ScanRequest) GetType() string { + if m != nil { + return m.Type + } + return "" +} + +func init() { + proto.RegisterType((*ScanRequest)(nil), "main.ScanRequest") +} + +func init() { proto.RegisterFile("store/scan_request.proto", fileDescriptor_812dc305bd560f72) } + +var fileDescriptor_812dc305bd560f72 = []byte{ + // 129 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x92, 0x28, 0x2e, 0xc9, 0x2f, + 0x4a, 0xd5, 0x2f, 0x4e, 0x4e, 0xcc, 0x8b, 0x2f, 0x4a, 0x2d, 0x2c, 0x4d, 0x2d, 0x2e, 0xd1, 0x2b, + 0x28, 0xca, 0x2f, 0xc9, 0x17, 0x62, 0xc9, 0x4d, 0xcc, 0xcc, 0x53, 0x0a, 0xe7, 0xe2, 0x0e, 0x4e, + 0x4e, 0xcc, 0x0b, 0x82, 0x48, 0x09, 0x09, 0x70, 0x31, 0x67, 0xa7, 0x56, 0x4a, 0x30, 0x2a, 0x30, + 0x6a, 0x70, 0x06, 0x81, 0x98, 0x42, 0x42, 0x5c, 0x2c, 0x69, 0x45, 0xf9, 0xb9, 0x12, 0x4c, 0x0a, + 0x8c, 0x1a, 0x2c, 0x41, 0x60, 0xb6, 0x10, 0x1f, 0x17, 0x53, 0x49, 0xbe, 0x04, 0x33, 0x58, 0x84, + 0xa9, 0x24, 0x1f, 0xa4, 0xa6, 0xa4, 0xb2, 0x20, 0x55, 0x82, 0x05, 0xac, 0x0d, 0xcc, 0x4e, 0x62, + 0x03, 0xdb, 0x62, 0x0c, 0x08, 0x00, 0x00, 0xff, 0xff, 0x2e, 0x77, 0x60, 0x56, 0x81, 0x00, 0x00, + 0x00, +} diff --git a/go/store.pb.go b/go/store.pb.go new file mode 100644 index 0000000..e6463cc --- /dev/null +++ b/go/store.pb.go @@ -0,0 +1,85 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// source: store.proto + +package main + +import ( + fmt "fmt" + proto "github.com/golang/protobuf/proto" + math "math" +) + +// Reference imports to suppress errors if they are not otherwise used. +var _ = proto.Marshal +var _ = fmt.Errorf +var _ = math.Inf + +// This is a compile-time assertion to ensure that this generated file +// is compatible with the proto package it is being compiled against. +// A compilation error at this line likely means your copy of the +// proto package needs to be updated. +const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package + +type Store struct { + Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` + Bite *Bite `protobuf:"bytes,2,opt,name=bite,proto3" json:"bite,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *Store) Reset() { *m = Store{} } +func (m *Store) String() string { return proto.CompactTextString(m) } +func (*Store) ProtoMessage() {} +func (*Store) Descriptor() ([]byte, []int) { + return fileDescriptor_98bbca36ef968dfc, []int{0} +} + +func (m *Store) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_Store.Unmarshal(m, b) +} +func (m *Store) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_Store.Marshal(b, m, deterministic) +} +func (m *Store) XXX_Merge(src proto.Message) { + xxx_messageInfo_Store.Merge(m, src) +} +func (m *Store) XXX_Size() int { + return xxx_messageInfo_Store.Size(m) +} +func (m *Store) XXX_DiscardUnknown() { + xxx_messageInfo_Store.DiscardUnknown(m) +} + +var xxx_messageInfo_Store proto.InternalMessageInfo + +func (m *Store) GetType() string { + if m != nil { + return m.Type + } + return "" +} + +func (m *Store) GetBite() *Bite { + if m != nil { + return m.Bite + } + return nil +} + +func init() { + proto.RegisterType((*Store)(nil), "main.Store") +} + +func init() { proto.RegisterFile("store.proto", fileDescriptor_98bbca36ef968dfc) } + +var fileDescriptor_98bbca36ef968dfc = []byte{ + // 104 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0xe2, 0x2e, 0x2e, 0xc9, 0x2f, + 0x4a, 0xd5, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0x62, 0xc9, 0x4d, 0xcc, 0xcc, 0x93, 0xe2, 0x4a, + 0xca, 0x2c, 0x81, 0x8a, 0x28, 0x59, 0x73, 0xb1, 0x06, 0x83, 0x14, 0x08, 0x09, 0x71, 0xb1, 0x94, + 0x54, 0x16, 0xa4, 0x4a, 0x30, 0x2a, 0x30, 0x6a, 0x70, 0x06, 0x81, 0xd9, 0x42, 0x72, 0x5c, 0x2c, + 0x20, 0xa5, 0x12, 0x4c, 0x0a, 0x8c, 0x1a, 0xdc, 0x46, 0x5c, 0x7a, 0x20, 0xdd, 0x7a, 0x4e, 0x99, + 0x25, 0xa9, 0x41, 0x60, 0xf1, 0x24, 0x36, 0xb0, 0x19, 0xc6, 0x80, 0x00, 0x00, 0x00, 0xff, 0xff, + 0x84, 0x05, 0xf9, 0x1a, 0x64, 0x00, 0x00, 0x00, +} diff --git a/response.proto b/response.proto new file mode 100644 index 0000000..a508943 --- /dev/null +++ b/response.proto @@ -0,0 +1,10 @@ +syntax = "proto3"; +package main; + +import "client.proto"; + +message Response { + uint32 code = 1; + bytes message = 2; + Client client = 3; +} diff --git a/scan_request.proto b/scan_request.proto new file mode 100644 index 0000000..858401c --- /dev/null +++ b/scan_request.proto @@ -0,0 +1,10 @@ +syntax = "proto3"; +package main; + +message ScanRequest { + string key = 1; + uint64 from = 2; + uint64 to = 3; + + string type = 4; +} diff --git a/store.proto b/store.proto new file mode 100644 index 0000000..8631b48 --- /dev/null +++ b/store.proto @@ -0,0 +1,9 @@ +syntax = "proto3"; +package main; + +import "bite.proto"; + +message Store { + string type = 1; + Bite bite = 2; +}