Documentation
¶
Overview ¶
Package server provides the HTTP API server (Fiber v3) and route handlers.
Index ¶
- Constants
- Variables
- func NewPipelineStepCallback(client *redis.Client) pipeline.StepCallback
- func RegisterChatAgentRoutes(a *fiber.App)
- func RunHomelabScan(cfg config.Homelab) error
- func RunServer(lc fx.Lifecycle, app *fiber.App, shutdowner fx.Shutdowner, _ store.Adapter, ...)
- func SetCacheStore(s *cache.RedisStore)
- type Controller
Constants ¶
View Source
const DataEventTopic = "pipeline:data_event"
Variables ¶
View Source
var Modules = fx.Options( flog.FxModule, metrics.Module(), modules.Modules, NotifyModules, MediaModules, OAuthModules, ReexecModules, fx.Provide( config.NewConfig, cache.NewCache, rdb.NewClient, cache.NewRedisStore, event.NewRouter, event.NewSubscriber, event.NewPublisher, slack.NewDriver, trace.NewTracerProvider, newController, newDatabaseAdapter, newHTTPServer, newAuditor, ), fx.Invoke( setServerCacheStore, setRouteAuditor, setAgentMetricsCollector, handleRoutes, handleEvents, initPipeline, initAgentAbility, initChatAgentScheduler, handleModules, handlePlatform, RunServer, profiling.NewProfiler, initPageDataCleanup, ), )
View Source
var NotifyModules = fx.Options( fx.Invoke( messagepusher.Register, ntfy.Register, pushover.Register, slack.Register, initNotificationGateway, ), )
View Source
var OAuthModules = fx.Options( fx.Invoke( github.Register, slack.Register, dropbox.Register, ), )
OAuthModules registers all OAuth provider factories via fx.
ReexecModules registers all reexec handlers via fx.
Functions ¶
func NewPipelineStepCallback ¶ added in v0.92.0
func NewPipelineStepCallback(client *redis.Client) pipeline.StepCallback
NewPipelineStepCallback creates a callback backed by the Redis client. Returns nil if rdb is nil.
func RegisterChatAgentRoutes ¶ added in v0.93.0
RegisterChatAgentRoutes wires Chat Agent REST endpoints for HTTP clients.
func RunHomelabScan ¶ added in v0.92.0
RunHomelabScan executes a full homelab scan + probe + registry update cycle. It walks the configured apps directory, discovers compose files, runs the probe engine for endpoint/auth discovery, and replaces the default registry. Exported for use by the homelab web handler to support manual rescan.
func SetCacheStore ¶ added in v0.92.0
func SetCacheStore(s *cache.RedisStore)
SetCacheStore sets the cache store for server functions.
Types ¶
type Controller ¶ added in v0.31.1
type Controller struct {
// contains filtered or unexported fields
}
Source Files
¶
- agent.go
- agent_ability.go
- capability.go
- chat.go
- chatagent_handler.go
- chatagent_http.go
- chatagent_http_messages.go
- chatagent_http_permissions.go
- chatagent_http_resources.go
- chatagent_http_scheduled.go
- chatagent_http_sessions.go
- chatagent_scheduler.go
- database.go
- error.go
- event.go
- func.go
- fx.go
- globals.go
- homelab.go
- http.go
- hub.go
- init.go
- media.go
- message.go
- message_direct.go
- module.go
- notify.go
- page_data.go
- pipeline.go
- platform.go
- providers.go
- reexec.go
- registration.go
- router.go
- server.go
- webhook.go
Directories
¶
| Path | Synopsis |
|---|---|
|
Package chatagent orchestrates the Flowbot chat assistant: session lifecycle, harness pooling, SSE streaming, tool confirmations, permissions, and scheduled tasks.
|
Package chatagent orchestrates the Flowbot chat assistant: session lifecycle, harness pooling, SSE streaming, tool confirmations, permissions, and scheduled tasks. |
Click to show internal directories.
Click to hide internal directories.