wal_service

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

type ConsensusWalOptionFunc func(option *ConsensusWalOption)

type MarshalFunc func(data interface{}) []byte

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

type WalOpType int

type WalService interface {
	// WalMode return wal write mode
	WalMode() WalWriteMode

	// Sync flush buffer into files
	Sync() error

	// LastIndex load the last index from wal file
	LastIndex() (index uint64, err error)

	// Write write the data into wal
	Write(data interface{}) error

	// Read read the data from wal
	Read(index uint64) (data []byte, err error)

	// TruncateFront truncate the data
	TruncateFront(index uint64) error

	// Close close the wal
	Close() error
}

type WalServiceImpl struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type WalWriteMode int