native

package

v0.1.13 Latest Latest Go to latest Published: Jun 23, 2026 License: Apache-2.0 Imports: 26 Imported by: 0

Details

Package native implements the built-in Eino-backed Leros engine.

Package native implements the built-in Eino-backed Leros runtime.

View Source

const EngineName = engines.EngineNative

EngineName is the registry name for the native engine.

This section is empty.

This section is empty.

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

Adapter implements engines.Engine for the in-process Eino runtime.

func NewAdapter(env *tools.Registry) (*Adapter, error)

NewAdapter creates a native engine adapter.

func (a *Adapter) GetSkillDir() string

GetSkillDir satisfies engines.Engine.

func (a *Adapter) Prepare(_ context.Context, _ engines.PrepareRequest) error

Prepare satisfies engines.Engine.

func (a *Adapter) Run(ctx context.Context, req engines.RunRequest) (*engines.RunHandle, error)

Run satisfies engines.Engine by delegating to the native Runner.

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

Runner 是 Leros 内置 Eino 运行时入口。

func NewRunner(ctx context.Context, env *tools.Registry) (*Runner, error)

NewRunner 创建基于 Eino Flow 的 Leros 内置 Agent。

func (r *Runner) Run(ctx context.Context, req engines.RunRequest) (<-chan events.Event, error)

Run 执行标准化请求，通过 Event channel 支持流式输出。