Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
C
chain33-sdk-go
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
JIRA
JIRA
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
link33
chain33-sdk-go
Commits
0d8b0474
Unverified
Commit
0d8b0474
authored
Jan 22, 2021
by
andyYuanFZM
Committed by
GitHub
Jan 22, 2021
Browse files
Options
Browse Files
Download
Plain Diff
Merge pull request #6 from jpeng-go/master
更新storage.proto
parents
1c627bbf
db9944a5
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
184 additions
and
44 deletions
+184
-44
storage.go
dapp/storage/storage.go
+3
-2
storage.proto
proto/storage.proto
+14
-3
storage.pb.go
types/storage.pb.go
+167
-39
No files found.
dapp/storage/storage.go
View file @
0d8b0474
...
@@ -5,6 +5,7 @@ import (
...
@@ -5,6 +5,7 @@ import (
"github.com/33cn/chain33-sdk-go/crypto"
"github.com/33cn/chain33-sdk-go/crypto"
.
"github.com/33cn/chain33-sdk-go/types"
.
"github.com/33cn/chain33-sdk-go/types"
"math/rand"
"math/rand"
"time"
)
)
/*
/*
...
@@ -35,10 +36,10 @@ func CreateContentStorageTx(paraName string, op int32, key string, content []byt
...
@@ -35,10 +36,10 @@ func CreateContentStorageTx(paraName string, op int32, key string, content []byt
}},
}},
}
}
if
paraName
==
""
{
if
paraName
==
""
{
tx
:=
&
Transaction
{
Execer
:
[]
byte
(
StorageX
),
Payload
:
Encode
(
payload
),
Fee
:
1e5
,
Nonce
:
rand
.
Int63
(
),
To
:
Addr
}
tx
:=
&
Transaction
{
Execer
:
[]
byte
(
StorageX
),
Payload
:
Encode
(
payload
),
Fee
:
1e5
,
Nonce
:
rand
.
Int63
n
(
time
.
Now
()
.
UnixNano
()
),
To
:
Addr
}
return
tx
,
nil
return
tx
,
nil
}
else
{
}
else
{
tx
:=
&
Transaction
{
Execer
:
[]
byte
(
paraName
+
StorageX
),
Payload
:
Encode
(
payload
),
Fee
:
1e5
,
Nonce
:
rand
.
Int63
(
),
To
:
crypto
.
GetExecAddress
(
paraName
+
StorageX
)}
tx
:=
&
Transaction
{
Execer
:
[]
byte
(
paraName
+
StorageX
),
Payload
:
Encode
(
payload
),
Fee
:
1e5
,
Nonce
:
rand
.
Int63
n
(
time
.
Now
()
.
UnixNano
()
),
To
:
crypto
.
GetExecAddress
(
paraName
+
StorageX
)}
return
tx
,
nil
return
tx
,
nil
}
}
}
}
...
...
proto/storage.proto
View file @
0d8b0474
...
@@ -8,8 +8,9 @@ message Storage {
...
@@ -8,8 +8,9 @@ message Storage {
LinkNotaryStorage
linkStorage
=
3
;
LinkNotaryStorage
linkStorage
=
3
;
EncryptNotaryStorage
encryptStorage
=
4
;
EncryptNotaryStorage
encryptStorage
=
4
;
EncryptShareNotaryStorage
encryptShareStorage
=
5
;
EncryptShareNotaryStorage
encryptShareStorage
=
5
;
EncryptNotaryAdd
encryptAdd
=
6
;
}
}
int32
ty
=
6
;
int32
ty
=
7
;
}
}
message
StorageAction
{
message
StorageAction
{
...
@@ -19,12 +20,12 @@ message StorageAction {
...
@@ -19,12 +20,12 @@ message StorageAction {
LinkNotaryStorage
linkStorage
=
3
;
LinkNotaryStorage
linkStorage
=
3
;
EncryptNotaryStorage
encryptStorage
=
4
;
EncryptNotaryStorage
encryptStorage
=
4
;
EncryptShareNotaryStorage
encryptShareStorage
=
5
;
EncryptShareNotaryStorage
encryptShareStorage
=
5
;
EncryptNotaryAdd
encryptAdd
=
6
;
}
}
int32
ty
=
6
;
int32
ty
=
7
;
}
}
// 内容存证模型
// 内容存证模型
message
ContentOnlyNotaryStorage
{
message
ContentOnlyNotaryStorage
{
//长度需要小于512k
//长度需要小于512k
bytes
content
=
1
;
bytes
content
=
1
;
//自定义的主键,可以为空,如果没传,则用txhash为key
//自定义的主键,可以为空,如果没传,则用txhash为key
...
@@ -85,6 +86,16 @@ message EncryptShareNotaryStorage {
...
@@ -85,6 +86,16 @@ message EncryptShareNotaryStorage {
//字符串值
//字符串值
string
value
=
5
;
string
value
=
5
;
}
}
// 加密存证数据运算
message
EncryptNotaryAdd
{
//源操作数存证索引
string
key
=
1
;
//待操作数据
bytes
encryptAdd
=
2
;
}
service
storage
{}
//根据txhash去状态数据库中查询存储内容
//根据txhash去状态数据库中查询存储内容
message
QueryStorage
{
message
QueryStorage
{
string
txHash
=
1
;
string
txHash
=
1
;
...
...
types/storage.pb.go
View file @
0d8b0474
...
@@ -4,9 +4,12 @@
...
@@ -4,9 +4,12 @@
package
types
package
types
import
(
import
(
context
"context"
fmt
"fmt"
fmt
"fmt"
proto
"github.com/golang/protobuf/proto"
math
"math"
math
"math"
proto
"github.com/golang/protobuf/proto"
grpc
"google.golang.org/grpc"
)
)
// Reference imports to suppress errors if they are not otherwise used.
// Reference imports to suppress errors if they are not otherwise used.
...
@@ -28,8 +31,9 @@ type Storage struct {
...
@@ -28,8 +31,9 @@ type Storage struct {
// *Storage_LinkStorage
// *Storage_LinkStorage
// *Storage_EncryptStorage
// *Storage_EncryptStorage
// *Storage_EncryptShareStorage
// *Storage_EncryptShareStorage
// *Storage_EncryptAdd
Value
isStorage_Value
`protobuf_oneof:"value"`
Value
isStorage_Value
`protobuf_oneof:"value"`
Ty
int32
`protobuf:"varint,
6
,opt,name=ty,proto3" json:"ty,omitempty"`
Ty
int32
`protobuf:"varint,
7
,opt,name=ty,proto3" json:"ty,omitempty"`
XXX_NoUnkeyedLiteral
struct
{}
`json:"-"`
XXX_NoUnkeyedLiteral
struct
{}
`json:"-"`
XXX_unrecognized
[]
byte
`json:"-"`
XXX_unrecognized
[]
byte
`json:"-"`
XXX_sizecache
int32
`json:"-"`
XXX_sizecache
int32
`json:"-"`
...
@@ -84,6 +88,10 @@ type Storage_EncryptShareStorage struct {
...
@@ -84,6 +88,10 @@ type Storage_EncryptShareStorage struct {
EncryptShareStorage
*
EncryptShareNotaryStorage
`protobuf:"bytes,5,opt,name=encryptShareStorage,proto3,oneof"`
EncryptShareStorage
*
EncryptShareNotaryStorage
`protobuf:"bytes,5,opt,name=encryptShareStorage,proto3,oneof"`
}
}
type
Storage_EncryptAdd
struct
{
EncryptAdd
*
EncryptNotaryAdd
`protobuf:"bytes,6,opt,name=encryptAdd,proto3,oneof"`
}
func
(
*
Storage_ContentStorage
)
isStorage_Value
()
{}
func
(
*
Storage_ContentStorage
)
isStorage_Value
()
{}
func
(
*
Storage_HashStorage
)
isStorage_Value
()
{}
func
(
*
Storage_HashStorage
)
isStorage_Value
()
{}
...
@@ -94,6 +102,8 @@ func (*Storage_EncryptStorage) isStorage_Value() {}
...
@@ -94,6 +102,8 @@ func (*Storage_EncryptStorage) isStorage_Value() {}
func
(
*
Storage_EncryptShareStorage
)
isStorage_Value
()
{}
func
(
*
Storage_EncryptShareStorage
)
isStorage_Value
()
{}
func
(
*
Storage_EncryptAdd
)
isStorage_Value
()
{}
func
(
m
*
Storage
)
GetValue
()
isStorage_Value
{
func
(
m
*
Storage
)
GetValue
()
isStorage_Value
{
if
m
!=
nil
{
if
m
!=
nil
{
return
m
.
Value
return
m
.
Value
...
@@ -136,6 +146,13 @@ func (m *Storage) GetEncryptShareStorage() *EncryptShareNotaryStorage {
...
@@ -136,6 +146,13 @@ func (m *Storage) GetEncryptShareStorage() *EncryptShareNotaryStorage {
return
nil
return
nil
}
}
func
(
m
*
Storage
)
GetEncryptAdd
()
*
EncryptNotaryAdd
{
if
x
,
ok
:=
m
.
GetValue
()
.
(
*
Storage_EncryptAdd
);
ok
{
return
x
.
EncryptAdd
}
return
nil
}
func
(
m
*
Storage
)
GetTy
()
int32
{
func
(
m
*
Storage
)
GetTy
()
int32
{
if
m
!=
nil
{
if
m
!=
nil
{
return
m
.
Ty
return
m
.
Ty
...
@@ -151,6 +168,7 @@ func (*Storage) XXX_OneofWrappers() []interface{} {
...
@@ -151,6 +168,7 @@ func (*Storage) XXX_OneofWrappers() []interface{} {
(
*
Storage_LinkStorage
)(
nil
),
(
*
Storage_LinkStorage
)(
nil
),
(
*
Storage_EncryptStorage
)(
nil
),
(
*
Storage_EncryptStorage
)(
nil
),
(
*
Storage_EncryptShareStorage
)(
nil
),
(
*
Storage_EncryptShareStorage
)(
nil
),
(
*
Storage_EncryptAdd
)(
nil
),
}
}
}
}
...
@@ -161,8 +179,9 @@ type StorageAction struct {
...
@@ -161,8 +179,9 @@ type StorageAction struct {
// *StorageAction_LinkStorage
// *StorageAction_LinkStorage
// *StorageAction_EncryptStorage
// *StorageAction_EncryptStorage
// *StorageAction_EncryptShareStorage
// *StorageAction_EncryptShareStorage
// *StorageAction_EncryptAdd
Value
isStorageAction_Value
`protobuf_oneof:"value"`
Value
isStorageAction_Value
`protobuf_oneof:"value"`
Ty
int32
`protobuf:"varint,
6
,opt,name=ty,proto3" json:"ty,omitempty"`
Ty
int32
`protobuf:"varint,
7
,opt,name=ty,proto3" json:"ty,omitempty"`
XXX_NoUnkeyedLiteral
struct
{}
`json:"-"`
XXX_NoUnkeyedLiteral
struct
{}
`json:"-"`
XXX_unrecognized
[]
byte
`json:"-"`
XXX_unrecognized
[]
byte
`json:"-"`
XXX_sizecache
int32
`json:"-"`
XXX_sizecache
int32
`json:"-"`
...
@@ -217,6 +236,10 @@ type StorageAction_EncryptShareStorage struct {
...
@@ -217,6 +236,10 @@ type StorageAction_EncryptShareStorage struct {
EncryptShareStorage
*
EncryptShareNotaryStorage
`protobuf:"bytes,5,opt,name=encryptShareStorage,proto3,oneof"`
EncryptShareStorage
*
EncryptShareNotaryStorage
`protobuf:"bytes,5,opt,name=encryptShareStorage,proto3,oneof"`
}
}
type
StorageAction_EncryptAdd
struct
{
EncryptAdd
*
EncryptNotaryAdd
`protobuf:"bytes,6,opt,name=encryptAdd,proto3,oneof"`
}
func
(
*
StorageAction_ContentStorage
)
isStorageAction_Value
()
{}
func
(
*
StorageAction_ContentStorage
)
isStorageAction_Value
()
{}
func
(
*
StorageAction_HashStorage
)
isStorageAction_Value
()
{}
func
(
*
StorageAction_HashStorage
)
isStorageAction_Value
()
{}
...
@@ -227,6 +250,8 @@ func (*StorageAction_EncryptStorage) isStorageAction_Value() {}
...
@@ -227,6 +250,8 @@ func (*StorageAction_EncryptStorage) isStorageAction_Value() {}
func
(
*
StorageAction_EncryptShareStorage
)
isStorageAction_Value
()
{}
func
(
*
StorageAction_EncryptShareStorage
)
isStorageAction_Value
()
{}
func
(
*
StorageAction_EncryptAdd
)
isStorageAction_Value
()
{}
func
(
m
*
StorageAction
)
GetValue
()
isStorageAction_Value
{
func
(
m
*
StorageAction
)
GetValue
()
isStorageAction_Value
{
if
m
!=
nil
{
if
m
!=
nil
{
return
m
.
Value
return
m
.
Value
...
@@ -269,6 +294,13 @@ func (m *StorageAction) GetEncryptShareStorage() *EncryptShareNotaryStorage {
...
@@ -269,6 +294,13 @@ func (m *StorageAction) GetEncryptShareStorage() *EncryptShareNotaryStorage {
return
nil
return
nil
}
}
func
(
m
*
StorageAction
)
GetEncryptAdd
()
*
EncryptNotaryAdd
{
if
x
,
ok
:=
m
.
GetValue
()
.
(
*
StorageAction_EncryptAdd
);
ok
{
return
x
.
EncryptAdd
}
return
nil
}
func
(
m
*
StorageAction
)
GetTy
()
int32
{
func
(
m
*
StorageAction
)
GetTy
()
int32
{
if
m
!=
nil
{
if
m
!=
nil
{
return
m
.
Ty
return
m
.
Ty
...
@@ -284,6 +316,7 @@ func (*StorageAction) XXX_OneofWrappers() []interface{} {
...
@@ -284,6 +316,7 @@ func (*StorageAction) XXX_OneofWrappers() []interface{} {
(
*
StorageAction_LinkStorage
)(
nil
),
(
*
StorageAction_LinkStorage
)(
nil
),
(
*
StorageAction_EncryptStorage
)(
nil
),
(
*
StorageAction_EncryptStorage
)(
nil
),
(
*
StorageAction_EncryptShareStorage
)(
nil
),
(
*
StorageAction_EncryptShareStorage
)(
nil
),
(
*
StorageAction_EncryptAdd
)(
nil
),
}
}
}
}
...
@@ -636,6 +669,56 @@ func (m *EncryptShareNotaryStorage) GetValue() string {
...
@@ -636,6 +669,56 @@ func (m *EncryptShareNotaryStorage) GetValue() string {
return
""
return
""
}
}
// 加密存证数据运算
type
EncryptNotaryAdd
struct
{
//源操作数存证索引
Key
string
`protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
//待操作数据
EncryptAdd
[]
byte
`protobuf:"bytes,2,opt,name=encryptAdd,proto3" json:"encryptAdd,omitempty"`
XXX_NoUnkeyedLiteral
struct
{}
`json:"-"`
XXX_unrecognized
[]
byte
`json:"-"`
XXX_sizecache
int32
`json:"-"`
}
func
(
m
*
EncryptNotaryAdd
)
Reset
()
{
*
m
=
EncryptNotaryAdd
{}
}
func
(
m
*
EncryptNotaryAdd
)
String
()
string
{
return
proto
.
CompactTextString
(
m
)
}
func
(
*
EncryptNotaryAdd
)
ProtoMessage
()
{}
func
(
*
EncryptNotaryAdd
)
Descriptor
()
([]
byte
,
[]
int
)
{
return
fileDescriptor_0d2c4ccf1453ffdb
,
[]
int
{
7
}
}
func
(
m
*
EncryptNotaryAdd
)
XXX_Unmarshal
(
b
[]
byte
)
error
{
return
xxx_messageInfo_EncryptNotaryAdd
.
Unmarshal
(
m
,
b
)
}
func
(
m
*
EncryptNotaryAdd
)
XXX_Marshal
(
b
[]
byte
,
deterministic
bool
)
([]
byte
,
error
)
{
return
xxx_messageInfo_EncryptNotaryAdd
.
Marshal
(
b
,
m
,
deterministic
)
}
func
(
m
*
EncryptNotaryAdd
)
XXX_Merge
(
src
proto
.
Message
)
{
xxx_messageInfo_EncryptNotaryAdd
.
Merge
(
m
,
src
)
}
func
(
m
*
EncryptNotaryAdd
)
XXX_Size
()
int
{
return
xxx_messageInfo_EncryptNotaryAdd
.
Size
(
m
)
}
func
(
m
*
EncryptNotaryAdd
)
XXX_DiscardUnknown
()
{
xxx_messageInfo_EncryptNotaryAdd
.
DiscardUnknown
(
m
)
}
var
xxx_messageInfo_EncryptNotaryAdd
proto
.
InternalMessageInfo
func
(
m
*
EncryptNotaryAdd
)
GetKey
()
string
{
if
m
!=
nil
{
return
m
.
Key
}
return
""
}
func
(
m
*
EncryptNotaryAdd
)
GetEncryptAdd
()
[]
byte
{
if
m
!=
nil
{
return
m
.
EncryptAdd
}
return
nil
}
//根据txhash去状态数据库中查询存储内容
//根据txhash去状态数据库中查询存储内容
type
QueryStorage
struct
{
type
QueryStorage
struct
{
TxHash
string
`protobuf:"bytes,1,opt,name=txHash,proto3" json:"txHash,omitempty"`
TxHash
string
`protobuf:"bytes,1,opt,name=txHash,proto3" json:"txHash,omitempty"`
...
@@ -648,7 +731,7 @@ func (m *QueryStorage) Reset() { *m = QueryStorage{} }
...
@@ -648,7 +731,7 @@ func (m *QueryStorage) Reset() { *m = QueryStorage{} }
func
(
m
*
QueryStorage
)
String
()
string
{
return
proto
.
CompactTextString
(
m
)
}
func
(
m
*
QueryStorage
)
String
()
string
{
return
proto
.
CompactTextString
(
m
)
}
func
(
*
QueryStorage
)
ProtoMessage
()
{}
func
(
*
QueryStorage
)
ProtoMessage
()
{}
func
(
*
QueryStorage
)
Descriptor
()
([]
byte
,
[]
int
)
{
func
(
*
QueryStorage
)
Descriptor
()
([]
byte
,
[]
int
)
{
return
fileDescriptor_0d2c4ccf1453ffdb
,
[]
int
{
7
}
return
fileDescriptor_0d2c4ccf1453ffdb
,
[]
int
{
8
}
}
}
func
(
m
*
QueryStorage
)
XXX_Unmarshal
(
b
[]
byte
)
error
{
func
(
m
*
QueryStorage
)
XXX_Unmarshal
(
b
[]
byte
)
error
{
...
@@ -688,7 +771,7 @@ func (m *BatchQueryStorage) Reset() { *m = BatchQueryStorage{} }
...
@@ -688,7 +771,7 @@ func (m *BatchQueryStorage) Reset() { *m = BatchQueryStorage{} }
func
(
m
*
BatchQueryStorage
)
String
()
string
{
return
proto
.
CompactTextString
(
m
)
}
func
(
m
*
BatchQueryStorage
)
String
()
string
{
return
proto
.
CompactTextString
(
m
)
}
func
(
*
BatchQueryStorage
)
ProtoMessage
()
{}
func
(
*
BatchQueryStorage
)
ProtoMessage
()
{}
func
(
*
BatchQueryStorage
)
Descriptor
()
([]
byte
,
[]
int
)
{
func
(
*
BatchQueryStorage
)
Descriptor
()
([]
byte
,
[]
int
)
{
return
fileDescriptor_0d2c4ccf1453ffdb
,
[]
int
{
8
}
return
fileDescriptor_0d2c4ccf1453ffdb
,
[]
int
{
9
}
}
}
func
(
m
*
BatchQueryStorage
)
XXX_Unmarshal
(
b
[]
byte
)
error
{
func
(
m
*
BatchQueryStorage
)
XXX_Unmarshal
(
b
[]
byte
)
error
{
...
@@ -727,7 +810,7 @@ func (m *BatchReplyStorage) Reset() { *m = BatchReplyStorage{} }
...
@@ -727,7 +810,7 @@ func (m *BatchReplyStorage) Reset() { *m = BatchReplyStorage{} }
func
(
m
*
BatchReplyStorage
)
String
()
string
{
return
proto
.
CompactTextString
(
m
)
}
func
(
m
*
BatchReplyStorage
)
String
()
string
{
return
proto
.
CompactTextString
(
m
)
}
func
(
*
BatchReplyStorage
)
ProtoMessage
()
{}
func
(
*
BatchReplyStorage
)
ProtoMessage
()
{}
func
(
*
BatchReplyStorage
)
Descriptor
()
([]
byte
,
[]
int
)
{
func
(
*
BatchReplyStorage
)
Descriptor
()
([]
byte
,
[]
int
)
{
return
fileDescriptor_0d2c4ccf1453ffdb
,
[]
int
{
9
}
return
fileDescriptor_0d2c4ccf1453ffdb
,
[]
int
{
10
}
}
}
func
(
m
*
BatchReplyStorage
)
XXX_Unmarshal
(
b
[]
byte
)
error
{
func
(
m
*
BatchReplyStorage
)
XXX_Unmarshal
(
b
[]
byte
)
error
{
...
@@ -765,7 +848,7 @@ func (m *ReceiptStorage) Reset() { *m = ReceiptStorage{} }
...
@@ -765,7 +848,7 @@ func (m *ReceiptStorage) Reset() { *m = ReceiptStorage{} }
func
(
m
*
ReceiptStorage
)
String
()
string
{
return
proto
.
CompactTextString
(
m
)
}
func
(
m
*
ReceiptStorage
)
String
()
string
{
return
proto
.
CompactTextString
(
m
)
}
func
(
*
ReceiptStorage
)
ProtoMessage
()
{}
func
(
*
ReceiptStorage
)
ProtoMessage
()
{}
func
(
*
ReceiptStorage
)
Descriptor
()
([]
byte
,
[]
int
)
{
func
(
*
ReceiptStorage
)
Descriptor
()
([]
byte
,
[]
int
)
{
return
fileDescriptor_0d2c4ccf1453ffdb
,
[]
int
{
1
0
}
return
fileDescriptor_0d2c4ccf1453ffdb
,
[]
int
{
1
1
}
}
}
func
(
m
*
ReceiptStorage
)
XXX_Unmarshal
(
b
[]
byte
)
error
{
func
(
m
*
ReceiptStorage
)
XXX_Unmarshal
(
b
[]
byte
)
error
{
...
@@ -794,6 +877,7 @@ func init() {
...
@@ -794,6 +877,7 @@ func init() {
proto
.
RegisterType
((
*
LinkNotaryStorage
)(
nil
),
"types.LinkNotaryStorage"
)
proto
.
RegisterType
((
*
LinkNotaryStorage
)(
nil
),
"types.LinkNotaryStorage"
)
proto
.
RegisterType
((
*
EncryptNotaryStorage
)(
nil
),
"types.EncryptNotaryStorage"
)
proto
.
RegisterType
((
*
EncryptNotaryStorage
)(
nil
),
"types.EncryptNotaryStorage"
)
proto
.
RegisterType
((
*
EncryptShareNotaryStorage
)(
nil
),
"types.EncryptShareNotaryStorage"
)
proto
.
RegisterType
((
*
EncryptShareNotaryStorage
)(
nil
),
"types.EncryptShareNotaryStorage"
)
proto
.
RegisterType
((
*
EncryptNotaryAdd
)(
nil
),
"types.EncryptNotaryAdd"
)
proto
.
RegisterType
((
*
QueryStorage
)(
nil
),
"types.QueryStorage"
)
proto
.
RegisterType
((
*
QueryStorage
)(
nil
),
"types.QueryStorage"
)
proto
.
RegisterType
((
*
BatchQueryStorage
)(
nil
),
"types.BatchQueryStorage"
)
proto
.
RegisterType
((
*
BatchQueryStorage
)(
nil
),
"types.BatchQueryStorage"
)
proto
.
RegisterType
((
*
BatchReplyStorage
)(
nil
),
"types.BatchReplyStorage"
)
proto
.
RegisterType
((
*
BatchReplyStorage
)(
nil
),
"types.BatchReplyStorage"
)
...
@@ -805,36 +889,80 @@ func init() {
...
@@ -805,36 +889,80 @@ func init() {
}
}
var
fileDescriptor_0d2c4ccf1453ffdb
=
[]
byte
{
var
fileDescriptor_0d2c4ccf1453ffdb
=
[]
byte
{
// 484 bytes of a gzipped FileDescriptorProto
// 528 bytes of a gzipped FileDescriptorProto
0x1f
,
0x8b
,
0x08
,
0x00
,
0x00
,
0x00
,
0x00
,
0x00
,
0x02
,
0xff
,
0xec
,
0x55
,
0xc1
,
0x8a
,
0xd4
,
0x40
,
0x1f
,
0x8b
,
0x08
,
0x00
,
0x00
,
0x00
,
0x00
,
0x00
,
0x02
,
0xff
,
0xec
,
0x95
,
0x4d
,
0x8b
,
0xd3
,
0x40
,
0x10
,
0x35
,
0xc9
,
0x64
,
0xc6
,
0xa9
,
0x64
,
0xc3
,
0x6e
,
0xbb
,
0x2e
,
0x11
,
0x05
,
0x43
,
0x0e
,
0xcb
,
0x18
,
0xc7
,
0x37
,
0x4d
,
0xd3
,
0x98
,
0x27
,
0xdd
,
0xd0
,
0x1d
,
0xd7
,
0x35
,
0xa2
,
0x68
,
0xc8
,
0x61
,
0x20
,
0x38
,
0x87
,
0xf5
,
0x2a
,
0xa8
,
0x2b
,
0x0b
,
0x23
,
0x8a
,
0x62
,
0xaf
,
0x3f
,
0x90
,
0x0d
,
0x8d
,
0x29
,
0x82
,
0x3d
,
0xd4
,
0x93
,
0x20
,
0x68
,
0x57
,
0x17
,
0x2a
,
0x8a
,
0xe2
,
0xac
,
0x5f
,
0x20
,
0x9b
,
0x09
,
0x13
,
0xba
,
0x43
,
0xd2
,
0x23
,
0xe6
,
0x17
,
0x3c
,
0xf9
,
0x05
,
0xde
,
0xfc
,
0x4f
,
0x49
,
0xa7
,
0x0e
,
0xa6
,
0x34
,
0xcc
,
0x84
,
0x64
,
0x2a
,
0xe6
,
0xcb
,
0x78
,
0xf3
,
0xa3
,
0x78
,
0xf2
,
0x4b
,
0x49
,
0xba
,
0x37
,
0x99
,
0x64
,
0xc0
,
0x83
,
0xe0
,
0x65
,
0x6f
,
0x5d
,
0x5d
,
0xaf
,
0xde
,
0x7b
,
0x55
,
0x95
,
0x26
,
0xcf
,
0xa4
,
0x49
,
0x9b
,
0x05
,
0x0f
,
0x5e
,
0x84
,
0xbd
,
0xcd
,
0x3c
,
0x2f
,
0xbf
,
0xe7
,
0xe5
,
0xd0
,
0x70
,
0x54
,
0x4b
,
0x51
,
0x25
,
0x5f
,
0xd9
,
0xba
,
0xac
,
0x84
,
0x14
,
0xc4
,
0x95
,
0x4d
,
0xc9
,
0x3f
,
0x6d
,
0xe0
,
0xb8
,
0x90
,
0x22
,
0x8f
,
0xbe
,
0xb2
,
0x59
,
0x96
,
0x0b
,
0x29
,
0x88
,
0x25
,
0xcb
,
0xea
,
0xf8
,
0x87
,
0x03
,
0x8b
,
0xeb
,
0x2e
,
0x41
,
0xde
,
0x41
,
0x90
,
0x0a
,
0x2e
,
0x19
,
0x97
,
0x78
,
0x8c
,
0x15
,
0xe1
,
0x2f
,
0x13
,
0xec
,
0xab
,
0xda
,
0x41
,
0xde
,
0x81
,
0x17
,
0x0b
,
0x2e
,
0x19
,
0x97
,
0x13
,
0x5a
,
0x91
,
0xb5
,
0xf2
,
0x2e
,
0x9e
,
0xae
,
0x15
,
0x76
,
0xfd
,
0xb6
,
0x4b
,
0x7e
,
0xe2
,
0x45
,
0x68
,
0xf1
,
0x8d
,
0xc0
,
0x98
,
0xba
,
0xf3
,
0x27
,
0x33
,
0x15
,
0x3b
,
0x7b
,
0x53
,
0x3b
,
0x3f
,
0xf1
,
0xf3
,
0x51
,
0xc8
,
0xa4
,
0x6a
,
0x10
,
0xb6
,
0xb9
,
0x47
,
0xf7
,
0x0a
,
0xc9
,
0x6b
,
0xf0
,
0xb2
,
0xa4
,
0xb4
,
0xfc
,
0x28
,
0x64
,
0x94
,
0x97
,
0x18
,
0xb6
,
0x3c
,
0xa2
,
0x7b
,
0x89
,
0xe4
,
0x35
,
0xb8
,
0x49
,
0xce
,
0x34
,
0x8f
,
0xad
,
0x78
,
0x9e
,
0x20
,
0xcf
,
0x26
,
0xa9
,
0xb3
,
0x29
,
0x92
,
0x7e
,
0x09
,
0x79
,
0x54
,
0x24
,
0x9a
,
0x33
,
0x50
,
0x9c
,
0x47
,
0xc8
,
0x59
,
0x46
,
0x45
,
0xd2
,
0x07
,
0x69
,
0xa7
,
0x90
,
0x09
,
0x5e
,
0x91
,
0xf3
,
0xad
,
0x66
,
0x70
,
0x14
,
0x43
,
0x88
,
0x0c
,
0x1f
,
0x72
,
0xbe
,
0x1d
,
0x55
,
0x97
,
0xe0
,
0xa6
,
0x6b
,
0xbe
,
0xd1
,
0x04
,
0x53
,
0x11
,
0x7c
,
0x24
,
0x7c
,
0x58
,
0xf3
,
0xcd
,
0x41
,
0xf7
,
0xe0
,
0xe4
,
0x0a
,
0x02
,
0xc6
,
0xd3
,
0xaa
,
0x29
,
0x4d
,
0x2b
,
0x33
,
0x45
,
0xf0
,
0x18
,
0x09
,
0x76
,
0x2b
,
0x9c
,
0x5c
,
0x82
,
0xc7
,
0x78
,
0x9c
,
0x97
,
0x59
,
0x33
,
0xca
,
0x50
,
0x01
,
0x1e
,
0x22
,
0xae
,
0xba
,
0xe4
,
0xa8
,
0x8d
,
0x61
,
0x11
,
0xf9
,
0x02
,
0x0f
,
0xf4
,
0x4d
,
0x96
,
0x54
,
0x4c
,
0x73
,
0xe0
,
0xb2
,
0x76
,
0x1e
,
0x8c
,
0xd1
,
0x4d
,
0x22
,
0x5f
,
0xe0
,
0xae
,
0xb6
,
0x24
,
0x51
,
0xce
,
0x34
,
0xb9
,
0x8a
,
0x2b
,
0x1a
,
0x72
,
0x29
,
0xc4
,
0x3e
,
0xe1
,
0x54
,
0x39
,
0x09
,
0xc0
,
0x96
,
0x4d
,
0x38
,
0xcb
,
0x52
,
0xac
,
0xa0
,
0xcb
,
0x52
,
0x11
,
0xfb
,
0xc0
,
0xbe
,
0x74
,
0xf2
,
0x02
,
0x00
,
0xcd
,
0x8b
,
0x8f
,
0xac
,
0x95
,
0x4b
,
0x6d
,
0xd9
,
0x5c
,
0x2e
,
0xc0
,
0xfd
,
0x96
,
0x14
,
0x3b
,
0x16
,
0xff
,
0x74
,
0xd5
,
0xca
,
0x1f
,
0x29
,
0xd8
,
0xfd
,
0xbe
,
0xc6
,
0x16
,
0xab
,
0xd5
,
0xf2
,
0x88
,
0xb6
,
0x82
,
0x89
,
0xe0
,
0x08
,
0x41
,
0x6f
,
0x52
,
0x99
,
0x0b
,
0x7e
,
0xb7
,
0x92
,
0xff
,
0xbd
,
0x92
,
0x02
,
0xc2
,
0x43
,
0x07
,
0x03
,
0x59
,
0xfa
,
0x76
,
0x60
,
0x4c
,
0x2d
,
0x3a
,
0x90
,
0xe5
,
0x85
,
0x0d
,
0xd6
,
0xb7
,
0x28
,
0x33
,
0x26
,
0x21
,
0x2c
,
0x70
,
0xc6
,
0x6a
,
0x2b
,
0x3e
,
0xd5
,
0x21
,
0x39
,
0x06
,
0x67
,
0xcb
,
0x1a
,
0xdd
,
0xb2
,
0xf0
,
0xb7
,
0x09
,
0xc7
,
0xc8
,
0x5f
,
0xc4
,
0x72
,
0x2d
,
0xf8
,
0xad
,
0x9a
,
0xff
,
0xb1
,
0x35
,
0xe3
,
0x25
,
0x6d
,
0x8f
,
0xad
,
0x80
,
0x28
,
0xd5
,
0xc8
,
0x5c
,
0x6a
,
0x8b
,
0x92
,
0x9c
,
0xa2
,
0x9a
,
0x29
,
0xf8
,
0x37
,
0xc9
,
0x43
,
0x7c
,
0xb0
,
0x51
,
0x1e
,
0x25
,
0xe8
,
0x98
,
0xea
,
0x2b
,
0x99
,
0x80
,
0x1a
,
0xc2
,
0x92
,
0xa2
,
0xda
,
0x35
,
0x3c
,
0x9c
,
0xdc
,
0x04
,
0x21
,
0x30
,
0x6b
,
0x37
,
0x81
,
0x80
,
0xb9
,
0x61
,
0xa5
,
0x92
,
0xc7
,
0xa1
,
0xd5
,
0xb1
,
0x2a
,
0x20
,
0x32
,
0xb5
,
0x6d
,
0x8b
,
0x0e
,
0x3a
,
0xea
,
0x3c
,
0x21
,
0x62
,
0x48
,
0x9d
,
0x3e
,
0x69
,
0x0a
,
0x27
,
0xa3
,
0xe5
,
0xb4
,
0x84
,
0xed
,
0x44
,
0x46
,
0x4e
,
0xb1
,
0x80
,
0xda
,
0x9f
,
0x43
,
0xb1
,
0xda
,
0x15
,
0xdc
,
0xeb
,
0x15
,
0x91
,
0x10
,
0x72
,
0x34
,
0x61
,
0x7b
,
0x36
,
0x22
,
0xf6
,
0x58
,
0xc4
,
0x99
,
0x10
,
0x19
,
0x38
,
0xff
,
0x65
,
0xc1
,
0x18
,
0x56
,
0x22
,
0x62
,
0x1d
,
0x75
,
0xee
,
0x29
,
0xd2
,
0x40
,
0xcd
,
0x36
,
0x34
,
0x86
,
0x93
,
0x03
,
0xe9
,
0xd4
,
0x06
,
0x49
,
0x04
,
0x1e
,
0x4e
,
0x65
,
0x73
,
0xdb
,
0x40
,
0xff
,
0x8a
,
0x9c
,
0x9b
,
0x0f
,
0x5d
,
0x2b
,
0x60
,
0xa5
,
0xab
,
0x06
,
0x56
,
0xe7
,
0xa6
,
0xc8
,
0xe0
,
0xb0
,
0x88
,
0xd9
,
0x53
,
0xa4
,
0x03
,
0x27
,
0x8d
,
0x06
,
0xf6
,
0x6e
,
0x5b
,
0x61
,
0x2e
,
0x78
,
0xda
,
0x75
,
0xe7
,
0xd3
,
0x2e
,
0xd0
,
0xd3
,
0xf9
,
0x0f
,
0x03
,
0x4e
,
0xfb
,
0xc4
,
0x27
,
0x01
,
0xb8
,
0xb8
,
0x95
,
0xe5
,
0x6e
,
0x80
,
0xb6
,
0x06
,
0x67
,
0x13
,
0x06
,
0xdd
,
0xbe
,
0xc1
,
0xdf
,
0x16
,
0x3c
,
0x3a
,
0xf8
,
0x59
,
0xfc
,
0x43
,
0x97
,
0x89
,
0x9c
,
0x37
,
0x6f
,
0x0a
,
0x37
,
0x8d
,
0x0d
,
0xec
,
0x59
,
0xab
,
0xc2
,
0x5c
,
0xf0
,
0xb8
,
0x9e
,
0x67
,
0x30
,
0x2f
,
0x77
,
0x37
,
0xef
,
0x71
,
0x66
,
0x3e
,
0xc5
,
0xe8
,
0xaf
,
0x7d
,
0x9e
,
0x83
,
0xff
,
0x6e
,
0x4c
,
0xeb
,
0x8b
,
0x6e
,
0x70
,
0xd8
,
0xd3
,
0xa0
,
0xd5
,
0x6e
,
0xf0
,
0xa7
,
0x01
,
0x0f
,
0x6e
,
0x79
,
0xc7
,
0x6e
,
0x9d
,
0x9d
,
0xc1
,
0x5c
,
0x7e
,
0x37
,
0xa6
,
0x96
,
0x14
,
0xa3
,
0xf8
,
0x39
,
0x9c
,
0x7c
,
0x51
,
0xff
,
0xb0
,
0xcb
,
0x33
,
0x18
,
0x65
,
0xdb
,
0xeb
,
0xf7
,
0xb8
,
0xb3
,
0x31
,
0xc5
,
0xdb
,
0x5c
,
0x26
,
0x32
,
0xcd
,
0x06
,
0xe0
,
0x10
,
0x16
,
0x5d
,
0xba
,
0x0e
,
0xad
,
0xc8
,
0x59
,
0x2d
,
0xa9
,
0x5f
,
0xf7
,
0xf9
,
0x16
,
0x26
,
0xfb
,
0x6f
,
0x55
,
0xe7
,
0x1a
,
0xbb
,
0xdc
,
0xc7
,
0x9d
,
0xa7
,
0x5e
,
0x0e
,
0xe3
,
0x57
,
0x08
,
0xa7
,
0xac
,
0x2c
,
0x0c
,
0xfc
,
0x19
,
0xdc
,
0xc7
,
0x47
,
0xa1
,
0xc3
,
0x7b
,
0x77
,
0xd2
,
0xb2
,
0x84
,
0xe7
,
0x30
,
0xfe
,
0xbc
,
0x65
,
0xbb
,
0xf9
,
0xce
,
0x60
,
0x24
,
0xbf
,
0x37
,
0x17
,
0x01
,
0xfe
,
0x40
,
0x88
,
0xa0
,
0x26
,
0x1f
,
0x1f
,
0x43
,
0x40
,
0x59
,
0xca
,
0x72
,
0xf3
,
0x27
,
0xa3
,
0x39
,
0x14
,
0x6f
,
0xe1
,
0x33
,
0x38
,
0xb9
,
0x88
,
0x64
,
0x9c
,
0x74
,
0x82
,
0x7d
,
0xb0
,
0x6b
,
0xde
,
0xcc
,
0xd5
,
0x43
,
0xf2
,
0xe2
,
0x4f
,
0x00
,
0x00
,
0x00
,
0xff
,
0xff
,
0x50
,
0x57
,
0xda
,
0x93
,
0x77
,
0xe1
,
0x1b
,
0x81
,
0x39
,
0x75
,
0xa8
,
0xbe
,
0x86
,
0xaf
,
0x30
,
0x9c
,
0xb2
,
0x2c
,
0x6d
,
0xc2
,
0x59
,
0x06
,
0x00
,
0x00
,
0x9f
,
0xc2
,
0x1d
,
0xfc
,
0xa0
,
0xd5
,
0xf1
,
0xee
,
0xdc
,
0xc3
,
0x1f
,
0x1d
,
0x46
,
0xd0
,
0xc6
,
0x1f
,
0x4e
,
0xc0
,
0xa3
,
0x2c
,
0x66
,
0xeb
,
0xe6
,
0xaf
,
0x60
,
0xee
,
0x80
,
0x8d
,
0xde
,
0xeb
,
0x91
,
0xfa
,
0x1e
,
0x3e
,
0xff
,
0x13
,
0x00
,
0x00
,
0xff
,
0xff
,
0x66
,
0xc3
,
0x4e
,
0x48
,
0x20
,
0x07
,
0x00
,
0x00
,
}
// Reference imports to suppress errors if they are not otherwise used.
var
_
context
.
Context
var
_
grpc
.
ClientConnInterface
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const
_
=
grpc
.
SupportPackageIsVersion6
// StorageClient is the client API for Storage service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type
StorageClient
interface
{
}
type
storageClient
struct
{
cc
grpc
.
ClientConnInterface
}
func
NewStorageClient
(
cc
grpc
.
ClientConnInterface
)
StorageClient
{
return
&
storageClient
{
cc
}
}
// StorageServer is the server API for Storage service.
type
StorageServer
interface
{
}
// UnimplementedStorageServer can be embedded to have forward compatible implementations.
type
UnimplementedStorageServer
struct
{
}
func
RegisterStorageServer
(
s
*
grpc
.
Server
,
srv
StorageServer
)
{
s
.
RegisterService
(
&
_Storage_serviceDesc
,
srv
)
}
var
_Storage_serviceDesc
=
grpc
.
ServiceDesc
{
ServiceName
:
"types.storage"
,
HandlerType
:
(
*
StorageServer
)(
nil
),
Methods
:
[]
grpc
.
MethodDesc
{},
Streams
:
[]
grpc
.
StreamDesc
{},
Metadata
:
"storage.proto"
,
}
}
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment