netkvserver

Documentation

Index

• type Server
  • func Launch(listenAddr string, dsn string) (*Server, error)
  • func (s *Server) BatchDelete(ctx context.Context, keys *pbnetkv.Keys) (*pbnetkv.EmptyResponse, error)
  • func (s *Server) BatchGet(keys *pbnetkv.Keys, stream pbnetkv.NetKV_BatchGetServer) error
  • func (s *Server) BatchPrefix(req *pbnetkv.BatchPrefixRequest, stream pbnetkv.NetKV_BatchPrefixServer) error
  • func (s *Server) BatchPut(ctx context.Context, kvs *pbnetkv.KeyValues) (*pbnetkv.EmptyResponse, error)
  • func (s *Server) BatchScan(req *pbnetkv.BatchScanRequest, stream pbnetkv.NetKV_BatchScanServer) error
  • func (s *Server) Close() error
  • func (s *Server) Prefix(req *pbnetkv.PrefixRequest, stream pbnetkv.NetKV_PrefixServer) error
  • func (s *Server) Scan(req *pbnetkv.ScanRequest, stream pbnetkv.NetKV_ScanServer) error

Types

type Server

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

func Launch

func Launch(listenAddr string, dsn string) (*Server, error)

func (*Server) BatchDelete

func (s *Server) BatchDelete(ctx context.Context, keys *pbnetkv.Keys) (*pbnetkv.EmptyResponse, error)

func (*Server) BatchGet

func (s *Server) BatchGet(keys *pbnetkv.Keys, stream pbnetkv.NetKV_BatchGetServer) error

BatchGet returns only values, and assumes the same order in values as the order of the input keys.

func (*Server) BatchPrefix

func (s *Server) BatchPrefix(req *pbnetkv.BatchPrefixRequest, stream pbnetkv.NetKV_BatchPrefixServer) error

func (*Server) BatchPut

func (s *Server) BatchPut(ctx context.Context, kvs *pbnetkv.KeyValues) (*pbnetkv.EmptyResponse, error)

func (*Server) BatchScan

func (s *Server) BatchScan(req *pbnetkv.BatchScanRequest, stream pbnetkv.NetKV_BatchScanServer) error

func (*Server) Close

func (s *Server) Close() error

func (*Server) Prefix

func (s *Server) Prefix(req *pbnetkv.PrefixRequest, stream pbnetkv.NetKV_PrefixServer) error

func (*Server) Scan

func (s *Server) Scan(req *pbnetkv.ScanRequest, stream pbnetkv.NetKV_ScanServer) error