Versions in this module Expand all Collapse all v0 v0.0.3 Jun 29, 2020 Changes in this version + const KVGetService + const KVHandshakeService + const KVPutService + const SerializerHandshakeService + const SerializerMarshalService + var File_example_proto protoreflect.FileDescriptor + func RunKV(impl KV) error + func RunSerializer(impl Serializer) error type KV + func LoadKV(s string) (KV, error) + func TestKV(impl KV) (KV, error) + type MarshalRequest struct + Data map[string]*any.Any + func (*MarshalRequest) Descriptor() ([]byte, []int) + func (*MarshalRequest) ProtoMessage() + func (x *MarshalRequest) GetData() map[string]*any.Any + func (x *MarshalRequest) ProtoReflect() protoreflect.Message + func (x *MarshalRequest) Reset() + func (x *MarshalRequest) String() string + type MarshalResponse struct + Data []byte + func (*MarshalResponse) Descriptor() ([]byte, []int) + func (*MarshalResponse) ProtoMessage() + func (x *MarshalResponse) GetData() []byte + func (x *MarshalResponse) ProtoReflect() protoreflect.Message + func (x *MarshalResponse) Reset() + func (x *MarshalResponse) String() string + type Serializer interface + Marshal func(data map[string]*any.Any) ([]byte, error) + func LoadSerializer(s string) (Serializer, error) + func TestSerializer(impl Serializer) (Serializer, error) v0.0.2 Jun 22, 2020 Changes in this version + func Run(impl KV) error type KV + func Test(impl KV) (KV, error) v0.0.1 Jun 20, 2020 Changes in this version + const GetService + const PutService + var File_kv_proto protoreflect.FileDescriptor + type Empty struct + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (x *Empty) ProtoReflect() protoreflect.Message + func (x *Empty) Reset() + func (x *Empty) String() string + type GetRequest struct + Key string + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (x *GetRequest) GetKey() string + func (x *GetRequest) ProtoReflect() protoreflect.Message + func (x *GetRequest) Reset() + func (x *GetRequest) String() string + type GetResponse struct + Value []byte + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (x *GetResponse) GetValue() []byte + func (x *GetResponse) ProtoReflect() protoreflect.Message + func (x *GetResponse) Reset() + func (x *GetResponse) String() string + type KV interface + Get func(key string) ([]byte, error) + Put func(key string, value []byte) error + type KVHost struct + func Load(filename string) (*KVHost, error) + func (x *KVHost) Get(key string) ([]byte, error) + func (x *KVHost) Put(key string, value []byte) error + type KVPlugin struct + Impl KV + func (x *KVPlugin) Get(req proto.Message) (proto.Message, error) + func (x *KVPlugin) Link(srv plug.Service) (proto.Message, plug.GenPluginMethod, error) + func (x *KVPlugin) Put(req proto.Message) (proto.Message, error) + type PutRequest struct + Key string + Value []byte + func (*PutRequest) Descriptor() ([]byte, []int) + func (*PutRequest) ProtoMessage() + func (x *PutRequest) GetKey() string + func (x *PutRequest) GetValue() []byte + func (x *PutRequest) ProtoReflect() protoreflect.Message + func (x *PutRequest) Reset() + func (x *PutRequest) String() string