kv_v1

package
v0.6.2 Latest Latest
Warning

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

 Go to latest Published: Nov 25, 2020 License: BSD-3-Clause Imports: 9 Imported by: 0

Documentation

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")
	ErrUnexpectedEndOfGroupKv = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterStorageServer 

func RegisterStorageServer(s *grpc.Server, srv StorageServer)

Types

type ErrNoKey added in v0.1.4 

type ErrNoKey struct{}

ErrNoKey error

func (ErrNoKey) Error added in v0.1.4 

func (e ErrNoKey) Error() string

func (ErrNoKey) GRPCStatus added in v0.1.4 

func (e ErrNoKey) GRPCStatus() *status.Status

GRPCStatus ...

type ErrNoTable added in v0.1.4 

type ErrNoTable struct{}

ErrNoTable error

func (ErrNoTable) Error added in v0.1.4 

func (e ErrNoTable) Error() string

func (ErrNoTable) GRPCStatus added in v0.1.4 

func (e ErrNoTable) GRPCStatus() *status.Status

GRPCStatus used by go-rpc to construct error answer

type ErrNotALeader added in v0.3.3 

type ErrNotALeader struct{}

ErrNotALeader error

func (ErrNotALeader) Error added in v0.3.3 

func (e ErrNotALeader) Error() string

func (ErrNotALeader) GRPCStatus added in v0.3.3 

func (e ErrNotALeader) GRPCStatus() *status.Status

GRPCStatus used by go-rpc to construct error answer

type Server added in v0.1.3 

type Server struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Ip                   string   `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	Host                 string   `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	RpcPort              string   `protobuf:"bytes,4,opt,name=rpc_port,json=rpcPort,proto3" json:"rpc_port,omitempty"`
	RaftPort             string   `protobuf:"bytes,5,opt,name=raft_port,json=raftPort,proto3" json:"raft_port,omitempty"`
	IsLeader             bool     `protobuf:"varint,6,opt,name=is_leader,json=isLeader,proto3" json:"is_leader,omitempty"`
	Online               bool     `protobuf:"varint,7,opt,name=online,proto3" json:"online,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Server) Descriptor added in v0.1.3 

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

func (*Server) GetHost added in v0.3.0 

func (m *Server) GetHost() string

func (*Server) GetId added in v0.1.3 

func (m *Server) GetId() string

func (*Server) GetIp added in v0.3.0 

func (m *Server) GetIp() string

func (*Server) GetIsLeader added in v0.1.3 

func (m *Server) GetIsLeader() bool

func (*Server) GetOnline added in v0.1.3 

func (m *Server) GetOnline() bool

func (*Server) GetRaftPort added in v0.3.0 

func (m *Server) GetRaftPort() string

func (*Server) GetRpcPort added in v0.3.0 

func (m *Server) GetRpcPort() string

func (*Server) Marshal added in v0.1.3 

func (m *Server) Marshal() (dAtA []byte, err error)

func (*Server) MarshalTo added in v0.1.3 

func (m *Server) MarshalTo(dAtA []byte) (int, error)

func (*Server) MarshalToSizedBuffer added in v0.1.3 

func (m *Server) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Server) ProtoMessage added in v0.1.3 

func (*Server) ProtoMessage()

func (*Server) Reset added in v0.1.3 

func (m *Server) Reset()

func (*Server) Size added in v0.1.3 

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

func (*Server) String added in v0.1.3 

func (m *Server) String() string

func (*Server) Unmarshal added in v0.1.3 

func (m *Server) Unmarshal(dAtA []byte) error

func (*Server) XXX_DiscardUnknown added in v0.1.3 

func (m *Server) XXX_DiscardUnknown()

func (*Server) XXX_Marshal added in v0.1.3 

func (m *Server) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Server) XXX_Merge added in v0.1.3 

func (m *Server) XXX_Merge(src proto.Message)

func (*Server) XXX_Size added in v0.1.3 

func (m *Server) XXX_Size() int

func (*Server) XXX_Unmarshal added in v0.1.3 

func (m *Server) XXX_Unmarshal(b []byte) error

type ServersArgs added in v0.1.3 

type ServersArgs struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServersArgs) Descriptor added in v0.1.3 

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

func (*ServersArgs) Marshal added in v0.1.3 

func (m *ServersArgs) Marshal() (dAtA []byte, err error)

func (*ServersArgs) MarshalTo added in v0.1.3 

func (m *ServersArgs) MarshalTo(dAtA []byte) (int, error)

func (*ServersArgs) MarshalToSizedBuffer added in v0.1.3 

func (m *ServersArgs) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServersArgs) ProtoMessage added in v0.1.3 

func (*ServersArgs) ProtoMessage()

func (*ServersArgs) Reset added in v0.1.3 

func (m *ServersArgs) Reset()

func (*ServersArgs) Size added in v0.1.3 

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

func (*ServersArgs) String added in v0.1.3 

func (m *ServersArgs) String() string

func (*ServersArgs) Unmarshal added in v0.1.3 

func (m *ServersArgs) Unmarshal(dAtA []byte) error

func (*ServersArgs) XXX_DiscardUnknown added in v0.1.3 

func (m *ServersArgs) XXX_DiscardUnknown()

func (*ServersArgs) XXX_Marshal added in v0.1.3 

func (m *ServersArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServersArgs) XXX_Merge added in v0.1.3 

func (m *ServersArgs) XXX_Merge(src proto.Message)

func (*ServersArgs) XXX_Size added in v0.1.3 

func (m *ServersArgs) XXX_Size() int

func (*ServersArgs) XXX_Unmarshal added in v0.1.3 

func (m *ServersArgs) XXX_Unmarshal(b []byte) error

type ServersReply added in v0.1.3 

type ServersReply struct {
	Servers              []*Server `protobuf:"bytes,1,rep,name=servers,proto3" json:"servers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ServersReply) Descriptor added in v0.1.3 

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

