Documentation ¶
Index ¶
- Constants
- func DecodeAOF(content []byte) (uid []byte, args [][]byte, leftover []byte, err error)
- func EncodeAOF(uid []byte, args [][]byte) []byte
- func GetRedisCmdHandler(database *Database) func(conn redcon.Conn, cmd redcon.Command)
- func NewRpcServer(database *Database) *grpc.Server
- type AOFBus
- type Database
- func (db *Database) Close() error
- func (db *Database) Daemon() error
- func (db *Database) Exec(args [][]byte) (result *executor.Result, err error)
- func (db *Database) Following(ctx context.Context) error
- func (db *Database) IExec(args [][]byte) (result *executor.Result, err error)
- func (db *Database) IsWritable() bool
- func (db *Database) Record(cmd [][]byte) error
- func (db *Database) Run()
- func (db *Database) SlaveOf(host, port string) error
- func (db *Database) Sync(ctx context.Context, writer io.Writer, offset []byte) error
- type Node
- type Options
- type PiKVService
- type UID
Constants ¶
View Source
const UIDSize = 12
Variables ¶
This section is empty.
Functions ¶
func GetRedisCmdHandler ¶
func NewRpcServer ¶
Types ¶
type Database ¶
type Database struct {
// contains filtered or unexported fields
}
func (*Database) IsWritable ¶
type PiKVService ¶
type PiKVService struct { proto.UnimplementedPiKVServer // contains filtered or unexported fields }
func NewPiKVService ¶
func NewPiKVService(database *Database) *PiKVService
func (*PiKVService) Oplog ¶
func (s *PiKVService) Oplog(req *proto.OplogReq, srv proto.PiKV_OplogServer) error
func (*PiKVService) Snapshot ¶
func (s *PiKVService) Snapshot(req *proto.SnapshotReq, srv proto.PiKV_SnapshotServer) error
Click to show internal directories.
Click to hide internal directories.