server

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Mar 28, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrNotFound = errors.New("not found")

Functions

This section is empty.

Types

type Database 

type Database struct {
	ID int
	*Records
}

Database represents a database.

func NewDatabaseWithID 

func NewDatabaseWithID(id int) *Database

NewDatabaseWithID returns a new database with the specified ID.

func (*Database) GetListRecord added in v1.1.0 

func (db *Database) GetListRecord(key string) (*Record, *List, error)

func (*Database) GetSetRecord added in v1.1.0 

func (db *Database) GetSetRecord(key string) (*Record, *Set, error)

func (*Database) GetZSetRecord added in v1.1.0 

func (db *Database) GetZSetRecord(key string) (*Record, *ZSet, error)

type Databases 

type Databases struct {
	sync.Map
}

Databases represents a database map.

func NewDatabases added in v1.2.0 

func NewDatabases() *Databases

func (*Databases) GetDatabase 

func (dbs *Databases) GetDatabase(id int) (*Database, bool)

GetDatabase returns the database with the specified ID.

func (*Databases) SetDatabase added in v1.2.0 

func (dbs *Databases) SetDatabase(db *Database)

SetDatabase set a database with the specified ID.

type Hash added in v1.1.0 

type Hash map[string]string

func (Hash) Del added in v1.1.0 

func (hash Hash) Del(fields []string) int

func (Hash) Set added in v1.1.0 

func (hash Hash) Set(field string, val string, opt redis.HSetOption) int

nolint: ifshort

type List added in v1.1.0 

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

func NewList added in v1.1.0 

func NewList() *List

func (*List) Index added in v1.1.0 

func (list *List) Index(idx int) (string, bool)

func (*List) LPop added in v1.1.0 

func (list *List) LPop(count int) ([]string, bool)

func (*List) LPush added in v1.1.0 

func (list *List) LPush(elems []string) int

func (*List) Len added in v1.1.0 

func (list *List) Len() int

func (*List) RPop added in v1.1.0 

func (list *List) RPop(count int) ([]string, bool)

func (*List) RPush added in v1.1.0 

func (list *List) RPush(elems []string) int

func (*List) Range added in v1.1.0 

func (list *List) Range(start int, stop int) []string

type Record 

type Record struct {
	Key       string
	Data      any
	Timestamp time.Time
	TTL       time.Duration
}

Record represents a database record.

type Records 

type Records struct {
	sync.Map
}

Records represents a database record map.

func NewRecords added in v1.2.0 

func NewRecords() *Records

func (*Records) GetRecord 

func (rmap *Records) GetRecord(key string) (*Record, bool)

GetRecord gets a record with the specified key.

func (*Records) HasRecord added in v1.1.0 

func (rmap *Records) HasRecord(key string) bool

HasRecord returns true if the database has the specified key record, otherwise false.

func (*Records) Keys added in v1.0.0 

func (rmap *Records) Keys() []string

Keys returns all key names.

func (*Records) RemoveRecord added in v1.0.0 

func (rmap *Records) RemoveRecord(key string) error

RemoveRecord removes a record with the specified key.

func (*Records) RenameRecord added in v1.0.0 

func (rmap *Records) RenameRecord(key string, newkey string) error

RenameRecord renames the specified key record to the specified new record.

func (*Records) SetRecord 

func (rmap *Records) SetRecord(record *Record) error

SetRecord sets the specified record into the records.

type Server 

type Server struct {
	*redis.Server
	*Databases
}

Server represents an example server.

func NewServer 

func NewServer() *Server

NewServer returns an example server instance.

func (*Server) Del added in v1.0.0 

func (server *Server) Del(conn *redis.Conn, keys []string) (*redis.Message, error)

func (*Server) Exists added in v1.0.0 

func (server *Server) Exists(conn *redis.Conn, keys []string) (*redis.Message, error)

func (*Server) Expire added in v1.0.0 

func (server *Server) Expire(conn *redis.Conn, key string, opt redis.ExpireOption) (*redis.Message, error)

func (*Server) Get 

func (server *Server) Get(conn *redis.Conn, key string) (*redis.Message, error)

func (*Server) GetDatabase 

func (server *Server) GetDatabase(id int) (*Database, error)

GetDatabase returns the database with the specified ID.

func (*Server) HDel added in v1.0.0 

func (server *Server) HDel(conn *redis.Conn, key string, fields []string) (*redis.Message, error)

func (*Server) HGet added in v1.0.0 

func (server *Server) HGet(conn *redis.Conn, key string, field string) (*redis.Message, error)

func (*Server) HGetAll added in v1.0.0 

func (server *Server) HGetAll(conn *redis.Conn, key string) (*redis.Message, error)

func (*Server) HMGet added in v1.0.0 

func (server *Server) HMGet(conn *redis.Conn, key string, fields []string) (*redis.Message, error)

func (*Server) HMSet added in v1.0.0 

func (server *Server) HMSet(conn *redis.Conn, key string, dict map[string]string) (*redis.Message, error)

func (*Server) HSet added in v1.0.0 

func (server *Server) HSet(conn *redis.Conn, key string, field string, val string, opt redis.HSetOption) (*redis.Message, error)

nolint: ifshort

func (*Server) Keys added in v1.0.0 

