synclog

package

v2.6.2 Latest Latest Go to latest Published: Dec 2, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Details

View Source

const (
	Meta_Head = "SYNCLOG"
)

This section is empty.

This section is empty.

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

func OpenLogFile(dirPath string, metaInfo *MetaInfo, syncLog *SyncLog) (*LogInfo, error)

func (l *LogInfo) Close() error

func (l *LogInfo) Write(data []byte) error

type MetaData struct {
	//headSize uint8
	Version uint8
	Offset  uint32
	Head    string
}

func NewMetaData() *MetaData

func (m *MetaData) FromBytes(reader io.Reader) error

func (m *MetaData) MetaSize() int

func (m *MetaData) ToBytes() []byte

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

func OpenMetaFile(dirPath string) (*MetaInfo, error)

func (m *MetaInfo) Close() error

func (m *MetaInfo) SaveOffset(offset uint32)

type ReadFunc func([]byte) error

type ReadRequest struct {
	Offset   uint32
	PlayLoad []byte
}

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

func NewSyncLog(dirPath string, f ReadFunc) *SyncLog

func (l *SyncLog) Close() error

func (l *SyncLog) Init() error

func (l *SyncLog) Write(loger SyncLoger) error

Write write loger to sync log

type SyncLogKVItem struct {
	Key   []byte
	Value []byte
}

func (kv *SyncLogKVItem) Format() []byte

func (kv *SyncLogKVItem) Parse(data []byte) error

type SyncLoger interface {
	Format() []byte
	Parse([]byte) error
}