msg

package

Go to main page

Versions in this module

v0

v0.2.11

Oct 19, 2026

Changes in this version

type ConversationMessage

+ ToolChrome bool

v0.2.9

Aug 16, 2026

v0.2.7

Aug 16, 2026

Changes in this version

type MsgSetRunBudget

+ AutoApprovePersist bool

v0.2.6

Aug 15, 2026

v0.2.5

Aug 9, 2026

v0.2.4

Aug 9, 2026

v0.2.3

Aug 8, 2026

Changes in this version

+ const GatewayLeaseMaxTokens

+ const GatewayLeaseMinTokens

+ const GatewayLeaseRenewBefore

+ const GatewayLeaseRenewFraction

+ const GatewayLeaseTTL

+ const GatewayLeaseWantFraction

+ const ProxyBlocked

+ const ProxyBudgetRateLimited

+ const TagGatewayUsageBatch

+ const UsageScopePane

+ const UsageScopeTenant

+ func GatewayUsageSubject(workspaceID string) string

+ func GatewayUsageWildcardSubject() string

+ func RegisterGatewayCodecs(r *CodecRegistry)

+ func TenantScope(tenant string) string

type ConversationMessage

+ Model string

+ ProviderName string

+ func (m ConversationMessage) Attribution() string

+ type GatewayLeaseReply struct

+ ActiveDaemons int

+ CeilingTokens int64

+ ExpiresAt time.Time

+ GrantedTokens int64

+ MaxLeaseTokens int64

+ RemainingToday int64

+ type GatewayLeaseRequest struct

+ DaemonID string

+ Scope string

+ SpentSince int64

+ WantTokens int64

+ type GatewayUsageRollup struct

+ CacheRead int64

+ CacheWrite int64

+ Calls int64

+ CostMicroUSD int64

+ InTokens int64

+ OutTokens int64

+ Tenant string

+ UsageDate string

+ func (r GatewayUsageRollup) Tokens() int64

+ type MsgGatewayUsageBatch struct

+ DaemonID string

+ Rollups []GatewayUsageRollup

+ SentAt time.Time

+ Seq int64

+ WorkspaceID string

type MsgProxyRequestAudit

+ Attempts int

+ Tenant string

+ Upstream string

type MsgUsageCheck

+ Tenant string

type MsgUsageCheckReply

+ Scope string

+ Tenant string

type MsgUsageRecord

+ Tenant string

type NATSPublisher

+ func (p *NATSPublisher) SendGatewayUsage(b *MsgGatewayUsageBatch) error

v0.1.0

Jul 27, 2026

Changes in this version

+ const MaxMemoryEntries

+ const ProxyBudgetExceeded

+ const ProxyBudgetOK

+ const StepApprovalWait

+ const StepCompaction

+ const StepDone

+ const StepError

+ const StepFinalAnswer

+ const StepGrounded

+ const StepPaused

+ const StepQuestion

+ const StepResumed

+ const StepRunStart

+ const StepSubAgentEnd

+ const StepSubAgentStart

+ const StepToolEnd

+ const StepToolStart

+ const StoppedReasonAwaitingInfo

+ const StoppedReasonCancelled

+ const StoppedReasonMaxDuration

+ const StoppedReasonMaxIterations

+ const StoppedReasonMaxTokens

+ const TagAgenticCancel

+ const TagAgenticContinue

+ const TagAgenticOutput

+ const TagAgenticPrompt

+ const TagAgenticStatus

+ const TagAgenticStep

+ const TagApprovalRequest

+ const TagApprovalResponse

+ const TagBrowserActionRequest

+ const TagBrowserActionResponse

+ const TagChatbotHumanReply

+ const TagChatbotRelease

+ const TagChatbotSessionClosed

+ const TagChatbotSessionCreated

+ const TagChatbotSessionList

+ const TagChatbotSessionListReply

+ const TagChatbotTakeover

+ const TagChatbotVisitorTyping

+ const TagConversationAppend

+ const TagConversationHistoryAppend

+ const TagConversationHistoryReply

+ const TagCreateApprovalPane

+ const TagDestroyApprovalPane

+ const TagGetConversationHistory

+ const TagGetGroundingState

+ const TagGetRunStatus

+ const TagGetSessionMemory

+ const TagGroundingStateReply

+ const TagMemoryAppend

+ const TagMemoryGet

+ const TagMemoryGetReply

+ const TagMemoryStateUpdate

+ const TagMemorySummarize

+ const TagMemorySummarizeDone

+ const TagOrchestratorDone

+ const TagPaneAIHistoryAppend

+ const TagPaneAIOutputAppend

+ const TagPaneChatHistoryAppend

+ const TagPaneChatOutputAppend

+ const TagPaneExternalHistoryAppend

+ const TagPaneExternalOutputAppend

+ const TagPaneHistoryAppend

+ const TagPaneOutputAppend

+ const TagPaneRyshHistoryAppend

+ const TagPaneRyshOutputAppend

+ const TagPaneSetApprovalPaneGroups

+ const TagPaneShellHistoryAppend

+ const TagPaneShellOutputAppend

+ const TagPaneStatusUpdate

+ const TagPipelineOutputAppend

+ const TagProxyAuditSnapshotReply

+ const TagProxyAuditSnapshotRequest

+ const TagProxyRequestAudit

+ const TagReloadPrompts

+ const TagRestoreConversation

+ const TagRunStatusReply

+ const TagSessionMemoryReplace

+ const TagSessionMemoryReply

+ const TagSetChatOutputPane

+ const TagSetGroundingMode

+ const TagSetRunBudget

+ const TagSpawnSubOrchestrator

+ const TagSubOrchestratorResult

+ const TagToolCall

+ const TagToolResult

+ const TagUsageBudgetSet

+ const TagUsageCheck

+ const TagUsageCheckReply

+ const TagUsageRecord

+ const TagUsageSnapshotReply

+ const TagUsageSnapshotRequest

+ const UsageSourceAgent

+ const UsageSourceCI

+ const UsageSourceEval

+ const UsageSourceProxy

+ func FormatMemoryForPrompt(state *MemoryState) string

+ func InitMsgLog(logMessages bool)

+ func MemorySummarizationPrompt(mode ConversationType, turns []ConversationMessage) string

+ func NewTurnID() string

+ func NowMs() int64

+ func ProxyAuditInboxSubject() string

+ func ProxyAuditSubject(paneID string) string

+ func ProxyAuditWildcardSubject() string

+ func RegisterAgenticCodecs(r *CodecRegistry)

+ func RegisterBrowserCodecs(r *CodecRegistry)

+ func RegisterChatbotCodecs(r *CodecRegistry)

+ func RegisterProxyAuditCodecs(r *CodecRegistry)

+ func RegisterUsageCodecs(r *CodecRegistry)

+ func SessionPrefix() string

+ func SetSessionPrefix(session string)

+ func T(parts ...string) string

+ func UsageCheckSubject() string

+ func UsageInboxSubject() string

+ func UsageSubject(paneID string) string

+ func UsageWildcardSubject() string

+ type ApprovalDecision string

+ const DecisionChoiceSelected

+ const DecisionNo

+ const DecisionNoWithExplanation

+ const DecisionYes

+ const DecisionYesAlways

+ type ApprovalType string

+ const ApprovalTypeChoice

+ const ApprovalTypeDestructive

+ const ApprovalTypeDiff

+ const ApprovalTypeQuestion

+ type ChatbotSessionInfo struct

+ CreatedAt string

+ LastMessage string

+ MessageCount int

+ OriginURL string

+ PaneID string

+ SessionID string

+ Status string

+ TakenOverBy string

+ VisitorID string

+ VisitorName string

+ type Choice struct

+ Description string

+ Label string

+ type CodecRegistry struct

+ func DefaultCodecRegistry() *CodecRegistry

