forked from mirror/ledisdb
158 lines
2.3 KiB
Go
158 lines
2.3 KiB
Go
package ledis
|
|
|
|
import ()
|
|
|
|
func lpushCommand(c *client) error {
|
|
args := c.args
|
|
if len(args) < 2 {
|
|
return ErrCmdParams
|
|
}
|
|
|
|
if n, err := c.app.list_lpush(args[0], args[1:]); err != nil {
|
|
return err
|
|
} else {
|
|
c.writeInteger(n)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func rpushCommand(c *client) error {
|
|
args := c.args
|
|
if len(args) < 2 {
|
|
return ErrCmdParams
|
|
}
|
|
|
|
if n, err := c.app.list_rpush(args[0], args[1:]); err != nil {
|
|
return err
|
|
} else {
|
|
c.writeInteger(n)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func lpopCommand(c *client) error {
|
|
args := c.args
|
|
if len(args) != 1 {
|
|
return ErrCmdParams
|
|
}
|
|
|
|
if v, err := c.app.list_lpop(args[0]); err != nil {
|
|
return err
|
|
} else {
|
|
c.writeBulk(v)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func rpopCommand(c *client) error {
|
|
args := c.args
|
|
if len(args) != 1 {
|
|
return ErrCmdParams
|
|
}
|
|
|
|
if v, err := c.app.list_rpop(args[0]); err != nil {
|
|
return err
|
|
} else {
|
|
c.writeBulk(v)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func llenCommand(c *client) error {
|
|
args := c.args
|
|
if len(args) != 1 {
|
|
return ErrCmdParams
|
|
}
|
|
|
|
if n, err := c.app.list_len(args[0]); err != nil {
|
|
return err
|
|
} else {
|
|
c.writeInteger(n)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func lindexCommand(c *client) error {
|
|
args := c.args
|
|
if len(args) != 2 {
|
|
return ErrCmdParams
|
|
}
|
|
|
|
index, err := StrInt64(args[1], nil)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if v, err := c.app.list_index(args[0], int32(index)); err != nil {
|
|
return err
|
|
} else {
|
|
c.writeBulk(v)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func lrangeCommand(c *client) error {
|
|
args := c.args
|
|
if len(args) != 3 {
|
|
return ErrCmdParams
|
|
}
|
|
|
|
var start int64
|
|
var stop int64
|
|
var err error
|
|
|
|
start, err = StrInt64(args[1], nil)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
stop, err = StrInt64(args[2], nil)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if v, err := c.app.list_range(args[0], int32(start), int32(stop)); err != nil {
|
|
return err
|
|
} else {
|
|
c.writeArray(v)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func lclearCommand(c *client) error {
|
|
args := c.args
|
|
if len(args) != 1 {
|
|
return ErrCmdParams
|
|
}
|
|
|
|
if n, err := c.app.list_clear(args[0]); err != nil {
|
|
return err
|
|
} else {
|
|
c.writeInteger(n)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func init() {
|
|
register("lindex", lindexCommand)
|
|
register("llen", llenCommand)
|
|
register("lpop", lpopCommand)
|
|
register("lrange", lrangeCommand)
|
|
register("lpush", lpushCommand)
|
|
register("rpop", rpopCommand)
|
|
register("rpush", rpushCommand)
|
|
|
|
//ledisdb special command
|
|
|
|
register("lclear", lclearCommand)
|
|
|
|
}
|