Extended pipeline protobufs + extra documentation + gitignore
UnicodingUnicorn
parent
09335166fe
commit
42f41d05c6
|
|
@ -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
|
||||
76
README.md
76
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. |
|
||||
|
|
|
|||
|
|
@ -0,0 +1,9 @@
|
|||
syntax = "proto3";
|
||||
package main;
|
||||
|
||||
message DataRequest {
|
||||
string key = 1;
|
||||
uint64 start = 2;
|
||||
|
||||
string type = 3;
|
||||
}
|
||||
|
|
@ -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,
|
||||
}
|
||||
|
|
@ -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,
|
||||
}
|
||||
|
|
@ -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,
|
||||
}
|
||||
|
|
@ -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,
|
||||
}
|
||||
|
|
@ -0,0 +1,10 @@
|
|||
syntax = "proto3";
|
||||
package main;
|
||||
|
||||
import "client.proto";
|
||||
|
||||
message Response {
|
||||
uint32 code = 1;
|
||||
bytes message = 2;
|
||||
Client client = 3;
|
||||
}
|
||||
|
|
@ -0,0 +1,10 @@
|
|||
syntax = "proto3";
|
||||
package main;
|
||||
|
||||
message ScanRequest {
|
||||
string key = 1;
|
||||
uint64 from = 2;
|
||||
uint64 to = 3;
|
||||
|
||||
string type = 4;
|
||||
}
|
||||
|
|
@ -0,0 +1,9 @@
|
|||
syntax = "proto3";
|
||||
package main;
|
||||
|
||||
import "bite.proto";
|
||||
|
||||
message Store {
|
||||
string type = 1;
|
||||
Bite bite = 2;
|
||||
}
|
||||
Loading…
Reference in New Issue