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 PidisService
- 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 PidisService ¶
type PidisService struct { proto.UnimplementedPidisServer // contains filtered or unexported fields }
func NewPidisService ¶
func NewPidisService(database *Database) *PidisService
func (*PidisService) Oplog ¶
func (s *PidisService) Oplog(req *proto.OplogReq, srv proto.Pidis_OplogServer) error
func (*PidisService) Snapshot ¶
func (s *PidisService) Snapshot(req *proto.SnapshotReq, srv proto.Pidis_SnapshotServer) error
Click to show internal directories.
Click to hide internal directories.