Documentation ¶
Overview ¶
Package kv is a generated protocol buffer package.
It is generated from these files:
github.com/eliquious/sandbox/kv/kv-proto/kv.proto
It has these top-level messages:
Key Value KVPair
Index ¶
- Variables
- func RegisterKeyValueServiceServer(s *grpc.Server, srv KeyValueServiceServer)
- type KVPair
- func (*KVPair) Descriptor() ([]byte, []int)
- func (this *KVPair) Equal(that interface{}) bool
- func (m *KVPair) Marshal() (data []byte, err error)
- func (m *KVPair) MarshalTo(data []byte) (int, error)
- func (*KVPair) ProtoMessage()
- func (m *KVPair) Reset()
- func (m *KVPair) Size() (n int)
- func (this *KVPair) String() string
- func (m *KVPair) Unmarshal(data []byte) error
- func (this *KVPair) VerboseEqual(that interface{}) error
- type Key
- func (*Key) Descriptor() ([]byte, []int)
- func (this *Key) Equal(that interface{}) bool
- func (m *Key) Marshal() (data []byte, err error)
- func (m *Key) MarshalTo(data []byte) (int, error)
- func (*Key) ProtoMessage()
- func (m *Key) Reset()
- func (m *Key) Size() (n int)
- func (this *Key) String() string
- func (m *Key) Unmarshal(data []byte) error
- func (this *Key) VerboseEqual(that interface{}) error
- type KeyValueServiceClient
- type KeyValueServiceServer
- type KeyValueService_GetStreamClient
- type KeyValueService_GetStreamServer
- type KeyValueService_SetStreamClient
- type KeyValueService_SetStreamServer
- type Value
- func (*Value) Descriptor() ([]byte, []int)
- func (this *Value) Equal(that interface{}) bool
- func (m *Value) Marshal() (data []byte, err error)
- func (m *Value) MarshalTo(data []byte) (int, error)
- func (*Value) ProtoMessage()
- func (m *Value) Reset()
- func (m *Value) Size() (n int)
- func (this *Value) String() string
- func (m *Value) Unmarshal(data []byte) error
- func (this *Value) VerboseEqual(that interface{}) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthKv = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowKv = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterKeyValueServiceServer ¶
func RegisterKeyValueServiceServer(s *grpc.Server, srv KeyValueServiceServer)
Types ¶
type KVPair ¶
type KVPair struct { Key []byte `protobuf:"bytes,1,opt,name=Key,json=key,proto3" json:"Key,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=Value,json=value,proto3" json:"Value,omitempty"` }
func NewPopulatedKVPair ¶
func (*KVPair) Descriptor ¶
func (*KVPair) ProtoMessage ¶
func (*KVPair) ProtoMessage()
func (*KVPair) VerboseEqual ¶
type Key ¶
type Key struct {
Data []byte `protobuf:"bytes,1,opt,name=Data,json=data,proto3" json:"Data,omitempty"`
}
func NewPopulatedKey ¶
func (*Key) Descriptor ¶
func (*Key) ProtoMessage ¶
func (*Key) ProtoMessage()
func (*Key) VerboseEqual ¶
type KeyValueServiceClient ¶
type KeyValueServiceClient interface { Get(ctx context.Context, in *Key, opts ...grpc.CallOption) (*Value, error) GetStream(ctx context.Context, opts ...grpc.CallOption) (KeyValueService_GetStreamClient, error) Set(ctx context.Context, in *KVPair, opts ...grpc.CallOption) (*Value, error) SetStream(ctx context.Context, opts ...grpc.CallOption) (KeyValueService_SetStreamClient, error) }
func NewKeyValueServiceClient ¶
func NewKeyValueServiceClient(cc *grpc.ClientConn) KeyValueServiceClient
type KeyValueServiceServer ¶
type Value ¶
type Value struct {
Data []byte `protobuf:"bytes,1,opt,name=Data,json=data,proto3" json:"Data,omitempty"`
}
func NewPopulatedValue ¶
func (*Value) Descriptor ¶
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()
func (*Value) VerboseEqual ¶
Click to show internal directories.
Click to hide internal directories.