+ func NewCodecRegistry() *CodecRegistry

+ func (r *CodecRegistry) Decode(tag string, payload []byte) (interface{}, error)

+ func (r *CodecRegistry) Register(tag string, typeName string, decode func([]byte) (interface{}, error))

+ func (r *CodecRegistry) TagOf(msg interface{}) string

+ type ConversationMessage struct

+ Content string

+ ConversationType ConversationType

+ InputType InputType

+ MessageSource MessageSource

+ Origin *MessageOrigin

+ Role string

+ Sensitive bool

+ Streaming bool

+ SubjectToShare bool

+ TimestampMs int64

+ TurnID string

+ TurnType TurnType

+ func NewAIAnswer(turnID, output string, streaming bool) *ConversationMessage

+ func NewAIQuestion(turnID, prompt string) *ConversationMessage

+ func NewChannelMessage(turnID string, turnType TurnType, convType ConversationType, ...) *ConversationMessage

+ func NewChatMessage(turnID string, turnType TurnType, content, role string, source MessageSource) *ConversationMessage

+ func NewRyshAnswer(turnID, output string) *ConversationMessage

+ func NewRyshQuestion(turnID, command string) *ConversationMessage

+ func NewShellAnswer(turnID, output string) *ConversationMessage

+ func NewShellQuestion(turnID, command string) *ConversationMessage

+ type ConversationTurnInfo struct

+ Category string

+ Content string

+ IsError bool

+ Origin string

+ Role string

+ Summary string

+ TimestampMs int64

+ ToolCallID string

+ ToolCalls []ToolCallInfo

+ type ConversationType string

+ const ConvAI

+ const ConvChat

+ const ConvChatbot

+ const ConvEmail

+ const ConvRysh

+ const ConvShell

+ const ConvSlack

+ func (ct ConversationType) HasMemory() bool

+ func (ct ConversationType) IsDualPublish() bool

+ type DiffPayload struct

+ FilePath string

+ UnifiedDiff string

+ type GroundingReportInfo struct

+ Evidence string

+ MissingInfo string

+ Question string

+ RelevantFiles []string

+ TimestampMs int64

+ Understood bool

+ type InputType string

+ const InputApproval

+ const InputCommand

+ const InputMessage

+ const InputPrompt

+ const InputShell

+ type MemoryEntry struct

+ CreatedAtMs int64

+ ID string

+ Mode ConversationType

+ Summary string

+ TurnCount int

+ TurnIDs []string

+ func NewMemoryEntry(mode ConversationType, summary string, turnIDs []string) *MemoryEntry

+ type MemoryState struct

+ Entries []MemoryEntry

+ Mode ConversationType

+ PaneID string

+ TotalSummarizedTurns int

+ type MessageLogger struct

+ func MsgLog() *MessageLogger

+ func (ml *MessageLogger) Enabled() bool

+ func (ml *MessageLogger) LogError(context, subject string, err error, actor string)

+ func (ml *MessageLogger) LogPayload(direction, subject, typeTag string, payload []byte, actor string)

+ func (ml *MessageLogger) LogRecv(subject, typeTag string, actor string, isRequest bool)

+ func (ml *MessageLogger) LogReply(replyTo, typeTag string, payloadSize int, actor string)

+ func (ml *MessageLogger) LogRequest(subject, typeTag string, payloadSize int, timeout time.Duration, actor string)

+ func (ml *MessageLogger) LogSend(subject, typeTag string, payloadSize int, actor string)

+ type MessageOrigin struct

+ MirrorPaneID string

+ MirrorTabID string

+ SourcePaneAlias string

+ SourcePaneID string

+ SourceShareID string

+ SourceTabID string

+ type MessageSource string

+ const SourceAI

+ const SourceAgent

+ const SourceExternal

+ const SourceHuman

+ const SourceHumanoid

+ const SourceSubagent

+ const SourceSystem

+ type MsgAgenticCancel struct

+ type MsgAgenticContinue struct

