kv

package
v0.0.0-...-deed90d Latest Latest
Warning

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

Go to latest
Published: Jun 15, 2016 License: Apache-2.0 Imports: 10 Imported by: 0

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

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 NewPopulatedKVPair(r randyKv, easy bool) *KVPair

func (*KVPair) Descriptor

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

func (*KVPair) Equal

func (this *KVPair) Equal(that interface{}) bool

func (*KVPair) Marshal

func (m *KVPair) Marshal() (data []byte, err error)

func (*KVPair) MarshalTo

func (m *KVPair) MarshalTo(data []byte) (int, error)

func (*KVPair) ProtoMessage

func (*KVPair) ProtoMessage()

func (*KVPair) Reset

func (m *KVPair) Reset()

func (*KVPair) Size

func (m *KVPair) Size() (n int)

func (*KVPair) String

func (this *KVPair) String() string

func (*KVPair) Unmarshal

func (m *KVPair) Unmarshal(data []byte) error

func (*KVPair) VerboseEqual

func (this *KVPair) VerboseEqual(that interface{}) error

type Key

type Key struct {
	Data []byte `protobuf:"bytes,1,opt,name=Data,json=data,proto3" json:"Data,omitempty"`
}

func NewPopulatedKey

func NewPopulatedKey(r randyKv, easy bool) *Key

func (*Key) Descriptor

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

func (*Key) Equal

func (this *Key) Equal(that interface{}) bool

func (*Key) Marshal

func (m *Key) Marshal() (data []byte, err error)

func (*Key) MarshalTo

func (m *Key) MarshalTo(data []byte) (int, error)

func (*Key) ProtoMessage

func (*Key) ProtoMessage()

func (*Key) Reset

func (m *Key) Reset()

func (*Key) Size

func (m *Key) Size() (n int)

func (*Key) String

func (this *Key) String() string

func (*Key) Unmarshal

func (m *Key) Unmarshal(data []byte) error

func (*Key) VerboseEqual

func (this *Key) VerboseEqual(that interface{}) error

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 KeyValueServiceServer interface {
	Get(context.Context, *Key) (*Value, error)
	GetStream(KeyValueService_GetStreamServer) error
	Set(context.Context, *KVPair) (*Value, error)
	SetStream(KeyValueService_SetStreamServer) error
}

type KeyValueService_GetStreamClient

type KeyValueService_GetStreamClient interface {
	Send(*Key) error
	Recv() (*Value, error)
	grpc.ClientStream
}

type KeyValueService_GetStreamServer

type KeyValueService_GetStreamServer interface {
	Send(*Value) error
	Recv() (*Key, error)
	grpc.ServerStream
}

type KeyValueService_SetStreamClient

type KeyValueService_SetStreamClient interface {
	Send(*KVPair) error
	Recv() (*Value, error)
	grpc.ClientStream
}

type KeyValueService_SetStreamServer

type KeyValueService_SetStreamServer interface {
	Send(*Value) error
	Recv() (*KVPair, error)
	grpc.ServerStream
}

type Value

type Value struct {
	Data []byte `protobuf:"bytes,1,opt,name=Data,json=data,proto3" json:"Data,omitempty"`
}

func NewPopulatedValue

func NewPopulatedValue(r randyKv, easy bool) *Value

func (*Value) Descriptor

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

func (*Value) Equal

func (this *Value) Equal(that interface{}) bool

func (*Value) Marshal

func (m *Value) Marshal() (data []byte, err error)

func (*Value) MarshalTo

func (m *Value) MarshalTo(data []byte) (int, error)

func (*Value) ProtoMessage

func (*Value) ProtoMessage()

func (*Value) Reset

func (m *Value) Reset()

func (*Value) Size

func (m *Value) Size() (n int)

func (*Value) String

func (this *Value) String() string

func (*Value) Unmarshal

func (m *Value) Unmarshal(data []byte) error

func (*Value) VerboseEqual

func (this *Value) VerboseEqual(that interface{}) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL