serviceimpl

package

Go to main page

Versions in this module

v0

v0.11.0

May 9, 2026

v0.10.16

May 8, 2026

v0.10.15

May 8, 2026

v0.10.14

May 7, 2026

v0.10.13

May 7, 2026

v0.10.12

May 7, 2026

Changes in this version

type ExecuteRunnerDecision

+ ServerInstance string

type NativeDecision

+ ServerInstance string

type NativeRouteCandidate

+ ServerInstance string

v0.10.11

May 6, 2026

v0.10.10

May 6, 2026

v0.10.9

May 6, 2026

v0.10.8

May 5, 2026

Changes in this version

+ func DispatchExecuteRun(ctx context.Context, req ExecuteDispatchRequest, cb ExecuteDispatchCallbacks)

+ func ReplaySession(ctx context.Context, path string, w io.Writer) error

+ func RunNative(ctx context.Context, req NativeRequest, cb NativeCallbacks)

+ func RunSubprocess(ctx context.Context, req SubprocessRequest, runner harnesses.Harness, ...)

+ func SessionLogDir(overrideDir, configDir string) string

+ func SessionLogPath(dir, sessionID string) (string, error)

+ func SystemClock() time.Time

+ func TailSessionLog(ctx context.Context, sessionID string, subscribe SessionSubscriber) (<-chan harnesses.Event, error)

+ func ToolNames(tools []agentcore.Tool) []string

+ func UsageReport(ctx context.Context, logDir string, opts session.UsageOptions) (*session.UsageReport, error)

+ func WriteSessionLog(ctx context.Context, path string, w io.Writer) error

+ type Clock func() time.Time

+ type ExecuteDispatchCallbacks struct

+ Finalize func(harnesses.FinalData)

+ IsHTTPProvider func(harness string) bool

+ RunNative func(context.Context)

+ RunScript func(context.Context)

+ RunSubprocess func(context.Context, harnesses.Harness)

+ RunVirtual func(context.Context)

+ type ExecuteDispatchRequest struct

+ Decision ExecuteRunnerDecision

+ Started time.Time

+ type ExecuteRunnerDecision struct

+ Harness string

+ Model string

+ Provider string

+ type ExecuteRunnerRequest struct

+ Decision ExecuteRunnerDecision

+ Metadata map[string]string

+ Prompt string

+ Started time.Time

+ type ExecuteRunnerResult struct

+ EmitText bool

+ Final harnesses.FinalData

+ Text string

+ func RunScript(ctx context.Context, req ExecuteRunnerRequest) ExecuteRunnerResult

+ func RunVirtual(ctx context.Context, req ExecuteRunnerRequest) ExecuteRunnerResult

+ type NativeCallbacks struct

+ BeforeFinal func(harnesses.FinalData)

+ CompactionAssertionHook func(messagesBefore, messagesAfter, tokensFreed int)

+ Compactor func(model string) agentcore.Compactor

+ EmitEvent func(harnesses.EventType, any)

+ Finalize func(harnesses.FinalData)

+ ObserveAgentEvent func(agentcore.Event)

+ ObserveTokenUsage func(provider string, tokens int, at time.Time)

+ PromptAssertionHook func(systemPrompt, prompt string, contextFiles []string)

+ ProviderNotConfiguredError func(NativeProviderRequest, NativeDecision) string

+ ResolveProvider func(NativeProviderRequest) NativeProviderResolution

+ ToolWiringHook func(harness string, toolNames []string)

+ type NativeDecision struct

+ Candidates []NativeRouteCandidate

+ Harness string

+ Model string

+ Provider string

+ type NativeProviderRequest struct

+ Harness string

+ Model string

+ Provider string

+ type NativeProviderResolution struct

+ Model string

+ Name string

+ Provider agentcore.Provider

+ type NativeRequest struct

+ CachePolicy string

+ Decision NativeDecision

+ Harness string

+ MaxIterations int

+ MaxTokens int

+ Metadata map[string]string

+ MinP *float64

+ Model string

+ NoStream bool

+ Permissions string

+ PlanningMode bool

+ Prompt string

+ Provider string

+ ProviderTimeout time.Duration

+ Reasoning agentcore.Reasoning

+ ReasoningByteLimit int

+ RepetitionPenalty *float64

+ SamplingSource string

+ Seed *int64

+ SessionID string

+ StallMaxReadOnlyIteration *int

+ Started time.Time

+ SystemPrompt string

+ Temperature *float32

+ Timeout time.Duration

+ ToolPreset string

+ Tools []agentcore.Tool

+ TopK *int

+ TopP *float64

+ WorkDir string

+ type NativeRouteCandidate struct

+ Eligible bool

+ Endpoint string

+ Model string

+ Provider string

+ type Runtime struct

+ func NewRuntime(deps RuntimeDeps) Runtime

+ func (r Runtime) Now() time.Time

+ type RuntimeDeps struct

+ Now Clock

+ func (d RuntimeDeps) Clock() Clock

+ type SessionLogEntry struct

+ ModTime time.Time

+ SessionID string

+ Size int64

+ func ListSessionLogs(ctx context.Context, logDir string) ([]SessionLogEntry, error)

+ type SessionSubscriber func(sessionID string) (<-chan harnesses.Event, error)

+ type SubprocessCallbacks struct

+ BeforeExecute func()

+ BeforeFinal func(harnesses.FinalData)

+ EmitEvent func(harnesses.Event) bool

+ Finalize func(harnesses.FinalData)

+ ObserveEvent func(harnesses.Event) harnesses.Event

+ WriteEnd func(map[string]string, harnesses.FinalData)

+ type SubprocessRequest struct

+ Decision ExecuteRunnerDecision

+ IdleTimeout time.Duration

+ Metadata map[string]string

+ Permissions string

+ Prompt string

+ Reasoning reasoning.Reasoning

+ Seed *int64

+ SessionLogDir string

+ SessionLogPath string

+ Started time.Time

+ SystemPrompt string

+ Temperature *float32

+ Timeout time.Duration

+ WorkDir string

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