service

package
v1.5.0 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2022 License: BSD-2-Clause Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BitsetExistError = errors.New("bitset exist, please delete it or change other")
View Source 
var BitsetRangeError = errors.New("bitset out of range, please check it")
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 NotFoundBitsetError = errors.New("not found bitset, please create it")
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 BSCreate 

func BSCreate(key []byte, size 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 

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

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.