func (*ServersReply) GetServers added in v0.1.3 

func (m *ServersReply) GetServers() []*Server

func (*ServersReply) Marshal added in v0.1.3 

func (m *ServersReply) Marshal() (dAtA []byte, err error)

func (*ServersReply) MarshalTo added in v0.1.3 

func (m *ServersReply) MarshalTo(dAtA []byte) (int, error)

func (*ServersReply) MarshalToSizedBuffer added in v0.1.3 

func (m *ServersReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServersReply) ProtoMessage added in v0.1.3 

func (*ServersReply) ProtoMessage()

func (*ServersReply) Reset added in v0.1.3 

func (m *ServersReply) Reset()

func (*ServersReply) Size added in v0.1.3 

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

func (*ServersReply) String added in v0.1.3 

func (m *ServersReply) String() string

func (*ServersReply) Unmarshal added in v0.1.3 

func (m *ServersReply) Unmarshal(dAtA []byte) error

func (*ServersReply) XXX_DiscardUnknown added in v0.1.3 

func (m *ServersReply) XXX_DiscardUnknown()

func (*ServersReply) XXX_Marshal added in v0.1.3 

func (m *ServersReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServersReply) XXX_Merge added in v0.1.3 

func (m *ServersReply) XXX_Merge(src proto.Message)

func (*ServersReply) XXX_Size added in v0.1.3 

func (m *ServersReply) XXX_Size() int

func (*ServersReply) XXX_Unmarshal added in v0.1.3 

func (m *ServersReply) XXX_Unmarshal(b []byte) error

type StorageClient 

type StorageClient interface {
	Put(ctx context.Context, in *StoragePutArgs, opts ...grpc.CallOption) (*StoragePutReply, error)
	Get(ctx context.Context, in *StorageGetArgs, opts ...grpc.CallOption) (*StorageGetReply, error)
	Delete(ctx context.Context, in *StorageDeleteArgs, opts ...grpc.CallOption) (*StorageDeleteReply, error)
	Servers(ctx context.Context, in *ServersArgs, opts ...grpc.CallOption) (*ServersReply, error)
}

