server

package
v1.0.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BitsetServer 

type BitsetServer struct {
	pb.UnimplementedSDBServer
}

func (*BitsetServer) BSCount 

func (server *BitsetServer) BSCount(_ context.Context, request *pb.BSCountRequest) (*pb.BSCountResponse, error)

func (*BitsetServer) BSCountRange 

func (server *BitsetServer) BSCountRange(_ context.Context, request *pb.BSCountRangeRequest) (*pb.BSCountRangeResponse, error)

func (*BitsetServer) BSCreate 

func (server *BitsetServer) BSCreate(_ context.Context, request *pb.BSCreateRequest) (*pb.BSCreateResponse, error)

func (*BitsetServer) BSDel 

func (server *BitsetServer) BSDel(_ context.Context, request *pb.BSDelRequest) (*pb.BSDelResponse, error)

func (*BitsetServer) BSGetRange 

func (server *BitsetServer) BSGetRange(_ context.Context, request *pb.BSGetRangeRequest) (*pb.BSGetRangeResponse, error)

func (*BitsetServer) BSMGet 

func (server *BitsetServer) BSMGet(_ context.Context, request *pb.BSMGetRequest) (*pb.BSMGetResponse, error)

func (*BitsetServer) BSMSet 

func (server *BitsetServer) BSMSet(_ context.Context, request *pb.BSMSetRequest) (*pb.BSMSetResponse, error)

func (*BitsetServer) BSSetRange 

func (server *BitsetServer) BSSetRange(_ context.Context, request *pb.BSSetRangeRequest) (*pb.BSSetRangeResponse, error)

type BloomFilterServer 

type BloomFilterServer struct {
	pb.UnimplementedSDBServer
}

func (*BloomFilterServer) BFAdd 

func (server *BloomFilterServer) BFAdd(_ context.Context, request *pb.BFAddRequest) (*pb.BFAddResponse, error)

func (*BloomFilterServer) BFCreate 

func (server *BloomFilterServer) BFCreate(_ context.Context, request *pb.BFCreateRequest) (*pb.BFCreateResponse, error)

func (*BloomFilterServer) BFDel 

func (server *BloomFilterServer) BFDel(_ context.Context, request *pb.BFDelRequest) (*pb.BFDelResponse, error)

func (*BloomFilterServer) BFExist 

func (server *BloomFilterServer) BFExist(_ context.Context, request *pb.BFExistRequest) (*pb.BFExistResponse, error)

type GeoHashServer 

type GeoHashServer struct {
	pb.UnimplementedSDBServer
}

func (*GeoHashServer) GHAdd 

func (server *GeoHashServer) GHAdd(_ context.Context, request *pb.GHAddRequest) (*pb.GHAddResponse, error)

func (*GeoHashServer) GHCount 

func (server *GeoHashServer) GHCount(_ context.Context, request *pb.GHCountRequest) (*pb.GHCountResponse, error)

func (*GeoHashServer) GHCreate 

func (server *GeoHashServer) GHCreate(_ context.Context, request *pb.GHCreateRequest) (*pb.GHCreateResponse, error)

func (*GeoHashServer) GHDel 

func (server *GeoHashServer) GHDel(_ context.Context, request *pb.GHDelRequest) (*pb.GHDelResponse, error)

func (*GeoHashServer) GHGetBoxes 

func (server *GeoHashServer) GHGetBoxes(_ context.Context, request *pb.GHGetBoxesRequest) (*pb.GHGetBoxesResponse, error)

func (*GeoHashServer) GHGetNeighbors 

func (server *GeoHashServer) GHGetNeighbors(_ context.Context, request *pb.GHGetNeighborsRequest) (*pb.GHGetNeighborsResponse, error)

func (*GeoHashServer) GHMembers 

func (server *GeoHashServer) GHMembers(_ context.Context, request *pb.GHMembersRequest) (*pb.GHMembersResponse, error)

func (*GeoHashServer) GHPop 

func (server *GeoHashServer) GHPop(_ context.Context, request *pb.GHPopRequest) (*pb.GHPopResponse, error)

type HttpServer 

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

func NewHttpServer 

func NewHttpServer() *HttpServer