+ type MsgAgenticOutput struct

+ Content string

+ Metadata map[string]string

+ OrchestratorID string

+ Type string

+ type MsgAgenticPrompt struct

+ ContentBlocks []provider.ContentBlock

+ Prompt string

+ RequestID string

+ ScopeHint string

+ type MsgAgenticStatus struct

+ ActiveTools []string

+ Iteration int

+ MaxIterations int

+ OrchestratorID string

+ Phase string

+ type MsgAgenticStep struct

+ Category string

+ Depth int

+ Detail string

+ Iteration int

+ Kind string

+ OrchestratorID string

+ Origin string

+ TimestampMs int64

+ Title string

+ type MsgApprovalRequest struct

+ Choices []Choice

+ Description string

+ Diff *DiffPayload

+ OrchestratorID string

+ RequestID string

+ ToolCallID string

+ Type ApprovalType

+ type MsgApprovalResponse struct

+ ChoiceIdx int

+ Decision ApprovalDecision

+ Reason string

+ RequestID string

+ RespondingPaneID string

+ type MsgBrowserActionRequest struct

+ Action string

+ Params json.RawMessage

+ RequestID string

+ type MsgBrowserActionResponse struct

+ Error string

+ RequestID string

+ Result json.RawMessage

+ Screenshot string

+ Success bool

+ type MsgChatbotHumanReply struct

+ Content string

+ PaneID string

+ SessionID string

+ UserName string

+ type MsgChatbotRelease struct

+ PaneID string

+ SessionID string

+ UserID string

+ type MsgChatbotSessionClosed struct

+ ConfigID string

+ PaneID string

+ Reason string

+ SessionID string

+ type MsgChatbotSessionCreated struct

+ ConfigID string

+ OriginURL string

+ PaneID string

+ SessionID string

+ VisitorID string

+ VisitorName string

+ type MsgChatbotSessionList struct

+ ConfigID string

+ type MsgChatbotSessionListReply struct

+ Sessions []ChatbotSessionInfo

+ type MsgChatbotTakeover struct

+ PaneID string

+ SessionID string

+ UserID string

+ UserName string

+ type MsgChatbotVisitorTyping struct

+ IsTyping bool

+ SessionID string

+ type MsgConversationAppend struct

+ Message *ConversationMessage

+ type MsgConversationHistoryAppend struct

+ Message *ConversationMessage

+ type MsgConversationHistoryReply struct

+ PaneID string

+ Turns []ConversationTurnInfo

+ type MsgCreateApprovalPane struct

+ ApprovalRequest *MsgApprovalRequest

+ OrchestratorID string

+ RequestID string

+ ResponseSubject string

+ SourcePaneID string

+ SourcePaneName string

+ type MsgDestroyApprovalPane struct

+ RequestID string

+ type MsgGetConversationHistory struct

+ LastN int

+ type MsgGetGroundingState struct

+ type MsgGetRunStatus struct

+ type MsgGetSessionMemory struct

+ type MsgGroundingStateReply struct

+ DefaultMode string

+ LastReport *GroundingReportInfo

+ Mode string

+ Overridden bool

+ PaneID string

+ RunActive bool

+ type MsgMemoryAppend struct

+ Entry MemoryEntry

+ PaneID string

+ type MsgMemoryGet struct

+ Mode ConversationType

+ PaneID string

+ type MsgMemoryGetReply struct

+ State *MemoryState

+ type MsgMemoryStateUpdate struct

+ State *MemoryState

+ type MsgMemorySummarize struct

+ Mode ConversationType

+ PaneID string

+ Turns []ConversationMessage

+ type MsgMemorySummarizeDone struct

+ Entry MemoryEntry

+ Error string

+ Mode ConversationType

+ PaneID string

+ type MsgOrchestratorDone struct

+ CacheReadTokens int

+ CacheWriteTokens int

+ Conversation []provider.ConversationTurn

+ Errors []string

+ FilesChanged []string

