Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewWriteAheadLogger ¶
func NewWriteAheadLogger( walFilePath string, conf config.WriteAheadLogging, logFactory definitions.LoggerFactory, ) (definitions.WriteAheadLogger, error)
Types ¶
type DefaultWriteAheadLogger ¶
type DefaultWriteAheadLogger struct {
// contains filtered or unexported fields
}
func (*DefaultWriteAheadLogger) ReadEntries ¶
func (l *DefaultWriteAheadLogger) ReadEntries() ([]definitions.LogEntry, error)
ReadEntries reads all entries from the WAL file
func (*DefaultWriteAheadLogger) ReadLastEntries ¶ added in v0.1.0
func (l *DefaultWriteAheadLogger) ReadLastEntries() ([]definitions.LogEntry, error)
ReadLastEntries retrieves the last in-progress entries per session
func (*DefaultWriteAheadLogger) WriteEntry ¶
func (l *DefaultWriteAheadLogger) WriteEntry(entry definitions.LogEntry)
WriteEntry writes a log entry to the WAL with the option to mark it as complete
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.