func (*HttpServer) ServeHTTP 

func (httpServer *HttpServer) ServeHTTP(writer http.ResponseWriter, request *http.Request)

func (*HttpServer) Start 

func (httpServer *HttpServer) Start()

type HyperLogLogServer 

type HyperLogLogServer struct {
	pb.UnimplementedSDBServer
}

func (*HyperLogLogServer) HLLAdd 

func (server *HyperLogLogServer) HLLAdd(_ context.Context, request *pb.HLLAddRequest) (*pb.HLLAddResponse, error)

func (*HyperLogLogServer) HLLCount 

func (server *HyperLogLogServer) HLLCount(_ context.Context, request *pb.HLLCountRequest) (*pb.HLLCountResponse, error)

func (*HyperLogLogServer) HLLCreate 

func (server *HyperLogLogServer) HLLCreate(_ context.Context, request *pb.HLLCreateRequest) (*pb.HLLCreateResponse, error)

func (*HyperLogLogServer) HLLDel 

func (server *HyperLogLogServer) HLLDel(_ context.Context, request *pb.HLLDelRequest) (*pb.HLLDelResponse, error)

type ListServer 

type ListServer struct {
	pb.UnimplementedSDBServer
}

func (*ListServer) LCount 

func (server *ListServer) LCount(_ context.Context, request *pb.LCountRequest) (*pb.LCountResponse, error)

func (*ListServer) LDel 

func (server *ListServer) LDel(_ context.Context, request *pb.LDelRequest) (*pb.LDelResponse, error)

func (*ListServer) LExist 

func (server *ListServer) LExist(_ context.Context, request *pb.LExistRequest) (*pb.LExistResponse, error)

func (*ListServer) LLPush 

func (server *ListServer) LLPush(_ context.Context, request *pb.LLPushRequest) (*pb.LLPushResponse, error)

func (*ListServer) LMembers 

func (server *ListServer) LMembers(_ context.Context, request *pb.LMembersRequest) (*pb.LMembersResponse, error)

func (*ListServer) LPop 

func (server *ListServer) LPop(_ context.Context, request *pb.LPopRequest) (*pb.LPopResponse, error)

func (*ListServer) LRPush 

func (server *ListServer) LRPush(_ context.Context, request *pb.LRPushRequest) (*pb.LRPushResponse, error)

func (*ListServer) LRange 

func (server *ListServer) LRange(_ context.Context, request *pb.LRangeRequest) (*pb.LRangeResponse, error)

type MapServer 

type MapServer struct {
	pb.UnimplementedSDBServer
}

func (*MapServer) MCount 

func (server *MapServer) MCount(_ context.Context, request *pb.MCountRequest) (*pb.MCountResponse, error)

func (*MapServer) MDel 

func (server *MapServer) MDel(_ context.Context, request *pb.MDelRequest) (*pb.MDelResponse, error)

func (*MapServer) MExist 

func (server *MapServer) MExist(_ context.Context, request *pb.MExistRequest) (*pb.MExistResponse, error)

func (*MapServer) MMembers 

func (server *MapServer) MMembers(_ context.Context, request *pb.MMembersRequest) (*pb.MMembersResponse, error)

func (*MapServer) MPop 

func (server *MapServer) MPop(_ context.Context, request *pb.MPopRequest) (*pb.MPopResponse, error)

func (*MapServer) MPush 

func (server *MapServer) MPush(_ context.Context, request *pb.MPushRequest) (*pb.MPushResponse, error)

type PageServer 

type PageServer struct {
	pb.UnimplementedSDBServer
}

func (*PageServer) PList 

func (server *PageServer) PList(_ context.Context, request *pb.PListRequest) (*pb.PListResponse, error)

type PubSubServer 

type PubSubServer struct {
	pb.UnimplementedSDBServer
}

func (*PubSubServer) Publish 

func (server *PubSubServer) Publish(_ context.Context, request *pb.PublishRequest) (*pb.PublishResponse, error)

func (*PubSubServer) Subscribe 

func (server *PubSubServer) Subscribe(request *pb.SubscribeRequest, subscribeServer pb.SDB_SubscribeServer) error