+ FreshInputTokens int

+ Interrupted bool

+ OrchestratorID string

+ StoppedReason string

+ Success bool

+ Summary string

+ TokensUsed int

+ type MsgPaneAIHistoryAppend struct

+ Entry string

+ type MsgPaneAIOutputAppend struct

+ Text string

+ type MsgPaneChatHistoryAppend struct

+ Entry string

+ type MsgPaneChatOutputAppend struct

+ Role string

+ Text string

+ type MsgPaneExternalHistoryAppend struct

+ Entry string

+ type MsgPaneExternalOutputAppend struct

+ Text string

+ type MsgPaneHistoryAppend struct

+ Entry string

+ type MsgPaneOutputAppend struct

+ Text string

+ type MsgPaneRyshHistoryAppend struct

+ Entry string

+ type MsgPaneRyshOutputAppend struct

+ Text string

+ type MsgPaneSetApprovalPaneGroups struct

+ PaneGroupIDs []string

+ PaneName string

+ type MsgPaneShellHistoryAppend struct

+ Entry string

+ type MsgPaneShellOutputAppend struct

+ Text string

+ type MsgPaneStatusUpdate struct

+ Status string

+ type MsgPipelineOutputAppend struct

+ Text string

+ type MsgProxyAuditSnapshotReply struct

+ Durable bool

+ Records []MsgProxyRequestAudit

+ type MsgProxyAuditSnapshotRequest struct

+ Limit int

+ type MsgProxyRequestAudit struct

+ BudgetState string

+ Dialect string

+ Endpoint string

+ InTokens int

+ Model string

+ OutTokens int

+ PaneID string

+ RedactionHits int

+ ReqBytes int

+ Status int

+ TS time.Time

+ type MsgReloadPrompts struct

+ EmailGovernance string

+ SystemPrompt string

+ type MsgRestoreConversation struct

+ Conversation []provider.ConversationTurn

+ type MsgRunStatusReply struct

+ Armed bool

+ ArmedAtMs int64

+ CacheReadTokens int

+ CacheWriteTokens int

+ ContinuesLeft int

+ DeadlineMs int64

+ Finalizer bool

+ FreshInputTokens int

+ InFlight bool

+ MaxContextTokens int

+ PaneID string

+ Paused bool

+ PausedReason string

+ StepInterval int

+ TokensUsed int

+ TokensUsedTotal int

+ type MsgSessionMemoryReplace struct

+ Paused bool

+ PausedReason string

+ SourceAlias string

+ SourcePaneID string

+ Turns []provider.ConversationTurn

+ type MsgSessionMemoryReply struct

+ PaneID string

+ Paused bool

+ PausedReason string

+ Turns []provider.ConversationTurn

+ type MsgSetChatOutputPane struct

+ PaneID string

+ type MsgSetGroundingMode struct

+ Mode string

+ type MsgSetRunBudget struct

+ AutoApprove bool

+ AutoContinue bool

+ Effort string

+ FinalizerEffort string

+ FinalizerMaxContextTokens int

+ FinalizerMaxDurationMs int64

+ FinalizerMaxIterations int

+ FinalizerModel string

+ FinalizerPrompt string

+ MaxContextTokens int

+ MaxDurationMs int64

+ MaxTotalIterations int

+ Model string

+ OutputDir string

+ StepInterval int

+ type MsgSpawnSubOrchestrator struct

+ Context string

+ ParentOrchestratorID string

+ SubOrchestratorID string

+ Task string

+ type MsgSubOrchestratorResult struct

+ ParentOrchestratorID string

+ SubOrchestratorID string

+ Success bool

+ Summary string

+ type MsgToolCall struct

+ Parameters json.RawMessage

+ ToolCallID string

+ ToolName string

+ type MsgToolResult struct

+ Approved bool

+ Content string

+ Error string

+ ExitCode int

+ ToolCallID string

+ ToolName string

+ type MsgUsageBudgetSet struct

