mirror of https://github.com/ledisdb/ledisdb.git
112 lines
1.8 KiB
Go
112 lines
1.8 KiB
Go
package rpl
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/binary"
|
|
"io"
|
|
)
|
|
|
|
type Log struct {
|
|
ID uint64
|
|
CreateTime uint32
|
|
Compression uint8
|
|
|
|
Data []byte
|
|
}
|
|
|
|
func (l *Log) HeadSize() int {
|
|
return 17
|
|
}
|
|
|
|
func (l *Log) Size() int {
|
|
return l.HeadSize() + len(l.Data)
|
|
}
|
|
|
|
func (l *Log) Marshal() ([]byte, error) {
|
|
buf := bytes.NewBuffer(make([]byte, l.HeadSize()+len(l.Data)))
|
|
buf.Reset()
|
|
|
|
if err := l.Encode(buf); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return buf.Bytes(), nil
|
|
}
|
|
|
|
func (l *Log) Unmarshal(b []byte) error {
|
|
buf := bytes.NewBuffer(b)
|
|
|
|
return l.Decode(buf)
|
|
}
|
|
|
|
func (l *Log) Encode(w io.Writer) error {
|
|
buf := make([]byte, l.HeadSize())
|
|
|
|
pos := 0
|
|
binary.BigEndian.PutUint64(buf[pos:], l.ID)
|
|
pos += 8
|
|
|
|
binary.BigEndian.PutUint32(buf[pos:], l.CreateTime)
|
|
pos += 4
|
|
|
|
buf[pos] = l.Compression
|
|
pos++
|
|
|
|
binary.BigEndian.PutUint32(buf[pos:], uint32(len(l.Data)))
|
|
|
|
if n, err := w.Write(buf); err != nil {
|
|
return err
|
|
} else if n != len(buf) {
|
|
return io.ErrShortWrite
|
|
}
|
|
|
|
if n, err := w.Write(l.Data); err != nil {
|
|
return err
|
|
} else if n != len(l.Data) {
|
|
return io.ErrShortWrite
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (l *Log) Decode(r io.Reader) error {
|
|
length, err := l.DecodeHead(r)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
l.Data = l.Data[0:0]
|
|
|
|
if cap(l.Data) >= int(length) {
|
|
l.Data = l.Data[0:length]
|
|
} else {
|
|
l.Data = make([]byte, length)
|
|
}
|
|
if _, err := io.ReadFull(r, l.Data); err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (l *Log) DecodeHead(r io.Reader) (uint32, error) {
|
|
buf := make([]byte, l.HeadSize())
|
|
|
|
if _, err := io.ReadFull(r, buf); err != nil {
|
|
return 0, err
|
|
}
|
|
|
|
pos := 0
|
|
l.ID = binary.BigEndian.Uint64(buf[pos:])
|
|
pos += 8
|
|
|
|
l.CreateTime = binary.BigEndian.Uint32(buf[pos:])
|
|
pos += 4
|
|
|
|
l.Compression = uint8(buf[pos])
|
|
pos++
|
|
|
|
length := binary.BigEndian.Uint32(buf[pos:])
|
|
|
|
return length, nil
|
|
}
|