service

package

v1.7.0 Latest Latest Go to latest Published: Mar 12, 2022 License: BSD-2-Clause Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/yemingfeng/sdb

Documentation ¶

Index ¶

Variables
func BFAdd(key []byte, values [][]byte) error
func BFCreate(key []byte, n uint32, p float64) error
func BFDel(key []byte) error
func BFExist(key []byte, values [][]byte) ([]bool, error)
func BSCount(key []byte) (uint32, error)
func BSCountRange(key []byte, start uint32, end uint32) (uint32, error)
func BSDel(key []byte) error
func BSGetRange(key []byte, start uint32, end uint32) ([]bool, error)
func BSMGet(key []byte, bits []uint32) ([]bool, error)
func BSMSet(key []byte, bits []uint32, value bool) error
func BSSetRange(key []byte, start uint32, end uint32, value bool) error
func CleanSubscribeServer(subscribeServer *pb.SDB_SubscribeServer)
func Del(key []byte) error
func GHAdd(key []byte, points []*pb.Point) error
func GHCount(key []byte) (uint32, error)
func GHCreate(key []byte, precision int32) error
func GHDel(key []byte) error
func GHGetBoxes(key []byte, latitude float64, longitude float64) ([]*pb.Point, error)
func GHGetNeighbors(key []byte, latitude float64, longitude float64) ([]*pb.Point, error)
func GHMembers(key []byte) ([]*pb.Point, error)
func GHPop(key []byte, ids [][]byte) error
func Get(key []byte) ([]byte, error)
func GetStopChannel(subscribeServer *pb.SDB_SubscribeServer) chan bool
func HLLAdd(key []byte, values [][]byte) error
func HLLCount(key []byte) (uint32, error)
func HLLCreate(key []byte) error
func HLLDel(key []byte) error
func Incr(key []byte, delta int32) error
func LCount(key []byte) (uint32, error)
func LDel(key []byte) error
func LExist(key []byte, values [][]byte) ([]bool, error)
func LLPush(key []byte, values [][]byte) error
func LMembers(key []byte) ([][]byte, error)
func LPop(key []byte, values [][]byte) error
func LRPush(key []byte, values [][]byte) error
func LRange(key []byte, offset int32, limit uint32) ([][]byte, error)
func MCount(key []byte) (uint32, error)
func MDel(key []byte) error
func MExist(key []byte, keys [][]byte) ([]bool, error)
func MGet(keys [][]byte) ([][]byte, error)
func MMembers(key []byte) ([]*pb.Pair, error)
func MPop(key []byte, keys [][]byte) error
func MPush(key []byte, pairs []*pb.Pair) error
func MSet(keys [][]byte, values [][]byte) error
func PAdd(dataType pb.DataType, key []byte, batch engine.Batch) error
func PDel(dataType pb.DataType, key []byte, batch engine.Batch) error
func PList(dataType pb.DataType, key []byte, offset int32, limit uint32) ([][]byte, error)
func Publish(request *pb.PublishRequest) (bool, error)
func SCount(key []byte) (uint32, error)
func SDel(key []byte) error
func SExist(key []byte, values [][]byte) ([]bool, error)
func SMembers(key []byte) ([][]byte, error)
func SPop(key []byte, values [][]byte) error
func SPush(key []byte, values [][]byte) error
func Set(key []byte, value []byte) error
func SetNX(key []byte, value []byte) error
func Subscribe(topic []byte, subscribeServer *pb.SDB_SubscribeServer) (bool, error)
func ZCount(key []byte) (uint32, error)
func ZDel(key []byte) error
func ZExist(key []byte, values [][]byte) ([]bool, error)
func ZMembers(key []byte) ([]*pb.Tuple, error)
func ZPop(key []byte, values [][]byte) error
func ZPush(key []byte, tuples []*pb.Tuple) error
func ZRange(key []byte, offset int32, limit uint32) ([]*pb.Tuple, error)
type DataType

Constants ¶

