native

package

v0.1.23 Latest Latest Go to latest Published: Jul 6, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Details

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

Package native provides the built-in Leros (Eino) Runtime.

View Source

const (
	// Kind is the canonical runtime kind for the built-in Leros runtime.
	Kind = agent.RuntimeKindLeros
)

This section is empty.

This section is empty.

type Executor interface {
	Execute(context.Context, agent.ExecutionRequest, agent.NodeObserver) (agent.ExecutionResult, error)
}

Executor is the in-process execution backend used by the native Runtime.

type Runner struct{}

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

func NewRunner(context.Context) (*Runner, error)

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

func (r *Runner) Execute(
	ctx context.Context,
	req agent.ExecutionRequest,
	observer agent.NodeObserver,
) (agent.ExecutionResult, error)

Execute runs one prepared native request and emits only activity events.

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

Runtime executes requests directly through the in-process Eino runner.

func New() (*Runtime, error)

New creates the native Runtime.

func NewWithExecutor(executor Executor) (*Runtime, error)

NewWithExecutor creates a native Runtime with an injected execution backend.

func (r *Runtime) Execute(
	ctx context.Context,
	request agent.ExecutionRequest,
	observer agent.NodeObserver,
) (agent.ExecutionResult, error)

func (r *Runtime) Name() string