Documentation
¶
Index ¶
- func API(c *container.Container) error
- func All() []container.Option
- func Auth(c *container.Container) error
- func Cache(c *container.Container) error
- func CacheEvents(c *container.Container) error
- func Catalog(c *container.Container) error
- func Consumer(c *container.Container) error
- func Core(c *container.Container) error
- func Gateway(c *container.Container) error
- func LoadBalancer(c *container.Container) error
- func MCP(c *container.Container) error
- func Plugins(c *container.Container) error
- func Policy(c *container.Container) error
- func Providers(c *container.Container) error
- func Proxy(c *container.Container) error
- func Registry(c *container.Container) error
- func Role(c *container.Container) error
- func ServerAdmin(c *container.Container) error
- func ServerMCP(c *container.Container) error
- func ServerProxy(c *container.Container) error
- func Session(c *container.Container) error
- func StartCacheEventListener(ctx context.Context, p CacheEventListenerParams)
- func StartCatalogSync(p CatalogSyncParams)
- func StartMetricsWorker(p MetricsWorkerParams)
- func Telemetry(c *container.Container) error
- type CacheEventListenerParams
- type CatalogSyncParams
- type MetricsWorkerParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CacheEvents ¶
CacheEvents wires the Redis pub/sub invalidation pipeline: a publisher used by the mutating application services and a listener plus subscribers that drop stale in-process cache entries across every process.
func Gateway ¶
Gateway wires the Gateway aggregate end-to-end: pgx repository, the four application services, and the five admin HTTP handlers.
func LoadBalancer ¶
func ServerAdmin ¶
func ServerProxy ¶
func StartCacheEventListener ¶
func StartCacheEventListener(ctx context.Context, p CacheEventListenerParams)
StartCacheEventListener registers the cache invalidation subscribers and starts the Redis pub/sub listener in a background goroutine. It is meant to be invoked once per process (admin and proxy) at boot.
func StartCatalogSync ¶
func StartCatalogSync(p CatalogSyncParams)
func StartMetricsWorker ¶
func StartMetricsWorker(p MetricsWorkerParams)
StartMetricsWorker starts the background metrics worker goroutines. It is meant to be invoked once on the proxy plane at boot.
Types ¶
type CacheEventListenerParams ¶
type CacheEventListenerParams struct {
dig.In
Logger *slog.Logger
Listener cache.EventListener
GatewayDataSub cache.EventSubscriber[event.InvalidateGatewayDataEvent]
RegistryCacheSub cache.EventSubscriber[event.InvalidateRegistryCacheEvent]
}
CacheEventListenerParams collects everything StartCacheEventListener needs.
type CatalogSyncParams ¶
type MetricsWorkerParams ¶
type MetricsWorkerParams struct {
dig.In
Logger *slog.Logger
Cfg *config.Config
Worker appmetrics.Worker
}
MetricsWorkerParams collects everything StartMetricsWorker needs.
Source Files