This section is empty.

Variables ¶

View Source

var BloomFilterExistError = errors.New("bloom filter exist, please delete it or change other")

View Source

var GeoHashExistError = errors.New("geo hash exist, please delete it or change other")

View Source

var GeoHashInvalidIdError = errors.New("id can not be equals to key, please change other id")

View Source

var HyperLogLogExistError = errors.New("hyper log log exist, please delete it or change other")

View Source

var NotFoundBloomFilterError = errors.New("not found bloom filter, please create it")

View Source

var NotFoundGeoHashError = errors.New("not found geo hash, please create it")

View Source

var NotFoundHyperLogLogError = errors.New("not found hyper log log, please create it")

Functions ¶

func BFAdd ¶

func BFAdd(key []byte, values [][]byte) error

func BFCreate ¶

func BFCreate(key []byte, n uint32, p float64) error

func BFDel ¶

func BFDel(key []byte) error

func BFExist ¶

func BFExist(key []byte, values [][]byte) ([]bool, error)

func BSCount ¶

func BSCount(key []byte) (uint32, error)

func BSCountRange ¶

func BSCountRange(key []byte, start uint32, end uint32) (uint32, error)

func BSDel ¶

func BSDel(key []byte) error

func BSGetRange ¶

func BSGetRange(key []byte, start uint32, end uint32) ([]bool, error)

func BSMGet ¶

func BSMGet(key []byte, bits []uint32) ([]bool, error)

func BSMSet ¶

func BSMSet(key []byte, bits []uint32, value bool) error

func BSSetRange ¶

func BSSetRange(key []byte, start uint32, end uint32, value bool) error

func CleanSubscribeServer ¶

func CleanSubscribeServer(subscribeServer *pb.SDB_SubscribeServer)

func Del ¶

func Del(key []byte) error

func GHAdd ¶

func GHAdd(key []byte, points []*pb.Point) error

func GHCount ¶

func GHCount(key []byte) (uint32, error)

func GHCreate ¶

func GHCreate(key []byte, precision int32) error

func GHDel ¶

func GHDel(key []byte) error

func GHGetBoxes ¶

func GHGetBoxes(key []byte, latitude float64, longitude float64) ([]*pb.Point, error)

func GHGetNeighbors ¶

func GHGetNeighbors(key []byte, latitude float64, longitude float64) ([]*pb.Point, error)

func GHMembers ¶

func GHMembers(key []byte) ([]*pb.Point, error)

func GHPop ¶

func GHPop(key []byte, ids [][]byte) error

func Get ¶

func Get(key []byte) ([]byte, error)

func GetStopChannel ¶

func GetStopChannel(subscribeServer *pb.SDB_SubscribeServer) chan bool

func HLLAdd ¶

func HLLAdd(key []byte, values [][]byte) error

func HLLCount ¶

func HLLCount(key []byte) (uint32, error)

func HLLCreate ¶

func HLLCreate(key []byte) error

func HLLDel ¶

func HLLDel(key []byte) error

func Incr ¶

func Incr(key []byte, delta int32) error

func LCount ¶

func LCount(key []byte) (uint32, error)

func LDel ¶

func LDel(key []byte) error

func LExist ¶

func LExist(key []byte, values [][]byte) ([]bool, error)

func LLPush ¶

func LLPush(key []byte, values [][]byte) error

func LMembers ¶

func LMembers(key []byte) ([][]byte, error)

func LPop ¶

func LPop(key []byte, values [][]byte) error

func LRPush ¶

func LRPush(key []byte, values [][]byte) error

func LRange ¶

func LRange(key []byte, offset int32, limit uint32) ([][]byte, error)

func MCount ¶

func MCount(key []byte) (uint32, error)

func MDel ¶

func MDel(key []byte) error

func MExist ¶

func MExist(key []byte, keys [][]byte) ([]bool, error)

func MGet ¶

func MGet(keys [][]byte) ([][]byte, error)

