Documentation
¶
Index ¶
- func NewInvalidateGatewayDataEventSubscriber(logger *slog.Logger, c cache.Client) cache.EventSubscriber[event.InvalidateGatewayDataEvent]
- func NewInvalidateRegistryCacheEventSubscriber(logger *slog.Logger, c cache.Client) cache.EventSubscriber[event.InvalidateRegistryCacheEvent]
- func NewSnapshotDirtyEventSubscriber(signaler SnapshotSignaler) cache.EventSubscriber[event.SnapshotDirtyEvent]
- type InvalidateGatewayDataEventSubscriber
- type InvalidateRegistryCacheEventSubscriber
- type SnapshotDirtyEventSubscriber
- type SnapshotSignaler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewInvalidateGatewayDataEventSubscriber ¶
func NewInvalidateGatewayDataEventSubscriber( logger *slog.Logger, c cache.Client, ) cache.EventSubscriber[event.InvalidateGatewayDataEvent]
func NewInvalidateRegistryCacheEventSubscriber ¶
func NewInvalidateRegistryCacheEventSubscriber( logger *slog.Logger, c cache.Client, ) cache.EventSubscriber[event.InvalidateRegistryCacheEvent]
func NewSnapshotDirtyEventSubscriber ¶ added in v0.5.0
func NewSnapshotDirtyEventSubscriber(signaler SnapshotSignaler) cache.EventSubscriber[event.SnapshotDirtyEvent]
Types ¶
type InvalidateGatewayDataEventSubscriber ¶
type InvalidateGatewayDataEventSubscriber struct {
// contains filtered or unexported fields
}
InvalidateGatewayDataEventSubscriber drops the in-process caches that hold gateway-scoped configuration. It must never delete from Redis: that keyspace holds durable OAuth state (user credentials, client registrations, sessions) rather than cached config, which now reaches data planes over config-sync.
func (*InvalidateGatewayDataEventSubscriber) OnEvent ¶
func (s *InvalidateGatewayDataEventSubscriber) OnEvent(_ context.Context, evt event.InvalidateGatewayDataEvent) error
type InvalidateRegistryCacheEventSubscriber ¶
type InvalidateRegistryCacheEventSubscriber struct {
// contains filtered or unexported fields
}
InvalidateRegistryCacheEventSubscriber drops the cached backend entity, the aggregated consumer-data view that embeds the backend, and every load balancer of the gateway (balancers embed backend config), forcing the next request to rebuild them from fresh backend data.
func (*InvalidateRegistryCacheEventSubscriber) OnEvent ¶
func (s *InvalidateRegistryCacheEventSubscriber) OnEvent(_ context.Context, evt event.InvalidateRegistryCacheEvent) error
type SnapshotDirtyEventSubscriber ¶ added in v0.5.0
type SnapshotDirtyEventSubscriber struct {
// contains filtered or unexported fields
}
SnapshotDirtyEventSubscriber recompiles the local snapshot when a peer admin replica reports a config change, so every replica pushes the new version to its own connected data planes without waiting for the backstop timer.
func (*SnapshotDirtyEventSubscriber) OnEvent ¶ added in v0.5.0
func (s *SnapshotDirtyEventSubscriber) OnEvent(_ context.Context, _ event.SnapshotDirtyEvent) error
type SnapshotSignaler ¶ added in v0.5.0
type SnapshotSignaler interface {
Signal()
}
SnapshotSignaler triggers a local recompile-and-broadcast of the runtime config snapshot. It is satisfied by the config-sync dispatcher.
Source Files