dsrpc

package module
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Aug 2, 2021 License: MIT Imports: 13 Imported by: 2

README

go-ds-rpc

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrCode_name = map[int32]string{
		0:   "None",
		1:   "ErrNotFound",
		100: "Others",
	}
	ErrCode_value = map[string]int32{
		"None":        0,
		"ErrNotFound": 1,
		"Others":      100,
	}
)

Enum value maps for ErrCode.

View Source 
var File_store_proto protoreflect.FileDescriptor
View Source 
var KVStore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dsrpc.KVStore",
	HandlerType: (*KVStoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Put",
			Handler:    _KVStore_Put_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _KVStore_Delete_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _KVStore_Get_Handler,
		},
		{
			MethodName: "Has",
			Handler:    _KVStore_Has_Handler,
		},
		{
			MethodName: "GetSize",
			Handler:    _KVStore_GetSize_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Query",
			Handler:       _KVStore_Query_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "store.proto",
}

KVStore_ServiceDesc is the grpc.ServiceDesc for KVStore service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterKVStoreServer 

func RegisterKVStoreServer(s grpc.ServiceRegistrar, srv KVStoreServer)

Types

type CommonReply 

type CommonReply struct {
	Code    ErrCode `protobuf:"varint,1,opt,name=code,proto3,enum=dsrpc.ErrCode" json:"code,omitempty"`
	Msg     string  `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Value   []byte  `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Success bool    `protobuf:"varint,4,opt,name=success,proto3" json:"success,omitempty"`
	Size    int64   `protobuf:"varint,5,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*CommonReply) Descriptor deprecated 

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

Deprecated: Use CommonReply.ProtoReflect.Descriptor instead.

func (*CommonReply) GetCode 

func (x *CommonReply) GetCode() ErrCode

func (*CommonReply) GetMsg 

func (x *CommonReply) GetMsg() string

func (*CommonReply) GetSize 

func (x *CommonReply) GetSize() int64

func (*CommonReply) GetSuccess 

func (x *CommonReply) GetSuccess() bool

func (*CommonReply) GetValue 

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

func (*CommonReply) ProtoMessage 

func (*CommonReply) ProtoMessage()

func (*CommonReply) ProtoReflect 

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

func (*CommonReply) Reset 

func (x *CommonReply) Reset()

func (*CommonReply) String 

func (x *CommonReply) String() string

type CommonRequest 

type CommonRequest 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 (*CommonRequest) Descriptor deprecated 

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

Deprecated: Use CommonRequest.ProtoReflect.Descriptor instead.

func (*CommonRequest) GetKey 

func (x *CommonRequest) GetKey() string

func (*CommonRequest) GetValue 

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

func (*CommonRequest) ProtoMessage 

func (*CommonRequest) ProtoMessage()

func (*CommonRequest) ProtoReflect 

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

func (*CommonRequest) Reset 

func (x *CommonRequest) Reset()

func (*CommonRequest) String 

func (x *CommonRequest) String() string

type DataStore 

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

func NewDataStore 

func NewDataStore(client KVStoreClient) (*DataStore, error)

func (*DataStore) Batch 

func (d *DataStore) Batch() (ds.Batch, error)

func (*DataStore) Close 

func (d *DataStore) Close() error

func (*DataStore) Delete 

func (d *DataStore) Delete(k ds.Key) error

func (*DataStore) Get 

func (d *DataStore) Get(k ds.Key) ([]byte, error)

func (*DataStore) GetSize 

func (d *DataStore) GetSize(k ds.Key) (int, error)

func (*DataStore) Has 

func (d *DataStore) Has(k ds.Key) (bool, error)

func (*DataStore) Put 

func (d *DataStore) Put(k ds.Key, value []byte) error

func (*DataStore) Query 

func (d *DataStore) Query(q dsq.Query) (dsq.Results, error)

func (*DataStore) Sync 

func (d *DataStore) Sync(ds.Key) error

type ErrCode 

type ErrCode int32
const (
	ErrCode_None        ErrCode = 0
	ErrCode_ErrNotFound ErrCode = 1
	ErrCode_Others      ErrCode = 100
)

func (ErrCode) Descriptor 

func (ErrCode) Descriptor() protoreflect.EnumDescriptor

func (ErrCode) Enum 

func (x ErrCode) Enum() *ErrCode

func (ErrCode) EnumDescriptor deprecated 

func (ErrCode) EnumDescriptor() ([]byte, []int)

Deprecated: Use ErrCode.Descriptor instead.

func (ErrCode) Number 

func (x ErrCode) Number() protoreflect.EnumNumber

func (ErrCode) String 

func (x ErrCode) String() string

func (ErrCode) Type 

func (ErrCode) Type() protoreflect.EnumType

type KVStoreClient 

type KVStoreClient interface {
	Put(ctx context.Context, in *CommonRequest, opts ...grpc.CallOption) (*CommonReply, error)
	Delete(ctx context.Context, in *CommonRequest, opts ...grpc.CallOption) (*CommonReply, error)
	Get(ctx context.Context, in *CommonRequest, opts ...grpc.CallOption) (*CommonReply, error)
	Has(ctx context.Context, in *CommonRequest, opts ...grpc.CallOption) (*CommonReply, error)
	GetSize(ctx context.Context, in *CommonRequest, opts ...grpc.CallOption) (*CommonReply, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (KVStore_QueryClient, error)
}

KVStoreClient is the client API for KVStore service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewKVStoreClient 

func NewKVStoreClient(cc grpc.ClientConnInterface) KVStoreClient

type KVStoreServer 

type KVStoreServer interface {
	Put(context.Context, *CommonRequest) (*CommonReply, error)
	Delete(context.Context, *CommonRequest) (*CommonReply, error)
	Get(context.Context, *CommonRequest) (*CommonReply, error)
	Has(context.Context, *CommonRequest) (*CommonReply, error)
	GetSize(context.Context, *CommonRequest) (*CommonReply, error)
	Query(*QueryRequest, KVStore_QueryServer) error
	// contains filtered or unexported methods
}

KVStoreServer is the server API for KVStore service. All implementations must embed UnimplementedKVStoreServer for forward compatibility

type KVStore_QueryClient 

type KVStore_QueryClient interface {
	Recv() (*QueryReply, error)
	grpc.ClientStream
}

type KVStore_QueryServer 

type KVStore_QueryServer interface {
	Send(*QueryReply) error
	grpc.ServerStream
}

type QueryReply 

type QueryReply struct {
	Code ErrCode `protobuf:"varint,1,opt,name=code,proto3,enum=dsrpc.ErrCode" json:"code,omitempty"`
	Msg  string  `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Res  []byte  `protobuf:"bytes,3,opt,name=res,proto3" json:"res,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryReply) Descriptor deprecated 

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

Deprecated: Use QueryReply.ProtoReflect.Descriptor instead.

func (*QueryReply) GetCode 

func (x *QueryReply) GetCode() ErrCode

func (*QueryReply) GetMsg 

func (x *QueryReply) GetMsg() string

func (*QueryReply) GetRes 

func (x *QueryReply) GetRes() []byte

func (*QueryReply) ProtoMessage 

func (*QueryReply) ProtoMessage()

func (*QueryReply) ProtoReflect 

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

func (*QueryReply) Reset 

func (x *QueryReply) Reset()

func (*QueryReply) String 

func (x *QueryReply) String() string

type QueryRequest 

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

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetQ 

func (x *QueryRequest) GetQ() []byte

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

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

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type UnimplementedKVStoreServer 

type UnimplementedKVStoreServer struct {
}

UnimplementedKVStoreServer must be embedded to have forward compatible implementations.

func (UnimplementedKVStoreServer) Delete 

func (UnimplementedKVStoreServer) Delete(context.Context, *CommonRequest) (*CommonReply, error)

func (UnimplementedKVStoreServer) Get 

func (UnimplementedKVStoreServer) Get(context.Context, *CommonRequest) (*CommonReply, error)

func (UnimplementedKVStoreServer) GetSize 

func (UnimplementedKVStoreServer) GetSize(context.Context, *CommonRequest) (*CommonReply, error)

func (UnimplementedKVStoreServer) Has 

func (UnimplementedKVStoreServer) Has(context.Context, *CommonRequest) (*CommonReply, error)

func (UnimplementedKVStoreServer) Put 

func (UnimplementedKVStoreServer) Put(context.Context, *CommonRequest) (*CommonReply, error)

func (UnimplementedKVStoreServer) Query 

func (UnimplementedKVStoreServer) Query(*QueryRequest, KVStore_QueryServer) error

type UnsafeKVStoreServer 

type UnsafeKVStoreServer interface {
	// contains filtered or unexported methods
}

UnsafeKVStoreServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KVStoreServer will result in compilation errors.

Source Files

View all Source files

Directories

Path Synopsis
cmd
mongods
plugins
mongods

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.