engine

package

v1.0.0 Latest Latest Go to latest Published: Aug 22, 2024 License: MIT Imports: 13 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

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

func NewDefaultEngineFileHandler(input string) *DefaultEngineFileHandler

func (d *DefaultEngineFileHandler) Close()

func (d *DefaultEngineFileHandler) Read() (io.Reader, error)

func (d *DefaultEngineFileHandler) Write() (io.Writer, error)

type Engine struct {
	Handlers []handlerContext

	IgnoreRecoveryErrors bool
	// contains filtered or unexported fields
}

func New(ctx context.Context, config config.Config, files chan definitions.PrintInfo, writeAheadLogger repo.WriteAheadLogger) *Engine

func (e *Engine) Recover() error

func (e *Engine) Run()