func (server *Server) Keys(conn *redis.Conn, pattern string) (*redis.Message, error)

func (*Server) LIndex added in v1.1.0 

func (server *Server) LIndex(conn *redis.Conn, key string, idx int) (*redis.Message, error)

func (*Server) LLen added in v1.1.0 

func (server *Server) LLen(conn *redis.Conn, key string) (*redis.Message, error)

func (*Server) LPop added in v1.1.0 

func (server *Server) LPop(conn *redis.Conn, key string, count int) (*redis.Message, error)

func (*Server) LPush added in v1.1.0 

func (server *Server) LPush(conn *redis.Conn, key string, elems []string, opt redis.PushOption) (*redis.Message, error)

func (*Server) LRange added in v1.1.0 

func (server *Server) LRange(conn *redis.Conn, key string, start int, stop int) (*redis.Message, error)

func (*Server) MGet added in v1.0.0 

func (server *Server) MGet(conn *redis.Conn, keys []string) (*redis.Message, error)

func (*Server) MSet added in v1.0.0 

func (server *Server) MSet(conn *redis.Conn, dict map[string]string, opt redis.MSetOption) (*redis.Message, error)

func (*Server) RPop added in v1.1.0 

func (server *Server) RPop(conn *redis.Conn, key string, count int) (*redis.Message, error)

func (*Server) RPush added in v1.1.0 

func (server *Server) RPush(conn *redis.Conn, key string, elems []string, opt redis.PushOption) (*redis.Message, error)

func (*Server) Rename added in v1.0.0 

func (server *Server) Rename(conn *redis.Conn, key string, newkey string, opt redis.RenameOption) (*redis.Message, error)

func (*Server) SAdd added in v1.1.0 

func (server *Server) SAdd(conn *redis.Conn, key string, members []string) (*redis.Message, error)

func (*Server) SMembers added in v1.1.0 

func (server *Server) SMembers(conn *redis.Conn, key string) (*redis.Message, error)

func (*Server) SRem added in v1.1.0 

func (server *Server) SRem(conn *redis.Conn, key string, members []string) (*redis.Message, error)

func (*Server) Set 

func (server *Server) Set(conn *redis.Conn, key string, val string, opt redis.SetOption) (*redis.Message, error)

func (*Server) TTL added in v1.0.0 

func (server *Server) TTL(conn *redis.Conn, key string) (*redis.Message, error)

func (*Server) Type added in v1.0.0 

func (server *Server) Type(conn *redis.Conn, key string) (*redis.Message, error)

func (*Server) ZAdd added in v1.1.0 

func (server *Server) ZAdd(conn *redis.Conn, key string, members []*redis.ZSetMember, opt redis.ZAddOption) (*redis.Message, error)

func (*Server) ZIncBy added in v1.1.0 

func (server *Server) ZIncBy(conn *redis.Conn, key string, inc float64, member string) (*redis.Message, error)

func (*Server) ZRange added in v1.1.0 

func (server *Server) ZRange(conn *redis.Conn, key string, start int, stop int, opt redis.ZRangeOption) (*redis.Message, error)

func (*Server) ZRangeByScore added in v1.1.0 

func (server *Server) ZRangeByScore(conn *redis.Conn, key string, start float64, stop float64, opt redis.ZRangeOption) (*redis.Message, error)

func (*Server) ZRem added in v1.1.0 

func (server *Server) ZRem(conn *redis.Conn, key string, members []string) (*redis.Message, error)

func (*Server) ZScore added in v1.1.0 

func (server *Server) ZScore(conn *redis.Conn, key string, member string) (*redis.Message, error)

type Set added in v1.1.0 

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

func NewSet added in v1.1.0 

func NewSet() *Set

func (*Set) Add added in v1.1.0 

func (set *Set) Add(members []string) int

func (*Set) Members added in v1.1.0 

func (set *Set) Members() []string

func (*Set) Rem added in v1.1.0 

func (set *Set) Rem(members []string) int

type ZAddOption added in v1.1.0 

type ZAddOption = redis.ZAddOption

type ZRangeOption added in v1.1.0 

type ZRangeOption = redis.ZRangeOption

type ZSet added in v1.1.0 

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

func NewZSet added in v1.1.0 

func NewZSet() *ZSet

func (*ZSet) Add added in v1.1.0 

func (zset *ZSet) Add(nms []*ZSetMember, opt ZAddOption) int

func (*ZSet) IncBy added in v1.1.0 

func (zset *ZSet) IncBy(inc float64, member string) float64

func (*ZSet) Range added in v1.1.0 

func (zset *ZSet) Range(start int, stop int, opt ZRangeOption) []*ZSetMember

func (*ZSet) RangeByScore added in v1.1.0 

func (zset *ZSet) RangeByScore(min float64, max float64, opt ZRangeOption) []*ZSetMember

func (*ZSet) Rem added in v1.1.0 

func (zset *ZSet) Rem(members []string) int

func (*ZSet) Score added in v1.1.0 

func (zset *ZSet) Score(member string) (float64, bool)

type ZSetMember added in v1.1.0 

type ZSetMember = redis.ZSetMember

func NewZSetMember added in v1.1.0 

func NewZSetMember(score float64, data string) *ZSetMember

func NewZSetMembers added in v1.1.0 

func NewZSetMembers() []*ZSetMember

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.