func MMembers ¶

func MMembers(key []byte) ([]*pb.Pair, error)

func MPop ¶

func MPop(key []byte, keys [][]byte) error

func MPush ¶

func MPush(key []byte, pairs []*pb.Pair) error

func MSet ¶

func MSet(keys [][]byte, values [][]byte) error

func PAdd ¶

func PAdd(dataType pb.DataType, key []byte, batch engine.Batch) error

func PDel ¶

func PDel(dataType pb.DataType, key []byte, batch engine.Batch) error

func PList ¶

func PList(dataType pb.DataType, key []byte, offset int32, limit uint32) ([][]byte, error)

func Publish ¶

func Publish(request *pb.PublishRequest) (bool, error)

func SCount ¶

func SCount(key []byte) (uint32, error)

func SDel ¶

func SDel(key []byte) error

func SExist ¶

func SExist(key []byte, values [][]byte) ([]bool, error)

func SMembers ¶

func SMembers(key []byte) ([][]byte, error)

func SPop ¶

func SPop(key []byte, values [][]byte) error

func SPush ¶

func SPush(key []byte, values [][]byte) error

func Set ¶

func Set(key []byte, value []byte) error

func SetNX ¶

func SetNX(key []byte, value []byte) error

func Subscribe(topic []byte, subscribeServer *pb.SDB_SubscribeServer) (bool, error)

func ZCount ¶

func ZCount(key []byte) (uint32, error)

func ZDel ¶

func ZDel(key []byte) error

func ZExist ¶

func ZExist(key []byte, values [][]byte) ([]bool, error)

func ZMembers ¶

func ZMembers(key []byte) ([]*pb.Tuple, error)

func ZPop ¶

func ZPop(key []byte, values [][]byte) error

func ZPush ¶

func ZPush(key []byte, tuples []*pb.Tuple) error

func ZRange ¶

func ZRange(key []byte, offset int32, limit uint32) ([]*pb.Tuple, error)

Types ¶

type DataType ¶

type DataType int8

const (
	LString      DataType = 0x0
	LList        DataType = 0x1
	LSet         DataType = 0x2
	LSortedSet   DataType = 0x3
	LBloomFilter DataType = 0x4
	LHyperLogLog DataType = 0x5
	LBitset      DataType = 0x6
	LMap         DataType = 0x7
	LGeoHash     DataType = 0x8
)

Source Files ¶

View all Source files

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

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

func BFAdd ¶

func BFCreate ¶

func BFDel ¶

func BFExist ¶

func BSCount ¶

func BSCountRange ¶

func BSDel ¶

func BSGetRange ¶

func BSMGet ¶

func BSMSet ¶

func BSSetRange ¶

func CleanSubscribeServer ¶

func Del ¶

func GHAdd ¶

func GHCount ¶

func GHCreate ¶

func GHDel ¶

func GHGetBoxes ¶

func GHGetNeighbors ¶

func GHMembers ¶

func GHPop ¶

func Get ¶

func GetStopChannel ¶

func HLLAdd ¶

func HLLCount ¶

func HLLCreate ¶

func HLLDel ¶

func Incr ¶

func LCount ¶

func LDel ¶

func LExist ¶

func LLPush ¶

func LMembers ¶

func LPop ¶

func LRPush ¶

func LRange ¶

func MCount ¶

func MDel ¶

func MExist ¶

func MGet ¶

func MMembers ¶

func MPop ¶

func MPush ¶

func MSet ¶

func PAdd ¶

func PDel ¶

func PList ¶

func Publish ¶

func SCount ¶

func SDel ¶

func SExist ¶

func SMembers ¶

func SPop ¶

func SPush ¶

func Set ¶

func SetNX ¶

func Subscribe ¶

func ZCount ¶

func ZDel ¶

func ZExist ¶

func ZMembers ¶

func ZPop ¶

func ZPush ¶

func ZRange ¶

Types ¶

type DataType ¶

Source Files ¶