Documentation ¶
Overview ¶
Package groupproto is a generated protocol buffer package.
It is generated from these files:
group_api.proto
It has these top-level messages:
DeleteRequest DeleteResponse LookupGroupRequest LookupGroupResponse LookupGroupItem LookupRequest LookupResponse ReadGroupRequest ReadGroupResponse ReadGroupItem ReadRequest ReadResponse WriteRequest WriteResponse
Index ¶
- func RegisterGroupStoreServer(s *grpc.Server, srv GroupStoreServer)
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)
- func (m *DeleteRequest) GetChildKeyA() uint64
- func (m *DeleteRequest) GetChildKeyB() uint64
- func (m *DeleteRequest) GetKeyA() uint64
- func (m *DeleteRequest) GetKeyB() uint64
- func (m *DeleteRequest) GetRPCID() uint32
- func (m *DeleteRequest) GetTimestampMicro() int64
- func (*DeleteRequest) ProtoMessage()
- func (m *DeleteRequest) Reset()
- func (m *DeleteRequest) String() string
- type DeleteResponse
- type GroupStoreClient
- type GroupStoreServer
- type GroupStore_DeleteClient
- type GroupStore_DeleteServer
- type GroupStore_LookupClient
- type GroupStore_LookupGroupClient
- type GroupStore_LookupGroupServer
- type GroupStore_LookupServer
- type GroupStore_ReadClient
- type GroupStore_ReadGroupClient
- type GroupStore_ReadGroupServer
- type GroupStore_ReadServer
- type GroupStore_WriteClient
- type GroupStore_WriteServer
- type LookupGroupItem
- func (*LookupGroupItem) Descriptor() ([]byte, []int)
- func (m *LookupGroupItem) GetChildKeyA() uint64
- func (m *LookupGroupItem) GetChildKeyB() uint64
- func (m *LookupGroupItem) GetLength() uint32
- func (m *LookupGroupItem) GetRPCID() uint32
- func (m *LookupGroupItem) GetTimestampMicro() int64
- func (*LookupGroupItem) ProtoMessage()
- func (m *LookupGroupItem) Reset()
- func (m *LookupGroupItem) String() string
- type LookupGroupRequest
- func (*LookupGroupRequest) Descriptor() ([]byte, []int)
- func (m *LookupGroupRequest) GetKeyA() uint64
- func (m *LookupGroupRequest) GetKeyB() uint64
- func (m *LookupGroupRequest) GetRPCID() uint32
- func (*LookupGroupRequest) ProtoMessage()
- func (m *LookupGroupRequest) Reset()
- func (m *LookupGroupRequest) String() string
- type LookupGroupResponse
- func (*LookupGroupResponse) Descriptor() ([]byte, []int)
- func (m *LookupGroupResponse) GetErr() string
- func (m *LookupGroupResponse) GetItems() []*LookupGroupItem
- func (m *LookupGroupResponse) GetRPCID() uint32
- func (*LookupGroupResponse) ProtoMessage()
- func (m *LookupGroupResponse) Reset()
- func (m *LookupGroupResponse) String() string
- type LookupRequest
- func (*LookupRequest) Descriptor() ([]byte, []int)
- func (m *LookupRequest) GetChildKeyA() uint64
- func (m *LookupRequest) GetChildKeyB() uint64
- func (m *LookupRequest) GetKeyA() uint64
- func (m *LookupRequest) GetKeyB() uint64
- func (m *LookupRequest) GetRPCID() uint32
- func (*LookupRequest) ProtoMessage()
- func (m *LookupRequest) Reset()
- func (m *LookupRequest) String() string
- type LookupResponse
- func (*LookupResponse) Descriptor() ([]byte, []int)
- func (m *LookupResponse) GetErr() string
- func (m *LookupResponse) GetLength() uint32
- func (m *LookupResponse) GetRPCID() uint32
- func (m *LookupResponse) GetTimestampMicro() int64
- func (*LookupResponse) ProtoMessage()
- func (m *LookupResponse) Reset()
- func (m *LookupResponse) String() string
- type ReadGroupItem
- func (*ReadGroupItem) Descriptor() ([]byte, []int)
- func (m *ReadGroupItem) GetChildKeyA() uint64
- func (m *ReadGroupItem) GetChildKeyB() uint64
- func (m *ReadGroupItem) GetRPCID() uint32
- func (m *ReadGroupItem) GetTimestampMicro() int64
- func (m *ReadGroupItem) GetValue() []byte
- func (*ReadGroupItem) ProtoMessage()
- func (m *ReadGroupItem) Reset()
- func (m *ReadGroupItem) String() string
- type ReadGroupRequest
- func (*ReadGroupRequest) Descriptor() ([]byte, []int)
- func (m *ReadGroupRequest) GetKeyA() uint64
- func (m *ReadGroupRequest) GetKeyB() uint64
- func (m *ReadGroupRequest) GetRPCID() uint32
- func (*ReadGroupRequest) ProtoMessage()
- func (m *ReadGroupRequest) Reset()
- func (m *ReadGroupRequest) String() string
- type ReadGroupResponse
- func (*ReadGroupResponse) Descriptor() ([]byte, []int)
- func (m *ReadGroupResponse) GetErr() string
- func (m *ReadGroupResponse) GetItems() []*ReadGroupItem
- func (m *ReadGroupResponse) GetRPCID() uint32
- func (*ReadGroupResponse) ProtoMessage()
- func (m *ReadGroupResponse) Reset()
- func (m *ReadGroupResponse) String() string
- type ReadRequest
- func (*ReadRequest) Descriptor() ([]byte, []int)
- func (m *ReadRequest) GetChildKeyA() uint64
- func (m *ReadRequest) GetChildKeyB() uint64
- func (m *ReadRequest) GetKeyA() uint64
- func (m *ReadRequest) GetKeyB() uint64
- func (m *ReadRequest) GetRPCID() uint32
- func (*ReadRequest) ProtoMessage()
- func (m *ReadRequest) Reset()
- func (m *ReadRequest) String() string
- type ReadResponse
- func (*ReadResponse) Descriptor() ([]byte, []int)
- func (m *ReadResponse) GetErr() string
- func (m *ReadResponse) GetRPCID() uint32
- func (m *ReadResponse) GetTimestampMicro() int64
- func (m *ReadResponse) GetValue() []byte
- func (*ReadResponse) ProtoMessage()
- func (m *ReadResponse) Reset()
- func (m *ReadResponse) String() string
- type WriteRequest
- func (*WriteRequest) Descriptor() ([]byte, []int)
- func (m *WriteRequest) GetChildKeyA() uint64
- func (m *WriteRequest) GetChildKeyB() uint64
- func (m *WriteRequest) GetKeyA() uint64
- func (m *WriteRequest) GetKeyB() uint64
- func (m *WriteRequest) GetRPCID() uint32
- func (m *WriteRequest) GetTimestampMicro() int64
- func (m *WriteRequest) GetValue() []byte
- func (*WriteRequest) ProtoMessage()
- func (m *WriteRequest) Reset()
- func (m *WriteRequest) String() string
- type WriteResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterGroupStoreServer ¶
func RegisterGroupStoreServer(s *grpc.Server, srv GroupStoreServer)
Types ¶
type DeleteRequest ¶
type DeleteRequest struct { RPCID uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"` KeyA uint64 `protobuf:"varint,2,opt,name=KeyA" json:"KeyA,omitempty"` KeyB uint64 `protobuf:"varint,3,opt,name=KeyB" json:"KeyB,omitempty"` ChildKeyA uint64 `protobuf:"varint,4,opt,name=ChildKeyA" json:"ChildKeyA,omitempty"` ChildKeyB uint64 `protobuf:"varint,5,opt,name=ChildKeyB" json:"ChildKeyB,omitempty"` TimestampMicro int64 `protobuf:"varint,6,opt,name=TimestampMicro" json:"TimestampMicro,omitempty"` }
func (*DeleteRequest) Descriptor ¶
func (*DeleteRequest) Descriptor() ([]byte, []int)
func (*DeleteRequest) GetChildKeyA ¶
func (m *DeleteRequest) GetChildKeyA() uint64
func (*DeleteRequest) GetChildKeyB ¶
func (m *DeleteRequest) GetChildKeyB() uint64
func (*DeleteRequest) GetKeyA ¶
func (m *DeleteRequest) GetKeyA() uint64
func (*DeleteRequest) GetKeyB ¶
func (m *DeleteRequest) GetKeyB() uint64
func (*DeleteRequest) GetRPCID ¶
func (m *DeleteRequest) GetRPCID() uint32
func (*DeleteRequest) GetTimestampMicro ¶
func (m *DeleteRequest) GetTimestampMicro() int64
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) Reset ¶
func (m *DeleteRequest) Reset()
func (*DeleteRequest) String ¶
func (m *DeleteRequest) String() string
type DeleteResponse ¶
type DeleteResponse struct { RPCID uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"` TimestampMicro int64 `protobuf:"varint,2,opt,name=TimestampMicro" json:"TimestampMicro,omitempty"` Err string `protobuf:"bytes,3,opt,name=Err" json:"Err,omitempty"` }
func (*DeleteResponse) Descriptor ¶
func (*DeleteResponse) Descriptor() ([]byte, []int)
func (*DeleteResponse) GetErr ¶
func (m *DeleteResponse) GetErr() string
func (*DeleteResponse) GetRPCID ¶
func (m *DeleteResponse) GetRPCID() uint32
func (*DeleteResponse) GetTimestampMicro ¶
func (m *DeleteResponse) GetTimestampMicro() int64
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) Reset ¶
func (m *DeleteResponse) Reset()
func (*DeleteResponse) String ¶
func (m *DeleteResponse) String() string
type GroupStoreClient ¶
type GroupStoreClient interface { Delete(ctx context.Context, opts ...grpc.CallOption) (GroupStore_DeleteClient, error) LookupGroup(ctx context.Context, opts ...grpc.CallOption) (GroupStore_LookupGroupClient, error) Lookup(ctx context.Context, opts ...grpc.CallOption) (GroupStore_LookupClient, error) ReadGroup(ctx context.Context, opts ...grpc.CallOption) (GroupStore_ReadGroupClient, error) Read(ctx context.Context, opts ...grpc.CallOption) (GroupStore_ReadClient, error) Write(ctx context.Context, opts ...grpc.CallOption) (GroupStore_WriteClient, error) }
func NewGroupStoreClient ¶
func NewGroupStoreClient(cc *grpc.ClientConn) GroupStoreClient
type GroupStoreServer ¶
type GroupStoreServer interface { Delete(GroupStore_DeleteServer) error LookupGroup(GroupStore_LookupGroupServer) error Lookup(GroupStore_LookupServer) error ReadGroup(GroupStore_ReadGroupServer) error Read(GroupStore_ReadServer) error Write(GroupStore_WriteServer) error }
type GroupStore_DeleteClient ¶
type GroupStore_DeleteClient interface { Send(*DeleteRequest) error Recv() (*DeleteResponse, error) grpc.ClientStream }
type GroupStore_DeleteServer ¶
type GroupStore_DeleteServer interface { Send(*DeleteResponse) error Recv() (*DeleteRequest, error) grpc.ServerStream }
type GroupStore_LookupClient ¶
type GroupStore_LookupClient interface { Send(*LookupRequest) error Recv() (*LookupResponse, error) grpc.ClientStream }
type GroupStore_LookupGroupClient ¶
type GroupStore_LookupGroupClient interface { Send(*LookupGroupRequest) error Recv() (*LookupGroupResponse, error) grpc.ClientStream }
type GroupStore_LookupGroupServer ¶
type GroupStore_LookupGroupServer interface { Send(*LookupGroupResponse) error Recv() (*LookupGroupRequest, error) grpc.ServerStream }
type GroupStore_LookupServer ¶
type GroupStore_LookupServer interface { Send(*LookupResponse) error Recv() (*LookupRequest, error) grpc.ServerStream }
type GroupStore_ReadClient ¶
type GroupStore_ReadClient interface { Send(*ReadRequest) error Recv() (*ReadResponse, error) grpc.ClientStream }
type GroupStore_ReadGroupClient ¶
type GroupStore_ReadGroupClient interface { Send(*ReadGroupRequest) error Recv() (*ReadGroupResponse, error) grpc.ClientStream }
type GroupStore_ReadGroupServer ¶
type GroupStore_ReadGroupServer interface { Send(*ReadGroupResponse) error Recv() (*ReadGroupRequest, error) grpc.ServerStream }
type GroupStore_ReadServer ¶
type GroupStore_ReadServer interface { Send(*ReadResponse) error Recv() (*ReadRequest, error) grpc.ServerStream }
type GroupStore_WriteClient ¶
type GroupStore_WriteClient interface { Send(*WriteRequest) error Recv() (*WriteResponse, error) grpc.ClientStream }
type GroupStore_WriteServer ¶
type GroupStore_WriteServer interface { Send(*WriteResponse) error Recv() (*WriteRequest, error) grpc.ServerStream }
type LookupGroupItem ¶
type LookupGroupItem struct { RPCID uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"` ChildKeyA uint64 `protobuf:"varint,2,opt,name=ChildKeyA" json:"ChildKeyA,omitempty"` ChildKeyB uint64 `protobuf:"varint,3,opt,name=ChildKeyB" json:"ChildKeyB,omitempty"` TimestampMicro int64 `protobuf:"varint,4,opt,name=TimestampMicro" json:"TimestampMicro,omitempty"` Length uint32 `protobuf:"varint,5,opt,name=Length" json:"Length,omitempty"` }
func (*LookupGroupItem) Descriptor ¶
func (*LookupGroupItem) Descriptor() ([]byte, []int)
func (*LookupGroupItem) GetChildKeyA ¶
func (m *LookupGroupItem) GetChildKeyA() uint64
func (*LookupGroupItem) GetChildKeyB ¶
func (m *LookupGroupItem) GetChildKeyB() uint64
func (*LookupGroupItem) GetLength ¶
func (m *LookupGroupItem) GetLength() uint32
func (*LookupGroupItem) GetRPCID ¶
func (m *LookupGroupItem) GetRPCID() uint32
func (*LookupGroupItem) GetTimestampMicro ¶
func (m *LookupGroupItem) GetTimestampMicro() int64
func (*LookupGroupItem) ProtoMessage ¶
func (*LookupGroupItem) ProtoMessage()
func (*LookupGroupItem) Reset ¶
func (m *LookupGroupItem) Reset()
func (*LookupGroupItem) String ¶
func (m *LookupGroupItem) String() string
type LookupGroupRequest ¶
type LookupGroupRequest struct { RPCID uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"` KeyA uint64 `protobuf:"varint,2,opt,name=KeyA" json:"KeyA,omitempty"` KeyB uint64 `protobuf:"varint,3,opt,name=KeyB" json:"KeyB,omitempty"` }
func (*LookupGroupRequest) Descriptor ¶
func (*LookupGroupRequest) Descriptor() ([]byte, []int)
func (*LookupGroupRequest) GetKeyA ¶
func (m *LookupGroupRequest) GetKeyA() uint64
func (*LookupGroupRequest) GetKeyB ¶
func (m *LookupGroupRequest) GetKeyB() uint64
func (*LookupGroupRequest) GetRPCID ¶
func (m *LookupGroupRequest) GetRPCID() uint32
func (*LookupGroupRequest) ProtoMessage ¶
func (*LookupGroupRequest) ProtoMessage()
func (*LookupGroupRequest) Reset ¶
func (m *LookupGroupRequest) Reset()
func (*LookupGroupRequest) String ¶
func (m *LookupGroupRequest) String() string
type LookupGroupResponse ¶
type LookupGroupResponse struct { RPCID uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"` Items []*LookupGroupItem `protobuf:"bytes,2,rep,name=Items" json:"Items,omitempty"` Err string `protobuf:"bytes,3,opt,name=Err" json:"Err,omitempty"` }
func (*LookupGroupResponse) Descriptor ¶
func (*LookupGroupResponse) Descriptor() ([]byte, []int)
func (*LookupGroupResponse) GetErr ¶
func (m *LookupGroupResponse) GetErr() string
func (*LookupGroupResponse) GetItems ¶
func (m *LookupGroupResponse) GetItems() []*LookupGroupItem
func (*LookupGroupResponse) GetRPCID ¶
func (m *LookupGroupResponse) GetRPCID() uint32
func (*LookupGroupResponse) ProtoMessage ¶
func (*LookupGroupResponse) ProtoMessage()
func (*LookupGroupResponse) Reset ¶
func (m *LookupGroupResponse) Reset()
func (*LookupGroupResponse) String ¶
func (m *LookupGroupResponse) String() string
type LookupRequest ¶
type LookupRequest struct { RPCID uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"` KeyA uint64 `protobuf:"varint,2,opt,name=KeyA" json:"KeyA,omitempty"` KeyB uint64 `protobuf:"varint,3,opt,name=KeyB" json:"KeyB,omitempty"` ChildKeyA uint64 `protobuf:"varint,4,opt,name=ChildKeyA" json:"ChildKeyA,omitempty"` ChildKeyB uint64 `protobuf:"varint,5,opt,name=ChildKeyB" json:"ChildKeyB,omitempty"` }
func (*LookupRequest) Descriptor ¶
func (*LookupRequest) Descriptor() ([]byte, []int)
func (*LookupRequest) GetChildKeyA ¶
func (m *LookupRequest) GetChildKeyA() uint64
func (*LookupRequest) GetChildKeyB ¶
func (m *LookupRequest) GetChildKeyB() uint64
func (*LookupRequest) GetKeyA ¶
func (m *LookupRequest) GetKeyA() uint64
func (*LookupRequest) GetKeyB ¶
func (m *LookupRequest) GetKeyB() uint64
func (*LookupRequest) GetRPCID ¶
func (m *LookupRequest) GetRPCID() uint32
func (*LookupRequest) ProtoMessage ¶
func (*LookupRequest) ProtoMessage()
func (*LookupRequest) Reset ¶
func (m *LookupRequest) Reset()
func (*LookupRequest) String ¶
func (m *LookupRequest) String() string
type LookupResponse ¶
type LookupResponse struct { RPCID uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"` TimestampMicro int64 `protobuf:"varint,2,opt,name=TimestampMicro" json:"TimestampMicro,omitempty"` Length uint32 `protobuf:"varint,3,opt,name=Length" json:"Length,omitempty"` Err string `protobuf:"bytes,4,opt,name=Err" json:"Err,omitempty"` }
func (*LookupResponse) Descriptor ¶
func (*LookupResponse) Descriptor() ([]byte, []int)
func (*LookupResponse) GetErr ¶
func (m *LookupResponse) GetErr() string
func (*LookupResponse) GetLength ¶
func (m *LookupResponse) GetLength() uint32
func (*LookupResponse) GetRPCID ¶
func (m *LookupResponse) GetRPCID() uint32
func (*LookupResponse) GetTimestampMicro ¶
func (m *LookupResponse) GetTimestampMicro() int64
func (*LookupResponse) ProtoMessage ¶
func (*LookupResponse) ProtoMessage()
func (*LookupResponse) Reset ¶
func (m *LookupResponse) Reset()
func (*LookupResponse) String ¶
func (m *LookupResponse) String() string
type ReadGroupItem ¶
type ReadGroupItem struct { RPCID uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"` ChildKeyA uint64 `protobuf:"varint,2,opt,name=ChildKeyA" json:"ChildKeyA,omitempty"` ChildKeyB uint64 `protobuf:"varint,3,opt,name=ChildKeyB" json:"ChildKeyB,omitempty"` TimestampMicro int64 `protobuf:"varint,4,opt,name=TimestampMicro" json:"TimestampMicro,omitempty"` Value []byte `protobuf:"bytes,5,opt,name=Value,proto3" json:"Value,omitempty"` }
func (*ReadGroupItem) Descriptor ¶
func (*ReadGroupItem) Descriptor() ([]byte, []int)
func (*ReadGroupItem) GetChildKeyA ¶
func (m *ReadGroupItem) GetChildKeyA() uint64
func (*ReadGroupItem) GetChildKeyB ¶
func (m *ReadGroupItem) GetChildKeyB() uint64
func (*ReadGroupItem) GetRPCID ¶
func (m *ReadGroupItem) GetRPCID() uint32
func (*ReadGroupItem) GetTimestampMicro ¶
func (m *ReadGroupItem) GetTimestampMicro() int64
func (*ReadGroupItem) GetValue ¶
func (m *ReadGroupItem) GetValue() []byte
func (*ReadGroupItem) ProtoMessage ¶
func (*ReadGroupItem) ProtoMessage()
func (*ReadGroupItem) Reset ¶
func (m *ReadGroupItem) Reset()
func (*ReadGroupItem) String ¶
func (m *ReadGroupItem) String() string
type ReadGroupRequest ¶
type ReadGroupRequest struct { RPCID uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"` KeyA uint64 `protobuf:"varint,2,opt,name=KeyA" json:"KeyA,omitempty"` KeyB uint64 `protobuf:"varint,3,opt,name=KeyB" json:"KeyB,omitempty"` }
func (*ReadGroupRequest) Descriptor ¶
func (*ReadGroupRequest) Descriptor() ([]byte, []int)
func (*ReadGroupRequest) GetKeyA ¶
func (m *ReadGroupRequest) GetKeyA() uint64
func (*ReadGroupRequest) GetKeyB ¶
func (m *ReadGroupRequest) GetKeyB() uint64
func (*ReadGroupRequest) GetRPCID ¶
func (m *ReadGroupRequest) GetRPCID() uint32
func (*ReadGroupRequest) ProtoMessage ¶
func (*ReadGroupRequest) ProtoMessage()
func (*ReadGroupRequest) Reset ¶
func (m *ReadGroupRequest) Reset()
func (*ReadGroupRequest) String ¶
func (m *ReadGroupRequest) String() string
type ReadGroupResponse ¶
type ReadGroupResponse struct { RPCID uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"` Items []*ReadGroupItem `protobuf:"bytes,2,rep,name=Items" json:"Items,omitempty"` Err string `protobuf:"bytes,3,opt,name=Err" json:"Err,omitempty"` }
func (*ReadGroupResponse) Descriptor ¶
func (*ReadGroupResponse) Descriptor() ([]byte, []int)
func (*ReadGroupResponse) GetErr ¶
func (m *ReadGroupResponse) GetErr() string
func (*ReadGroupResponse) GetItems ¶
func (m *ReadGroupResponse) GetItems() []*ReadGroupItem
func (*ReadGroupResponse) GetRPCID ¶
func (m *ReadGroupResponse) GetRPCID() uint32
func (*ReadGroupResponse) ProtoMessage ¶
func (*ReadGroupResponse) ProtoMessage()
func (*ReadGroupResponse) Reset ¶
func (m *ReadGroupResponse) Reset()
func (*ReadGroupResponse) String ¶
func (m *ReadGroupResponse) String() string
type ReadRequest ¶
type ReadRequest struct { RPCID uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"` KeyA uint64 `protobuf:"varint,2,opt,name=KeyA" json:"KeyA,omitempty"` KeyB uint64 `protobuf:"varint,3,opt,name=KeyB" json:"KeyB,omitempty"` ChildKeyA uint64 `protobuf:"varint,4,opt,name=ChildKeyA" json:"ChildKeyA,omitempty"` ChildKeyB uint64 `protobuf:"varint,5,opt,name=ChildKeyB" json:"ChildKeyB,omitempty"` }
func (*ReadRequest) Descriptor ¶
func (*ReadRequest) Descriptor() ([]byte, []int)
func (*ReadRequest) GetChildKeyA ¶
func (m *ReadRequest) GetChildKeyA() uint64
func (*ReadRequest) GetChildKeyB ¶
func (m *ReadRequest) GetChildKeyB() uint64
func (*ReadRequest) GetKeyA ¶
func (m *ReadRequest) GetKeyA() uint64
func (*ReadRequest) GetKeyB ¶
func (m *ReadRequest) GetKeyB() uint64
func (*ReadRequest) GetRPCID ¶
func (m *ReadRequest) GetRPCID() uint32
func (*ReadRequest) ProtoMessage ¶
func (*ReadRequest) ProtoMessage()
func (*ReadRequest) Reset ¶
func (m *ReadRequest) Reset()
func (*ReadRequest) String ¶
func (m *ReadRequest) String() string
type ReadResponse ¶
type ReadResponse struct { RPCID uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"` TimestampMicro int64 `protobuf:"varint,2,opt,name=TimestampMicro" json:"TimestampMicro,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=Value,proto3" json:"Value,omitempty"` Err string `protobuf:"bytes,4,opt,name=Err" json:"Err,omitempty"` }
func (*ReadResponse) Descriptor ¶
func (*ReadResponse) Descriptor() ([]byte, []int)
func (*ReadResponse) GetErr ¶
func (m *ReadResponse) GetErr() string
func (*ReadResponse) GetRPCID ¶
func (m *ReadResponse) GetRPCID() uint32
func (*ReadResponse) GetTimestampMicro ¶
func (m *ReadResponse) GetTimestampMicro() int64
func (*ReadResponse) GetValue ¶
func (m *ReadResponse) GetValue() []byte
func (*ReadResponse) ProtoMessage ¶
func (*ReadResponse) ProtoMessage()
func (*ReadResponse) Reset ¶
func (m *ReadResponse) Reset()
func (*ReadResponse) String ¶
func (m *ReadResponse) String() string
type WriteRequest ¶
type WriteRequest struct { RPCID uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"` KeyA uint64 `protobuf:"varint,2,opt,name=KeyA" json:"KeyA,omitempty"` KeyB uint64 `protobuf:"varint,3,opt,name=KeyB" json:"KeyB,omitempty"` ChildKeyA uint64 `protobuf:"varint,4,opt,name=ChildKeyA" json:"ChildKeyA,omitempty"` ChildKeyB uint64 `protobuf:"varint,5,opt,name=ChildKeyB" json:"ChildKeyB,omitempty"` Value []byte `protobuf:"bytes,6,opt,name=Value,proto3" json:"Value,omitempty"` TimestampMicro int64 `protobuf:"varint,7,opt,name=TimestampMicro" json:"TimestampMicro,omitempty"` }
func (*WriteRequest) Descriptor ¶
func (*WriteRequest) Descriptor() ([]byte, []int)
func (*WriteRequest) GetChildKeyA ¶
func (m *WriteRequest) GetChildKeyA() uint64
func (*WriteRequest) GetChildKeyB ¶
func (m *WriteRequest) GetChildKeyB() uint64
func (*WriteRequest) GetKeyA ¶
func (m *WriteRequest) GetKeyA() uint64
func (*WriteRequest) GetKeyB ¶
func (m *WriteRequest) GetKeyB() uint64
func (*WriteRequest) GetRPCID ¶
func (m *WriteRequest) GetRPCID() uint32
func (*WriteRequest) GetTimestampMicro ¶
func (m *WriteRequest) GetTimestampMicro() int64
func (*WriteRequest) GetValue ¶
func (m *WriteRequest) GetValue() []byte
func (*WriteRequest) ProtoMessage ¶
func (*WriteRequest) ProtoMessage()
func (*WriteRequest) Reset ¶
func (m *WriteRequest) Reset()
func (*WriteRequest) String ¶
func (m *WriteRequest) String() string
type WriteResponse ¶
type WriteResponse struct { RPCID uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"` TimestampMicro int64 `protobuf:"varint,2,opt,name=TimestampMicro" json:"TimestampMicro,omitempty"` Err string `protobuf:"bytes,3,opt,name=Err" json:"Err,omitempty"` }
func (*WriteResponse) Descriptor ¶
func (*WriteResponse) Descriptor() ([]byte, []int)
func (*WriteResponse) GetErr ¶
func (m *WriteResponse) GetErr() string
func (*WriteResponse) GetRPCID ¶
func (m *WriteResponse) GetRPCID() uint32
func (*WriteResponse) GetTimestampMicro ¶
func (m *WriteResponse) GetTimestampMicro() int64
func (*WriteResponse) ProtoMessage ¶
func (*WriteResponse) ProtoMessage()
func (*WriteResponse) Reset ¶
func (m *WriteResponse) Reset()
func (*WriteResponse) String ¶
func (m *WriteResponse) String() string
Click to show internal directories.
Click to hide internal directories.