Versions in this module Expand all Collapse all v0 v0.2.4 Mar 12, 2026 v0.2.3 Mar 12, 2026 v0.2.2 Mar 11, 2026 v0.2.1 Mar 11, 2026 v0.2.0 Mar 11, 2026 v0.0.4 Mar 16, 2026 v0.0.3 Mar 14, 2026 v0.0.2 Mar 13, 2026 v0.0.1 Mar 13, 2026 Changes in this version + type AgentInfo struct + DisplayName string + ID string + ParentAgentID string + Role string + Transport string + Type string + type Artifact struct + ContentB64 string + ContentText string + ID string + Kind string + MIMEType string + Name string + Path string + SizeBytes int64 + SourcePath string + Storage string + URL string + type Capabilities struct + Camera bool + Canvas bool + Invoke bool + Location bool + Model bool + Run bool + Screen bool + type DispatchPolicy struct + ActionTags map[string][]string + AgentTags map[string][]string + AllowActions map[string][]string + AllowAgents map[string][]string + AllowRelayFallback bool + DenyActions map[string][]string + DenyAgents map[string][]string + PreferLocal bool + PreferP2P bool + type HTTPRelayTransport struct + Client *http.Client + Manager *Manager + func (s *HTTPRelayTransport) Name() string + func (s *HTTPRelayTransport) Send(ctx context.Context, req Request) (Response, error) + type Handler func(req Request) Response + type Manager struct + func DefaultManager() *Manager + func NewManager() *Manager + func (m *Manager) DispatchPolicy() DispatchPolicy + func (m *Manager) Get(id string) (NodeInfo, bool) + func (m *Manager) HandleWireMessage(msg WireMessage) bool + func (m *Manager) Invoke(req Request) (Response, bool) + func (m *Manager) List() []NodeInfo + func (m *Manager) MarkOffline(id string) + func (m *Manager) PickFor(action string) (NodeInfo, bool) + func (m *Manager) PickRequest(req Request, mode string) (NodeInfo, bool) + func (m *Manager) RegisterHandler(nodeID string, h Handler) + func (m *Manager) RegisterWireSender(nodeID string, sender WireSender) + func (m *Manager) Remove(id string) bool + func (m *Manager) SendWireRequest(ctx context.Context, nodeID string, req Request) (Response, error) + func (m *Manager) SetAuditPath(path string) + func (m *Manager) SetDispatchPolicy(policy DispatchPolicy) + func (m *Manager) SetStatePath(path string) + func (m *Manager) SupportsAction(nodeID, action string) bool + func (m *Manager) SupportsRequest(nodeID string, req Request) bool + func (m *Manager) Upsert(info NodeInfo) + type NodeInfo struct + Actions []string + Agents []AgentInfo + Arch string + Capabilities Capabilities + Endpoint string + ID string + LastSeenAt time.Time + Models []string + Name string + OS string + Online bool + RegisteredAt time.Time + Tags []string + Token string + Version string + type Request struct + Action string + Args map[string]interface{} + Model string + Node string + Task string + type Response struct + Action string + Code string + Error string + Node string + OK bool + Payload map[string]interface{} + func DoEndpointRequest(ctx context.Context, client *http.Client, endpoint, token string, req Request) (Response, error) + type Router struct + P2P Transport + Policy DispatchPolicy + Relay Transport + func (r *Router) Dispatch(ctx context.Context, req Request, mode string) (Response, error) + type Transport interface + Name func() string + Send func(ctx context.Context, req Request) (Response, error) + type WebRTCTransport struct + func NewWebRTCTransport(stunServers []string, extraICEServers ...webrtc.ICEServer) *WebRTCTransport + func (t *WebRTCTransport) BindSignaler(nodeID string, sender WireSender) + func (t *WebRTCTransport) HandleSignal(msg WireMessage) error + func (t *WebRTCTransport) Name() string + func (t *WebRTCTransport) Send(ctx context.Context, req Request) (Response, error) + func (t *WebRTCTransport) Snapshot() map[string]interface{} + func (t *WebRTCTransport) UnbindSignaler(nodeID string) + type WebsocketP2PTransport struct + Manager *Manager + func (s *WebsocketP2PTransport) Name() string + func (s *WebsocketP2PTransport) Send(ctx context.Context, req Request) (Response, error) + type WireAck struct + Error string + ID string + OK bool + Type string + type WireMessage struct + From string + ID string + Node *NodeInfo + Payload map[string]interface{} + Request *Request + Response *Response + Session string + To string + Type string + type WireSender interface + Send func(msg WireMessage) error
Go to main page