server

func (*AgentEventServer) Publish ¶

func (s *AgentEventServer) Publish(sessionID string, evt agent.AgentEvent)

func (*AgentEventServer) Sender ¶

func (s *AgentEventServer) Sender(sessionID string) api.AgentEventSender

func (*AgentEventServer) StreamAgentEvents ¶

func (s *AgentEventServer) StreamAgentEvents(ctx context.Context, req *api.StreamAgentEventsRequest) (api.AgentEventReceiver, error)

func (*AgentRPCServer) Abort ¶

func (s *AgentRPCServer) Abort(ctx context.Context, req *agentapi.AbortRequest) (*agentapi.AbortResponse, error)

func (*AgentRPCServer) Close ¶

func (s *AgentRPCServer) Close() error

func (*AgentRPCServer) Continue ¶

func (s *AgentRPCServer) Continue(ctx context.Context, req *agentapi.ContinueRequest) (api.AgentEventReceiver, error)

func (*AgentRPCServer) CreateSession ¶

func (s *AgentRPCServer) CreateSession(ctx context.Context, req *agentapi.CreateAgentSessionRequest) (*agentapi.CreateAgentSessionResponse, error)

func (*AgentRPCServer) DestroySession ¶

func (s *AgentRPCServer) DestroySession(ctx context.Context, req *agentapi.DestroyAgentSessionRequest) (*agentapi.DestroyAgentSessionResponse, error)

func (*AgentRPCServer) FollowUp ¶

func (s *AgentRPCServer) FollowUp(ctx context.Context, req *agentapi.FollowUpRequest) (*agentapi.FollowUpResponse, error)

func (*AgentRPCServer) GetSession ¶

func (s *AgentRPCServer) GetSession(ctx context.Context, req *agentapi.GetAgentSessionRequest) (*agentapi.GetAgentSessionResponse, error)

func (*AgentRPCServer) ListSessions ¶

func (s *AgentRPCServer) ListSessions(ctx context.Context, req *agentapi.ListAgentSessionsRequest) (*agentapi.ListAgentSessionsResponse, error)

func (*AgentRPCServer) ResumeSession ¶

func (s *AgentRPCServer) ResumeSession(ctx context.Context, req *agentapi.ResumeSessionRequest) (*agentapi.ResumeSessionResponse, error)

func (*AgentRPCServer) SendMessage ¶

func (s *AgentRPCServer) SendMessage(ctx context.Context, req *agentapi.SendMessageRequest) (api.AgentEventReceiver, error)

func (*AgentRPCServer) Steer ¶

func (s *AgentRPCServer) Steer(ctx context.Context, req *agentapi.SteerRequest) (*agentapi.SteerResponse, error)

func (*AgentRPCServer) SubscribeEvents ¶

func (s *AgentRPCServer) SubscribeEvents(ctx context.Context, req *agentapi.SubscribeEventsRequest) (api.AgentEventReceiver, error)

func (*SandboxServer) Close ¶

func (s *SandboxServer) Close() error

func (*SandboxServer) CreateSession ¶

func (s *SandboxServer) CreateSession(ctx context.Context, req *api.CreateSessionRequest) (*api.CreateSessionResponse, error)

func (*SandboxServer) CreateSnapshot ¶

func (s *SandboxServer) CreateSnapshot(ctx context.Context, req *api.CreateSnapshotRequest) (*api.CreateSnapshotResponse, error)

func (*SandboxServer) DestroySession ¶

func (s *SandboxServer) DestroySession(ctx context.Context, req *api.DestroySessionRequest) (*api.DestroySessionResponse, error)

func (*SandboxServer) ExecuteTool ¶

func (s *SandboxServer) ExecuteTool(ctx context.Context, req *api.ExecuteToolRequest) (*api.ExecuteToolResponse, error)

func (*SandboxServer) ExecuteToolStream ¶

func (s *SandboxServer) ExecuteToolStream(ctx context.Context, req *api.ExecuteToolRequest) (api.ExecuteToolStreamReceiver, error)

func (*SandboxServer) GetProcessStatus ¶

func (s *SandboxServer) GetProcessStatus(ctx context.Context, req *api.GetProcessStatusRequest) (*api.GetProcessStatusResponse, error)

func (*SandboxServer) GetSession ¶

func (s *SandboxServer) GetSession(ctx context.Context, req *api.GetSessionRequest) (*api.GetSessionResponse, error)

func (*SandboxServer) HealthCheck ¶

func (s *SandboxServer) HealthCheck(ctx context.Context, _ *api.HealthCheckRequest) (*api.HealthCheckResponse, error)

func (*SandboxServer) KillProcess ¶

func (s *SandboxServer) KillProcess(ctx context.Context, req *api.KillProcessRequest) (*api.KillProcessResponse, error)

func (*SandboxServer) LaunchProcess ¶

func (s *SandboxServer) LaunchProcess(ctx context.Context, req *api.LaunchProcessRequest) (*api.LaunchProcessResponse, error)

func (*SandboxServer) ListSnapshots ¶

func (s *SandboxServer) ListSnapshots(ctx context.Context, req *api.ListSnapshotsRequest) (*api.ListSnapshotsResponse, error)

func (*SandboxServer) PauseSession ¶

func (s *SandboxServer) PauseSession(ctx context.Context, req *api.PauseSessionRequest) (*api.PauseSessionResponse, error)

func (*SandboxServer) ResumeSession ¶

func (s *SandboxServer) ResumeSession(ctx context.Context, req *api.ResumeSessionRequest) (*api.ResumeSessionResponse, error)

func (*SandboxServer) RollbackSession ¶

func (s *SandboxServer) RollbackSession(ctx context.Context, req *api.RollbackSessionRequest) (*api.RollbackSessionResponse, error)

func (*SandboxServer) String ¶

func (s *SandboxServer) String() string

func (*SandboxServer) TurnComplete ¶

func (s *SandboxServer) TurnComplete(ctx context.Context, req *api.TurnCompleteRequest) (*api.TurnCompleteResponse, error)

func (*TerminalServer) StreamTerminal ¶

func (s *TerminalServer) StreamTerminal(ctx context.Context, req *api.StreamTerminalRequest) (api.TerminalStreamHandle, error)

StreamTerminal opens a bidirectional terminal stream for the given session. The returned handle's first Recv yields the Attached message (with scrollback and dimensions), followed by live Output messages. The handle accepts Input and Resize messages via Send. When the session ends, a Detached message is delivered and the handle returns io.EOF.