server

package
v0.97.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 20, 2026 License: GPL-3.0 Imports: 100 Imported by: 0

Documentation

Overview

Package server provides the HTTP API server (Fiber v3) and route handlers.

Index

Constants

View Source 
const DataEventTopic = "pipeline:data_event"

Variables

View Source 
var MediaModules = fx.Options(
	fx.Invoke(
		fs.Register,
		minio.Register,
	),
)
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,
		initClipAbility,
		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.

View Source 
var ReexecModules = fx.Options(
	fx.Invoke(
		shell.Register,
	),
)

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 

func RegisterChatAgentRoutes(a *fiber.App)

RegisterChatAgentRoutes wires Chat Agent REST endpoints for HTTP clients.

func RunHomelabScan added in v0.92.0 

func RunHomelabScan(cfg config.Homelab) error

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 RunServer added in v0.31.1 

func RunServer(
	lc fx.Lifecycle,
	app *fiber.App,
	shutdowner fx.Shutdowner,
	_ store.Adapter,
	_ *cache.Cache,
	_ *redis.Client,
	_ message.Publisher,
)

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

View all Source files

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.