Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
ListenAddr string // IMBRIDGE_LISTEN_ADDR, default ":8083"
DatabaseURL string // DATABASE_URL (shared PostgreSQL with agentserver)
}
Config holds configuration for the standalone imbridge service.
func LoadConfigFromEnv ¶
func LoadConfigFromEnv() Config
LoadConfigFromEnv returns a Config populated from environment variables.
type K8sExec ¶ added in v0.28.1
type K8sExec struct {
// contains filtered or unexported fields
}
K8sExec implements imbridge.ExecCommander using K8s pod exec. It is a lightweight alternative to sandbox.Manager that only supports one-shot command execution (used for IPC group registration).
func NewK8sExec ¶ added in v0.28.1
NewK8sExec creates a K8sExec from in-cluster or KUBECONFIG config. Returns nil (not an error) if K8s is not available, so imbridge can degrade gracefully in non-K8s environments.
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server is the standalone imbridge HTTP service.
func NewServer ¶
func NewServer(database *db.DB, authSvc *auth.Auth, sandboxStore *sbxstore.Store, bridge *imbridge.Bridge) *Server
NewServer creates a new imbridge service.
func (*Server) RestorePollers ¶
func (s *Server) RestorePollers()
RestorePollers restarts long-poll goroutines for all active workspace IM channels. Called once during startup to recover from restarts — the cursor is persisted in DB, so pollers resume without message loss.
Source Files