StorageClient is the client API for Storage service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewStorageClient 

func NewStorageClient(cc *grpc.ClientConn) StorageClient

type StorageDeleteArgs 

type StorageDeleteArgs struct {
	Tab                  []byte   `protobuf:"bytes,1,opt,name=tab,proto3" json:"tab,omitempty"`
	Key                  []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StorageDeleteArgs) Descriptor 

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

func (*StorageDeleteArgs) GetKey 

func (m *StorageDeleteArgs) GetKey() []byte

func (*StorageDeleteArgs) GetTab 

func (m *StorageDeleteArgs) GetTab() []byte

func (*StorageDeleteArgs) Marshal 

func (m *StorageDeleteArgs) Marshal() (dAtA []byte, err error)

func (*StorageDeleteArgs) MarshalTo 

func (m *StorageDeleteArgs) MarshalTo(dAtA []byte) (int, error)

func (*StorageDeleteArgs) MarshalToSizedBuffer 

func (m *StorageDeleteArgs) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StorageDeleteArgs) ProtoMessage 

func (*StorageDeleteArgs) ProtoMessage()

func (*StorageDeleteArgs) Reset 

func (m *StorageDeleteArgs) Reset()

func (*StorageDeleteArgs) Size 

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

func (*StorageDeleteArgs) String 

func (m *StorageDeleteArgs) String() string

func (*StorageDeleteArgs) Unmarshal 

func (m *StorageDeleteArgs) Unmarshal(dAtA []byte) error

func (*StorageDeleteArgs) XXX_DiscardUnknown 

func (m *StorageDeleteArgs) XXX_DiscardUnknown()

func (*StorageDeleteArgs) XXX_Marshal 

func (m *StorageDeleteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageDeleteArgs) XXX_Merge 

func (m *StorageDeleteArgs) XXX_Merge(src proto.Message)

func (*StorageDeleteArgs) XXX_Size 

func (m *StorageDeleteArgs) XXX_Size() int

func (*StorageDeleteArgs) XXX_Unmarshal 

func (m *StorageDeleteArgs) XXX_Unmarshal(b []byte) error

type StorageDeleteReply 

type StorageDeleteReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StorageDeleteReply) Descriptor 

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

func (*StorageDeleteReply) Marshal 

func (m *StorageDeleteReply) Marshal() (dAtA []byte, err error)

func (*StorageDeleteReply) MarshalTo 

func (m *StorageDeleteReply) MarshalTo(dAtA []byte) (int, error)

func (*StorageDeleteReply) MarshalToSizedBuffer 

func (m *StorageDeleteReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StorageDeleteReply) ProtoMessage 

func (*StorageDeleteReply) ProtoMessage()

func (*StorageDeleteReply) Reset 

func (m *StorageDeleteReply) Reset()

func (*StorageDeleteReply) Size 

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

func (*StorageDeleteReply) String 

func (m *StorageDeleteReply) String() string

func (*StorageDeleteReply) Unmarshal 

func (m *StorageDeleteReply) Unmarshal(dAtA []byte) error

func (*StorageDeleteReply) XXX_DiscardUnknown 

func (m *StorageDeleteReply) XXX_DiscardUnknown()

func (*StorageDeleteReply) XXX_Marshal 

func (m *StorageDeleteReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageDeleteReply) XXX_Merge 

func (m *StorageDeleteReply) XXX_Merge(src proto.Message)

func (*StorageDeleteReply) XXX_Size 

func (m *StorageDeleteReply) XXX_Size() int

func (*StorageDeleteReply) XXX_Unmarshal 

func (m *StorageDeleteReply) XXX_Unmarshal(b []byte) error

type StorageGetArgs 

