example

package
v0.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 29, 2020 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	KVGetService       runtime.Service = 0x0000
	KVPutService       runtime.Service = 0x0001
	KVHandshakeService runtime.Service = 0x00FF
)
View Source 
const (
	SerializerMarshalService   runtime.Service = 0x0100
	SerializerHandshakeService runtime.Service = 0x01FF
)

Variables

View Source 
var File_example_proto protoreflect.FileDescriptor

Functions

func RunKV added in v0.0.3 

func RunKV(impl KV) error

func RunSerializer added in v0.0.3 

func RunSerializer(impl Serializer) error

Types

type Empty 

type Empty struct {
	// contains filtered or unexported fields
}

func (*Empty) Descriptor deprecated 

func (*Empty) Descriptor() ([]byte, []int)

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type GetRequest 

type GetRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated 

func (*GetRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetKey 

func (x *GetRequest) GetKey() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

func (*GetResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetValue 

func (x *GetResponse) GetValue() []byte

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

func (x *GetResponse) ProtoReflect() protoreflect.Message

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

type KV 

type KV interface {
	Get(key string) ([]byte, error)
	Put(key string, value []byte) error
}

func LoadKV added in v0.0.3 

func LoadKV(s string) (KV, error)

func TestKV added in v0.0.3 

func TestKV(impl KV) (KV, error)

type MarshalRequest added in v0.0.3 

type MarshalRequest struct {
	Data map[string]*any.Any `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MarshalRequest) Descriptor deprecated added in v0.0.3 

func (*MarshalRequest) Descriptor() ([]byte, []int)

Deprecated: Use MarshalRequest.ProtoReflect.Descriptor instead.

func (*MarshalRequest) GetData added in v0.0.3 

func (x *MarshalRequest) GetData() map[string]*any.Any

func (*MarshalRequest) ProtoMessage added in v0.0.3 

func (*MarshalRequest) ProtoMessage()

func (*MarshalRequest) ProtoReflect added in v0.0.3 

func (x *MarshalRequest) ProtoReflect() protoreflect.Message

func (*MarshalRequest) Reset added in v0.0.3 

func (x *MarshalRequest) Reset()

func (*MarshalRequest) String added in v0.0.3 

func (x *MarshalRequest) String() string

type MarshalResponse added in v0.0.3 

type MarshalResponse struct {
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*MarshalResponse) Descriptor deprecated added in v0.0.3 

func (*MarshalResponse) Descriptor() ([]byte, []int)

Deprecated: Use MarshalResponse.ProtoReflect.Descriptor instead.

func (*MarshalResponse) GetData added in v0.0.3 

func (x *MarshalResponse) GetData() []byte

func (*MarshalResponse) ProtoMessage added in v0.0.3 

func (*MarshalResponse) ProtoMessage()

func (*MarshalResponse) ProtoReflect added in v0.0.3 

func (x *MarshalResponse) ProtoReflect() protoreflect.Message

func (*MarshalResponse) Reset added in v0.0.3 

func (x *MarshalResponse) Reset()

func (*MarshalResponse) String added in v0.0.3 

func (x *MarshalResponse) String() string

type PutRequest 

type PutRequest struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRequest) Descriptor deprecated 

func (*PutRequest) Descriptor() ([]byte, []int)

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetKey 

func (x *PutRequest) GetKey() string

func (*PutRequest) GetValue 

func (x *PutRequest) GetValue() []byte

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect 

func (x *PutRequest) ProtoReflect() protoreflect.Message

func (*PutRequest) Reset 

func (x *PutRequest) Reset()

func (*PutRequest) String 

func (x *PutRequest) String() string

type Serializer added in v0.0.3 

type Serializer interface {
	Marshal(data map[string]*any.Any) ([]byte, error)
}

func LoadSerializer added in v0.0.3 

func LoadSerializer(s string) (Serializer, error)

func TestSerializer added in v0.0.3 

func TestSerializer(impl Serializer) (Serializer, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.