Documentation
¶
Index ¶
- func NewDeleteGatewayCacheEventSubscriber(logger *slog.Logger, c cache.Client) cache.EventSubscriber[event.DeleteGatewayCacheEvent]
- func NewInvalidateGatewayDataEventSubscriber(logger *slog.Logger, c cache.Client) cache.EventSubscriber[event.InvalidateGatewayDataEvent]
- func NewInvalidateRegistryCacheEventSubscriber(logger *slog.Logger, c cache.Client) cache.EventSubscriber[event.InvalidateRegistryCacheEvent]
- type DeleteGatewayCacheEventSubscriber
- type InvalidateGatewayDataEventSubscriber
- type InvalidateRegistryCacheEventSubscriber
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDeleteGatewayCacheEventSubscriber ¶
func NewDeleteGatewayCacheEventSubscriber( logger *slog.Logger, c cache.Client, ) cache.EventSubscriber[event.DeleteGatewayCacheEvent]
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]
Types ¶
type DeleteGatewayCacheEventSubscriber ¶
type DeleteGatewayCacheEventSubscriber struct {
// contains filtered or unexported fields
}
func (*DeleteGatewayCacheEventSubscriber) OnEvent ¶
func (s *DeleteGatewayCacheEventSubscriber) OnEvent(ctx context.Context, evt event.DeleteGatewayCacheEvent) error
type InvalidateGatewayDataEventSubscriber ¶
type InvalidateGatewayDataEventSubscriber struct {
// contains filtered or unexported fields
}
func (*InvalidateGatewayDataEventSubscriber) OnEvent ¶
func (s *InvalidateGatewayDataEventSubscriber) OnEvent(ctx 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
Source Files
Click to show internal directories.
Click to hide internal directories.