server

package
v0.92.0 Latest Latest
Warning

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

 Go to latest Published: Jun 6, 2026 License: GPL-3.0 Imports: 89 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 LLMModules = fx.Options(
	fx.Invoke(
		llm.RegisterGemini,
		llm.RegisterOpenAI,
		llm.RegisterAnthropic,
	),
)

LLMModules registers all LLM provider backends via fx.

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,
	LLMModules,
	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,
		handleRoutes,
		handleEvents,
		initPipeline,
		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 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, _ 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

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.