+ CeilingTokens int64

+ PaneID string

+ type MsgUsageCheck struct

+ PaneID string

+ type MsgUsageCheckReply struct

+ CeilingTokens int64

+ Ok bool

+ PaneID string

+ SpentTokens int64

+ type MsgUsageRecord struct

+ AgentName string

+ CacheRead int

+ CacheWrite int

+ CostMicroUSD int64

+ InTokens int

+ Model string

+ OutTokens int

+ PaneID string

+ Provider string

+ Source string

+ TS time.Time

+ type MsgUsageSnapshotReply struct

+ ByAgent []UsageAgg

+ ByPane []UsageAgg

+ Ceilings []UsageCeiling

+ SessionCostMicroUSD int64

+ SessionTokens int64

+ Window string

+ type MsgUsageSnapshotRequest struct

+ Window string

+ type NATSEnvelope struct

+ Payload json.RawMessage

+ ReplyTo string

+ TypeTag string

+ type NATSPublisher struct

+ func NewNATSPublisher(nc *nats.Conn, codecs *CodecRegistry) *NATSPublisher

+ func (p *NATSPublisher) Codecs() *CodecRegistry

+ func (p *NATSPublisher) Flush() error

+ func (p *NATSPublisher) Request(subject string, message interface{}, timeout time.Duration) (interface{}, error)

+ func (p *NATSPublisher) Send(subject string, message interface{}) error

+ func (p *NATSPublisher) SendBrowserActionRequest(paneID string, req *MsgBrowserActionRequest) error

+ func (p *NATSPublisher) SendConversation(paneID string, cm *ConversationMessage) error

+ func (p *NATSPublisher) SendConversationHistory(paneID string, cm *ConversationMessage) error

+ func (p *NATSPublisher) SendMemoryAppend(paneID string, entry *MemoryEntry) error

+ func (p *NATSPublisher) SendMemorySummarize(paneID string, mode ConversationType, turns []ConversationMessage) error

+ func (p *NATSPublisher) SendPaneAIHistory(paneID, entry string) error

+ func (p *NATSPublisher) SendPaneAIOutput(paneID, text string) error

+ func (p *NATSPublisher) SendPaneChatHistory(paneID, entry string) error

+ func (p *NATSPublisher) SendPaneChatOutput(paneID, text string) error

+ func (p *NATSPublisher) SendPaneExternalOutput(paneID, text string) error

+ func (p *NATSPublisher) SendPaneHistory(paneID, entry string) error

+ func (p *NATSPublisher) SendPaneModeOutput(paneID, mode, text string) error

+ func (p *NATSPublisher) SendPaneOutput(paneID, text string) error

+ func (p *NATSPublisher) SendPaneRyshHistory(paneID, entry string) error

+ func (p *NATSPublisher) SendPaneRyshOutput(paneID, text string) error

+ func (p *NATSPublisher) SendPaneShellHistory(paneID, entry string) error

+ func (p *NATSPublisher) SendPaneShellOutput(paneID, text string) error

+ func (p *NATSPublisher) SendProxyAudit(rec *MsgProxyRequestAudit) error

+ func (p *NATSPublisher) SendUsageRecord(rec *MsgUsageRecord) error

+ type RequestEnvelope struct

+ Codecs *CodecRegistry

+ Inner interface{}

+ NC *nats.Conn

+ ReplyTo string

+ func (r *RequestEnvelope) Reply(responseMsg interface{}) error

+ type ToolCallInfo struct

+ ID string

+ Input json.RawMessage

+ Name string

+ type TurnType string

+ const TurnAnswer

+ const TurnQuestion

+ type UsageAgg struct

+ CacheRead int64

+ CacheWrite int64

+ Calls int64

+ CostMicroUSD int64

+ InTokens int64

+ Key string

+ Label string

+ OutTokens int64

+ UnknownCost bool

+ type UsageCeiling struct

+ CeilingTokens int64

+ PaneID string

+ SpentTokens int64

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