Documentation
¶
Index ¶
- func API(c *container.Container) error
- func All(plane string, dbless bool) []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 ConfigSyncData(c *container.Container) error
- func Consumer(c *container.Container) error
- func ControlConfigSync(c *container.Container) error
- func Core(c *container.Container) error
- func CoreData(c *container.Container) error
- func Gateway(c *container.Container) error
- func LoadBalancer(c *container.Container) error
- func MCP(c *container.Container) error
- func MCPVaultPostgres(c *container.Container) error
- func MCPVaultRedis(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 StartCacheJanitor(ctx context.Context, mgr *cache.TTLMapManager)
- 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 ConfigSyncData ¶ added in v0.3.4
ConfigSyncData wires the data-plane half of the config sync: the atomic snapshot store the read ports resolve from, the protobuf codec, the AES-256-GCM crypto guarding the encrypted last-known-good, the gRPC client that dials the control plane and serves as both the snapshot fetcher and the change-notice stream transport, the LKG store, and the convergence worker.
func ControlConfigSync ¶ added in v0.3.4
ControlConfigSync registers the control-plane half of the gRPC-based config sync: the snapshot compiler over the live repositories, the atomic holder the gRPC server serves from, the protobuf codec, the connection hub that fans version notices out to connected data planes, the ConfigSync gRPC service and its TLS/auth-guarded server, the debounced dispatcher that compiles snapshots and drains the change-marker outbox, and the version-bump signaler the admin write use cases call. The dispatcher and gRPC server are started in the control/run run funcs; nothing here resolves on the data plane graph.
func LoadBalancer ¶
func MCPVaultPostgres ¶ added in v0.3.4
func MCPVaultRedis ¶ added in v0.3.4
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 StartCacheJanitor ¶ added in v0.3.4
func StartCacheJanitor(ctx context.Context, mgr *cache.TTLMapManager)
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
¶
- api.go
- auth.go
- cache.go
- cache_events.go
- catalog.go
- config_sync_data.go
- config_sync_signal.go
- consumer.go
- control_config_sync.go
- core.go
- core_data.go
- gateway.go
- loadbalancer.go
- mcp.go
- modules.go
- plugins.go
- policy.go
- providers.go
- proxy.go
- registry.go
- role.go
- server_admin.go
- server_mcp.go
- server_proxy.go
- session.go
- telemetry.go