type RateLimit 

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

func CreateRateLimit 

func CreateRateLimit(rate int) *RateLimit

func (*RateLimit) Limit 

func (rateLimit *RateLimit) Limit() bool

type SDBGrpcServer 

type SDBGrpcServer struct {
	StringServer
	ListServer
	SetServer
	SortedSetServer
	BloomFilterServer
	HyperLogLogServer
	BitsetServer
	MapServer
	GeoHashServer
	PageServer
	PubSubServer
	// contains filtered or unexported fields
}

func NewSDBGrpcServer 

func NewSDBGrpcServer() *SDBGrpcServer

func (*SDBGrpcServer) Start 

func (sdbGrpcServer *SDBGrpcServer) Start()

type SetServer 

type SetServer struct {
	pb.UnimplementedSDBServer
}

func (*SetServer) SCount 

func (server *SetServer) SCount(_ context.Context, request *pb.SCountRequest) (*pb.SCountResponse, error)

func (*SetServer) SDel 

func (server *SetServer) SDel(_ context.Context, request *pb.SDelRequest) (*pb.SDelResponse, error)

func (*SetServer) SExist 

func (server *SetServer) SExist(_ context.Context, request *pb.SExistRequest) (*pb.SExistResponse, error)

func (*SetServer) SMembers 

func (server *SetServer) SMembers(_ context.Context, request *pb.SMembersRequest) (*pb.SMembersResponse, error)

func (*SetServer) SPop 

func (server *SetServer) SPop(_ context.Context, request *pb.SPopRequest) (*pb.SPopResponse, error)

func (*SetServer) SPush 

func (server *SetServer) SPush(_ context.Context, request *pb.SPushRequest) (*pb.SPushResponse, error)

func (*SetServer) ZCount 

func (server *SetServer) ZCount(_ context.Context, request *pb.ZCountRequest) (*pb.ZCountResponse, error)

func (*SetServer) ZMembers 

func (server *SetServer) ZMembers(_ context.Context, request *pb.ZMembersRequest) (*pb.ZMembersResponse, error)

type SortedSetServer 

type SortedSetServer struct {
	pb.UnimplementedSDBServer
}

func (*SortedSetServer) ZDel 

func (server *SortedSetServer) ZDel(_ context.Context, request *pb.ZDelRequest) (*pb.ZDelResponse, error)

func (*SortedSetServer) ZExist 

func (server *SortedSetServer) ZExist(_ context.Context, request *pb.ZExistRequest) (*pb.ZExistResponse, error)

func (*SortedSetServer) ZPop 

func (server *SortedSetServer) ZPop(_ context.Context, request *pb.ZPopRequest) (*pb.ZPopResponse, error)

func (*SortedSetServer) ZPush 

func (server *SortedSetServer) ZPush(_ context.Context, request *pb.ZPushRequest) (*pb.ZPushResponse, error)

func (*SortedSetServer) ZRange 

func (server *SortedSetServer) ZRange(_ context.Context, request *pb.ZRangeRequest) (*pb.ZRangeResponse, error)

type StringServer 

type StringServer struct {
	pb.UnimplementedSDBServer
}

func (*StringServer) Del 

func (server *StringServer) Del(_ context.Context, request *pb.DelRequest) (*pb.DelResponse, error)

func (*StringServer) Get 

func (server *StringServer) Get(_ context.Context, request *pb.GetRequest) (*pb.GetResponse, error)

func (*StringServer) Incr 

func (server *StringServer) Incr(_ context.Context, request *pb.IncrRequest) (*pb.IncrResponse, error)

func (*StringServer) MGet 

func (server *StringServer) MGet(_ context.Context, request *pb.MGetRequest) (*pb.MGetResponse, error)

func (*StringServer) MSet 

func (server *StringServer) MSet(_ context.Context, request *pb.MSetRequest) (*pb.MSetResponse, error)

func (*StringServer) Set 

func (server *StringServer) Set(_ context.Context, request *pb.SetRequest) (*pb.SetResponse, error)

func (*StringServer) SetNX 

func (server *StringServer) SetNX(_ context.Context, request *pb.SetNXRequest) (*pb.SetNXResponse, 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.