server

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 29, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Overview

Package server implements the AgentRuntime gRPC service defined in proto/agent/runtime/v1. This is a runnable skeleton: Run / RunStream / RunAgent / RunAgentStream / HealthCheck are backed by an eino chat model, while Resume / Stop return Unimplemented until the full engine lands.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StreamTraceInterceptor

func StreamTraceInterceptor() grpc.StreamServerInterceptor

StreamTraceInterceptor binds inbound gRPC trace metadata to server-streaming contexts before service handlers run.

func UnaryTraceInterceptor

func UnaryTraceInterceptor() grpc.UnaryServerInterceptor

UnaryTraceInterceptor binds inbound gRPC trace metadata to the request context before service handlers run.

Types

type Config

type Config struct {
	DefaultModel eino.ModelConfig

	// Memory is optional. When Store is non-nil the server injects memory into
	// the system prompt and mines new memories after each response.
	Store        *memory.MemStore
	Reviewer     *memory.BackgroundReviewer
	InjectMemory bool

	// Dispatch carries operator-level defaults (sandbox / skills) into each run.
	Dispatch dispatcher.Config
}

Config configures the server's default model (used when a request omits models).

type Server

type Server struct {
	runtimev1.UnimplementedAgentRuntimeServer
	// contains filtered or unexported fields
}

Server implements runtimev1.AgentRuntimeServer.

func New

func New(cfg Config) *Server

New creates a Server.

func (*Server) GenerateMedia

GenerateMedia invokes a user-selected media model directly, without an LLM deciding whether or how to call the model.

func (*Server) HealthCheck

HealthCheck reports serving status.

func (*Server) Resume

Resume is not yet implemented (approval/checkpoint engine pending).

func (*Server) Run

Run performs a non-streaming completion.

func (*Server) RunAgent

RunAgent performs a non-streaming autonomous task (natural language input).

func (*Server) RunAgentStream

RunAgentStream streams an autonomous task response.

func (*Server) RunStream

RunStream streams a completion for a configured Run request.

func (*Server) Stop

Stop is not yet implemented (run registry pending).

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL