Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterRatchetDaemonServer(s grpc.ServiceRegistrar, srv RatchetDaemonServer)
- type AddProviderReq
- func (*AddProviderReq) Descriptor() ([]byte, []int)deprecated
- func (x *AddProviderReq) GetAlias() string
- func (x *AddProviderReq) GetApiKey() string
- func (x *AddProviderReq) GetBaseUrl() string
- func (x *AddProviderReq) GetIsDefault() bool
- func (x *AddProviderReq) GetMaxTokens() int32
- func (x *AddProviderReq) GetModel() string
- func (x *AddProviderReq) GetType() string
- func (*AddProviderReq) ProtoMessage()
- func (x *AddProviderReq) ProtoReflect() protoreflect.Message
- func (x *AddProviderReq) Reset()
- func (x *AddProviderReq) String() string
- type Agent
- func (*Agent) Descriptor() ([]byte, []int)deprecated
- func (x *Agent) GetCurrentTask() string
- func (x *Agent) GetId() string
- func (x *Agent) GetModel() string
- func (x *Agent) GetName() string
- func (x *Agent) GetProvider() string
- func (x *Agent) GetRole() string
- func (x *Agent) GetSessionId() string
- func (x *Agent) GetStatus() string
- func (*Agent) ProtoMessage()
- func (x *Agent) ProtoReflect() protoreflect.Message
- func (x *Agent) Reset()
- func (x *Agent) String() string
- type AgentList
- type AgentMessage
- func (*AgentMessage) Descriptor() ([]byte, []int)deprecated
- func (x *AgentMessage) GetContent() string
- func (x *AgentMessage) GetFromAgent() string
- func (x *AgentMessage) GetToAgent() string
- func (*AgentMessage) ProtoMessage()
- func (x *AgentMessage) ProtoReflect() protoreflect.Message
- func (x *AgentMessage) Reset()
- func (x *AgentMessage) String() string
- type AgentSpawned
- func (*AgentSpawned) Descriptor() ([]byte, []int)deprecated
- func (x *AgentSpawned) GetAgentId() string
- func (x *AgentSpawned) GetAgentName() string
- func (x *AgentSpawned) GetRole() string
- func (*AgentSpawned) ProtoMessage()
- func (x *AgentSpawned) ProtoReflect() protoreflect.Message
- func (x *AgentSpawned) Reset()
- func (x *AgentSpawned) String() string
- type AgentStatusReq
- type ApprovePlanReq
- func (*ApprovePlanReq) Descriptor() ([]byte, []int)deprecated
- func (x *ApprovePlanReq) GetPlanId() string
- func (x *ApprovePlanReq) GetSessionId() string
- func (x *ApprovePlanReq) GetSkipSteps() []string
- func (*ApprovePlanReq) ProtoMessage()
- func (x *ApprovePlanReq) ProtoReflect() protoreflect.Message
- func (x *ApprovePlanReq) Reset()
- func (x *ApprovePlanReq) String() string
- type AttachReq
- type AttachTeamReq
- func (*AttachTeamReq) Descriptor() ([]byte, []int)deprecated
- func (x *AttachTeamReq) GetMode() string
- func (x *AttachTeamReq) GetTeamId() string
- func (*AttachTeamReq) ProtoMessage()
- func (x *AttachTeamReq) ProtoReflect() protoreflect.Message
- func (x *AttachTeamReq) Reset()
- func (x *AttachTeamReq) String() string
- type AuthError
- func (*AuthError) Descriptor() ([]byte, []int)deprecated
- func (x *AuthError) GetAlias() string
- func (x *AuthError) GetMessage() string
- func (x *AuthError) GetProvider() string
- func (*AuthError) ProtoMessage()
- func (x *AuthError) ProtoReflect() protoreflect.Message
- func (x *AuthError) Reset()
- func (x *AuthError) String() string
- type BlackboardSync
- func (*BlackboardSync) Descriptor() ([]byte, []int)deprecated
- func (x *BlackboardSync) GetAuthor() string
- func (x *BlackboardSync) GetKey() string
- func (x *BlackboardSync) GetRevision() int64
- func (x *BlackboardSync) GetSection() string
- func (x *BlackboardSync) GetValue() []byte
- func (*BlackboardSync) ProtoMessage()
- func (x *BlackboardSync) ProtoReflect() protoreflect.Message
- func (x *BlackboardSync) Reset()
- func (x *BlackboardSync) String() string
- type ChatEvent
- func (*ChatEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ChatEvent) GetAgentMessage() *AgentMessage
- func (x *ChatEvent) GetAgentSpawned() *AgentSpawned
- func (x *ChatEvent) GetAuthError() *AuthError
- func (x *ChatEvent) GetComplete() *SessionComplete
- func (x *ChatEvent) GetContextCompressed() *ContextCompressedEvent
- func (x *ChatEvent) GetError() *ErrorEvent
- func (x *ChatEvent) GetEvent() isChatEvent_Event
- func (x *ChatEvent) GetFleetStatus() *FleetStatus
- func (x *ChatEvent) GetHistory() *SessionHistory
- func (x *ChatEvent) GetPermission() *PermissionRequest
- func (x *ChatEvent) GetPlanProposed() *Plan
- func (x *ChatEvent) GetPlanStepUpdate() *PlanStep
- func (x *ChatEvent) GetThinking() *ThinkingBlock
- func (x *ChatEvent) GetToken() *TokenDelta
- func (x *ChatEvent) GetToolResult() *ToolCallResult
- func (x *ChatEvent) GetToolStart() *ToolCallStart
- func (*ChatEvent) ProtoMessage()
- func (x *ChatEvent) ProtoReflect() protoreflect.Message
- func (x *ChatEvent) Reset()
- func (x *ChatEvent) String() string
- type ChatEvent_AgentMessage
- type ChatEvent_AgentSpawned
- type ChatEvent_AuthError
- type ChatEvent_Complete
- type ChatEvent_ContextCompressed
- type ChatEvent_Error
- type ChatEvent_FleetStatus
- type ChatEvent_History
- type ChatEvent_Permission
- type ChatEvent_PlanProposed
- type ChatEvent_PlanStepUpdate
- type ChatEvent_Thinking
- type ChatEvent_Token
- type ChatEvent_ToolResult
- type ChatEvent_ToolStart
- type ContextCompressedEvent
- func (*ContextCompressedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ContextCompressedEvent) GetMessagesKept() int32
- func (x *ContextCompressedEvent) GetMessagesRemoved() int32
- func (x *ContextCompressedEvent) GetSessionId() string
- func (x *ContextCompressedEvent) GetSummary() string
- func (*ContextCompressedEvent) ProtoMessage()
- func (x *ContextCompressedEvent) ProtoReflect() protoreflect.Message
- func (x *ContextCompressedEvent) Reset()
- func (x *ContextCompressedEvent) String() string
- type CreateCronReq
- func (*CreateCronReq) Descriptor() ([]byte, []int)deprecated
- func (x *CreateCronReq) GetCommand() string
- func (x *CreateCronReq) GetSchedule() string
- func (x *CreateCronReq) GetSessionId() string
- func (*CreateCronReq) ProtoMessage()
- func (x *CreateCronReq) ProtoReflect() protoreflect.Message
- func (x *CreateCronReq) Reset()
- func (x *CreateCronReq) String() string
- type CreateSessionReq
- func (*CreateSessionReq) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSessionReq) GetInitialPrompt() string
- func (x *CreateSessionReq) GetModel() string
- func (x *CreateSessionReq) GetProvider() string
- func (x *CreateSessionReq) GetWorkingDir() string
- func (*CreateSessionReq) ProtoMessage()
- func (x *CreateSessionReq) ProtoReflect() protoreflect.Message
- func (x *CreateSessionReq) Reset()
- func (x *CreateSessionReq) String() string
- type CronJob
- func (*CronJob) Descriptor() ([]byte, []int)deprecated
- func (x *CronJob) GetCommand() string
- func (x *CronJob) GetId() string
- func (x *CronJob) GetLastRun() string
- func (x *CronJob) GetNextRun() string
- func (x *CronJob) GetRunCount() int32
- func (x *CronJob) GetSchedule() string
- func (x *CronJob) GetSessionId() string
- func (x *CronJob) GetStatus() string
- func (*CronJob) ProtoMessage()
- func (x *CronJob) ProtoReflect() protoreflect.Message
- func (x *CronJob) Reset()
- func (x *CronJob) String() string
- type CronJobList
- type CronJobReq
- type DetachReq
- type DirectMessageReq
- func (*DirectMessageReq) Descriptor() ([]byte, []int)deprecated
- func (x *DirectMessageReq) GetContent() string
- func (x *DirectMessageReq) GetTeamId() string
- func (x *DirectMessageReq) GetToAgent() string
- func (*DirectMessageReq) ProtoMessage()
- func (x *DirectMessageReq) ProtoReflect() protoreflect.Message
- func (x *DirectMessageReq) Reset()
- func (x *DirectMessageReq) String() string
- type Empty
- type ErrorEvent
- type FleetStatus
- func (*FleetStatus) Descriptor() ([]byte, []int)deprecated
- func (x *FleetStatus) GetCompleted() int32
- func (x *FleetStatus) GetFleetId() string
- func (x *FleetStatus) GetSessionId() string
- func (x *FleetStatus) GetStatus() string
- func (x *FleetStatus) GetTotal() int32
- func (x *FleetStatus) GetWorkers() []*FleetWorker
- func (*FleetStatus) ProtoMessage()
- func (x *FleetStatus) ProtoReflect() protoreflect.Message
- func (x *FleetStatus) Reset()
- func (x *FleetStatus) String() string
- type FleetStatusReq
- type FleetWorker
- func (*FleetWorker) Descriptor() ([]byte, []int)deprecated
- func (x *FleetWorker) GetError() string
- func (x *FleetWorker) GetId() string
- func (x *FleetWorker) GetModel() string
- func (x *FleetWorker) GetName() string
- func (x *FleetWorker) GetProvider() string
- func (x *FleetWorker) GetStatus() string
- func (x *FleetWorker) GetStepId() string
- func (*FleetWorker) ProtoMessage()
- func (x *FleetWorker) ProtoReflect() protoreflect.Message
- func (x *FleetWorker) Reset()
- func (x *FleetWorker) String() string
- type HealthResponse
- func (*HealthResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HealthResponse) GetActiveAgents() int32
- func (x *HealthResponse) GetActiveSessions() int32
- func (x *HealthResponse) GetCommit() string
- func (x *HealthResponse) GetHealthy() bool
- func (x *HealthResponse) GetProtoVersion() int32
- func (x *HealthResponse) GetUptime() string
- func (x *HealthResponse) GetVersion() string
- func (*HealthResponse) ProtoMessage()
- func (x *HealthResponse) ProtoReflect() protoreflect.Message
- func (x *HealthResponse) Reset()
- func (x *HealthResponse) String() string
- type HistoryMessage
- func (*HistoryMessage) Descriptor() ([]byte, []int)deprecated
- func (x *HistoryMessage) GetContent() string
- func (x *HistoryMessage) GetRole() string
- func (x *HistoryMessage) GetTimestamp() *timestamppb.Timestamp
- func (x *HistoryMessage) GetToolCallId() string
- func (x *HistoryMessage) GetToolName() string
- func (*HistoryMessage) ProtoMessage()
- func (x *HistoryMessage) ProtoReflect() protoreflect.Message
- func (x *HistoryMessage) Reset()
- func (x *HistoryMessage) String() string
- type HumanRequest
- func (*HumanRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HumanRequest) GetFromAgent() string
- func (x *HumanRequest) GetQuestion() string
- func (x *HumanRequest) GetRequestId() string
- func (x *HumanRequest) GetTeamId() string
- func (x *HumanRequest) GetTimestamp() string
- func (*HumanRequest) ProtoMessage()
- func (x *HumanRequest) ProtoReflect() protoreflect.Message
- func (x *HumanRequest) Reset()
- func (x *HumanRequest) String() string
- type HumanResponse
- func (*HumanResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HumanResponse) GetContent() string
- func (x *HumanResponse) GetRequestId() string
- func (x *HumanResponse) GetTeamId() string
- func (*HumanResponse) ProtoMessage()
- func (x *HumanResponse) ProtoReflect() protoreflect.Message
- func (x *HumanResponse) Reset()
- func (x *HumanResponse) String() string
- type Job
- func (*Job) Descriptor() ([]byte, []int)deprecated
- func (x *Job) GetElapsed() string
- func (x *Job) GetId() string
- func (x *Job) GetMetadata() map[string]string
- func (x *Job) GetName() string
- func (x *Job) GetSessionId() string
- func (x *Job) GetStartedAt() string
- func (x *Job) GetStatus() string
- func (x *Job) GetType() string
- func (*Job) ProtoMessage()
- func (x *Job) ProtoReflect() protoreflect.Message
- func (x *Job) Reset()
- func (x *Job) String() string
- type JobList
- type JobReq
- type KillFleetWorkerReq
- func (*KillFleetWorkerReq) Descriptor() ([]byte, []int)deprecated
- func (x *KillFleetWorkerReq) GetFleetId() string
- func (x *KillFleetWorkerReq) GetWorkerId() string
- func (*KillFleetWorkerReq) ProtoMessage()
- func (x *KillFleetWorkerReq) ProtoReflect() protoreflect.Message
- func (x *KillFleetWorkerReq) Reset()
- func (x *KillFleetWorkerReq) String() string
- type KillReq
- type KillTeamReq
- type ListTeamsReq
- type MeshEvent
- func (*MeshEvent) Descriptor() ([]byte, []int)deprecated
- func (x *MeshEvent) GetAgentMessage() *AgentMessage
- func (x *MeshEvent) GetBlackboardSync() *BlackboardSync
- func (x *MeshEvent) GetEvent() isMeshEvent_Event
- func (x *MeshEvent) GetNodeRegistered() *RegisterNodeResp
- func (*MeshEvent) ProtoMessage()
- func (x *MeshEvent) ProtoReflect() protoreflect.Message
- func (x *MeshEvent) Reset()
- func (x *MeshEvent) String() string
- type MeshEvent_AgentMessage
- type MeshEvent_BlackboardSync
- type MeshEvent_NodeRegistered
- type PendingHumanList
- func (*PendingHumanList) Descriptor() ([]byte, []int)deprecated
- func (x *PendingHumanList) GetRequests() []*HumanRequest
- func (*PendingHumanList) ProtoMessage()
- func (x *PendingHumanList) ProtoReflect() protoreflect.Message
- func (x *PendingHumanList) Reset()
- func (x *PendingHumanList) String() string
- type PendingHumanReq
- type PermissionRequest
- func (*PermissionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PermissionRequest) GetArgumentsJson() string
- func (x *PermissionRequest) GetDescription() string
- func (x *PermissionRequest) GetRequestId() string
- func (x *PermissionRequest) GetToolName() string
- func (*PermissionRequest) ProtoMessage()
- func (x *PermissionRequest) ProtoReflect() protoreflect.Message
- func (x *PermissionRequest) Reset()
- func (x *PermissionRequest) String() string
- type PermissionResponse
- func (*PermissionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PermissionResponse) GetAllowed() bool
- func (x *PermissionResponse) GetRequestId() string
- func (x *PermissionResponse) GetScope() string
- func (*PermissionResponse) ProtoMessage()
- func (x *PermissionResponse) ProtoReflect() protoreflect.Message
- func (x *PermissionResponse) Reset()
- func (x *PermissionResponse) String() string
- type Plan
- func (*Plan) Descriptor() ([]byte, []int)deprecated
- func (x *Plan) GetCreatedAt() string
- func (x *Plan) GetFeedback() string
- func (x *Plan) GetGoal() string
- func (x *Plan) GetId() string
- func (x *Plan) GetSessionId() string
- func (x *Plan) GetStatus() string
- func (x *Plan) GetSteps() []*PlanStep
- func (*Plan) ProtoMessage()
- func (x *Plan) ProtoReflect() protoreflect.Message
- func (x *Plan) Reset()
- func (x *Plan) String() string
- type PlanStep
- func (*PlanStep) Descriptor() ([]byte, []int)deprecated
- func (x *PlanStep) GetDescription() string
- func (x *PlanStep) GetError() string
- func (x *PlanStep) GetFiles() []string
- func (x *PlanStep) GetId() string
- func (x *PlanStep) GetStatus() string
- func (*PlanStep) ProtoMessage()
- func (x *PlanStep) ProtoReflect() protoreflect.Message
- func (x *PlanStep) Reset()
- func (x *PlanStep) String() string
- type ProjectList
- type ProjectReq
- type ProjectStatus
- func (*ProjectStatus) Descriptor() ([]byte, []int)deprecated
- func (x *ProjectStatus) GetCreatedAt() string
- func (x *ProjectStatus) GetId() string
- func (x *ProjectStatus) GetName() string
- func (x *ProjectStatus) GetStatus() string
- func (x *ProjectStatus) GetTeamIds() []string
- func (*ProjectStatus) ProtoMessage()
- func (x *ProjectStatus) ProtoReflect() protoreflect.Message
- func (x *ProjectStatus) Reset()
- func (x *ProjectStatus) String() string
- type Provider
- func (*Provider) Descriptor() ([]byte, []int)deprecated
- func (x *Provider) GetAlias() string
- func (x *Provider) GetBaseUrl() string
- func (x *Provider) GetIsDefault() bool
- func (x *Provider) GetModel() string
- func (x *Provider) GetType() string
- func (*Provider) ProtoMessage()
- func (x *Provider) ProtoReflect() protoreflect.Message
- func (x *Provider) Reset()
- func (x *Provider) String() string
- type ProviderList
- type RatchetDaemonClient
- type RatchetDaemonServer
- type RatchetDaemon_ApprovePlanClient
- type RatchetDaemon_ApprovePlanServer
- type RatchetDaemon_AttachSessionClient
- type RatchetDaemon_AttachSessionServer
- type RatchetDaemon_AttachTeamClient
- type RatchetDaemon_AttachTeamServer
- type RatchetDaemon_MeshStreamClient
- type RatchetDaemon_MeshStreamServer
- type RatchetDaemon_RequestReloadClient
- type RatchetDaemon_RequestReloadServer
- type RatchetDaemon_SendMessageClient
- type RatchetDaemon_SendMessageServer
- type RatchetDaemon_StartFleetClient
- type RatchetDaemon_StartFleetServer
- type RatchetDaemon_StartTeamClient
- type RatchetDaemon_StartTeamServer
- type RegisterNodeReq
- func (*RegisterNodeReq) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterNodeReq) GetModel() string
- func (x *RegisterNodeReq) GetName() string
- func (x *RegisterNodeReq) GetProvider() string
- func (x *RegisterNodeReq) GetRole() string
- func (x *RegisterNodeReq) GetTools() []string
- func (*RegisterNodeReq) ProtoMessage()
- func (x *RegisterNodeReq) ProtoReflect() protoreflect.Message
- func (x *RegisterNodeReq) Reset()
- func (x *RegisterNodeReq) String() string
- type RegisterNodeResp
- type RejectPlanReq
- func (*RejectPlanReq) Descriptor() ([]byte, []int)deprecated
- func (x *RejectPlanReq) GetFeedback() string
- func (x *RejectPlanReq) GetPlanId() string
- func (x *RejectPlanReq) GetSessionId() string
- func (*RejectPlanReq) ProtoMessage()
- func (x *RejectPlanReq) ProtoReflect() protoreflect.Message
- func (x *RejectPlanReq) Reset()
- func (x *RejectPlanReq) String() string
- type ReloadReq
- type ReloadStatus
- func (*ReloadStatus) Descriptor() ([]byte, []int)deprecated
- func (x *ReloadStatus) GetMessage() string
- func (x *ReloadStatus) GetStatus() string
- func (*ReloadStatus) ProtoMessage()
- func (x *ReloadStatus) ProtoReflect() protoreflect.Message
- func (x *ReloadStatus) Reset()
- func (x *ReloadStatus) String() string
- type RemoveProviderReq
- type SendMessageReq
- func (*SendMessageReq) Descriptor() ([]byte, []int)deprecated
- func (x *SendMessageReq) GetContent() string
- func (x *SendMessageReq) GetSessionId() string
- func (*SendMessageReq) ProtoMessage()
- func (x *SendMessageReq) ProtoReflect() protoreflect.Message
- func (x *SendMessageReq) Reset()
- func (x *SendMessageReq) String() string
- type Session
- func (*Session) Descriptor() ([]byte, []int)deprecated
- func (x *Session) GetActiveAgents() int32
- func (x *Session) GetCreatedAt() *timestamppb.Timestamp
- func (x *Session) GetId() string
- func (x *Session) GetModel() string
- func (x *Session) GetName() string
- func (x *Session) GetProvider() string
- func (x *Session) GetStatus() string
- func (x *Session) GetWorkingDir() string
- func (*Session) ProtoMessage()
- func (x *Session) ProtoReflect() protoreflect.Message
- func (x *Session) Reset()
- func (x *Session) String() string
- type SessionComplete
- func (*SessionComplete) Descriptor() ([]byte, []int)deprecated
- func (x *SessionComplete) GetSummary() string
- func (x *SessionComplete) GetTotalTokens() int32
- func (*SessionComplete) ProtoMessage()
- func (x *SessionComplete) ProtoReflect() protoreflect.Message
- func (x *SessionComplete) Reset()
- func (x *SessionComplete) String() string
- type SessionHistory
- type SessionList
- type SetDefaultProviderReq
- func (*SetDefaultProviderReq) Descriptor() ([]byte, []int)deprecated
- func (x *SetDefaultProviderReq) GetAlias() string
- func (*SetDefaultProviderReq) ProtoMessage()
- func (x *SetDefaultProviderReq) ProtoReflect() protoreflect.Message
- func (x *SetDefaultProviderReq) Reset()
- func (x *SetDefaultProviderReq) String() string
- type StartFleetReq
- func (*StartFleetReq) Descriptor() ([]byte, []int)deprecated
- func (x *StartFleetReq) GetMaxWorkers() int32
- func (x *StartFleetReq) GetPlanId() string
- func (x *StartFleetReq) GetSessionId() string
- func (*StartFleetReq) ProtoMessage()
- func (x *StartFleetReq) ProtoReflect() protoreflect.Message
- func (x *StartFleetReq) Reset()
- func (x *StartFleetReq) String() string
- type StartProjectReq
- func (*StartProjectReq) Descriptor() ([]byte, []int)deprecated
- func (x *StartProjectReq) GetConfigPath() string
- func (x *StartProjectReq) GetName() string
- func (*StartProjectReq) ProtoMessage()
- func (x *StartProjectReq) ProtoReflect() protoreflect.Message
- func (x *StartProjectReq) Reset()
- func (x *StartProjectReq) String() string
- type StartTeamReq
- func (*StartTeamReq) Descriptor() ([]byte, []int)deprecated
- func (x *StartTeamReq) GetOrchestratorProvider() string
- func (x *StartTeamReq) GetSessionId() string
- func (x *StartTeamReq) GetTask() string
- func (x *StartTeamReq) GetTeamConfigName() string
- func (*StartTeamReq) ProtoMessage()
- func (x *StartTeamReq) ProtoReflect() protoreflect.Message
- func (x *StartTeamReq) Reset()
- func (x *StartTeamReq) String() string
- type SteerTeamReq
- func (*SteerTeamReq) Descriptor() ([]byte, []int)deprecated
- func (x *SteerTeamReq) GetDirective() string
- func (x *SteerTeamReq) GetTeamId() string
- func (*SteerTeamReq) ProtoMessage()
- func (x *SteerTeamReq) ProtoReflect() protoreflect.Message
- func (x *SteerTeamReq) Reset()
- func (x *SteerTeamReq) String() string
- type TaskClaimReq
- func (*TaskClaimReq) Descriptor() ([]byte, []int)deprecated
- func (x *TaskClaimReq) GetAgentName() string
- func (x *TaskClaimReq) GetTaskId() string
- func (*TaskClaimReq) ProtoMessage()
- func (x *TaskClaimReq) ProtoReflect() protoreflect.Message
- func (x *TaskClaimReq) Reset()
- func (x *TaskClaimReq) String() string
- type TaskCreateReq
- func (*TaskCreateReq) Descriptor() ([]byte, []int)deprecated
- func (x *TaskCreateReq) GetAssignedTeam() string
- func (x *TaskCreateReq) GetDescription() string
- func (x *TaskCreateReq) GetPriority() int32
- func (x *TaskCreateReq) GetProjectId() string
- func (x *TaskCreateReq) GetTitle() string
- func (*TaskCreateReq) ProtoMessage()
- func (x *TaskCreateReq) ProtoReflect() protoreflect.Message
- func (x *TaskCreateReq) Reset()
- func (x *TaskCreateReq) String() string
- type TaskInfo
- func (*TaskInfo) Descriptor() ([]byte, []int)deprecated
- func (x *TaskInfo) GetAssignedTeam() string
- func (x *TaskInfo) GetClaimedBy() string
- func (x *TaskInfo) GetCreatedAt() string
- func (x *TaskInfo) GetDescription() string
- func (x *TaskInfo) GetId() string
- func (x *TaskInfo) GetPriority() int32
- func (x *TaskInfo) GetProjectId() string
- func (x *TaskInfo) GetStatus() string
- func (x *TaskInfo) GetTitle() string
- func (x *TaskInfo) GetUpdatedAt() string
- func (*TaskInfo) ProtoMessage()
- func (x *TaskInfo) ProtoReflect() protoreflect.Message
- func (x *TaskInfo) Reset()
- func (x *TaskInfo) String() string
- type TaskList
- type TaskListReq
- func (*TaskListReq) Descriptor() ([]byte, []int)deprecated
- func (x *TaskListReq) GetLimit() int32
- func (x *TaskListReq) GetProjectId() string
- func (x *TaskListReq) GetStatus() string
- func (x *TaskListReq) GetTeam() string
- func (*TaskListReq) ProtoMessage()
- func (x *TaskListReq) ProtoReflect() protoreflect.Message
- func (x *TaskListReq) Reset()
- func (x *TaskListReq) String() string
- type TaskReq
- type TaskUpdateReq
- func (*TaskUpdateReq) Descriptor() ([]byte, []int)deprecated
- func (x *TaskUpdateReq) GetNotes() string
- func (x *TaskUpdateReq) GetStatus() string
- func (x *TaskUpdateReq) GetTaskId() string
- func (*TaskUpdateReq) ProtoMessage()
- func (x *TaskUpdateReq) ProtoReflect() protoreflect.Message
- func (x *TaskUpdateReq) Reset()
- func (x *TaskUpdateReq) String() string
- type TeamActivityEvent
- func (*TeamActivityEvent) Descriptor() ([]byte, []int)deprecated
- func (x *TeamActivityEvent) GetAgentMessage() *AgentMessage
- func (x *TeamActivityEvent) GetComplete() *SessionComplete
- func (x *TeamActivityEvent) GetError() *ErrorEvent
- func (x *TeamActivityEvent) GetEvent() isTeamActivityEvent_Event
- func (x *TeamActivityEvent) GetHumanRequest() *HumanRequest
- func (x *TeamActivityEvent) GetToken() *TokenDelta
- func (*TeamActivityEvent) ProtoMessage()
- func (x *TeamActivityEvent) ProtoReflect() protoreflect.Message
- func (x *TeamActivityEvent) Reset()
- func (x *TeamActivityEvent) String() string
- type TeamActivityEvent_AgentMessage
- type TeamActivityEvent_Complete
- type TeamActivityEvent_Error
- type TeamActivityEvent_HumanRequest
- type TeamActivityEvent_Token
- type TeamAddAgentReq
- func (*TeamAddAgentReq) Descriptor() ([]byte, []int)deprecated
- func (x *TeamAddAgentReq) GetAgentSpec() string
- func (x *TeamAddAgentReq) GetTeamId() string
- func (*TeamAddAgentReq) ProtoMessage()
- func (x *TeamAddAgentReq) ProtoReflect() protoreflect.Message
- func (x *TeamAddAgentReq) Reset()
- func (x *TeamAddAgentReq) String() string
- type TeamEvent
- func (*TeamEvent) Descriptor() ([]byte, []int)deprecated
- func (x *TeamEvent) GetAgentMessage() *AgentMessage
- func (x *TeamEvent) GetAgentSpawned() *AgentSpawned
- func (x *TeamEvent) GetComplete() *SessionComplete
- func (x *TeamEvent) GetError() *ErrorEvent
- func (x *TeamEvent) GetEvent() isTeamEvent_Event
- func (x *TeamEvent) GetPermission() *PermissionRequest
- func (x *TeamEvent) GetToken() *TokenDelta
- func (x *TeamEvent) GetToolResult() *ToolCallResult
- func (x *TeamEvent) GetToolStart() *ToolCallStart
- func (*TeamEvent) ProtoMessage()
- func (x *TeamEvent) ProtoReflect() protoreflect.Message
- func (x *TeamEvent) Reset()
- func (x *TeamEvent) String() string
- type TeamEvent_AgentMessage
- type TeamEvent_AgentSpawned
- type TeamEvent_Complete
- type TeamEvent_Error
- type TeamEvent_Permission
- type TeamEvent_Token
- type TeamEvent_ToolResult
- type TeamEvent_ToolStart
- type TeamList
- type TeamRemoveAgentReq
- func (*TeamRemoveAgentReq) Descriptor() ([]byte, []int)deprecated
- func (x *TeamRemoveAgentReq) GetAgentName() string
- func (x *TeamRemoveAgentReq) GetTeamId() string
- func (*TeamRemoveAgentReq) ProtoMessage()
- func (x *TeamRemoveAgentReq) ProtoReflect() protoreflect.Message
- func (x *TeamRemoveAgentReq) Reset()
- func (x *TeamRemoveAgentReq) String() string
- type TeamRenameReq
- func (*TeamRenameReq) Descriptor() ([]byte, []int)deprecated
- func (x *TeamRenameReq) GetNewName() string
- func (x *TeamRenameReq) GetTeamId() string
- func (*TeamRenameReq) ProtoMessage()
- func (x *TeamRenameReq) ProtoReflect() protoreflect.Message
- func (x *TeamRenameReq) Reset()
- func (x *TeamRenameReq) String() string
- type TeamStatus
- func (*TeamStatus) Descriptor() ([]byte, []int)deprecated
- func (x *TeamStatus) GetAgents() []*Agent
- func (x *TeamStatus) GetStatus() string
- func (x *TeamStatus) GetTask() string
- func (x *TeamStatus) GetTeamId() string
- func (*TeamStatus) ProtoMessage()
- func (x *TeamStatus) ProtoReflect() protoreflect.Message
- func (x *TeamStatus) Reset()
- func (x *TeamStatus) String() string
- type TeamStatusReq
- type TestProviderReq
- type TestProviderResult
- func (*TestProviderResult) Descriptor() ([]byte, []int)deprecated
- func (x *TestProviderResult) GetLatencyMs() int64
- func (x *TestProviderResult) GetMessage() string
- func (x *TestProviderResult) GetSuccess() bool
- func (*TestProviderResult) ProtoMessage()
- func (x *TestProviderResult) ProtoReflect() protoreflect.Message
- func (x *TestProviderResult) Reset()
- func (x *TestProviderResult) String() string
- type ThinkingBlock
- type TokenDelta
- type ToolCallResult
- func (*ToolCallResult) Descriptor() ([]byte, []int)deprecated
- func (x *ToolCallResult) GetCallId() string
- func (x *ToolCallResult) GetResultJson() string
- func (x *ToolCallResult) GetSuccess() bool
- func (*ToolCallResult) ProtoMessage()
- func (x *ToolCallResult) ProtoReflect() protoreflect.Message
- func (x *ToolCallResult) Reset()
- func (x *ToolCallResult) String() string
- type ToolCallStart
- func (*ToolCallStart) Descriptor() ([]byte, []int)deprecated
- func (x *ToolCallStart) GetArgumentsJson() string
- func (x *ToolCallStart) GetCallId() string
- func (x *ToolCallStart) GetToolName() string
- func (*ToolCallStart) ProtoMessage()
- func (x *ToolCallStart) ProtoReflect() protoreflect.Message
- func (x *ToolCallStart) Reset()
- func (x *ToolCallStart) String() string
- type UnimplementedRatchetDaemonServer
- func (UnimplementedRatchetDaemonServer) AddProvider(context.Context, *AddProviderReq) (*Provider, error)
- func (UnimplementedRatchetDaemonServer) ApprovePlan(*ApprovePlanReq, grpc.ServerStreamingServer[ChatEvent]) error
- func (UnimplementedRatchetDaemonServer) AttachSession(*AttachReq, grpc.ServerStreamingServer[ChatEvent]) error
- func (UnimplementedRatchetDaemonServer) AttachTeam(*AttachTeamReq, grpc.ServerStreamingServer[TeamActivityEvent]) error
- func (UnimplementedRatchetDaemonServer) CheckVersion(context.Context, *VersionCheckReq) (*VersionCheckResp, error)
- func (UnimplementedRatchetDaemonServer) ClaimTask(context.Context, *TaskClaimReq) (*TaskInfo, error)
- func (UnimplementedRatchetDaemonServer) CreateCron(context.Context, *CreateCronReq) (*CronJob, error)
- func (UnimplementedRatchetDaemonServer) CreateSession(context.Context, *CreateSessionReq) (*Session, error)
- func (UnimplementedRatchetDaemonServer) CreateTask(context.Context, *TaskCreateReq) (*TaskInfo, error)
- func (UnimplementedRatchetDaemonServer) DetachSession(context.Context, *DetachReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) DirectMessage(context.Context, *DirectMessageReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) GetAgentStatus(context.Context, *AgentStatusReq) (*Agent, error)
- func (UnimplementedRatchetDaemonServer) GetFleetStatus(context.Context, *FleetStatusReq) (*FleetStatus, error)
- func (UnimplementedRatchetDaemonServer) GetProjectStatus(context.Context, *ProjectReq) (*ProjectStatus, error)
- func (UnimplementedRatchetDaemonServer) GetTask(context.Context, *TaskReq) (*TaskInfo, error)
- func (UnimplementedRatchetDaemonServer) GetTeamStatus(context.Context, *TeamStatusReq) (*TeamStatus, error)
- func (UnimplementedRatchetDaemonServer) Health(context.Context, *Empty) (*HealthResponse, error)
- func (UnimplementedRatchetDaemonServer) KillFleetWorker(context.Context, *KillFleetWorkerReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) KillJob(context.Context, *JobReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) KillProject(context.Context, *ProjectReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) KillSession(context.Context, *KillReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) KillTeam(context.Context, *KillTeamReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) ListAgents(context.Context, *Empty) (*AgentList, error)
- func (UnimplementedRatchetDaemonServer) ListCrons(context.Context, *Empty) (*CronJobList, error)
- func (UnimplementedRatchetDaemonServer) ListJobs(context.Context, *Empty) (*JobList, error)
- func (UnimplementedRatchetDaemonServer) ListPendingHuman(context.Context, *PendingHumanReq) (*PendingHumanList, error)
- func (UnimplementedRatchetDaemonServer) ListProjects(context.Context, *Empty) (*ProjectList, error)
- func (UnimplementedRatchetDaemonServer) ListProviders(context.Context, *Empty) (*ProviderList, error)
- func (UnimplementedRatchetDaemonServer) ListSessions(context.Context, *Empty) (*SessionList, error)
- func (UnimplementedRatchetDaemonServer) ListTasks(context.Context, *TaskListReq) (*TaskList, error)
- func (UnimplementedRatchetDaemonServer) ListTeams(context.Context, *ListTeamsReq) (*TeamList, error)
- func (UnimplementedRatchetDaemonServer) MeshStream(grpc.BidiStreamingServer[MeshEvent, MeshEvent]) error
- func (UnimplementedRatchetDaemonServer) PauseCron(context.Context, *CronJobReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) PauseJob(context.Context, *JobReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) PauseProject(context.Context, *ProjectReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) RegisterMeshNode(context.Context, *RegisterNodeReq) (*RegisterNodeResp, error)
- func (UnimplementedRatchetDaemonServer) RejectPlan(context.Context, *RejectPlanReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) RemoveProvider(context.Context, *RemoveProviderReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) RenameTeam(context.Context, *TeamRenameReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) RequestReload(*ReloadReq, grpc.ServerStreamingServer[ReloadStatus]) error
- func (UnimplementedRatchetDaemonServer) RespondToHuman(context.Context, *HumanResponse) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) RespondToPermission(context.Context, *PermissionResponse) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) ResumeCron(context.Context, *CronJobReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) ResumeJob(context.Context, *JobReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) ResumeProject(context.Context, *ProjectReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) SendMessage(*SendMessageReq, grpc.ServerStreamingServer[ChatEvent]) error
- func (UnimplementedRatchetDaemonServer) SetDefaultProvider(context.Context, *SetDefaultProviderReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) Shutdown(context.Context, *Empty) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) StartFleet(*StartFleetReq, grpc.ServerStreamingServer[ChatEvent]) error
- func (UnimplementedRatchetDaemonServer) StartProject(context.Context, *StartProjectReq) (*ProjectStatus, error)
- func (UnimplementedRatchetDaemonServer) StartTeam(*StartTeamReq, grpc.ServerStreamingServer[TeamEvent]) error
- func (UnimplementedRatchetDaemonServer) SteerTeam(context.Context, *SteerTeamReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) StopCron(context.Context, *CronJobReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) TeamAddAgent(context.Context, *TeamAddAgentReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) TeamRemoveAgent(context.Context, *TeamRemoveAgentReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) TestProvider(context.Context, *TestProviderReq) (*TestProviderResult, error)
- func (UnimplementedRatchetDaemonServer) UpdateProviderModel(context.Context, *UpdateProviderModelReq) (*Empty, error)
- func (UnimplementedRatchetDaemonServer) UpdateTask(context.Context, *TaskUpdateReq) (*TaskInfo, error)
- type UnsafeRatchetDaemonServer
- type UpdateProviderModelReq
- func (*UpdateProviderModelReq) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateProviderModelReq) GetAlias() string
- func (x *UpdateProviderModelReq) GetModel() string
- func (*UpdateProviderModelReq) ProtoMessage()
- func (x *UpdateProviderModelReq) ProtoReflect() protoreflect.Message
- func (x *UpdateProviderModelReq) Reset()
- func (x *UpdateProviderModelReq) String() string
- type VersionCheckReq
- func (*VersionCheckReq) Descriptor() ([]byte, []int)deprecated
- func (x *VersionCheckReq) GetCliCommit() string
- func (x *VersionCheckReq) GetCliProtoVersion() int32
- func (x *VersionCheckReq) GetCliVersion() string
- func (*VersionCheckReq) ProtoMessage()
- func (x *VersionCheckReq) ProtoReflect() protoreflect.Message
- func (x *VersionCheckReq) Reset()
- func (x *VersionCheckReq) String() string
- type VersionCheckResp
- func (*VersionCheckResp) Descriptor() ([]byte, []int)deprecated
- func (x *VersionCheckResp) GetCompatible() bool
- func (x *VersionCheckResp) GetDaemonVersion() string
- func (x *VersionCheckResp) GetMessage() string
- func (x *VersionCheckResp) GetReloadRecommended() bool
- func (*VersionCheckResp) ProtoMessage()
- func (x *VersionCheckResp) ProtoReflect() protoreflect.Message
- func (x *VersionCheckResp) Reset()
- func (x *VersionCheckResp) String() string
Constants ¶
const ( RatchetDaemon_CreateSession_FullMethodName = "/ratchet.RatchetDaemon/CreateSession" RatchetDaemon_ListSessions_FullMethodName = "/ratchet.RatchetDaemon/ListSessions" RatchetDaemon_AttachSession_FullMethodName = "/ratchet.RatchetDaemon/AttachSession" RatchetDaemon_DetachSession_FullMethodName = "/ratchet.RatchetDaemon/DetachSession" RatchetDaemon_KillSession_FullMethodName = "/ratchet.RatchetDaemon/KillSession" RatchetDaemon_SendMessage_FullMethodName = "/ratchet.RatchetDaemon/SendMessage" RatchetDaemon_RespondToPermission_FullMethodName = "/ratchet.RatchetDaemon/RespondToPermission" RatchetDaemon_AddProvider_FullMethodName = "/ratchet.RatchetDaemon/AddProvider" RatchetDaemon_ListProviders_FullMethodName = "/ratchet.RatchetDaemon/ListProviders" RatchetDaemon_TestProvider_FullMethodName = "/ratchet.RatchetDaemon/TestProvider" RatchetDaemon_RemoveProvider_FullMethodName = "/ratchet.RatchetDaemon/RemoveProvider" RatchetDaemon_SetDefaultProvider_FullMethodName = "/ratchet.RatchetDaemon/SetDefaultProvider" RatchetDaemon_UpdateProviderModel_FullMethodName = "/ratchet.RatchetDaemon/UpdateProviderModel" RatchetDaemon_ListAgents_FullMethodName = "/ratchet.RatchetDaemon/ListAgents" RatchetDaemon_GetAgentStatus_FullMethodName = "/ratchet.RatchetDaemon/GetAgentStatus" RatchetDaemon_StartTeam_FullMethodName = "/ratchet.RatchetDaemon/StartTeam" RatchetDaemon_GetTeamStatus_FullMethodName = "/ratchet.RatchetDaemon/GetTeamStatus" RatchetDaemon_ApprovePlan_FullMethodName = "/ratchet.RatchetDaemon/ApprovePlan" RatchetDaemon_RejectPlan_FullMethodName = "/ratchet.RatchetDaemon/RejectPlan" RatchetDaemon_StartFleet_FullMethodName = "/ratchet.RatchetDaemon/StartFleet" RatchetDaemon_GetFleetStatus_FullMethodName = "/ratchet.RatchetDaemon/GetFleetStatus" RatchetDaemon_KillFleetWorker_FullMethodName = "/ratchet.RatchetDaemon/KillFleetWorker" RatchetDaemon_CreateCron_FullMethodName = "/ratchet.RatchetDaemon/CreateCron" RatchetDaemon_ListCrons_FullMethodName = "/ratchet.RatchetDaemon/ListCrons" RatchetDaemon_PauseCron_FullMethodName = "/ratchet.RatchetDaemon/PauseCron" RatchetDaemon_ResumeCron_FullMethodName = "/ratchet.RatchetDaemon/ResumeCron" RatchetDaemon_StopCron_FullMethodName = "/ratchet.RatchetDaemon/StopCron" RatchetDaemon_ListJobs_FullMethodName = "/ratchet.RatchetDaemon/ListJobs" RatchetDaemon_PauseJob_FullMethodName = "/ratchet.RatchetDaemon/PauseJob" RatchetDaemon_ResumeJob_FullMethodName = "/ratchet.RatchetDaemon/ResumeJob" RatchetDaemon_KillJob_FullMethodName = "/ratchet.RatchetDaemon/KillJob" RatchetDaemon_Health_FullMethodName = "/ratchet.RatchetDaemon/Health" RatchetDaemon_Shutdown_FullMethodName = "/ratchet.RatchetDaemon/Shutdown" RatchetDaemon_CheckVersion_FullMethodName = "/ratchet.RatchetDaemon/CheckVersion" RatchetDaemon_RequestReload_FullMethodName = "/ratchet.RatchetDaemon/RequestReload" RatchetDaemon_RegisterMeshNode_FullMethodName = "/ratchet.RatchetDaemon/RegisterMeshNode" RatchetDaemon_MeshStream_FullMethodName = "/ratchet.RatchetDaemon/MeshStream" RatchetDaemon_ListTeams_FullMethodName = "/ratchet.RatchetDaemon/ListTeams" RatchetDaemon_KillTeam_FullMethodName = "/ratchet.RatchetDaemon/KillTeam" RatchetDaemon_RenameTeam_FullMethodName = "/ratchet.RatchetDaemon/RenameTeam" RatchetDaemon_TeamAddAgent_FullMethodName = "/ratchet.RatchetDaemon/TeamAddAgent" RatchetDaemon_TeamRemoveAgent_FullMethodName = "/ratchet.RatchetDaemon/TeamRemoveAgent" RatchetDaemon_AttachTeam_FullMethodName = "/ratchet.RatchetDaemon/AttachTeam" RatchetDaemon_SteerTeam_FullMethodName = "/ratchet.RatchetDaemon/SteerTeam" RatchetDaemon_DirectMessage_FullMethodName = "/ratchet.RatchetDaemon/DirectMessage" RatchetDaemon_RespondToHuman_FullMethodName = "/ratchet.RatchetDaemon/RespondToHuman" RatchetDaemon_ListPendingHuman_FullMethodName = "/ratchet.RatchetDaemon/ListPendingHuman" RatchetDaemon_StartProject_FullMethodName = "/ratchet.RatchetDaemon/StartProject" RatchetDaemon_ListProjects_FullMethodName = "/ratchet.RatchetDaemon/ListProjects" RatchetDaemon_PauseProject_FullMethodName = "/ratchet.RatchetDaemon/PauseProject" RatchetDaemon_ResumeProject_FullMethodName = "/ratchet.RatchetDaemon/ResumeProject" RatchetDaemon_KillProject_FullMethodName = "/ratchet.RatchetDaemon/KillProject" RatchetDaemon_GetProjectStatus_FullMethodName = "/ratchet.RatchetDaemon/GetProjectStatus" RatchetDaemon_CreateTask_FullMethodName = "/ratchet.RatchetDaemon/CreateTask" RatchetDaemon_ClaimTask_FullMethodName = "/ratchet.RatchetDaemon/ClaimTask" RatchetDaemon_UpdateTask_FullMethodName = "/ratchet.RatchetDaemon/UpdateTask" RatchetDaemon_ListTasks_FullMethodName = "/ratchet.RatchetDaemon/ListTasks" RatchetDaemon_GetTask_FullMethodName = "/ratchet.RatchetDaemon/GetTask" )
Variables ¶
var File_internal_proto_ratchet_proto protoreflect.FileDescriptor
var RatchetDaemon_ServiceDesc = grpc.ServiceDesc{ ServiceName: "ratchet.RatchetDaemon", HandlerType: (*RatchetDaemonServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateSession", Handler: _RatchetDaemon_CreateSession_Handler, }, { MethodName: "ListSessions", Handler: _RatchetDaemon_ListSessions_Handler, }, { MethodName: "DetachSession", Handler: _RatchetDaemon_DetachSession_Handler, }, { MethodName: "KillSession", Handler: _RatchetDaemon_KillSession_Handler, }, { MethodName: "RespondToPermission", Handler: _RatchetDaemon_RespondToPermission_Handler, }, { MethodName: "AddProvider", Handler: _RatchetDaemon_AddProvider_Handler, }, { MethodName: "ListProviders", Handler: _RatchetDaemon_ListProviders_Handler, }, { MethodName: "TestProvider", Handler: _RatchetDaemon_TestProvider_Handler, }, { MethodName: "RemoveProvider", Handler: _RatchetDaemon_RemoveProvider_Handler, }, { MethodName: "SetDefaultProvider", Handler: _RatchetDaemon_SetDefaultProvider_Handler, }, { MethodName: "UpdateProviderModel", Handler: _RatchetDaemon_UpdateProviderModel_Handler, }, { MethodName: "ListAgents", Handler: _RatchetDaemon_ListAgents_Handler, }, { MethodName: "GetAgentStatus", Handler: _RatchetDaemon_GetAgentStatus_Handler, }, { MethodName: "GetTeamStatus", Handler: _RatchetDaemon_GetTeamStatus_Handler, }, { MethodName: "RejectPlan", Handler: _RatchetDaemon_RejectPlan_Handler, }, { MethodName: "GetFleetStatus", Handler: _RatchetDaemon_GetFleetStatus_Handler, }, { MethodName: "KillFleetWorker", Handler: _RatchetDaemon_KillFleetWorker_Handler, }, { MethodName: "CreateCron", Handler: _RatchetDaemon_CreateCron_Handler, }, { MethodName: "ListCrons", Handler: _RatchetDaemon_ListCrons_Handler, }, { MethodName: "PauseCron", Handler: _RatchetDaemon_PauseCron_Handler, }, { MethodName: "ResumeCron", Handler: _RatchetDaemon_ResumeCron_Handler, }, { MethodName: "StopCron", Handler: _RatchetDaemon_StopCron_Handler, }, { MethodName: "ListJobs", Handler: _RatchetDaemon_ListJobs_Handler, }, { MethodName: "PauseJob", Handler: _RatchetDaemon_PauseJob_Handler, }, { MethodName: "ResumeJob", Handler: _RatchetDaemon_ResumeJob_Handler, }, { MethodName: "KillJob", Handler: _RatchetDaemon_KillJob_Handler, }, { MethodName: "Health", Handler: _RatchetDaemon_Health_Handler, }, { MethodName: "Shutdown", Handler: _RatchetDaemon_Shutdown_Handler, }, { MethodName: "CheckVersion", Handler: _RatchetDaemon_CheckVersion_Handler, }, { MethodName: "RegisterMeshNode", Handler: _RatchetDaemon_RegisterMeshNode_Handler, }, { MethodName: "ListTeams", Handler: _RatchetDaemon_ListTeams_Handler, }, { MethodName: "KillTeam", Handler: _RatchetDaemon_KillTeam_Handler, }, { MethodName: "RenameTeam", Handler: _RatchetDaemon_RenameTeam_Handler, }, { MethodName: "TeamAddAgent", Handler: _RatchetDaemon_TeamAddAgent_Handler, }, { MethodName: "TeamRemoveAgent", Handler: _RatchetDaemon_TeamRemoveAgent_Handler, }, { MethodName: "SteerTeam", Handler: _RatchetDaemon_SteerTeam_Handler, }, { MethodName: "DirectMessage", Handler: _RatchetDaemon_DirectMessage_Handler, }, { MethodName: "RespondToHuman", Handler: _RatchetDaemon_RespondToHuman_Handler, }, { MethodName: "ListPendingHuman", Handler: _RatchetDaemon_ListPendingHuman_Handler, }, { MethodName: "StartProject", Handler: _RatchetDaemon_StartProject_Handler, }, { MethodName: "ListProjects", Handler: _RatchetDaemon_ListProjects_Handler, }, { MethodName: "PauseProject", Handler: _RatchetDaemon_PauseProject_Handler, }, { MethodName: "ResumeProject", Handler: _RatchetDaemon_ResumeProject_Handler, }, { MethodName: "KillProject", Handler: _RatchetDaemon_KillProject_Handler, }, { MethodName: "GetProjectStatus", Handler: _RatchetDaemon_GetProjectStatus_Handler, }, { MethodName: "CreateTask", Handler: _RatchetDaemon_CreateTask_Handler, }, { MethodName: "ClaimTask", Handler: _RatchetDaemon_ClaimTask_Handler, }, { MethodName: "UpdateTask", Handler: _RatchetDaemon_UpdateTask_Handler, }, { MethodName: "ListTasks", Handler: _RatchetDaemon_ListTasks_Handler, }, { MethodName: "GetTask", Handler: _RatchetDaemon_GetTask_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "AttachSession", Handler: _RatchetDaemon_AttachSession_Handler, ServerStreams: true, }, { StreamName: "SendMessage", Handler: _RatchetDaemon_SendMessage_Handler, ServerStreams: true, }, { StreamName: "StartTeam", Handler: _RatchetDaemon_StartTeam_Handler, ServerStreams: true, }, { StreamName: "ApprovePlan", Handler: _RatchetDaemon_ApprovePlan_Handler, ServerStreams: true, }, { StreamName: "StartFleet", Handler: _RatchetDaemon_StartFleet_Handler, ServerStreams: true, }, { StreamName: "RequestReload", Handler: _RatchetDaemon_RequestReload_Handler, ServerStreams: true, }, { StreamName: "MeshStream", Handler: _RatchetDaemon_MeshStream_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "AttachTeam", Handler: _RatchetDaemon_AttachTeam_Handler, ServerStreams: true, }, }, Metadata: "internal/proto/ratchet.proto", }
RatchetDaemon_ServiceDesc is the grpc.ServiceDesc for RatchetDaemon service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRatchetDaemonServer ¶
func RegisterRatchetDaemonServer(s grpc.ServiceRegistrar, srv RatchetDaemonServer)
Types ¶
type AddProviderReq ¶
type AddProviderReq struct {
Alias string `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
Model string `protobuf:"bytes,3,opt,name=model,proto3" json:"model,omitempty"`
ApiKey string `protobuf:"bytes,4,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"`
BaseUrl string `protobuf:"bytes,5,opt,name=base_url,json=baseUrl,proto3" json:"base_url,omitempty"`
MaxTokens int32 `protobuf:"varint,6,opt,name=max_tokens,json=maxTokens,proto3" json:"max_tokens,omitempty"`
IsDefault bool `protobuf:"varint,7,opt,name=is_default,json=isDefault,proto3" json:"is_default,omitempty"`
// contains filtered or unexported fields
}
Provider management
func (*AddProviderReq) Descriptor
deprecated
func (*AddProviderReq) Descriptor() ([]byte, []int)
Deprecated: Use AddProviderReq.ProtoReflect.Descriptor instead.
func (*AddProviderReq) GetAlias ¶
func (x *AddProviderReq) GetAlias() string
func (*AddProviderReq) GetApiKey ¶
func (x *AddProviderReq) GetApiKey() string
func (*AddProviderReq) GetBaseUrl ¶
func (x *AddProviderReq) GetBaseUrl() string
func (*AddProviderReq) GetIsDefault ¶
func (x *AddProviderReq) GetIsDefault() bool
func (*AddProviderReq) GetMaxTokens ¶
func (x *AddProviderReq) GetMaxTokens() int32
func (*AddProviderReq) GetModel ¶
func (x *AddProviderReq) GetModel() string
func (*AddProviderReq) GetType ¶
func (x *AddProviderReq) GetType() string
func (*AddProviderReq) ProtoMessage ¶
func (*AddProviderReq) ProtoMessage()
func (*AddProviderReq) ProtoReflect ¶
func (x *AddProviderReq) ProtoReflect() protoreflect.Message
func (*AddProviderReq) Reset ¶
func (x *AddProviderReq) Reset()
func (*AddProviderReq) String ¶
func (x *AddProviderReq) String() string
type Agent ¶
type Agent struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Role string `protobuf:"bytes,3,opt,name=role,proto3" json:"role,omitempty"`
Status string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
Model string `protobuf:"bytes,5,opt,name=model,proto3" json:"model,omitempty"`
Provider string `protobuf:"bytes,6,opt,name=provider,proto3" json:"provider,omitempty"`
CurrentTask string `protobuf:"bytes,7,opt,name=current_task,json=currentTask,proto3" json:"current_task,omitempty"`
SessionId string `protobuf:"bytes,8,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
// contains filtered or unexported fields
}
Agent management
func (*Agent) Descriptor
deprecated
func (*Agent) GetCurrentTask ¶
func (*Agent) GetProvider ¶
func (*Agent) GetSessionId ¶
func (*Agent) ProtoMessage ¶
func (*Agent) ProtoMessage()
func (*Agent) ProtoReflect ¶
func (x *Agent) ProtoReflect() protoreflect.Message
type AgentList ¶
type AgentList struct {
Agents []*Agent `protobuf:"bytes,1,rep,name=agents,proto3" json:"agents,omitempty"`
// contains filtered or unexported fields
}
func (*AgentList) Descriptor
deprecated
func (*AgentList) ProtoMessage ¶
func (*AgentList) ProtoMessage()
func (*AgentList) ProtoReflect ¶
func (x *AgentList) ProtoReflect() protoreflect.Message
type AgentMessage ¶
type AgentMessage struct {
FromAgent string `protobuf:"bytes,1,opt,name=from_agent,json=fromAgent,proto3" json:"from_agent,omitempty"`
ToAgent string `protobuf:"bytes,2,opt,name=to_agent,json=toAgent,proto3" json:"to_agent,omitempty"`
Content string `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
// contains filtered or unexported fields
}
func (*AgentMessage) Descriptor
deprecated
func (*AgentMessage) Descriptor() ([]byte, []int)
Deprecated: Use AgentMessage.ProtoReflect.Descriptor instead.
func (*AgentMessage) GetContent ¶
func (x *AgentMessage) GetContent() string
func (*AgentMessage) GetFromAgent ¶
func (x *AgentMessage) GetFromAgent() string
func (*AgentMessage) GetToAgent ¶
func (x *AgentMessage) GetToAgent() string
func (*AgentMessage) ProtoMessage ¶
func (*AgentMessage) ProtoMessage()
func (*AgentMessage) ProtoReflect ¶
func (x *AgentMessage) ProtoReflect() protoreflect.Message
func (*AgentMessage) Reset ¶
func (x *AgentMessage) Reset()
func (*AgentMessage) String ¶
func (x *AgentMessage) String() string
type AgentSpawned ¶
type AgentSpawned struct {
AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
AgentName string `protobuf:"bytes,2,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"`
Role string `protobuf:"bytes,3,opt,name=role,proto3" json:"role,omitempty"`
// contains filtered or unexported fields
}
func (*AgentSpawned) Descriptor
deprecated
func (*AgentSpawned) Descriptor() ([]byte, []int)
Deprecated: Use AgentSpawned.ProtoReflect.Descriptor instead.
func (*AgentSpawned) GetAgentId ¶
func (x *AgentSpawned) GetAgentId() string
func (*AgentSpawned) GetAgentName ¶
func (x *AgentSpawned) GetAgentName() string
func (*AgentSpawned) GetRole ¶
func (x *AgentSpawned) GetRole() string
func (*AgentSpawned) ProtoMessage ¶
func (*AgentSpawned) ProtoMessage()
func (*AgentSpawned) ProtoReflect ¶
func (x *AgentSpawned) ProtoReflect() protoreflect.Message
func (*AgentSpawned) Reset ¶
func (x *AgentSpawned) Reset()
func (*AgentSpawned) String ¶
func (x *AgentSpawned) String() string
type AgentStatusReq ¶
type AgentStatusReq struct {
AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
// contains filtered or unexported fields
}
func (*AgentStatusReq) Descriptor
deprecated
func (*AgentStatusReq) Descriptor() ([]byte, []int)
Deprecated: Use AgentStatusReq.ProtoReflect.Descriptor instead.
func (*AgentStatusReq) GetAgentId ¶
func (x *AgentStatusReq) GetAgentId() string
func (*AgentStatusReq) ProtoMessage ¶
func (*AgentStatusReq) ProtoMessage()
func (*AgentStatusReq) ProtoReflect ¶
func (x *AgentStatusReq) ProtoReflect() protoreflect.Message
func (*AgentStatusReq) Reset ¶
func (x *AgentStatusReq) Reset()
func (*AgentStatusReq) String ¶
func (x *AgentStatusReq) String() string
type ApprovePlanReq ¶
type ApprovePlanReq struct {
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
PlanId string `protobuf:"bytes,2,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty"`
SkipSteps []string `protobuf:"bytes,3,rep,name=skip_steps,json=skipSteps,proto3" json:"skip_steps,omitempty"`
// contains filtered or unexported fields
}
func (*ApprovePlanReq) Descriptor
deprecated
func (*ApprovePlanReq) Descriptor() ([]byte, []int)
Deprecated: Use ApprovePlanReq.ProtoReflect.Descriptor instead.
func (*ApprovePlanReq) GetPlanId ¶
func (x *ApprovePlanReq) GetPlanId() string
func (*ApprovePlanReq) GetSessionId ¶
func (x *ApprovePlanReq) GetSessionId() string
func (*ApprovePlanReq) GetSkipSteps ¶
func (x *ApprovePlanReq) GetSkipSteps() []string
func (*ApprovePlanReq) ProtoMessage ¶
func (*ApprovePlanReq) ProtoMessage()
func (*ApprovePlanReq) ProtoReflect ¶
func (x *ApprovePlanReq) ProtoReflect() protoreflect.Message
func (*ApprovePlanReq) Reset ¶
func (x *ApprovePlanReq) Reset()
func (*ApprovePlanReq) String ¶
func (x *ApprovePlanReq) String() string
type AttachReq ¶
type AttachReq struct {
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
// contains filtered or unexported fields
}
func (*AttachReq) Descriptor
deprecated
func (*AttachReq) GetSessionId ¶
func (*AttachReq) ProtoMessage ¶
func (*AttachReq) ProtoMessage()
func (*AttachReq) ProtoReflect ¶
func (x *AttachReq) ProtoReflect() protoreflect.Message
type AttachTeamReq ¶
type AttachTeamReq struct {
TeamId string `protobuf:"bytes,1,opt,name=team_id,json=teamId,proto3" json:"team_id,omitempty"`
Mode string `protobuf:"bytes,2,opt,name=mode,proto3" json:"mode,omitempty"` // "observe" or "join"
// contains filtered or unexported fields
}
Attach/detach
func (*AttachTeamReq) Descriptor
deprecated
func (*AttachTeamReq) Descriptor() ([]byte, []int)
Deprecated: Use AttachTeamReq.ProtoReflect.Descriptor instead.
func (*AttachTeamReq) GetMode ¶
func (x *AttachTeamReq) GetMode() string
func (*AttachTeamReq) GetTeamId ¶
func (x *AttachTeamReq) GetTeamId() string
func (*AttachTeamReq) ProtoMessage ¶
func (*AttachTeamReq) ProtoMessage()
func (*AttachTeamReq) ProtoReflect ¶
func (x *AttachTeamReq) ProtoReflect() protoreflect.Message
func (*AttachTeamReq) Reset ¶
func (x *AttachTeamReq) Reset()
func (*AttachTeamReq) String ¶
func (x *AttachTeamReq) String() string
type AuthError ¶
type AuthError struct {
Provider string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"`
Alias string `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*AuthError) Descriptor
deprecated
func (*AuthError) GetMessage ¶
func (*AuthError) GetProvider ¶
func (*AuthError) ProtoMessage ¶
func (*AuthError) ProtoMessage()
func (*AuthError) ProtoReflect ¶
func (x *AuthError) ProtoReflect() protoreflect.Message
type BlackboardSync ¶
type BlackboardSync struct {
Section string `protobuf:"bytes,1,opt,name=section,proto3" json:"section,omitempty"`
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
Author string `protobuf:"bytes,4,opt,name=author,proto3" json:"author,omitempty"`
Revision int64 `protobuf:"varint,5,opt,name=revision,proto3" json:"revision,omitempty"`
// contains filtered or unexported fields
}
Blackboard sync between mesh peers
func (*BlackboardSync) Descriptor
deprecated
func (*BlackboardSync) Descriptor() ([]byte, []int)
Deprecated: Use BlackboardSync.ProtoReflect.Descriptor instead.
func (*BlackboardSync) GetAuthor ¶
func (x *BlackboardSync) GetAuthor() string
func (*BlackboardSync) GetKey ¶
func (x *BlackboardSync) GetKey() string
func (*BlackboardSync) GetRevision ¶
func (x *BlackboardSync) GetRevision() int64
func (*BlackboardSync) GetSection ¶
func (x *BlackboardSync) GetSection() string
func (*BlackboardSync) GetValue ¶
func (x *BlackboardSync) GetValue() []byte
func (*BlackboardSync) ProtoMessage ¶
func (*BlackboardSync) ProtoMessage()
func (*BlackboardSync) ProtoReflect ¶
func (x *BlackboardSync) ProtoReflect() protoreflect.Message
func (*BlackboardSync) Reset ¶
func (x *BlackboardSync) Reset()
func (*BlackboardSync) String ¶
func (x *BlackboardSync) String() string
type ChatEvent ¶
type ChatEvent struct {
// Types that are valid to be assigned to Event:
//
// *ChatEvent_Token
// *ChatEvent_ToolStart
// *ChatEvent_ToolResult
// *ChatEvent_Permission
// *ChatEvent_AgentSpawned
// *ChatEvent_AgentMessage
// *ChatEvent_Complete
// *ChatEvent_Error
// *ChatEvent_History
// *ChatEvent_PlanProposed
// *ChatEvent_PlanStepUpdate
// *ChatEvent_FleetStatus
// *ChatEvent_ContextCompressed
// *ChatEvent_AuthError
// *ChatEvent_Thinking
Event isChatEvent_Event `protobuf_oneof:"event"`
// contains filtered or unexported fields
}
func (*ChatEvent) Descriptor
deprecated
func (*ChatEvent) GetAgentMessage ¶
func (x *ChatEvent) GetAgentMessage() *AgentMessage
func (*ChatEvent) GetAgentSpawned ¶
func (x *ChatEvent) GetAgentSpawned() *AgentSpawned
func (*ChatEvent) GetAuthError ¶
func (*ChatEvent) GetComplete ¶
func (x *ChatEvent) GetComplete() *SessionComplete
func (*ChatEvent) GetContextCompressed ¶
func (x *ChatEvent) GetContextCompressed() *ContextCompressedEvent
func (*ChatEvent) GetError ¶
func (x *ChatEvent) GetError() *ErrorEvent
func (*ChatEvent) GetFleetStatus ¶
func (x *ChatEvent) GetFleetStatus() *FleetStatus
func (*ChatEvent) GetHistory ¶
func (x *ChatEvent) GetHistory() *SessionHistory
func (*ChatEvent) GetPermission ¶
func (x *ChatEvent) GetPermission() *PermissionRequest
func (*ChatEvent) GetPlanProposed ¶
func (*ChatEvent) GetPlanStepUpdate ¶
func (*ChatEvent) GetThinking ¶
func (x *ChatEvent) GetThinking() *ThinkingBlock
func (*ChatEvent) GetToken ¶
func (x *ChatEvent) GetToken() *TokenDelta
func (*ChatEvent) GetToolResult ¶
func (x *ChatEvent) GetToolResult() *ToolCallResult
func (*ChatEvent) GetToolStart ¶
func (x *ChatEvent) GetToolStart() *ToolCallStart
func (*ChatEvent) ProtoMessage ¶
func (*ChatEvent) ProtoMessage()
func (*ChatEvent) ProtoReflect ¶
func (x *ChatEvent) ProtoReflect() protoreflect.Message
type ChatEvent_AgentMessage ¶
type ChatEvent_AgentMessage struct {
AgentMessage *AgentMessage `protobuf:"bytes,6,opt,name=agent_message,json=agentMessage,proto3,oneof"`
}
type ChatEvent_AgentSpawned ¶
type ChatEvent_AgentSpawned struct {
AgentSpawned *AgentSpawned `protobuf:"bytes,5,opt,name=agent_spawned,json=agentSpawned,proto3,oneof"`
}
type ChatEvent_AuthError ¶
type ChatEvent_AuthError struct {
AuthError *AuthError `protobuf:"bytes,14,opt,name=auth_error,json=authError,proto3,oneof"`
}
type ChatEvent_Complete ¶
type ChatEvent_Complete struct {
Complete *SessionComplete `protobuf:"bytes,7,opt,name=complete,proto3,oneof"`
}
type ChatEvent_ContextCompressed ¶
type ChatEvent_ContextCompressed struct {
ContextCompressed *ContextCompressedEvent `protobuf:"bytes,13,opt,name=context_compressed,json=contextCompressed,proto3,oneof"`
}
type ChatEvent_Error ¶
type ChatEvent_Error struct {
Error *ErrorEvent `protobuf:"bytes,8,opt,name=error,proto3,oneof"`
}
type ChatEvent_FleetStatus ¶
type ChatEvent_FleetStatus struct {
FleetStatus *FleetStatus `protobuf:"bytes,12,opt,name=fleet_status,json=fleetStatus,proto3,oneof"`
}
type ChatEvent_History ¶
type ChatEvent_History struct {
History *SessionHistory `protobuf:"bytes,9,opt,name=history,proto3,oneof"`
}
type ChatEvent_Permission ¶
type ChatEvent_Permission struct {
Permission *PermissionRequest `protobuf:"bytes,4,opt,name=permission,proto3,oneof"`
}
type ChatEvent_PlanProposed ¶
type ChatEvent_PlanProposed struct {
PlanProposed *Plan `protobuf:"bytes,10,opt,name=plan_proposed,json=planProposed,proto3,oneof"`
}
type ChatEvent_PlanStepUpdate ¶
type ChatEvent_PlanStepUpdate struct {
PlanStepUpdate *PlanStep `protobuf:"bytes,11,opt,name=plan_step_update,json=planStepUpdate,proto3,oneof"`
}
type ChatEvent_Thinking ¶
type ChatEvent_Thinking struct {
Thinking *ThinkingBlock `protobuf:"bytes,15,opt,name=thinking,proto3,oneof"`
}
type ChatEvent_Token ¶
type ChatEvent_Token struct {
Token *TokenDelta `protobuf:"bytes,1,opt,name=token,proto3,oneof"`
}
type ChatEvent_ToolResult ¶
type ChatEvent_ToolResult struct {
ToolResult *ToolCallResult `protobuf:"bytes,3,opt,name=tool_result,json=toolResult,proto3,oneof"`
}
type ChatEvent_ToolStart ¶
type ChatEvent_ToolStart struct {
ToolStart *ToolCallStart `protobuf:"bytes,2,opt,name=tool_start,json=toolStart,proto3,oneof"`
}
type ContextCompressedEvent ¶
type ContextCompressedEvent struct {
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
Summary string `protobuf:"bytes,2,opt,name=summary,proto3" json:"summary,omitempty"` // short text summary of compressed messages
MessagesRemoved int32 `protobuf:"varint,3,opt,name=messages_removed,json=messagesRemoved,proto3" json:"messages_removed,omitempty"`
MessagesKept int32 `protobuf:"varint,4,opt,name=messages_kept,json=messagesKept,proto3" json:"messages_kept,omitempty"`
// contains filtered or unexported fields
}
func (*ContextCompressedEvent) Descriptor
deprecated
func (*ContextCompressedEvent) Descriptor() ([]byte, []int)
Deprecated: Use ContextCompressedEvent.ProtoReflect.Descriptor instead.
func (*ContextCompressedEvent) GetMessagesKept ¶
func (x *ContextCompressedEvent) GetMessagesKept() int32
func (*ContextCompressedEvent) GetMessagesRemoved ¶
func (x *ContextCompressedEvent) GetMessagesRemoved() int32
func (*ContextCompressedEvent) GetSessionId ¶
func (x *ContextCompressedEvent) GetSessionId() string
func (*ContextCompressedEvent) GetSummary ¶
func (x *ContextCompressedEvent) GetSummary() string
func (*ContextCompressedEvent) ProtoMessage ¶
func (*ContextCompressedEvent) ProtoMessage()
func (*ContextCompressedEvent) ProtoReflect ¶
func (x *ContextCompressedEvent) ProtoReflect() protoreflect.Message
func (*ContextCompressedEvent) Reset ¶
func (x *ContextCompressedEvent) Reset()
func (*ContextCompressedEvent) String ¶
func (x *ContextCompressedEvent) String() string
type CreateCronReq ¶
type CreateCronReq struct {
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
Schedule string `protobuf:"bytes,2,opt,name=schedule,proto3" json:"schedule,omitempty"`
Command string `protobuf:"bytes,3,opt,name=command,proto3" json:"command,omitempty"`
// contains filtered or unexported fields
}
func (*CreateCronReq) Descriptor
deprecated
func (*CreateCronReq) Descriptor() ([]byte, []int)
Deprecated: Use CreateCronReq.ProtoReflect.Descriptor instead.
func (*CreateCronReq) GetCommand ¶
func (x *CreateCronReq) GetCommand() string
func (*CreateCronReq) GetSchedule ¶
func (x *CreateCronReq) GetSchedule() string
func (*CreateCronReq) GetSessionId ¶
func (x *CreateCronReq) GetSessionId() string
func (*CreateCronReq) ProtoMessage ¶
func (*CreateCronReq) ProtoMessage()
func (*CreateCronReq) ProtoReflect ¶
func (x *CreateCronReq) ProtoReflect() protoreflect.Message
func (*CreateCronReq) Reset ¶
func (x *CreateCronReq) Reset()
func (*CreateCronReq) String ¶
func (x *CreateCronReq) String() string
type CreateSessionReq ¶
type CreateSessionReq struct {
InitialPrompt string `protobuf:"bytes,1,opt,name=initial_prompt,json=initialPrompt,proto3" json:"initial_prompt,omitempty"`
WorkingDir string `protobuf:"bytes,2,opt,name=working_dir,json=workingDir,proto3" json:"working_dir,omitempty"`
Provider string `protobuf:"bytes,3,opt,name=provider,proto3" json:"provider,omitempty"`
Model string `protobuf:"bytes,4,opt,name=model,proto3" json:"model,omitempty"`
// contains filtered or unexported fields
}
func (*CreateSessionReq) Descriptor
deprecated
func (*CreateSessionReq) Descriptor() ([]byte, []int)
Deprecated: Use CreateSessionReq.ProtoReflect.Descriptor instead.
func (*CreateSessionReq) GetInitialPrompt ¶
func (x *CreateSessionReq) GetInitialPrompt() string
func (*CreateSessionReq) GetModel ¶
func (x *CreateSessionReq) GetModel() string
func (*CreateSessionReq) GetProvider ¶
func (x *CreateSessionReq) GetProvider() string
func (*CreateSessionReq) GetWorkingDir ¶
func (x *CreateSessionReq) GetWorkingDir() string
func (*CreateSessionReq) ProtoMessage ¶
func (*CreateSessionReq) ProtoMessage()
func (*CreateSessionReq) ProtoReflect ¶
func (x *CreateSessionReq) ProtoReflect() protoreflect.Message
func (*CreateSessionReq) Reset ¶
func (x *CreateSessionReq) Reset()
func (*CreateSessionReq) String ¶
func (x *CreateSessionReq) String() string
type CronJob ¶
type CronJob struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
Schedule string `protobuf:"bytes,3,opt,name=schedule,proto3" json:"schedule,omitempty"` // duration ("5m") or cron expr ("*/10 * * * *")
Command string `protobuf:"bytes,4,opt,name=command,proto3" json:"command,omitempty"` // slash command or prompt
Status string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"` // active, paused, stopped
LastRun string `protobuf:"bytes,6,opt,name=last_run,json=lastRun,proto3" json:"last_run,omitempty"`
NextRun string `protobuf:"bytes,7,opt,name=next_run,json=nextRun,proto3" json:"next_run,omitempty"`
RunCount int32 `protobuf:"varint,8,opt,name=run_count,json=runCount,proto3" json:"run_count,omitempty"`
// contains filtered or unexported fields
}
Cron scheduling
func (*CronJob) Descriptor
deprecated
func (*CronJob) GetCommand ¶
func (*CronJob) GetLastRun ¶
func (*CronJob) GetNextRun ¶
func (*CronJob) GetRunCount ¶
func (*CronJob) GetSchedule ¶
func (*CronJob) GetSessionId ¶
func (*CronJob) ProtoMessage ¶
func (*CronJob) ProtoMessage()
func (*CronJob) ProtoReflect ¶
func (x *CronJob) ProtoReflect() protoreflect.Message
type CronJobList ¶
type CronJobList struct {
Jobs []*CronJob `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
// contains filtered or unexported fields
}
func (*CronJobList) Descriptor
deprecated
func (*CronJobList) Descriptor() ([]byte, []int)
Deprecated: Use CronJobList.ProtoReflect.Descriptor instead.
func (*CronJobList) GetJobs ¶
func (x *CronJobList) GetJobs() []*CronJob
func (*CronJobList) ProtoMessage ¶
func (*CronJobList) ProtoMessage()
func (*CronJobList) ProtoReflect ¶
func (x *CronJobList) ProtoReflect() protoreflect.Message
func (*CronJobList) Reset ¶
func (x *CronJobList) Reset()
func (*CronJobList) String ¶
func (x *CronJobList) String() string
type CronJobReq ¶
type CronJobReq struct {
JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
// contains filtered or unexported fields
}
func (*CronJobReq) Descriptor
deprecated
func (*CronJobReq) Descriptor() ([]byte, []int)
Deprecated: Use CronJobReq.ProtoReflect.Descriptor instead.
func (*CronJobReq) GetJobId ¶
func (x *CronJobReq) GetJobId() string
func (*CronJobReq) ProtoMessage ¶
func (*CronJobReq) ProtoMessage()
func (*CronJobReq) ProtoReflect ¶
func (x *CronJobReq) ProtoReflect() protoreflect.Message
func (*CronJobReq) Reset ¶
func (x *CronJobReq) Reset()
func (*CronJobReq) String ¶
func (x *CronJobReq) String() string
type DetachReq ¶
type DetachReq struct {
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
// contains filtered or unexported fields
}
func (*DetachReq) Descriptor
deprecated
func (*DetachReq) GetSessionId ¶
func (*DetachReq) ProtoMessage ¶
func (*DetachReq) ProtoMessage()
func (*DetachReq) ProtoReflect ¶
func (x *DetachReq) ProtoReflect() protoreflect.Message
type DirectMessageReq ¶
type DirectMessageReq struct {
TeamId string `protobuf:"bytes,1,opt,name=team_id,json=teamId,proto3" json:"team_id,omitempty"`
ToAgent string `protobuf:"bytes,2,opt,name=to_agent,json=toAgent,proto3" json:"to_agent,omitempty"`
Content string `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
// contains filtered or unexported fields
}
func (*DirectMessageReq) Descriptor
deprecated
func (*DirectMessageReq) Descriptor() ([]byte, []int)
Deprecated: Use DirectMessageReq.ProtoReflect.Descriptor instead.
func (*DirectMessageReq) GetContent ¶
func (x *DirectMessageReq) GetContent() string
func (*DirectMessageReq) GetTeamId ¶
func (x *DirectMessageReq) GetTeamId() string
func (*DirectMessageReq) GetToAgent ¶
func (x *DirectMessageReq) GetToAgent() string
func (*DirectMessageReq) ProtoMessage ¶
func (*DirectMessageReq) ProtoMessage()
func (*DirectMessageReq) ProtoReflect ¶
func (x *DirectMessageReq) ProtoReflect() protoreflect.Message
func (*DirectMessageReq) Reset ¶
func (x *DirectMessageReq) Reset()
func (*DirectMessageReq) String ¶
func (x *DirectMessageReq) String() string
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
type ErrorEvent ¶
type ErrorEvent struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
// contains filtered or unexported fields
}
func (*ErrorEvent) Descriptor
deprecated
func (*ErrorEvent) Descriptor() ([]byte, []int)
Deprecated: Use ErrorEvent.ProtoReflect.Descriptor instead.
func (*ErrorEvent) GetCode ¶
func (x *ErrorEvent) GetCode() string
func (*ErrorEvent) GetMessage ¶
func (x *ErrorEvent) GetMessage() string
func (*ErrorEvent) ProtoMessage ¶
func (*ErrorEvent) ProtoMessage()
func (*ErrorEvent) ProtoReflect ¶
func (x *ErrorEvent) ProtoReflect() protoreflect.Message
func (*ErrorEvent) Reset ¶
func (x *ErrorEvent) Reset()
func (*ErrorEvent) String ¶
func (x *ErrorEvent) String() string
type FleetStatus ¶
type FleetStatus struct {
FleetId string `protobuf:"bytes,1,opt,name=fleet_id,json=fleetId,proto3" json:"fleet_id,omitempty"`
SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
Workers []*FleetWorker `protobuf:"bytes,3,rep,name=workers,proto3" json:"workers,omitempty"`
Status string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"` // running, completed, failed
Completed int32 `protobuf:"varint,5,opt,name=completed,proto3" json:"completed,omitempty"`
Total int32 `protobuf:"varint,6,opt,name=total,proto3" json:"total,omitempty"`
// contains filtered or unexported fields
}
func (*FleetStatus) Descriptor
deprecated
func (*FleetStatus) Descriptor() ([]byte, []int)
Deprecated: Use FleetStatus.ProtoReflect.Descriptor instead.
func (*FleetStatus) GetCompleted ¶
func (x *FleetStatus) GetCompleted() int32
func (*FleetStatus) GetFleetId ¶
func (x *FleetStatus) GetFleetId() string
func (*FleetStatus) GetSessionId ¶
func (x *FleetStatus) GetSessionId() string
func (*FleetStatus) GetStatus ¶
func (x *FleetStatus) GetStatus() string
func (*FleetStatus) GetTotal ¶
func (x *FleetStatus) GetTotal() int32
func (*FleetStatus) GetWorkers ¶
func (x *FleetStatus) GetWorkers() []*FleetWorker
func (*FleetStatus) ProtoMessage ¶
func (*FleetStatus) ProtoMessage()
func (*FleetStatus) ProtoReflect ¶
func (x *FleetStatus) ProtoReflect() protoreflect.Message
func (*FleetStatus) Reset ¶
func (x *FleetStatus) Reset()
func (*FleetStatus) String ¶
func (x *FleetStatus) String() string
type FleetStatusReq ¶
type FleetStatusReq struct {
FleetId string `protobuf:"bytes,1,opt,name=fleet_id,json=fleetId,proto3" json:"fleet_id,omitempty"`
// contains filtered or unexported fields
}
func (*FleetStatusReq) Descriptor
deprecated
func (*FleetStatusReq) Descriptor() ([]byte, []int)
Deprecated: Use FleetStatusReq.ProtoReflect.Descriptor instead.
func (*FleetStatusReq) GetFleetId ¶
func (x *FleetStatusReq) GetFleetId() string
func (*FleetStatusReq) ProtoMessage ¶
func (*FleetStatusReq) ProtoMessage()
func (*FleetStatusReq) ProtoReflect ¶
func (x *FleetStatusReq) ProtoReflect() protoreflect.Message
func (*FleetStatusReq) Reset ¶
func (x *FleetStatusReq) Reset()
func (*FleetStatusReq) String ¶
func (x *FleetStatusReq) String() string
type FleetWorker ¶
type FleetWorker struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
StepId string `protobuf:"bytes,3,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
Status string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"` // pending, running, completed, failed
Model string `protobuf:"bytes,5,opt,name=model,proto3" json:"model,omitempty"`
Provider string `protobuf:"bytes,6,opt,name=provider,proto3" json:"provider,omitempty"`
Error string `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*FleetWorker) Descriptor
deprecated
func (*FleetWorker) Descriptor() ([]byte, []int)
Deprecated: Use FleetWorker.ProtoReflect.Descriptor instead.
func (*FleetWorker) GetError ¶
func (x *FleetWorker) GetError() string
func (*FleetWorker) GetId ¶
func (x *FleetWorker) GetId() string
func (*FleetWorker) GetModel ¶
func (x *FleetWorker) GetModel() string
func (*FleetWorker) GetName ¶
func (x *FleetWorker) GetName() string
func (*FleetWorker) GetProvider ¶
func (x *FleetWorker) GetProvider() string
func (*FleetWorker) GetStatus ¶
func (x *FleetWorker) GetStatus() string
func (*FleetWorker) GetStepId ¶
func (x *FleetWorker) GetStepId() string
func (*FleetWorker) ProtoMessage ¶
func (*FleetWorker) ProtoMessage()
func (*FleetWorker) ProtoReflect ¶
func (x *FleetWorker) ProtoReflect() protoreflect.Message
func (*FleetWorker) Reset ¶
func (x *FleetWorker) Reset()
func (*FleetWorker) String ¶
func (x *FleetWorker) String() string
type HealthResponse ¶
type HealthResponse struct {
Healthy bool `protobuf:"varint,1,opt,name=healthy,proto3" json:"healthy,omitempty"`
ActiveSessions int32 `protobuf:"varint,2,opt,name=active_sessions,json=activeSessions,proto3" json:"active_sessions,omitempty"`
ActiveAgents int32 `protobuf:"varint,3,opt,name=active_agents,json=activeAgents,proto3" json:"active_agents,omitempty"`
Uptime string `protobuf:"bytes,4,opt,name=uptime,proto3" json:"uptime,omitempty"`
Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
Commit string `protobuf:"bytes,6,opt,name=commit,proto3" json:"commit,omitempty"`
ProtoVersion int32 `protobuf:"varint,7,opt,name=proto_version,json=protoVersion,proto3" json:"proto_version,omitempty"`
// contains filtered or unexported fields
}
Daemon health
func (*HealthResponse) Descriptor
deprecated
func (*HealthResponse) Descriptor() ([]byte, []int)
Deprecated: Use HealthResponse.ProtoReflect.Descriptor instead.
func (*HealthResponse) GetActiveAgents ¶
func (x *HealthResponse) GetActiveAgents() int32
func (*HealthResponse) GetActiveSessions ¶
func (x *HealthResponse) GetActiveSessions() int32
func (*HealthResponse) GetCommit ¶
func (x *HealthResponse) GetCommit() string
func (*HealthResponse) GetHealthy ¶
func (x *HealthResponse) GetHealthy() bool
func (*HealthResponse) GetProtoVersion ¶
func (x *HealthResponse) GetProtoVersion() int32
func (*HealthResponse) GetUptime ¶
func (x *HealthResponse) GetUptime() string
func (*HealthResponse) GetVersion ¶
func (x *HealthResponse) GetVersion() string
func (*HealthResponse) ProtoMessage ¶
func (*HealthResponse) ProtoMessage()
func (*HealthResponse) ProtoReflect ¶
func (x *HealthResponse) ProtoReflect() protoreflect.Message
func (*HealthResponse) Reset ¶
func (x *HealthResponse) Reset()
func (*HealthResponse) String ¶
func (x *HealthResponse) String() string
type HistoryMessage ¶
type HistoryMessage struct {
Role string `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
Content string `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
ToolName string `protobuf:"bytes,3,opt,name=tool_name,json=toolName,proto3" json:"tool_name,omitempty"`
ToolCallId string `protobuf:"bytes,4,opt,name=tool_call_id,json=toolCallId,proto3" json:"tool_call_id,omitempty"`
Timestamp *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// contains filtered or unexported fields
}
func (*HistoryMessage) Descriptor
deprecated
func (*HistoryMessage) Descriptor() ([]byte, []int)
Deprecated: Use HistoryMessage.ProtoReflect.Descriptor instead.
func (*HistoryMessage) GetContent ¶
func (x *HistoryMessage) GetContent() string
func (*HistoryMessage) GetRole ¶
func (x *HistoryMessage) GetRole() string
func (*HistoryMessage) GetTimestamp ¶
func (x *HistoryMessage) GetTimestamp() *timestamppb.Timestamp
func (*HistoryMessage) GetToolCallId ¶
func (x *HistoryMessage) GetToolCallId() string
func (*HistoryMessage) GetToolName ¶
func (x *HistoryMessage) GetToolName() string
func (*HistoryMessage) ProtoMessage ¶
func (*HistoryMessage) ProtoMessage()
func (*HistoryMessage) ProtoReflect ¶
func (x *HistoryMessage) ProtoReflect() protoreflect.Message
func (*HistoryMessage) Reset ¶
func (x *HistoryMessage) Reset()
func (*HistoryMessage) String ¶
func (x *HistoryMessage) String() string
type HumanRequest ¶
type HumanRequest struct {
RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
TeamId string `protobuf:"bytes,2,opt,name=team_id,json=teamId,proto3" json:"team_id,omitempty"`
FromAgent string `protobuf:"bytes,3,opt,name=from_agent,json=fromAgent,proto3" json:"from_agent,omitempty"`
Question string `protobuf:"bytes,4,opt,name=question,proto3" json:"question,omitempty"`
Timestamp string `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// contains filtered or unexported fields
}
Human-in-the-loop
func (*HumanRequest) Descriptor
deprecated
func (*HumanRequest) Descriptor() ([]byte, []int)
Deprecated: Use HumanRequest.ProtoReflect.Descriptor instead.
func (*HumanRequest) GetFromAgent ¶
func (x *HumanRequest) GetFromAgent() string
func (*HumanRequest) GetQuestion ¶
func (x *HumanRequest) GetQuestion() string
func (*HumanRequest) GetRequestId ¶
func (x *HumanRequest) GetRequestId() string
func (*HumanRequest) GetTeamId ¶
func (x *HumanRequest) GetTeamId() string
func (*HumanRequest) GetTimestamp ¶
func (x *HumanRequest) GetTimestamp() string
func (*HumanRequest) ProtoMessage ¶
func (*HumanRequest) ProtoMessage()
func (*HumanRequest) ProtoReflect ¶
func (x *HumanRequest) ProtoReflect() protoreflect.Message
func (*HumanRequest) Reset ¶
func (x *HumanRequest) Reset()
func (*HumanRequest) String ¶
func (x *HumanRequest) String() string
type HumanResponse ¶
type HumanResponse struct {
RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
TeamId string `protobuf:"bytes,2,opt,name=team_id,json=teamId,proto3" json:"team_id,omitempty"`
Content string `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
// contains filtered or unexported fields
}
func (*HumanResponse) Descriptor
deprecated
func (*HumanResponse) Descriptor() ([]byte, []int)
Deprecated: Use HumanResponse.ProtoReflect.Descriptor instead.
func (*HumanResponse) GetContent ¶
func (x *HumanResponse) GetContent() string
func (*HumanResponse) GetRequestId ¶
func (x *HumanResponse) GetRequestId() string
func (*HumanResponse) GetTeamId ¶
func (x *HumanResponse) GetTeamId() string
func (*HumanResponse) ProtoMessage ¶
func (*HumanResponse) ProtoMessage()
func (*HumanResponse) ProtoReflect ¶
func (x *HumanResponse) ProtoReflect() protoreflect.Message
func (*HumanResponse) Reset ¶
func (x *HumanResponse) Reset()
func (*HumanResponse) String ¶
func (x *HumanResponse) String() string
type Job ¶
type Job struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // session, fleet_worker, team_agent, cron, tool_exec
Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
Status string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"` // running, paused, completed, failed, pending
SessionId string `protobuf:"bytes,5,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
StartedAt string `protobuf:"bytes,6,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
Elapsed string `protobuf:"bytes,7,opt,name=elapsed,proto3" json:"elapsed,omitempty"`
Metadata map[string]string `` /* 143-byte string literal not displayed */
// contains filtered or unexported fields
}
Job control
func (*Job) Descriptor
deprecated
func (*Job) GetElapsed ¶
func (*Job) GetMetadata ¶
func (*Job) GetSessionId ¶
func (*Job) GetStartedAt ¶
func (*Job) ProtoMessage ¶
func (*Job) ProtoMessage()
func (*Job) ProtoReflect ¶
func (x *Job) ProtoReflect() protoreflect.Message
type JobList ¶
type JobList struct {
Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
// contains filtered or unexported fields
}
func (*JobList) Descriptor
deprecated
func (*JobList) ProtoMessage ¶
func (*JobList) ProtoMessage()
func (*JobList) ProtoReflect ¶
func (x *JobList) ProtoReflect() protoreflect.Message
type JobReq ¶
type JobReq struct {
JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
// contains filtered or unexported fields
}
func (*JobReq) Descriptor
deprecated
func (*JobReq) ProtoMessage ¶
func (*JobReq) ProtoMessage()
func (*JobReq) ProtoReflect ¶
func (x *JobReq) ProtoReflect() protoreflect.Message
type KillFleetWorkerReq ¶
type KillFleetWorkerReq struct {
FleetId string `protobuf:"bytes,1,opt,name=fleet_id,json=fleetId,proto3" json:"fleet_id,omitempty"`
WorkerId string `protobuf:"bytes,2,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
// contains filtered or unexported fields
}
func (*KillFleetWorkerReq) Descriptor
deprecated
func (*KillFleetWorkerReq) Descriptor() ([]byte, []int)
Deprecated: Use KillFleetWorkerReq.ProtoReflect.Descriptor instead.
func (*KillFleetWorkerReq) GetFleetId ¶
func (x *KillFleetWorkerReq) GetFleetId() string
func (*KillFleetWorkerReq) GetWorkerId ¶
func (x *KillFleetWorkerReq) GetWorkerId() string
func (*KillFleetWorkerReq) ProtoMessage ¶
func (*KillFleetWorkerReq) ProtoMessage()
func (*KillFleetWorkerReq) ProtoReflect ¶
func (x *KillFleetWorkerReq) ProtoReflect() protoreflect.Message
func (*KillFleetWorkerReq) Reset ¶
func (x *KillFleetWorkerReq) Reset()
func (*KillFleetWorkerReq) String ¶
func (x *KillFleetWorkerReq) String() string
type KillReq ¶
type KillReq struct {
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
// contains filtered or unexported fields
}
func (*KillReq) Descriptor
deprecated
func (*KillReq) GetSessionId ¶
func (*KillReq) ProtoMessage ¶
func (*KillReq) ProtoMessage()
func (*KillReq) ProtoReflect ¶
func (x *KillReq) ProtoReflect() protoreflect.Message
type KillTeamReq ¶
type KillTeamReq struct {
TeamId string `protobuf:"bytes,1,opt,name=team_id,json=teamId,proto3" json:"team_id,omitempty"`
// contains filtered or unexported fields
}
func (*KillTeamReq) Descriptor
deprecated
func (*KillTeamReq) Descriptor() ([]byte, []int)
Deprecated: Use KillTeamReq.ProtoReflect.Descriptor instead.
func (*KillTeamReq) GetTeamId ¶
func (x *KillTeamReq) GetTeamId() string
func (*KillTeamReq) ProtoMessage ¶
func (*KillTeamReq) ProtoMessage()
func (*KillTeamReq) ProtoReflect ¶
func (x *KillTeamReq) ProtoReflect() protoreflect.Message
func (*KillTeamReq) Reset ¶
func (x *KillTeamReq) Reset()
func (*KillTeamReq) String ¶
func (x *KillTeamReq) String() string
type ListTeamsReq ¶
type ListTeamsReq struct {
ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` // optional filter by project
// contains filtered or unexported fields
}
func (*ListTeamsReq) Descriptor
deprecated
func (*ListTeamsReq) Descriptor() ([]byte, []int)
Deprecated: Use ListTeamsReq.ProtoReflect.Descriptor instead.
func (*ListTeamsReq) GetProjectId ¶
func (x *ListTeamsReq) GetProjectId() string
func (*ListTeamsReq) ProtoMessage ¶
func (*ListTeamsReq) ProtoMessage()
func (*ListTeamsReq) ProtoReflect ¶
func (x *ListTeamsReq) ProtoReflect() protoreflect.Message
func (*ListTeamsReq) Reset ¶
func (x *ListTeamsReq) Reset()
func (*ListTeamsReq) String ¶
func (x *ListTeamsReq) String() string
type MeshEvent ¶
type MeshEvent struct {
// Types that are valid to be assigned to Event:
//
// *MeshEvent_BlackboardSync
// *MeshEvent_AgentMessage
// *MeshEvent_NodeRegistered
Event isMeshEvent_Event `protobuf_oneof:"event"`
// contains filtered or unexported fields
}
MeshEvent carries mesh-related events between daemons
func (*MeshEvent) Descriptor
deprecated
func (*MeshEvent) GetAgentMessage ¶
func (x *MeshEvent) GetAgentMessage() *AgentMessage
func (*MeshEvent) GetBlackboardSync ¶
func (x *MeshEvent) GetBlackboardSync() *BlackboardSync
func (*MeshEvent) GetNodeRegistered ¶
func (x *MeshEvent) GetNodeRegistered() *RegisterNodeResp
func (*MeshEvent) ProtoMessage ¶
func (*MeshEvent) ProtoMessage()
func (*MeshEvent) ProtoReflect ¶
func (x *MeshEvent) ProtoReflect() protoreflect.Message
type MeshEvent_AgentMessage ¶
type MeshEvent_AgentMessage struct {
AgentMessage *AgentMessage `protobuf:"bytes,2,opt,name=agent_message,json=agentMessage,proto3,oneof"`
}
type MeshEvent_BlackboardSync ¶
type MeshEvent_BlackboardSync struct {
BlackboardSync *BlackboardSync `protobuf:"bytes,1,opt,name=blackboard_sync,json=blackboardSync,proto3,oneof"`
}
type MeshEvent_NodeRegistered ¶
type MeshEvent_NodeRegistered struct {
NodeRegistered *RegisterNodeResp `protobuf:"bytes,3,opt,name=node_registered,json=nodeRegistered,proto3,oneof"`
}
type PendingHumanList ¶
type PendingHumanList struct {
Requests []*HumanRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
// contains filtered or unexported fields
}
func (*PendingHumanList) Descriptor
deprecated
func (*PendingHumanList) Descriptor() ([]byte, []int)
Deprecated: Use PendingHumanList.ProtoReflect.Descriptor instead.
func (*PendingHumanList) GetRequests ¶
func (x *PendingHumanList) GetRequests() []*HumanRequest
func (*PendingHumanList) ProtoMessage ¶
func (*PendingHumanList) ProtoMessage()
func (*PendingHumanList) ProtoReflect ¶
func (x *PendingHumanList) ProtoReflect() protoreflect.Message
func (*PendingHumanList) Reset ¶
func (x *PendingHumanList) Reset()
func (*PendingHumanList) String ¶
func (x *PendingHumanList) String() string
type PendingHumanReq ¶
type PendingHumanReq struct {
TeamId string `protobuf:"bytes,1,opt,name=team_id,json=teamId,proto3" json:"team_id,omitempty"` // optional filter
// contains filtered or unexported fields
}
func (*PendingHumanReq) Descriptor
deprecated
func (*PendingHumanReq) Descriptor() ([]byte, []int)
Deprecated: Use PendingHumanReq.ProtoReflect.Descriptor instead.
func (*PendingHumanReq) GetTeamId ¶
func (x *PendingHumanReq) GetTeamId() string
func (*PendingHumanReq) ProtoMessage ¶
func (*PendingHumanReq) ProtoMessage()
func (*PendingHumanReq) ProtoReflect ¶
func (x *PendingHumanReq) ProtoReflect() protoreflect.Message
func (*PendingHumanReq) Reset ¶
func (x *PendingHumanReq) Reset()
func (*PendingHumanReq) String ¶
func (x *PendingHumanReq) String() string
type PermissionRequest ¶
type PermissionRequest struct {
RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
ToolName string `protobuf:"bytes,2,opt,name=tool_name,json=toolName,proto3" json:"tool_name,omitempty"`
ArgumentsJson string `protobuf:"bytes,3,opt,name=arguments_json,json=argumentsJson,proto3" json:"arguments_json,omitempty"`
Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
// contains filtered or unexported fields
}
func (*PermissionRequest) Descriptor
deprecated
func (*PermissionRequest) Descriptor() ([]byte, []int)
Deprecated: Use PermissionRequest.ProtoReflect.Descriptor instead.
func (*PermissionRequest) GetArgumentsJson ¶
func (x *PermissionRequest) GetArgumentsJson() string
func (*PermissionRequest) GetDescription ¶
func (x *PermissionRequest) GetDescription() string
func (*PermissionRequest) GetRequestId ¶
func (x *PermissionRequest) GetRequestId() string
func (*PermissionRequest) GetToolName ¶
func (x *PermissionRequest) GetToolName() string
func (*PermissionRequest) ProtoMessage ¶
func (*PermissionRequest) ProtoMessage()
func (*PermissionRequest) ProtoReflect ¶
func (x *PermissionRequest) ProtoReflect() protoreflect.Message
func (*PermissionRequest) Reset ¶
func (x *PermissionRequest) Reset()
func (*PermissionRequest) String ¶
func (x *PermissionRequest) String() string
type PermissionResponse ¶
type PermissionResponse struct {
RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
Allowed bool `protobuf:"varint,2,opt,name=allowed,proto3" json:"allowed,omitempty"`
Scope string `protobuf:"bytes,3,opt,name=scope,proto3" json:"scope,omitempty"` // "once", "session", "always"
// contains filtered or unexported fields
}
func (*PermissionResponse) Descriptor
deprecated
func (*PermissionResponse) Descriptor() ([]byte, []int)
Deprecated: Use PermissionResponse.ProtoReflect.Descriptor instead.
func (*PermissionResponse) GetAllowed ¶
func (x *PermissionResponse) GetAllowed() bool
func (*PermissionResponse) GetRequestId ¶
func (x *PermissionResponse) GetRequestId() string
func (*PermissionResponse) GetScope ¶
func (x *PermissionResponse) GetScope() string
func (*PermissionResponse) ProtoMessage ¶
func (*PermissionResponse) ProtoMessage()
func (*PermissionResponse) ProtoReflect ¶
func (x *PermissionResponse) ProtoReflect() protoreflect.Message
func (*PermissionResponse) Reset ¶
func (x *PermissionResponse) Reset()
func (*PermissionResponse) String ¶
func (x *PermissionResponse) String() string
type Plan ¶
type Plan struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
Goal string `protobuf:"bytes,3,opt,name=goal,proto3" json:"goal,omitempty"`
Steps []*PlanStep `protobuf:"bytes,4,rep,name=steps,proto3" json:"steps,omitempty"`
Status string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"` // proposed, approved, executing, completed, rejected
CreatedAt string `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
Feedback string `protobuf:"bytes,7,opt,name=feedback,proto3" json:"feedback,omitempty"` // rejection feedback from user
// contains filtered or unexported fields
}
func (*Plan) Descriptor
deprecated
func (*Plan) GetCreatedAt ¶
func (*Plan) GetFeedback ¶
func (*Plan) GetSessionId ¶
func (*Plan) ProtoMessage ¶
func (*Plan) ProtoMessage()
func (*Plan) ProtoReflect ¶
func (x *Plan) ProtoReflect() protoreflect.Message
type PlanStep ¶
type PlanStep struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"` // pending, in_progress, completed, failed, skipped
Files []string `protobuf:"bytes,4,rep,name=files,proto3" json:"files,omitempty"`
Error string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
Plan mode
func (*PlanStep) Descriptor
deprecated
func (*PlanStep) GetDescription ¶
func (*PlanStep) ProtoMessage ¶
func (*PlanStep) ProtoMessage()
func (*PlanStep) ProtoReflect ¶
func (x *PlanStep) ProtoReflect() protoreflect.Message
type ProjectList ¶
type ProjectList struct {
Projects []*ProjectStatus `protobuf:"bytes,1,rep,name=projects,proto3" json:"projects,omitempty"`
// contains filtered or unexported fields
}
func (*ProjectList) Descriptor
deprecated
func (*ProjectList) Descriptor() ([]byte, []int)
Deprecated: Use ProjectList.ProtoReflect.Descriptor instead.
func (*ProjectList) GetProjects ¶
func (x *ProjectList) GetProjects() []*ProjectStatus
func (*ProjectList) ProtoMessage ¶
func (*ProjectList) ProtoMessage()
func (*ProjectList) ProtoReflect ¶
func (x *ProjectList) ProtoReflect() protoreflect.Message
func (*ProjectList) Reset ¶
func (x *ProjectList) Reset()
func (*ProjectList) String ¶
func (x *ProjectList) String() string
type ProjectReq ¶
type ProjectReq struct {
ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
// contains filtered or unexported fields
}
func (*ProjectReq) Descriptor
deprecated
func (*ProjectReq) Descriptor() ([]byte, []int)
Deprecated: Use ProjectReq.ProtoReflect.Descriptor instead.
func (*ProjectReq) GetProjectId ¶
func (x *ProjectReq) GetProjectId() string
func (*ProjectReq) ProtoMessage ¶
func (*ProjectReq) ProtoMessage()
func (*ProjectReq) ProtoReflect ¶
func (x *ProjectReq) ProtoReflect() protoreflect.Message
func (*ProjectReq) Reset ¶
func (x *ProjectReq) Reset()
func (*ProjectReq) String ¶
func (x *ProjectReq) String() string
type ProjectStatus ¶
type ProjectStatus struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
TeamIds []string `protobuf:"bytes,4,rep,name=team_ids,json=teamIds,proto3" json:"team_ids,omitempty"`
CreatedAt string `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
// contains filtered or unexported fields
}
func (*ProjectStatus) Descriptor
deprecated
func (*ProjectStatus) Descriptor() ([]byte, []int)
Deprecated: Use ProjectStatus.ProtoReflect.Descriptor instead.
func (*ProjectStatus) GetCreatedAt ¶
func (x *ProjectStatus) GetCreatedAt() string
func (*ProjectStatus) GetId ¶
func (x *ProjectStatus) GetId() string
func (*ProjectStatus) GetName ¶
func (x *ProjectStatus) GetName() string
func (*ProjectStatus) GetStatus ¶
func (x *ProjectStatus) GetStatus() string
func (*ProjectStatus) GetTeamIds ¶
func (x *ProjectStatus) GetTeamIds() []string
func (*ProjectStatus) ProtoMessage ¶
func (*ProjectStatus) ProtoMessage()
func (*ProjectStatus) ProtoReflect ¶
func (x *ProjectStatus) ProtoReflect() protoreflect.Message
func (*ProjectStatus) Reset ¶
func (x *ProjectStatus) Reset()
func (*ProjectStatus) String ¶
func (x *ProjectStatus) String() string
type Provider ¶
type Provider struct {
Alias string `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
Model string `protobuf:"bytes,3,opt,name=model,proto3" json:"model,omitempty"`
BaseUrl string `protobuf:"bytes,4,opt,name=base_url,json=baseUrl,proto3" json:"base_url,omitempty"`
IsDefault bool `protobuf:"varint,5,opt,name=is_default,json=isDefault,proto3" json:"is_default,omitempty"`
// contains filtered or unexported fields
}
func (*Provider) Descriptor
deprecated
func (*Provider) GetBaseUrl ¶
func (*Provider) GetIsDefault ¶
func (*Provider) ProtoMessage ¶
func (*Provider) ProtoMessage()
func (*Provider) ProtoReflect ¶
func (x *Provider) ProtoReflect() protoreflect.Message
type ProviderList ¶
type ProviderList struct {
Providers []*Provider `protobuf:"bytes,1,rep,name=providers,proto3" json:"providers,omitempty"`
// contains filtered or unexported fields
}
func (*ProviderList) Descriptor
deprecated
func (*ProviderList) Descriptor() ([]byte, []int)
Deprecated: Use ProviderList.ProtoReflect.Descriptor instead.
func (*ProviderList) GetProviders ¶
func (x *ProviderList) GetProviders() []*Provider
func (*ProviderList) ProtoMessage ¶
func (*ProviderList) ProtoMessage()
func (*ProviderList) ProtoReflect ¶
func (x *ProviderList) ProtoReflect() protoreflect.Message
func (*ProviderList) Reset ¶
func (x *ProviderList) Reset()
func (*ProviderList) String ¶
func (x *ProviderList) String() string
type RatchetDaemonClient ¶
type RatchetDaemonClient interface {
// Session management
CreateSession(ctx context.Context, in *CreateSessionReq, opts ...grpc.CallOption) (*Session, error)
ListSessions(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*SessionList, error)
AttachSession(ctx context.Context, in *AttachReq, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ChatEvent], error)
DetachSession(ctx context.Context, in *DetachReq, opts ...grpc.CallOption) (*Empty, error)
KillSession(ctx context.Context, in *KillReq, opts ...grpc.CallOption) (*Empty, error)
// Chat
SendMessage(ctx context.Context, in *SendMessageReq, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ChatEvent], error)
// Permissions
RespondToPermission(ctx context.Context, in *PermissionResponse, opts ...grpc.CallOption) (*Empty, error)
// Providers
AddProvider(ctx context.Context, in *AddProviderReq, opts ...grpc.CallOption) (*Provider, error)
ListProviders(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ProviderList, error)
TestProvider(ctx context.Context, in *TestProviderReq, opts ...grpc.CallOption) (*TestProviderResult, error)
RemoveProvider(ctx context.Context, in *RemoveProviderReq, opts ...grpc.CallOption) (*Empty, error)
SetDefaultProvider(ctx context.Context, in *SetDefaultProviderReq, opts ...grpc.CallOption) (*Empty, error)
UpdateProviderModel(ctx context.Context, in *UpdateProviderModelReq, opts ...grpc.CallOption) (*Empty, error)
// Agents
ListAgents(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*AgentList, error)
GetAgentStatus(ctx context.Context, in *AgentStatusReq, opts ...grpc.CallOption) (*Agent, error)
// Teams
StartTeam(ctx context.Context, in *StartTeamReq, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TeamEvent], error)
GetTeamStatus(ctx context.Context, in *TeamStatusReq, opts ...grpc.CallOption) (*TeamStatus, error)
// Plan mode
ApprovePlan(ctx context.Context, in *ApprovePlanReq, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ChatEvent], error)
RejectPlan(ctx context.Context, in *RejectPlanReq, opts ...grpc.CallOption) (*Empty, error)
// Fleet mode
StartFleet(ctx context.Context, in *StartFleetReq, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ChatEvent], error)
GetFleetStatus(ctx context.Context, in *FleetStatusReq, opts ...grpc.CallOption) (*FleetStatus, error)
KillFleetWorker(ctx context.Context, in *KillFleetWorkerReq, opts ...grpc.CallOption) (*Empty, error)
// Cron scheduling
CreateCron(ctx context.Context, in *CreateCronReq, opts ...grpc.CallOption) (*CronJob, error)
ListCrons(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*CronJobList, error)
PauseCron(ctx context.Context, in *CronJobReq, opts ...grpc.CallOption) (*Empty, error)
ResumeCron(ctx context.Context, in *CronJobReq, opts ...grpc.CallOption) (*Empty, error)
StopCron(ctx context.Context, in *CronJobReq, opts ...grpc.CallOption) (*Empty, error)
// Job control
ListJobs(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*JobList, error)
PauseJob(ctx context.Context, in *JobReq, opts ...grpc.CallOption) (*Empty, error)
ResumeJob(ctx context.Context, in *JobReq, opts ...grpc.CallOption) (*Empty, error)
KillJob(ctx context.Context, in *JobReq, opts ...grpc.CallOption) (*Empty, error)
// Daemon
Health(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*HealthResponse, error)
Shutdown(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
// Version and reload
CheckVersion(ctx context.Context, in *VersionCheckReq, opts ...grpc.CallOption) (*VersionCheckResp, error)
RequestReload(ctx context.Context, in *ReloadReq, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ReloadStatus], error)
// Agent Mesh (scaffolded — handlers return Unimplemented)
RegisterMeshNode(ctx context.Context, in *RegisterNodeReq, opts ...grpc.CallOption) (*RegisterNodeResp, error)
MeshStream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[MeshEvent, MeshEvent], error)
// Teams (extended)
ListTeams(ctx context.Context, in *ListTeamsReq, opts ...grpc.CallOption) (*TeamList, error)
KillTeam(ctx context.Context, in *KillTeamReq, opts ...grpc.CallOption) (*Empty, error)
RenameTeam(ctx context.Context, in *TeamRenameReq, opts ...grpc.CallOption) (*Empty, error)
TeamAddAgent(ctx context.Context, in *TeamAddAgentReq, opts ...grpc.CallOption) (*Empty, error)
TeamRemoveAgent(ctx context.Context, in *TeamRemoveAgentReq, opts ...grpc.CallOption) (*Empty, error)
AttachTeam(ctx context.Context, in *AttachTeamReq, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TeamActivityEvent], error)
SteerTeam(ctx context.Context, in *SteerTeamReq, opts ...grpc.CallOption) (*Empty, error)
DirectMessage(ctx context.Context, in *DirectMessageReq, opts ...grpc.CallOption) (*Empty, error)
// Human-in-the-loop
RespondToHuman(ctx context.Context, in *HumanResponse, opts ...grpc.CallOption) (*Empty, error)
ListPendingHuman(ctx context.Context, in *PendingHumanReq, opts ...grpc.CallOption) (*PendingHumanList, error)
// Projects
StartProject(ctx context.Context, in *StartProjectReq, opts ...grpc.CallOption) (*ProjectStatus, error)
ListProjects(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ProjectList, error)
PauseProject(ctx context.Context, in *ProjectReq, opts ...grpc.CallOption) (*Empty, error)
ResumeProject(ctx context.Context, in *ProjectReq, opts ...grpc.CallOption) (*Empty, error)
KillProject(ctx context.Context, in *ProjectReq, opts ...grpc.CallOption) (*Empty, error)
GetProjectStatus(ctx context.Context, in *ProjectReq, opts ...grpc.CallOption) (*ProjectStatus, error)
// Task tracker
CreateTask(ctx context.Context, in *TaskCreateReq, opts ...grpc.CallOption) (*TaskInfo, error)
ClaimTask(ctx context.Context, in *TaskClaimReq, opts ...grpc.CallOption) (*TaskInfo, error)
UpdateTask(ctx context.Context, in *TaskUpdateReq, opts ...grpc.CallOption) (*TaskInfo, error)
ListTasks(ctx context.Context, in *TaskListReq, opts ...grpc.CallOption) (*TaskList, error)
GetTask(ctx context.Context, in *TaskReq, opts ...grpc.CallOption) (*TaskInfo, error)
}
RatchetDaemonClient is the client API for RatchetDaemon service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewRatchetDaemonClient ¶
func NewRatchetDaemonClient(cc grpc.ClientConnInterface) RatchetDaemonClient
type RatchetDaemonServer ¶
type RatchetDaemonServer interface {
// Session management
CreateSession(context.Context, *CreateSessionReq) (*Session, error)
ListSessions(context.Context, *Empty) (*SessionList, error)
AttachSession(*AttachReq, grpc.ServerStreamingServer[ChatEvent]) error
DetachSession(context.Context, *DetachReq) (*Empty, error)
KillSession(context.Context, *KillReq) (*Empty, error)
// Chat
SendMessage(*SendMessageReq, grpc.ServerStreamingServer[ChatEvent]) error
// Permissions
RespondToPermission(context.Context, *PermissionResponse) (*Empty, error)
// Providers
AddProvider(context.Context, *AddProviderReq) (*Provider, error)
ListProviders(context.Context, *Empty) (*ProviderList, error)
TestProvider(context.Context, *TestProviderReq) (*TestProviderResult, error)
RemoveProvider(context.Context, *RemoveProviderReq) (*Empty, error)
SetDefaultProvider(context.Context, *SetDefaultProviderReq) (*Empty, error)
UpdateProviderModel(context.Context, *UpdateProviderModelReq) (*Empty, error)
// Agents
ListAgents(context.Context, *Empty) (*AgentList, error)
GetAgentStatus(context.Context, *AgentStatusReq) (*Agent, error)
// Teams
StartTeam(*StartTeamReq, grpc.ServerStreamingServer[TeamEvent]) error
GetTeamStatus(context.Context, *TeamStatusReq) (*TeamStatus, error)
// Plan mode
ApprovePlan(*ApprovePlanReq, grpc.ServerStreamingServer[ChatEvent]) error
RejectPlan(context.Context, *RejectPlanReq) (*Empty, error)
// Fleet mode
StartFleet(*StartFleetReq, grpc.ServerStreamingServer[ChatEvent]) error
GetFleetStatus(context.Context, *FleetStatusReq) (*FleetStatus, error)
KillFleetWorker(context.Context, *KillFleetWorkerReq) (*Empty, error)
// Cron scheduling
CreateCron(context.Context, *CreateCronReq) (*CronJob, error)
ListCrons(context.Context, *Empty) (*CronJobList, error)
PauseCron(context.Context, *CronJobReq) (*Empty, error)
ResumeCron(context.Context, *CronJobReq) (*Empty, error)
StopCron(context.Context, *CronJobReq) (*Empty, error)
// Job control
ListJobs(context.Context, *Empty) (*JobList, error)
PauseJob(context.Context, *JobReq) (*Empty, error)
ResumeJob(context.Context, *JobReq) (*Empty, error)
KillJob(context.Context, *JobReq) (*Empty, error)
// Daemon
Health(context.Context, *Empty) (*HealthResponse, error)
Shutdown(context.Context, *Empty) (*Empty, error)
// Version and reload
CheckVersion(context.Context, *VersionCheckReq) (*VersionCheckResp, error)
RequestReload(*ReloadReq, grpc.ServerStreamingServer[ReloadStatus]) error
// Agent Mesh (scaffolded — handlers return Unimplemented)
RegisterMeshNode(context.Context, *RegisterNodeReq) (*RegisterNodeResp, error)
MeshStream(grpc.BidiStreamingServer[MeshEvent, MeshEvent]) error
// Teams (extended)
ListTeams(context.Context, *ListTeamsReq) (*TeamList, error)
KillTeam(context.Context, *KillTeamReq) (*Empty, error)
RenameTeam(context.Context, *TeamRenameReq) (*Empty, error)
TeamAddAgent(context.Context, *TeamAddAgentReq) (*Empty, error)
TeamRemoveAgent(context.Context, *TeamRemoveAgentReq) (*Empty, error)
AttachTeam(*AttachTeamReq, grpc.ServerStreamingServer[TeamActivityEvent]) error
SteerTeam(context.Context, *SteerTeamReq) (*Empty, error)
DirectMessage(context.Context, *DirectMessageReq) (*Empty, error)
// Human-in-the-loop
RespondToHuman(context.Context, *HumanResponse) (*Empty, error)
ListPendingHuman(context.Context, *PendingHumanReq) (*PendingHumanList, error)
// Projects
StartProject(context.Context, *StartProjectReq) (*ProjectStatus, error)
ListProjects(context.Context, *Empty) (*ProjectList, error)
PauseProject(context.Context, *ProjectReq) (*Empty, error)
ResumeProject(context.Context, *ProjectReq) (*Empty, error)
KillProject(context.Context, *ProjectReq) (*Empty, error)
GetProjectStatus(context.Context, *ProjectReq) (*ProjectStatus, error)
// Task tracker
CreateTask(context.Context, *TaskCreateReq) (*TaskInfo, error)
ClaimTask(context.Context, *TaskClaimReq) (*TaskInfo, error)
UpdateTask(context.Context, *TaskUpdateReq) (*TaskInfo, error)
ListTasks(context.Context, *TaskListReq) (*TaskList, error)
GetTask(context.Context, *TaskReq) (*TaskInfo, error)
// contains filtered or unexported methods
}
RatchetDaemonServer is the server API for RatchetDaemon service. All implementations must embed UnimplementedRatchetDaemonServer for forward compatibility.
type RatchetDaemon_ApprovePlanClient ¶
type RatchetDaemon_ApprovePlanClient = grpc.ServerStreamingClient[ChatEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RatchetDaemon_ApprovePlanServer ¶
type RatchetDaemon_ApprovePlanServer = grpc.ServerStreamingServer[ChatEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RatchetDaemon_AttachSessionClient ¶
type RatchetDaemon_AttachSessionClient = grpc.ServerStreamingClient[ChatEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RatchetDaemon_AttachSessionServer ¶
type RatchetDaemon_AttachSessionServer = grpc.ServerStreamingServer[ChatEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RatchetDaemon_AttachTeamClient ¶
type RatchetDaemon_AttachTeamClient = grpc.ServerStreamingClient[TeamActivityEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RatchetDaemon_AttachTeamServer ¶
type RatchetDaemon_AttachTeamServer = grpc.ServerStreamingServer[TeamActivityEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RatchetDaemon_MeshStreamClient ¶
type RatchetDaemon_MeshStreamClient = grpc.BidiStreamingClient[MeshEvent, MeshEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RatchetDaemon_MeshStreamServer ¶
type RatchetDaemon_MeshStreamServer = grpc.BidiStreamingServer[MeshEvent, MeshEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RatchetDaemon_RequestReloadClient ¶
type RatchetDaemon_RequestReloadClient = grpc.ServerStreamingClient[ReloadStatus]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RatchetDaemon_RequestReloadServer ¶
type RatchetDaemon_RequestReloadServer = grpc.ServerStreamingServer[ReloadStatus]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RatchetDaemon_SendMessageClient ¶
type RatchetDaemon_SendMessageClient = grpc.ServerStreamingClient[ChatEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RatchetDaemon_SendMessageServer ¶
type RatchetDaemon_SendMessageServer = grpc.ServerStreamingServer[ChatEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RatchetDaemon_StartFleetClient ¶
type RatchetDaemon_StartFleetClient = grpc.ServerStreamingClient[ChatEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RatchetDaemon_StartFleetServer ¶
type RatchetDaemon_StartFleetServer = grpc.ServerStreamingServer[ChatEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RatchetDaemon_StartTeamClient ¶
type RatchetDaemon_StartTeamClient = grpc.ServerStreamingClient[TeamEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RatchetDaemon_StartTeamServer ¶
type RatchetDaemon_StartTeamServer = grpc.ServerStreamingServer[TeamEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RegisterNodeReq ¶
type RegisterNodeReq struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Role string `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
Model string `protobuf:"bytes,3,opt,name=model,proto3" json:"model,omitempty"`
Provider string `protobuf:"bytes,4,opt,name=provider,proto3" json:"provider,omitempty"`
Tools []string `protobuf:"bytes,5,rep,name=tools,proto3" json:"tools,omitempty"`
// contains filtered or unexported fields
}
Agent mesh node registration
func (*RegisterNodeReq) Descriptor
deprecated
func (*RegisterNodeReq) Descriptor() ([]byte, []int)
Deprecated: Use RegisterNodeReq.ProtoReflect.Descriptor instead.
func (*RegisterNodeReq) GetModel ¶
func (x *RegisterNodeReq) GetModel() string
func (*RegisterNodeReq) GetName ¶
func (x *RegisterNodeReq) GetName() string
func (*RegisterNodeReq) GetProvider ¶
func (x *RegisterNodeReq) GetProvider() string
func (*RegisterNodeReq) GetRole ¶
func (x *RegisterNodeReq) GetRole() string
func (*RegisterNodeReq) GetTools ¶
func (x *RegisterNodeReq) GetTools() []string
func (*RegisterNodeReq) ProtoMessage ¶
func (*RegisterNodeReq) ProtoMessage()
func (*RegisterNodeReq) ProtoReflect ¶
func (x *RegisterNodeReq) ProtoReflect() protoreflect.Message
func (*RegisterNodeReq) Reset ¶
func (x *RegisterNodeReq) Reset()
func (*RegisterNodeReq) String ¶
func (x *RegisterNodeReq) String() string
type RegisterNodeResp ¶
type RegisterNodeResp struct {
NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
// contains filtered or unexported fields
}
func (*RegisterNodeResp) Descriptor
deprecated
func (*RegisterNodeResp) Descriptor() ([]byte, []int)
Deprecated: Use RegisterNodeResp.ProtoReflect.Descriptor instead.
func (*RegisterNodeResp) GetNodeId ¶
func (x *RegisterNodeResp) GetNodeId() string
func (*RegisterNodeResp) ProtoMessage ¶
func (*RegisterNodeResp) ProtoMessage()
func (*RegisterNodeResp) ProtoReflect ¶
func (x *RegisterNodeResp) ProtoReflect() protoreflect.Message
func (*RegisterNodeResp) Reset ¶
func (x *RegisterNodeResp) Reset()
func (*RegisterNodeResp) String ¶
func (x *RegisterNodeResp) String() string
type RejectPlanReq ¶
type RejectPlanReq struct {
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
PlanId string `protobuf:"bytes,2,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty"`
Feedback string `protobuf:"bytes,3,opt,name=feedback,proto3" json:"feedback,omitempty"`
// contains filtered or unexported fields
}
func (*RejectPlanReq) Descriptor
deprecated
func (*RejectPlanReq) Descriptor() ([]byte, []int)
Deprecated: Use RejectPlanReq.ProtoReflect.Descriptor instead.
func (*RejectPlanReq) GetFeedback ¶
func (x *RejectPlanReq) GetFeedback() string
func (*RejectPlanReq) GetPlanId ¶
func (x *RejectPlanReq) GetPlanId() string
func (*RejectPlanReq) GetSessionId ¶
func (x *RejectPlanReq) GetSessionId() string
func (*RejectPlanReq) ProtoMessage ¶
func (*RejectPlanReq) ProtoMessage()
func (*RejectPlanReq) ProtoReflect ¶
func (x *RejectPlanReq) ProtoReflect() protoreflect.Message
func (*RejectPlanReq) Reset ¶
func (x *RejectPlanReq) Reset()
func (*RejectPlanReq) String ¶
func (x *RejectPlanReq) String() string
type ReloadReq ¶
type ReloadReq struct {
NewBinaryPath string `protobuf:"bytes,1,opt,name=new_binary_path,json=newBinaryPath,proto3" json:"new_binary_path,omitempty"`
CliVersion string `protobuf:"bytes,2,opt,name=cli_version,json=cliVersion,proto3" json:"cli_version,omitempty"`
// contains filtered or unexported fields
}
Reload
func (*ReloadReq) Descriptor
deprecated
func (*ReloadReq) GetCliVersion ¶
func (*ReloadReq) GetNewBinaryPath ¶
func (*ReloadReq) ProtoMessage ¶
func (*ReloadReq) ProtoMessage()
func (*ReloadReq) ProtoReflect ¶
func (x *ReloadReq) ProtoReflect() protoreflect.Message
type ReloadStatus ¶
type ReloadStatus struct {
Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*ReloadStatus) Descriptor
deprecated
func (*ReloadStatus) Descriptor() ([]byte, []int)
Deprecated: Use ReloadStatus.ProtoReflect.Descriptor instead.
func (*ReloadStatus) GetMessage ¶
func (x *ReloadStatus) GetMessage() string
func (*ReloadStatus) GetStatus ¶
func (x *ReloadStatus) GetStatus() string
func (*ReloadStatus) ProtoMessage ¶
func (*ReloadStatus) ProtoMessage()
func (*ReloadStatus) ProtoReflect ¶
func (x *ReloadStatus) ProtoReflect() protoreflect.Message
func (*ReloadStatus) Reset ¶
func (x *ReloadStatus) Reset()
func (*ReloadStatus) String ¶
func (x *ReloadStatus) String() string
type RemoveProviderReq ¶
type RemoveProviderReq struct {
Alias string `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
// contains filtered or unexported fields
}
func (*RemoveProviderReq) Descriptor
deprecated
func (*RemoveProviderReq) Descriptor() ([]byte, []int)
Deprecated: Use RemoveProviderReq.ProtoReflect.Descriptor instead.
func (*RemoveProviderReq) GetAlias ¶
func (x *RemoveProviderReq) GetAlias() string
func (*RemoveProviderReq) ProtoMessage ¶
func (*RemoveProviderReq) ProtoMessage()
func (*RemoveProviderReq) ProtoReflect ¶
func (x *RemoveProviderReq) ProtoReflect() protoreflect.Message
func (*RemoveProviderReq) Reset ¶
func (x *RemoveProviderReq) Reset()
func (*RemoveProviderReq) String ¶
func (x *RemoveProviderReq) String() string
type SendMessageReq ¶
type SendMessageReq struct {
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
Content string `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
// contains filtered or unexported fields
}
Chat streaming
func (*SendMessageReq) Descriptor
deprecated
func (*SendMessageReq) Descriptor() ([]byte, []int)
Deprecated: Use SendMessageReq.ProtoReflect.Descriptor instead.
func (*SendMessageReq) GetContent ¶
func (x *SendMessageReq) GetContent() string
func (*SendMessageReq) GetSessionId ¶
func (x *SendMessageReq) GetSessionId() string
func (*SendMessageReq) ProtoMessage ¶
func (*SendMessageReq) ProtoMessage()
func (*SendMessageReq) ProtoReflect ¶
func (x *SendMessageReq) ProtoReflect() protoreflect.Message
func (*SendMessageReq) Reset ¶
func (x *SendMessageReq) Reset()
func (*SendMessageReq) String ¶
func (x *SendMessageReq) String() string
type Session ¶
type Session struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"` // active, background, completed
WorkingDir string `protobuf:"bytes,4,opt,name=working_dir,json=workingDir,proto3" json:"working_dir,omitempty"`
Provider string `protobuf:"bytes,5,opt,name=provider,proto3" json:"provider,omitempty"`
Model string `protobuf:"bytes,6,opt,name=model,proto3" json:"model,omitempty"`
CreatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
ActiveAgents int32 `protobuf:"varint,8,opt,name=active_agents,json=activeAgents,proto3" json:"active_agents,omitempty"`
// contains filtered or unexported fields
}
func (*Session) Descriptor
deprecated
func (*Session) GetActiveAgents ¶
func (*Session) GetCreatedAt ¶
func (x *Session) GetCreatedAt() *timestamppb.Timestamp
func (*Session) GetProvider ¶
func (*Session) GetWorkingDir ¶
func (*Session) ProtoMessage ¶
func (*Session) ProtoMessage()
func (*Session) ProtoReflect ¶
func (x *Session) ProtoReflect() protoreflect.Message
type SessionComplete ¶
type SessionComplete struct {
Summary string `protobuf:"bytes,1,opt,name=summary,proto3" json:"summary,omitempty"`
TotalTokens int32 `protobuf:"varint,2,opt,name=total_tokens,json=totalTokens,proto3" json:"total_tokens,omitempty"`
// contains filtered or unexported fields
}
func (*SessionComplete) Descriptor
deprecated
func (*SessionComplete) Descriptor() ([]byte, []int)
Deprecated: Use SessionComplete.ProtoReflect.Descriptor instead.
func (*SessionComplete) GetSummary ¶
func (x *SessionComplete) GetSummary() string
func (*SessionComplete) GetTotalTokens ¶
func (x *SessionComplete) GetTotalTokens() int32
func (*SessionComplete) ProtoMessage ¶
func (*SessionComplete) ProtoMessage()
func (*SessionComplete) ProtoReflect ¶
func (x *SessionComplete) ProtoReflect() protoreflect.Message
func (*SessionComplete) Reset ¶
func (x *SessionComplete) Reset()
func (*SessionComplete) String ¶
func (x *SessionComplete) String() string
type SessionHistory ¶
type SessionHistory struct {
Messages []*HistoryMessage `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
// contains filtered or unexported fields
}
func (*SessionHistory) Descriptor
deprecated
func (*SessionHistory) Descriptor() ([]byte, []int)
Deprecated: Use SessionHistory.ProtoReflect.Descriptor instead.
func (*SessionHistory) GetMessages ¶
func (x *SessionHistory) GetMessages() []*HistoryMessage
func (*SessionHistory) ProtoMessage ¶
func (*SessionHistory) ProtoMessage()
func (*SessionHistory) ProtoReflect ¶
func (x *SessionHistory) ProtoReflect() protoreflect.Message
func (*SessionHistory) Reset ¶
func (x *SessionHistory) Reset()
func (*SessionHistory) String ¶
func (x *SessionHistory) String() string
type SessionList ¶
type SessionList struct {
Sessions []*Session `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,omitempty"`
// contains filtered or unexported fields
}
func (*SessionList) Descriptor
deprecated
func (*SessionList) Descriptor() ([]byte, []int)
Deprecated: Use SessionList.ProtoReflect.Descriptor instead.
func (*SessionList) GetSessions ¶
func (x *SessionList) GetSessions() []*Session
func (*SessionList) ProtoMessage ¶
func (*SessionList) ProtoMessage()
func (*SessionList) ProtoReflect ¶
func (x *SessionList) ProtoReflect() protoreflect.Message
func (*SessionList) Reset ¶
func (x *SessionList) Reset()
func (*SessionList) String ¶
func (x *SessionList) String() string
type SetDefaultProviderReq ¶
type SetDefaultProviderReq struct {
Alias string `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
// contains filtered or unexported fields
}
func (*SetDefaultProviderReq) Descriptor
deprecated
func (*SetDefaultProviderReq) Descriptor() ([]byte, []int)
Deprecated: Use SetDefaultProviderReq.ProtoReflect.Descriptor instead.
func (*SetDefaultProviderReq) GetAlias ¶
func (x *SetDefaultProviderReq) GetAlias() string
func (*SetDefaultProviderReq) ProtoMessage ¶
func (*SetDefaultProviderReq) ProtoMessage()
func (*SetDefaultProviderReq) ProtoReflect ¶
func (x *SetDefaultProviderReq) ProtoReflect() protoreflect.Message
func (*SetDefaultProviderReq) Reset ¶
func (x *SetDefaultProviderReq) Reset()
func (*SetDefaultProviderReq) String ¶
func (x *SetDefaultProviderReq) String() string
type StartFleetReq ¶
type StartFleetReq struct {
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
PlanId string `protobuf:"bytes,2,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty"`
MaxWorkers int32 `protobuf:"varint,3,opt,name=max_workers,json=maxWorkers,proto3" json:"max_workers,omitempty"`
// contains filtered or unexported fields
}
Fleet mode
func (*StartFleetReq) Descriptor
deprecated
func (*StartFleetReq) Descriptor() ([]byte, []int)
Deprecated: Use StartFleetReq.ProtoReflect.Descriptor instead.
func (*StartFleetReq) GetMaxWorkers ¶
func (x *StartFleetReq) GetMaxWorkers() int32
func (*StartFleetReq) GetPlanId ¶
func (x *StartFleetReq) GetPlanId() string
func (*StartFleetReq) GetSessionId ¶
func (x *StartFleetReq) GetSessionId() string
func (*StartFleetReq) ProtoMessage ¶
func (*StartFleetReq) ProtoMessage()
func (*StartFleetReq) ProtoReflect ¶
func (x *StartFleetReq) ProtoReflect() protoreflect.Message
func (*StartFleetReq) Reset ¶
func (x *StartFleetReq) Reset()
func (*StartFleetReq) String ¶
func (x *StartFleetReq) String() string
type StartProjectReq ¶
type StartProjectReq struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
ConfigPath string `protobuf:"bytes,2,opt,name=config_path,json=configPath,proto3" json:"config_path,omitempty"`
// contains filtered or unexported fields
}
Project management
func (*StartProjectReq) Descriptor
deprecated
func (*StartProjectReq) Descriptor() ([]byte, []int)
Deprecated: Use StartProjectReq.ProtoReflect.Descriptor instead.
func (*StartProjectReq) GetConfigPath ¶
func (x *StartProjectReq) GetConfigPath() string
func (*StartProjectReq) GetName ¶
func (x *StartProjectReq) GetName() string
func (*StartProjectReq) ProtoMessage ¶
func (*StartProjectReq) ProtoMessage()
func (*StartProjectReq) ProtoReflect ¶
func (x *StartProjectReq) ProtoReflect() protoreflect.Message
func (*StartProjectReq) Reset ¶
func (x *StartProjectReq) Reset()
func (*StartProjectReq) String ¶
func (x *StartProjectReq) String() string
type StartTeamReq ¶
type StartTeamReq struct {
Task string `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
OrchestratorProvider string `protobuf:"bytes,3,opt,name=orchestrator_provider,json=orchestratorProvider,proto3" json:"orchestrator_provider,omitempty"`
TeamConfigName string `protobuf:"bytes,4,opt,name=team_config_name,json=teamConfigName,proto3" json:"team_config_name,omitempty"` // optional: builtin name (e.g. "code-gen") or YAML path
// contains filtered or unexported fields
}
Team management
func (*StartTeamReq) Descriptor
deprecated
func (*StartTeamReq) Descriptor() ([]byte, []int)
Deprecated: Use StartTeamReq.ProtoReflect.Descriptor instead.
func (*StartTeamReq) GetOrchestratorProvider ¶
func (x *StartTeamReq) GetOrchestratorProvider() string
func (*StartTeamReq) GetSessionId ¶
func (x *StartTeamReq) GetSessionId() string
func (*StartTeamReq) GetTask ¶
func (x *StartTeamReq) GetTask() string
func (*StartTeamReq) GetTeamConfigName ¶
func (x *StartTeamReq) GetTeamConfigName() string
func (*StartTeamReq) ProtoMessage ¶
func (*StartTeamReq) ProtoMessage()
func (*StartTeamReq) ProtoReflect ¶
func (x *StartTeamReq) ProtoReflect() protoreflect.Message
func (*StartTeamReq) Reset ¶
func (x *StartTeamReq) Reset()
func (*StartTeamReq) String ¶
func (x *StartTeamReq) String() string
type SteerTeamReq ¶
type SteerTeamReq struct {
TeamId string `protobuf:"bytes,1,opt,name=team_id,json=teamId,proto3" json:"team_id,omitempty"`
Directive string `protobuf:"bytes,2,opt,name=directive,proto3" json:"directive,omitempty"`
// contains filtered or unexported fields
}
func (*SteerTeamReq) Descriptor
deprecated
func (*SteerTeamReq) Descriptor() ([]byte, []int)
Deprecated: Use SteerTeamReq.ProtoReflect.Descriptor instead.
func (*SteerTeamReq) GetDirective ¶
func (x *SteerTeamReq) GetDirective() string
func (*SteerTeamReq) GetTeamId ¶
func (x *SteerTeamReq) GetTeamId() string
func (*SteerTeamReq) ProtoMessage ¶
func (*SteerTeamReq) ProtoMessage()
func (*SteerTeamReq) ProtoReflect ¶
func (x *SteerTeamReq) ProtoReflect() protoreflect.Message
func (*SteerTeamReq) Reset ¶
func (x *SteerTeamReq) Reset()
func (*SteerTeamReq) String ¶
func (x *SteerTeamReq) String() string
type TaskClaimReq ¶
type TaskClaimReq struct {
TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
AgentName string `protobuf:"bytes,2,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"`
// contains filtered or unexported fields
}
func (*TaskClaimReq) Descriptor
deprecated
func (*TaskClaimReq) Descriptor() ([]byte, []int)
Deprecated: Use TaskClaimReq.ProtoReflect.Descriptor instead.
func (*TaskClaimReq) GetAgentName ¶
func (x *TaskClaimReq) GetAgentName() string
func (*TaskClaimReq) GetTaskId ¶
func (x *TaskClaimReq) GetTaskId() string
func (*TaskClaimReq) ProtoMessage ¶
func (*TaskClaimReq) ProtoMessage()
func (*TaskClaimReq) ProtoReflect ¶
func (x *TaskClaimReq) ProtoReflect() protoreflect.Message
func (*TaskClaimReq) Reset ¶
func (x *TaskClaimReq) Reset()
func (*TaskClaimReq) String ¶
func (x *TaskClaimReq) String() string
type TaskCreateReq ¶
type TaskCreateReq struct {
Title string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
AssignedTeam string `protobuf:"bytes,3,opt,name=assigned_team,json=assignedTeam,proto3" json:"assigned_team,omitempty"`
Priority int32 `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
// contains filtered or unexported fields
}
Task tracker
func (*TaskCreateReq) Descriptor
deprecated
func (*TaskCreateReq) Descriptor() ([]byte, []int)
Deprecated: Use TaskCreateReq.ProtoReflect.Descriptor instead.
func (*TaskCreateReq) GetAssignedTeam ¶
func (x *TaskCreateReq) GetAssignedTeam() string
func (*TaskCreateReq) GetDescription ¶
func (x *TaskCreateReq) GetDescription() string
func (*TaskCreateReq) GetPriority ¶
func (x *TaskCreateReq) GetPriority() int32
func (*TaskCreateReq) GetProjectId ¶
func (x *TaskCreateReq) GetProjectId() string
func (*TaskCreateReq) GetTitle ¶
func (x *TaskCreateReq) GetTitle() string
func (*TaskCreateReq) ProtoMessage ¶
func (*TaskCreateReq) ProtoMessage()
func (*TaskCreateReq) ProtoReflect ¶
func (x *TaskCreateReq) ProtoReflect() protoreflect.Message
func (*TaskCreateReq) Reset ¶
func (x *TaskCreateReq) Reset()
func (*TaskCreateReq) String ¶
func (x *TaskCreateReq) String() string
type TaskInfo ¶
type TaskInfo struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Title string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
AssignedTeam string `protobuf:"bytes,4,opt,name=assigned_team,json=assignedTeam,proto3" json:"assigned_team,omitempty"`
ClaimedBy string `protobuf:"bytes,5,opt,name=claimed_by,json=claimedBy,proto3" json:"claimed_by,omitempty"`
Priority int32 `protobuf:"varint,6,opt,name=priority,proto3" json:"priority,omitempty"`
Description string `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`
ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
CreatedAt string `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
UpdatedAt string `protobuf:"bytes,10,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
// contains filtered or unexported fields
}
func (*TaskInfo) Descriptor
deprecated
func (*TaskInfo) GetAssignedTeam ¶
func (*TaskInfo) GetClaimedBy ¶
func (*TaskInfo) GetCreatedAt ¶
func (*TaskInfo) GetDescription ¶
func (*TaskInfo) GetPriority ¶
func (*TaskInfo) GetProjectId ¶
func (*TaskInfo) GetUpdatedAt ¶
func (*TaskInfo) ProtoMessage ¶
func (*TaskInfo) ProtoMessage()
func (*TaskInfo) ProtoReflect ¶
func (x *TaskInfo) ProtoReflect() protoreflect.Message
type TaskList ¶
type TaskList struct {
Tasks []*TaskInfo `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
// contains filtered or unexported fields
}
func (*TaskList) Descriptor
deprecated
func (*TaskList) ProtoMessage ¶
func (*TaskList) ProtoMessage()
func (*TaskList) ProtoReflect ¶
func (x *TaskList) ProtoReflect() protoreflect.Message
type TaskListReq ¶
type TaskListReq struct {
ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
Team string `protobuf:"bytes,2,opt,name=team,proto3" json:"team,omitempty"`
Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
Limit int32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
// contains filtered or unexported fields
}
func (*TaskListReq) Descriptor
deprecated
func (*TaskListReq) Descriptor() ([]byte, []int)
Deprecated: Use TaskListReq.ProtoReflect.Descriptor instead.
func (*TaskListReq) GetLimit ¶
func (x *TaskListReq) GetLimit() int32
func (*TaskListReq) GetProjectId ¶
func (x *TaskListReq) GetProjectId() string
func (*TaskListReq) GetStatus ¶
func (x *TaskListReq) GetStatus() string
func (*TaskListReq) GetTeam ¶
func (x *TaskListReq) GetTeam() string
func (*TaskListReq) ProtoMessage ¶
func (*TaskListReq) ProtoMessage()
func (*TaskListReq) ProtoReflect ¶
func (x *TaskListReq) ProtoReflect() protoreflect.Message
func (*TaskListReq) Reset ¶
func (x *TaskListReq) Reset()
func (*TaskListReq) String ¶
func (x *TaskListReq) String() string
type TaskReq ¶
type TaskReq struct {
TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
// contains filtered or unexported fields
}
func (*TaskReq) Descriptor
deprecated
func (*TaskReq) ProtoMessage ¶
func (*TaskReq) ProtoMessage()
func (*TaskReq) ProtoReflect ¶
func (x *TaskReq) ProtoReflect() protoreflect.Message
type TaskUpdateReq ¶
type TaskUpdateReq struct {
TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
Notes string `protobuf:"bytes,3,opt,name=notes,proto3" json:"notes,omitempty"`
// contains filtered or unexported fields
}
func (*TaskUpdateReq) Descriptor
deprecated
func (*TaskUpdateReq) Descriptor() ([]byte, []int)
Deprecated: Use TaskUpdateReq.ProtoReflect.Descriptor instead.
func (*TaskUpdateReq) GetNotes ¶
func (x *TaskUpdateReq) GetNotes() string
func (*TaskUpdateReq) GetStatus ¶
func (x *TaskUpdateReq) GetStatus() string
func (*TaskUpdateReq) GetTaskId ¶
func (x *TaskUpdateReq) GetTaskId() string
func (*TaskUpdateReq) ProtoMessage ¶
func (*TaskUpdateReq) ProtoMessage()
func (*TaskUpdateReq) ProtoReflect ¶
func (x *TaskUpdateReq) ProtoReflect() protoreflect.Message
func (*TaskUpdateReq) Reset ¶
func (x *TaskUpdateReq) Reset()
func (*TaskUpdateReq) String ¶
func (x *TaskUpdateReq) String() string
type TeamActivityEvent ¶
type TeamActivityEvent struct {
// Types that are valid to be assigned to Event:
//
// *TeamActivityEvent_AgentMessage
// *TeamActivityEvent_Token
// *TeamActivityEvent_Error
// *TeamActivityEvent_Complete
// *TeamActivityEvent_HumanRequest
Event isTeamActivityEvent_Event `protobuf_oneof:"event"`
// contains filtered or unexported fields
}
func (*TeamActivityEvent) Descriptor
deprecated
func (*TeamActivityEvent) Descriptor() ([]byte, []int)
Deprecated: Use TeamActivityEvent.ProtoReflect.Descriptor instead.
func (*TeamActivityEvent) GetAgentMessage ¶
func (x *TeamActivityEvent) GetAgentMessage() *AgentMessage
func (*TeamActivityEvent) GetComplete ¶
func (x *TeamActivityEvent) GetComplete() *SessionComplete
func (*TeamActivityEvent) GetError ¶
func (x *TeamActivityEvent) GetError() *ErrorEvent
func (*TeamActivityEvent) GetEvent ¶
func (x *TeamActivityEvent) GetEvent() isTeamActivityEvent_Event
func (*TeamActivityEvent) GetHumanRequest ¶
func (x *TeamActivityEvent) GetHumanRequest() *HumanRequest
func (*TeamActivityEvent) GetToken ¶
func (x *TeamActivityEvent) GetToken() *TokenDelta
func (*TeamActivityEvent) ProtoMessage ¶
func (*TeamActivityEvent) ProtoMessage()
func (*TeamActivityEvent) ProtoReflect ¶
func (x *TeamActivityEvent) ProtoReflect() protoreflect.Message
func (*TeamActivityEvent) Reset ¶
func (x *TeamActivityEvent) Reset()
func (*TeamActivityEvent) String ¶
func (x *TeamActivityEvent) String() string
type TeamActivityEvent_AgentMessage ¶
type TeamActivityEvent_AgentMessage struct {
AgentMessage *AgentMessage `protobuf:"bytes,1,opt,name=agent_message,json=agentMessage,proto3,oneof"`
}
type TeamActivityEvent_Complete ¶
type TeamActivityEvent_Complete struct {
Complete *SessionComplete `protobuf:"bytes,4,opt,name=complete,proto3,oneof"`
}
type TeamActivityEvent_Error ¶
type TeamActivityEvent_Error struct {
Error *ErrorEvent `protobuf:"bytes,3,opt,name=error,proto3,oneof"`
}
type TeamActivityEvent_HumanRequest ¶
type TeamActivityEvent_HumanRequest struct {
HumanRequest *HumanRequest `protobuf:"bytes,5,opt,name=human_request,json=humanRequest,proto3,oneof"`
}
type TeamActivityEvent_Token ¶
type TeamActivityEvent_Token struct {
Token *TokenDelta `protobuf:"bytes,2,opt,name=token,proto3,oneof"`
}
type TeamAddAgentReq ¶
type TeamAddAgentReq struct {
TeamId string `protobuf:"bytes,1,opt,name=team_id,json=teamId,proto3" json:"team_id,omitempty"`
AgentSpec string `protobuf:"bytes,2,opt,name=agent_spec,json=agentSpec,proto3" json:"agent_spec,omitempty"` // "name:provider[:model]"
// contains filtered or unexported fields
}
func (*TeamAddAgentReq) Descriptor
deprecated
func (*TeamAddAgentReq) Descriptor() ([]byte, []int)
Deprecated: Use TeamAddAgentReq.ProtoReflect.Descriptor instead.
func (*TeamAddAgentReq) GetAgentSpec ¶
func (x *TeamAddAgentReq) GetAgentSpec() string
func (*TeamAddAgentReq) GetTeamId ¶
func (x *TeamAddAgentReq) GetTeamId() string
func (*TeamAddAgentReq) ProtoMessage ¶
func (*TeamAddAgentReq) ProtoMessage()
func (*TeamAddAgentReq) ProtoReflect ¶
func (x *TeamAddAgentReq) ProtoReflect() protoreflect.Message
func (*TeamAddAgentReq) Reset ¶
func (x *TeamAddAgentReq) Reset()
func (*TeamAddAgentReq) String ¶
func (x *TeamAddAgentReq) String() string
type TeamEvent ¶
type TeamEvent struct {
// Types that are valid to be assigned to Event:
//
// *TeamEvent_AgentSpawned
// *TeamEvent_AgentMessage
// *TeamEvent_Token
// *TeamEvent_ToolStart
// *TeamEvent_ToolResult
// *TeamEvent_Permission
// *TeamEvent_Complete
// *TeamEvent_Error
Event isTeamEvent_Event `protobuf_oneof:"event"`
// contains filtered or unexported fields
}
func (*TeamEvent) Descriptor
deprecated
func (*TeamEvent) GetAgentMessage ¶
func (x *TeamEvent) GetAgentMessage() *AgentMessage
func (*TeamEvent) GetAgentSpawned ¶
func (x *TeamEvent) GetAgentSpawned() *AgentSpawned
func (*TeamEvent) GetComplete ¶
func (x *TeamEvent) GetComplete() *SessionComplete
func (*TeamEvent) GetError ¶
func (x *TeamEvent) GetError() *ErrorEvent
func (*TeamEvent) GetPermission ¶
func (x *TeamEvent) GetPermission() *PermissionRequest
func (*TeamEvent) GetToken ¶
func (x *TeamEvent) GetToken() *TokenDelta
func (*TeamEvent) GetToolResult ¶
func (x *TeamEvent) GetToolResult() *ToolCallResult
func (*TeamEvent) GetToolStart ¶
func (x *TeamEvent) GetToolStart() *ToolCallStart
func (*TeamEvent) ProtoMessage ¶
func (*TeamEvent) ProtoMessage()
func (*TeamEvent) ProtoReflect ¶
func (x *TeamEvent) ProtoReflect() protoreflect.Message
type TeamEvent_AgentMessage ¶
type TeamEvent_AgentMessage struct {
AgentMessage *AgentMessage `protobuf:"bytes,2,opt,name=agent_message,json=agentMessage,proto3,oneof"`
}
type TeamEvent_AgentSpawned ¶
type TeamEvent_AgentSpawned struct {
AgentSpawned *AgentSpawned `protobuf:"bytes,1,opt,name=agent_spawned,json=agentSpawned,proto3,oneof"`
}
type TeamEvent_Complete ¶
type TeamEvent_Complete struct {
Complete *SessionComplete `protobuf:"bytes,7,opt,name=complete,proto3,oneof"`
}
type TeamEvent_Error ¶
type TeamEvent_Error struct {
Error *ErrorEvent `protobuf:"bytes,8,opt,name=error,proto3,oneof"`
}
type TeamEvent_Permission ¶
type TeamEvent_Permission struct {
Permission *PermissionRequest `protobuf:"bytes,6,opt,name=permission,proto3,oneof"`
}
type TeamEvent_Token ¶
type TeamEvent_Token struct {
Token *TokenDelta `protobuf:"bytes,3,opt,name=token,proto3,oneof"`
}
type TeamEvent_ToolResult ¶
type TeamEvent_ToolResult struct {
ToolResult *ToolCallResult `protobuf:"bytes,5,opt,name=tool_result,json=toolResult,proto3,oneof"`
}
type TeamEvent_ToolStart ¶
type TeamEvent_ToolStart struct {
ToolStart *ToolCallStart `protobuf:"bytes,4,opt,name=tool_start,json=toolStart,proto3,oneof"`
}
type TeamList ¶
type TeamList struct {
Teams []*TeamStatus `protobuf:"bytes,1,rep,name=teams,proto3" json:"teams,omitempty"`
// contains filtered or unexported fields
}
func (*TeamList) Descriptor
deprecated
func (*TeamList) GetTeams ¶
func (x *TeamList) GetTeams() []*TeamStatus
func (*TeamList) ProtoMessage ¶
func (*TeamList) ProtoMessage()
func (*TeamList) ProtoReflect ¶
func (x *TeamList) ProtoReflect() protoreflect.Message
type TeamRemoveAgentReq ¶
type TeamRemoveAgentReq struct {
TeamId string `protobuf:"bytes,1,opt,name=team_id,json=teamId,proto3" json:"team_id,omitempty"`
AgentName string `protobuf:"bytes,2,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"`
// contains filtered or unexported fields
}
func (*TeamRemoveAgentReq) Descriptor
deprecated
func (*TeamRemoveAgentReq) Descriptor() ([]byte, []int)
Deprecated: Use TeamRemoveAgentReq.ProtoReflect.Descriptor instead.
func (*TeamRemoveAgentReq) GetAgentName ¶
func (x *TeamRemoveAgentReq) GetAgentName() string
func (*TeamRemoveAgentReq) GetTeamId ¶
func (x *TeamRemoveAgentReq) GetTeamId() string
func (*TeamRemoveAgentReq) ProtoMessage ¶
func (*TeamRemoveAgentReq) ProtoMessage()
func (*TeamRemoveAgentReq) ProtoReflect ¶
func (x *TeamRemoveAgentReq) ProtoReflect() protoreflect.Message
func (*TeamRemoveAgentReq) Reset ¶
func (x *TeamRemoveAgentReq) Reset()
func (*TeamRemoveAgentReq) String ¶
func (x *TeamRemoveAgentReq) String() string
type TeamRenameReq ¶
type TeamRenameReq struct {
TeamId string `protobuf:"bytes,1,opt,name=team_id,json=teamId,proto3" json:"team_id,omitempty"`
NewName string `protobuf:"bytes,2,opt,name=new_name,json=newName,proto3" json:"new_name,omitempty"`
// contains filtered or unexported fields
}
func (*TeamRenameReq) Descriptor
deprecated
func (*TeamRenameReq) Descriptor() ([]byte, []int)
Deprecated: Use TeamRenameReq.ProtoReflect.Descriptor instead.
func (*TeamRenameReq) GetNewName ¶
func (x *TeamRenameReq) GetNewName() string
func (*TeamRenameReq) GetTeamId ¶
func (x *TeamRenameReq) GetTeamId() string
func (*TeamRenameReq) ProtoMessage ¶
func (*TeamRenameReq) ProtoMessage()
func (*TeamRenameReq) ProtoReflect ¶
func (x *TeamRenameReq) ProtoReflect() protoreflect.Message
func (*TeamRenameReq) Reset ¶
func (x *TeamRenameReq) Reset()
func (*TeamRenameReq) String ¶
func (x *TeamRenameReq) String() string
type TeamStatus ¶
type TeamStatus struct {
TeamId string `protobuf:"bytes,1,opt,name=team_id,json=teamId,proto3" json:"team_id,omitempty"`
Task string `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
Agents []*Agent `protobuf:"bytes,3,rep,name=agents,proto3" json:"agents,omitempty"`
Status string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
// contains filtered or unexported fields
}
func (*TeamStatus) Descriptor
deprecated
func (*TeamStatus) Descriptor() ([]byte, []int)
Deprecated: Use TeamStatus.ProtoReflect.Descriptor instead.
func (*TeamStatus) GetAgents ¶
func (x *TeamStatus) GetAgents() []*Agent
func (*TeamStatus) GetStatus ¶
func (x *TeamStatus) GetStatus() string
func (*TeamStatus) GetTask ¶
func (x *TeamStatus) GetTask() string
func (*TeamStatus) GetTeamId ¶
func (x *TeamStatus) GetTeamId() string
func (*TeamStatus) ProtoMessage ¶
func (*TeamStatus) ProtoMessage()
func (*TeamStatus) ProtoReflect ¶
func (x *TeamStatus) ProtoReflect() protoreflect.Message
func (*TeamStatus) Reset ¶
func (x *TeamStatus) Reset()
func (*TeamStatus) String ¶
func (x *TeamStatus) String() string
type TeamStatusReq ¶
type TeamStatusReq struct {
TeamId string `protobuf:"bytes,1,opt,name=team_id,json=teamId,proto3" json:"team_id,omitempty"`
// contains filtered or unexported fields
}
func (*TeamStatusReq) Descriptor
deprecated
func (*TeamStatusReq) Descriptor() ([]byte, []int)
Deprecated: Use TeamStatusReq.ProtoReflect.Descriptor instead.
func (*TeamStatusReq) GetTeamId ¶
func (x *TeamStatusReq) GetTeamId() string
func (*TeamStatusReq) ProtoMessage ¶
func (*TeamStatusReq) ProtoMessage()
func (*TeamStatusReq) ProtoReflect ¶
func (x *TeamStatusReq) ProtoReflect() protoreflect.Message
func (*TeamStatusReq) Reset ¶
func (x *TeamStatusReq) Reset()
func (*TeamStatusReq) String ¶
func (x *TeamStatusReq) String() string
type TestProviderReq ¶
type TestProviderReq struct {
Alias string `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
// contains filtered or unexported fields
}
func (*TestProviderReq) Descriptor
deprecated
func (*TestProviderReq) Descriptor() ([]byte, []int)
Deprecated: Use TestProviderReq.ProtoReflect.Descriptor instead.
func (*TestProviderReq) GetAlias ¶
func (x *TestProviderReq) GetAlias() string
func (*TestProviderReq) ProtoMessage ¶
func (*TestProviderReq) ProtoMessage()
func (*TestProviderReq) ProtoReflect ¶
func (x *TestProviderReq) ProtoReflect() protoreflect.Message
func (*TestProviderReq) Reset ¶
func (x *TestProviderReq) Reset()
func (*TestProviderReq) String ¶
func (x *TestProviderReq) String() string
type TestProviderResult ¶
type TestProviderResult struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
LatencyMs int64 `protobuf:"varint,3,opt,name=latency_ms,json=latencyMs,proto3" json:"latency_ms,omitempty"`
// contains filtered or unexported fields
}
func (*TestProviderResult) Descriptor
deprecated
func (*TestProviderResult) Descriptor() ([]byte, []int)
Deprecated: Use TestProviderResult.ProtoReflect.Descriptor instead.
func (*TestProviderResult) GetLatencyMs ¶
func (x *TestProviderResult) GetLatencyMs() int64
func (*TestProviderResult) GetMessage ¶
func (x *TestProviderResult) GetMessage() string
func (*TestProviderResult) GetSuccess ¶
func (x *TestProviderResult) GetSuccess() bool
func (*TestProviderResult) ProtoMessage ¶
func (*TestProviderResult) ProtoMessage()
func (*TestProviderResult) ProtoReflect ¶
func (x *TestProviderResult) ProtoReflect() protoreflect.Message
func (*TestProviderResult) Reset ¶
func (x *TestProviderResult) Reset()
func (*TestProviderResult) String ¶
func (x *TestProviderResult) String() string
type ThinkingBlock ¶
type ThinkingBlock struct {
Content string `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
// contains filtered or unexported fields
}
func (*ThinkingBlock) Descriptor
deprecated
func (*ThinkingBlock) Descriptor() ([]byte, []int)
Deprecated: Use ThinkingBlock.ProtoReflect.Descriptor instead.
func (*ThinkingBlock) GetContent ¶
func (x *ThinkingBlock) GetContent() string
func (*ThinkingBlock) ProtoMessage ¶
func (*ThinkingBlock) ProtoMessage()
func (*ThinkingBlock) ProtoReflect ¶
func (x *ThinkingBlock) ProtoReflect() protoreflect.Message
func (*ThinkingBlock) Reset ¶
func (x *ThinkingBlock) Reset()
func (*ThinkingBlock) String ¶
func (x *ThinkingBlock) String() string
type TokenDelta ¶
type TokenDelta struct {
Content string `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
// contains filtered or unexported fields
}
func (*TokenDelta) Descriptor
deprecated
func (*TokenDelta) Descriptor() ([]byte, []int)
Deprecated: Use TokenDelta.ProtoReflect.Descriptor instead.
func (*TokenDelta) GetContent ¶
func (x *TokenDelta) GetContent() string
func (*TokenDelta) ProtoMessage ¶
func (*TokenDelta) ProtoMessage()
func (*TokenDelta) ProtoReflect ¶
func (x *TokenDelta) ProtoReflect() protoreflect.Message
func (*TokenDelta) Reset ¶
func (x *TokenDelta) Reset()
func (*TokenDelta) String ¶
func (x *TokenDelta) String() string
type ToolCallResult ¶
type ToolCallResult struct {
CallId string `protobuf:"bytes,1,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
ResultJson string `protobuf:"bytes,2,opt,name=result_json,json=resultJson,proto3" json:"result_json,omitempty"`
Success bool `protobuf:"varint,3,opt,name=success,proto3" json:"success,omitempty"`
// contains filtered or unexported fields
}
func (*ToolCallResult) Descriptor
deprecated
func (*ToolCallResult) Descriptor() ([]byte, []int)
Deprecated: Use ToolCallResult.ProtoReflect.Descriptor instead.
func (*ToolCallResult) GetCallId ¶
func (x *ToolCallResult) GetCallId() string
func (*ToolCallResult) GetResultJson ¶
func (x *ToolCallResult) GetResultJson() string
func (*ToolCallResult) GetSuccess ¶
func (x *ToolCallResult) GetSuccess() bool
func (*ToolCallResult) ProtoMessage ¶
func (*ToolCallResult) ProtoMessage()
func (*ToolCallResult) ProtoReflect ¶
func (x *ToolCallResult) ProtoReflect() protoreflect.Message
func (*ToolCallResult) Reset ¶
func (x *ToolCallResult) Reset()
func (*ToolCallResult) String ¶
func (x *ToolCallResult) String() string
type ToolCallStart ¶
type ToolCallStart struct {
ToolName string `protobuf:"bytes,1,opt,name=tool_name,json=toolName,proto3" json:"tool_name,omitempty"`
ArgumentsJson string `protobuf:"bytes,2,opt,name=arguments_json,json=argumentsJson,proto3" json:"arguments_json,omitempty"`
CallId string `protobuf:"bytes,3,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
// contains filtered or unexported fields
}
func (*ToolCallStart) Descriptor
deprecated
func (*ToolCallStart) Descriptor() ([]byte, []int)
Deprecated: Use ToolCallStart.ProtoReflect.Descriptor instead.
func (*ToolCallStart) GetArgumentsJson ¶
func (x *ToolCallStart) GetArgumentsJson() string
func (*ToolCallStart) GetCallId ¶
func (x *ToolCallStart) GetCallId() string
func (*ToolCallStart) GetToolName ¶
func (x *ToolCallStart) GetToolName() string
func (*ToolCallStart) ProtoMessage ¶
func (*ToolCallStart) ProtoMessage()
func (*ToolCallStart) ProtoReflect ¶
func (x *ToolCallStart) ProtoReflect() protoreflect.Message
func (*ToolCallStart) Reset ¶
func (x *ToolCallStart) Reset()
func (*ToolCallStart) String ¶
func (x *ToolCallStart) String() string
type UnimplementedRatchetDaemonServer ¶
type UnimplementedRatchetDaemonServer struct{}
UnimplementedRatchetDaemonServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedRatchetDaemonServer) AddProvider ¶
func (UnimplementedRatchetDaemonServer) AddProvider(context.Context, *AddProviderReq) (*Provider, error)
func (UnimplementedRatchetDaemonServer) ApprovePlan ¶
func (UnimplementedRatchetDaemonServer) ApprovePlan(*ApprovePlanReq, grpc.ServerStreamingServer[ChatEvent]) error
func (UnimplementedRatchetDaemonServer) AttachSession ¶
func (UnimplementedRatchetDaemonServer) AttachSession(*AttachReq, grpc.ServerStreamingServer[ChatEvent]) error
func (UnimplementedRatchetDaemonServer) AttachTeam ¶
func (UnimplementedRatchetDaemonServer) AttachTeam(*AttachTeamReq, grpc.ServerStreamingServer[TeamActivityEvent]) error
func (UnimplementedRatchetDaemonServer) CheckVersion ¶
func (UnimplementedRatchetDaemonServer) CheckVersion(context.Context, *VersionCheckReq) (*VersionCheckResp, error)
func (UnimplementedRatchetDaemonServer) ClaimTask ¶
func (UnimplementedRatchetDaemonServer) ClaimTask(context.Context, *TaskClaimReq) (*TaskInfo, error)
func (UnimplementedRatchetDaemonServer) CreateCron ¶
func (UnimplementedRatchetDaemonServer) CreateCron(context.Context, *CreateCronReq) (*CronJob, error)
func (UnimplementedRatchetDaemonServer) CreateSession ¶
func (UnimplementedRatchetDaemonServer) CreateSession(context.Context, *CreateSessionReq) (*Session, error)
func (UnimplementedRatchetDaemonServer) CreateTask ¶
func (UnimplementedRatchetDaemonServer) CreateTask(context.Context, *TaskCreateReq) (*TaskInfo, error)
func (UnimplementedRatchetDaemonServer) DetachSession ¶
func (UnimplementedRatchetDaemonServer) DirectMessage ¶
func (UnimplementedRatchetDaemonServer) DirectMessage(context.Context, *DirectMessageReq) (*Empty, error)
func (UnimplementedRatchetDaemonServer) GetAgentStatus ¶
func (UnimplementedRatchetDaemonServer) GetAgentStatus(context.Context, *AgentStatusReq) (*Agent, error)
func (UnimplementedRatchetDaemonServer) GetFleetStatus ¶
func (UnimplementedRatchetDaemonServer) GetFleetStatus(context.Context, *FleetStatusReq) (*FleetStatus, error)
func (UnimplementedRatchetDaemonServer) GetProjectStatus ¶
func (UnimplementedRatchetDaemonServer) GetProjectStatus(context.Context, *ProjectReq) (*ProjectStatus, error)
func (UnimplementedRatchetDaemonServer) GetTeamStatus ¶
func (UnimplementedRatchetDaemonServer) GetTeamStatus(context.Context, *TeamStatusReq) (*TeamStatus, error)
func (UnimplementedRatchetDaemonServer) Health ¶
func (UnimplementedRatchetDaemonServer) Health(context.Context, *Empty) (*HealthResponse, error)
func (UnimplementedRatchetDaemonServer) KillFleetWorker ¶
func (UnimplementedRatchetDaemonServer) KillFleetWorker(context.Context, *KillFleetWorkerReq) (*Empty, error)
func (UnimplementedRatchetDaemonServer) KillProject ¶
func (UnimplementedRatchetDaemonServer) KillProject(context.Context, *ProjectReq) (*Empty, error)
func (UnimplementedRatchetDaemonServer) KillSession ¶
func (UnimplementedRatchetDaemonServer) KillTeam ¶
func (UnimplementedRatchetDaemonServer) KillTeam(context.Context, *KillTeamReq) (*Empty, error)
func (UnimplementedRatchetDaemonServer) ListAgents ¶
func (UnimplementedRatchetDaemonServer) ListCrons ¶
func (UnimplementedRatchetDaemonServer) ListCrons(context.Context, *Empty) (*CronJobList, error)
func (UnimplementedRatchetDaemonServer) ListPendingHuman ¶
func (UnimplementedRatchetDaemonServer) ListPendingHuman(context.Context, *PendingHumanReq) (*PendingHumanList, error)
func (UnimplementedRatchetDaemonServer) ListProjects ¶
func (UnimplementedRatchetDaemonServer) ListProjects(context.Context, *Empty) (*ProjectList, error)
func (UnimplementedRatchetDaemonServer) ListProviders ¶
func (UnimplementedRatchetDaemonServer) ListProviders(context.Context, *Empty) (*ProviderList, error)
func (UnimplementedRatchetDaemonServer) ListSessions ¶
func (UnimplementedRatchetDaemonServer) ListSessions(context.Context, *Empty) (*SessionList, error)
func (UnimplementedRatchetDaemonServer) ListTasks ¶
func (UnimplementedRatchetDaemonServer) ListTasks(context.Context, *TaskListReq) (*TaskList, error)
func (UnimplementedRatchetDaemonServer) ListTeams ¶
func (UnimplementedRatchetDaemonServer) ListTeams(context.Context, *ListTeamsReq) (*TeamList, error)
func (UnimplementedRatchetDaemonServer) MeshStream ¶
func (UnimplementedRatchetDaemonServer) MeshStream(grpc.BidiStreamingServer[MeshEvent, MeshEvent]) error
func (UnimplementedRatchetDaemonServer) PauseCron ¶
func (UnimplementedRatchetDaemonServer) PauseCron(context.Context, *CronJobReq) (*Empty, error)
func (UnimplementedRatchetDaemonServer) PauseProject ¶
func (UnimplementedRatchetDaemonServer) PauseProject(context.Context, *ProjectReq) (*Empty, error)
func (UnimplementedRatchetDaemonServer) RegisterMeshNode ¶
func (UnimplementedRatchetDaemonServer) RegisterMeshNode(context.Context, *RegisterNodeReq) (*RegisterNodeResp, error)
func (UnimplementedRatchetDaemonServer) RejectPlan ¶
func (UnimplementedRatchetDaemonServer) RejectPlan(context.Context, *RejectPlanReq) (*Empty, error)
func (UnimplementedRatchetDaemonServer) RemoveProvider ¶
func (UnimplementedRatchetDaemonServer) RemoveProvider(context.Context, *RemoveProviderReq) (*Empty, error)
func (UnimplementedRatchetDaemonServer) RenameTeam ¶
func (UnimplementedRatchetDaemonServer) RenameTeam(context.Context, *TeamRenameReq) (*Empty, error)
func (UnimplementedRatchetDaemonServer) RequestReload ¶
func (UnimplementedRatchetDaemonServer) RequestReload(*ReloadReq, grpc.ServerStreamingServer[ReloadStatus]) error
func (UnimplementedRatchetDaemonServer) RespondToHuman ¶
func (UnimplementedRatchetDaemonServer) RespondToHuman(context.Context, *HumanResponse) (*Empty, error)
func (UnimplementedRatchetDaemonServer) RespondToPermission ¶
func (UnimplementedRatchetDaemonServer) RespondToPermission(context.Context, *PermissionResponse) (*Empty, error)
func (UnimplementedRatchetDaemonServer) ResumeCron ¶
func (UnimplementedRatchetDaemonServer) ResumeCron(context.Context, *CronJobReq) (*Empty, error)
func (UnimplementedRatchetDaemonServer) ResumeProject ¶
func (UnimplementedRatchetDaemonServer) ResumeProject(context.Context, *ProjectReq) (*Empty, error)
func (UnimplementedRatchetDaemonServer) SendMessage ¶
func (UnimplementedRatchetDaemonServer) SendMessage(*SendMessageReq, grpc.ServerStreamingServer[ChatEvent]) error
func (UnimplementedRatchetDaemonServer) SetDefaultProvider ¶
func (UnimplementedRatchetDaemonServer) SetDefaultProvider(context.Context, *SetDefaultProviderReq) (*Empty, error)
func (UnimplementedRatchetDaemonServer) StartFleet ¶
func (UnimplementedRatchetDaemonServer) StartFleet(*StartFleetReq, grpc.ServerStreamingServer[ChatEvent]) error
func (UnimplementedRatchetDaemonServer) StartProject ¶
func (UnimplementedRatchetDaemonServer) StartProject(context.Context, *StartProjectReq) (*ProjectStatus, error)
func (UnimplementedRatchetDaemonServer) StartTeam ¶
func (UnimplementedRatchetDaemonServer) StartTeam(*StartTeamReq, grpc.ServerStreamingServer[TeamEvent]) error
func (UnimplementedRatchetDaemonServer) SteerTeam ¶
func (UnimplementedRatchetDaemonServer) SteerTeam(context.Context, *SteerTeamReq) (*Empty, error)
func (UnimplementedRatchetDaemonServer) StopCron ¶
func (UnimplementedRatchetDaemonServer) StopCron(context.Context, *CronJobReq) (*Empty, error)
func (UnimplementedRatchetDaemonServer) TeamAddAgent ¶
func (UnimplementedRatchetDaemonServer) TeamAddAgent(context.Context, *TeamAddAgentReq) (*Empty, error)
func (UnimplementedRatchetDaemonServer) TeamRemoveAgent ¶
func (UnimplementedRatchetDaemonServer) TeamRemoveAgent(context.Context, *TeamRemoveAgentReq) (*Empty, error)
func (UnimplementedRatchetDaemonServer) TestProvider ¶
func (UnimplementedRatchetDaemonServer) TestProvider(context.Context, *TestProviderReq) (*TestProviderResult, error)
func (UnimplementedRatchetDaemonServer) UpdateProviderModel ¶
func (UnimplementedRatchetDaemonServer) UpdateProviderModel(context.Context, *UpdateProviderModelReq) (*Empty, error)
func (UnimplementedRatchetDaemonServer) UpdateTask ¶
func (UnimplementedRatchetDaemonServer) UpdateTask(context.Context, *TaskUpdateReq) (*TaskInfo, error)
type UnsafeRatchetDaemonServer ¶
type UnsafeRatchetDaemonServer interface {
// contains filtered or unexported methods
}
UnsafeRatchetDaemonServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RatchetDaemonServer will result in compilation errors.
type UpdateProviderModelReq ¶
type UpdateProviderModelReq struct {
Alias string `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
Model string `protobuf:"bytes,2,opt,name=model,proto3" json:"model,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateProviderModelReq) Descriptor
deprecated
func (*UpdateProviderModelReq) Descriptor() ([]byte, []int)
Deprecated: Use UpdateProviderModelReq.ProtoReflect.Descriptor instead.
func (*UpdateProviderModelReq) GetAlias ¶
func (x *UpdateProviderModelReq) GetAlias() string
func (*UpdateProviderModelReq) GetModel ¶
func (x *UpdateProviderModelReq) GetModel() string
func (*UpdateProviderModelReq) ProtoMessage ¶
func (*UpdateProviderModelReq) ProtoMessage()
func (*UpdateProviderModelReq) ProtoReflect ¶
func (x *UpdateProviderModelReq) ProtoReflect() protoreflect.Message
func (*UpdateProviderModelReq) Reset ¶
func (x *UpdateProviderModelReq) Reset()
func (*UpdateProviderModelReq) String ¶
func (x *UpdateProviderModelReq) String() string
type VersionCheckReq ¶
type VersionCheckReq struct {
CliVersion string `protobuf:"bytes,1,opt,name=cli_version,json=cliVersion,proto3" json:"cli_version,omitempty"`
CliCommit string `protobuf:"bytes,2,opt,name=cli_commit,json=cliCommit,proto3" json:"cli_commit,omitempty"`
CliProtoVersion int32 `protobuf:"varint,3,opt,name=cli_proto_version,json=cliProtoVersion,proto3" json:"cli_proto_version,omitempty"`
// contains filtered or unexported fields
}
Version check
func (*VersionCheckReq) Descriptor
deprecated
func (*VersionCheckReq) Descriptor() ([]byte, []int)
Deprecated: Use VersionCheckReq.ProtoReflect.Descriptor instead.
func (*VersionCheckReq) GetCliCommit ¶
func (x *VersionCheckReq) GetCliCommit() string
func (*VersionCheckReq) GetCliProtoVersion ¶
func (x *VersionCheckReq) GetCliProtoVersion() int32
func (*VersionCheckReq) GetCliVersion ¶
func (x *VersionCheckReq) GetCliVersion() string
func (*VersionCheckReq) ProtoMessage ¶
func (*VersionCheckReq) ProtoMessage()
func (*VersionCheckReq) ProtoReflect ¶
func (x *VersionCheckReq) ProtoReflect() protoreflect.Message
func (*VersionCheckReq) Reset ¶
func (x *VersionCheckReq) Reset()
func (*VersionCheckReq) String ¶
func (x *VersionCheckReq) String() string
type VersionCheckResp ¶
type VersionCheckResp struct {
Compatible bool `protobuf:"varint,1,opt,name=compatible,proto3" json:"compatible,omitempty"`
ReloadRecommended bool `protobuf:"varint,2,opt,name=reload_recommended,json=reloadRecommended,proto3" json:"reload_recommended,omitempty"`
DaemonVersion string `protobuf:"bytes,3,opt,name=daemon_version,json=daemonVersion,proto3" json:"daemon_version,omitempty"`
Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*VersionCheckResp) Descriptor
deprecated
func (*VersionCheckResp) Descriptor() ([]byte, []int)
Deprecated: Use VersionCheckResp.ProtoReflect.Descriptor instead.
func (*VersionCheckResp) GetCompatible ¶
func (x *VersionCheckResp) GetCompatible() bool
func (*VersionCheckResp) GetDaemonVersion ¶
func (x *VersionCheckResp) GetDaemonVersion() string
func (*VersionCheckResp) GetMessage ¶
func (x *VersionCheckResp) GetMessage() string
func (*VersionCheckResp) GetReloadRecommended ¶
func (x *VersionCheckResp) GetReloadRecommended() bool
func (*VersionCheckResp) ProtoMessage ¶
func (*VersionCheckResp) ProtoMessage()
func (*VersionCheckResp) ProtoReflect ¶
func (x *VersionCheckResp) ProtoReflect() protoreflect.Message
func (*VersionCheckResp) Reset ¶
func (x *VersionCheckResp) Reset()
func (*VersionCheckResp) String ¶
func (x *VersionCheckResp) String() string