engine

package

v0.0.3 Latest Latest Go to latest Published: May 26, 2026 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ConnectionState interface {
	Close(error)
}

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

func New(heartbeat app.Heartbeat, runtime Runtime, io IO, state ConnectionState, logger app.Logger) *Engine

func (engine *Engine) Close(ctx context.Context) error

func (engine *Engine) Start(ctx context.Context, input StartEngineInput)

type IO interface {
	Reader
	Writer
}

type Inbox interface {
	Next(context.Context) (app.Message, error)
}

type Reader interface {
	Read(context.Context) error
}

type Runtime interface {
	Run(context.Context) error
}

type StartEngineInput struct {
	Timeout time.Duration
}

type Writer interface {
	Write(context.Context) error
}