type StorageGetArgs struct {
	Lvl                  int32    `protobuf:"varint,1,opt,name=lvl,proto3" json:"lvl,omitempty"`
	Tab                  []byte   `protobuf:"bytes,2,opt,name=tab,proto3" json:"tab,omitempty"`
	Key                  []byte   `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StorageGetArgs) Descriptor 

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

func (*StorageGetArgs) GetKey 

func (m *StorageGetArgs) GetKey() []byte

func (*StorageGetArgs) GetLvl added in v0.0.8 

func (m *StorageGetArgs) GetLvl() int32

func (*StorageGetArgs) GetTab 

func (m *StorageGetArgs) GetTab() []byte

func (*StorageGetArgs) Marshal 

func (m *StorageGetArgs) Marshal() (dAtA []byte, err error)

func (*StorageGetArgs) MarshalTo 

func (m *StorageGetArgs) MarshalTo(dAtA []byte) (int, error)

func (*StorageGetArgs) MarshalToSizedBuffer 

func (m *StorageGetArgs) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StorageGetArgs) ProtoMessage 

func (*StorageGetArgs) ProtoMessage()

func (*StorageGetArgs) Reset 

func (m *StorageGetArgs) Reset()

func (*StorageGetArgs) Size 

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

func (*StorageGetArgs) String 

func (m *StorageGetArgs) String() string

func (*StorageGetArgs) Unmarshal 

func (m *StorageGetArgs) Unmarshal(dAtA []byte) error

func (*StorageGetArgs) XXX_DiscardUnknown 

func (m *StorageGetArgs) XXX_DiscardUnknown()

func (*StorageGetArgs) XXX_Marshal 

func (m *StorageGetArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageGetArgs) XXX_Merge 

func (m *StorageGetArgs) XXX_Merge(src proto.Message)

func (*StorageGetArgs) XXX_Size 

func (m *StorageGetArgs) XXX_Size() int

func (*StorageGetArgs) XXX_Unmarshal 

func (m *StorageGetArgs) XXX_Unmarshal(b []byte) error

type StorageGetReply 

type StorageGetReply struct {
	Val                  []byte   `protobuf:"bytes,1,opt,name=val,proto3" json:"val,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StorageGetReply) Descriptor 

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

func (*StorageGetReply) GetVal 

func (m *StorageGetReply) GetVal() []byte

func (*StorageGetReply) Marshal 

func (m *StorageGetReply) Marshal() (dAtA []byte, err error)

func (*StorageGetReply) MarshalTo 

func (m *StorageGetReply) MarshalTo(dAtA []byte) (int, error)

func (*StorageGetReply) MarshalToSizedBuffer 

func (m *StorageGetReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StorageGetReply) ProtoMessage 

func (*StorageGetReply) ProtoMessage()

func (*StorageGetReply) Reset 

func (m *StorageGetReply) Reset()

func (*StorageGetReply) Size 

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

func (*StorageGetReply) String 

func (m *StorageGetReply) String() string

func (*StorageGetReply) Unmarshal 

func (m *StorageGetReply) Unmarshal(dAtA []byte) error

func (*StorageGetReply) XXX_DiscardUnknown 

func (m *StorageGetReply) XXX_DiscardUnknown()

func (*StorageGetReply) XXX_Marshal 

func (m *StorageGetReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageGetReply) XXX_Merge 

func (m *StorageGetReply) XXX_Merge(src proto.Message)

func (*StorageGetReply) XXX_Size 

func (m *StorageGetReply) XXX_Size() int

func (*StorageGetReply) XXX_Unmarshal 

func (m *StorageGetReply) XXX_Unmarshal(b []byte) error

type StoragePutArgs 

type StoragePutArgs struct {
	Tab                  []byte   `protobuf:"bytes,1,opt,name=tab,proto3" json:"tab,omitempty"`
	Key                  []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Val                  []byte   `protobuf:"bytes,3,opt,name=val,proto3" json:"val,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StoragePutArgs) Descriptor 

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

func (*StoragePutArgs) GetKey 

func (m *StoragePutArgs) GetKey() []byte

func (*StoragePutArgs) GetTab 

func (m *StoragePutArgs) GetTab() []byte

func (*StoragePutArgs) GetVal 

func (m *StoragePutArgs) GetVal() []byte

func (*StoragePutArgs) Marshal 

func (m *StoragePutArgs) Marshal() (dAtA []byte, err error)

func (*StoragePutArgs) MarshalTo 

func (m *StoragePutArgs) MarshalTo(dAtA []byte) (int, error)

func (*StoragePutArgs) MarshalToSizedBuffer 

func (m *StoragePutArgs) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StoragePutArgs) ProtoMessage 

func (*StoragePutArgs) ProtoMessage()

func (*StoragePutArgs) Reset 

func (m *StoragePutArgs) Reset()

func (*StoragePutArgs) Size 

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

func (*StoragePutArgs) String 

func (m *StoragePutArgs) String() string

func (*StoragePutArgs) Unmarshal 

func (m *StoragePutArgs) Unmarshal(dAtA []byte) error

func (*StoragePutArgs) XXX_DiscardUnknown 

func (m *StoragePutArgs) XXX_DiscardUnknown()

func (*StoragePutArgs) XXX_Marshal 

func (m *StoragePutArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StoragePutArgs) XXX_Merge 

func (m *StoragePutArgs) XXX_Merge(src proto.Message)

func (*StoragePutArgs) XXX_Size 

func (m *StoragePutArgs) XXX_Size() int

func (*StoragePutArgs) XXX_Unmarshal 

func (m *StoragePutArgs) XXX_Unmarshal(b []byte) error

type StoragePutReply 

type StoragePutReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StoragePutReply) Descriptor 

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

func (*StoragePutReply) Marshal 

func (m *StoragePutReply) Marshal() (dAtA []byte, err error)

func (*StoragePutReply) MarshalTo 

func (m *StoragePutReply) MarshalTo(dAtA []byte) (int, error)

func (*StoragePutReply) MarshalToSizedBuffer 

func (m *StoragePutReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StoragePutReply) ProtoMessage 

func (*StoragePutReply) ProtoMessage()

func (*StoragePutReply) Reset 

func (m *StoragePutReply) Reset()

func (*StoragePutReply) Size 

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

func (*StoragePutReply) String 

func (m *StoragePutReply) String() string

func (*StoragePutReply) Unmarshal 

func (m *StoragePutReply) Unmarshal(dAtA []byte) error

func (*StoragePutReply) XXX_DiscardUnknown 

func (m *StoragePutReply) XXX_DiscardUnknown()

func (*StoragePutReply) XXX_Marshal 

func (m *StoragePutReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StoragePutReply) XXX_Merge 

func (m *StoragePutReply) XXX_Merge(src proto.Message)

func (*StoragePutReply) XXX_Size 

func (m *StoragePutReply) XXX_Size() int

func (*StoragePutReply) XXX_Unmarshal 

func (m *StoragePutReply) XXX_Unmarshal(b []byte) error

type StorageServer 

type StorageServer interface {
	Put(context.Context, *StoragePutArgs) (*StoragePutReply, error)
	Get(context.Context, *StorageGetArgs) (*StorageGetReply, error)
	Delete(context.Context, *StorageDeleteArgs) (*StorageDeleteReply, error)
	Servers(context.Context, *ServersArgs) (*ServersReply, error)
}

StorageServer is the server API for Storage service.

type UnimplementedStorageServer 

type UnimplementedStorageServer struct {
}

UnimplementedStorageServer can be embedded to have forward compatible implementations.

func (*UnimplementedStorageServer) Delete 

func (*UnimplementedStorageServer) Delete(ctx context.Context, req *StorageDeleteArgs) (*StorageDeleteReply, error)

func (*UnimplementedStorageServer) Get 

func (*UnimplementedStorageServer) Get(ctx context.Context, req *StorageGetArgs) (*StorageGetReply, error)

func (*UnimplementedStorageServer) Put 

func (*UnimplementedStorageServer) Put(ctx context.Context, req *StoragePutArgs) (*StoragePutReply, error)

func (*UnimplementedStorageServer) Servers added in v0.1.3 

func (*UnimplementedStorageServer) Servers(ctx context.Context, req *ServersArgs) (*ServersReply, error)

Source Files

View all Source files

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.