repo

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

type LogEntry struct {
	SessionID   uuid.UUID                    `json:"session_id"`
	HandlerName string                       `json:"handler_name"`
	HandlerID   string                       `json:"handler_id"`
	InputFile   string                       `json:"input_file"`
	OutputFile  string                       `json:"output_file"`
	FlowObject  definitions.EngineFlowObject `json:"flow_object"`
}

type WriteAheadLogger interface {
	WriteEntry(entry LogEntry)
	ReadEntries() ([]LogEntry, error)
}