redistransport

Jul 20, 2026

Changes in this version

+ type Redis struct

+ HistoryLimit *int64

+ Size int64

+ Stream string

+ URL string

+ func (Redis) CaddyModule() caddy.ModuleInfo

+ func (r *Redis) Cleanup() error

+ func (r *Redis) GetTransport() mercure.Transport

+ func (r *Redis) Provision(ctx caddy.Context) error

+ func (r *Redis) UnmarshalCaddyfile(d *caddyfile.Dispenser) error

+ type RedisTransport struct

+ func NewRedisTransport(subscriberList *mercure.SubscriberList, logger *slog.Logger, url string, ...) (*RedisTransport, error)

+ func (t *RedisTransport) AddSubscriber(ctx context.Context, subscriber *mercure.LocalSubscriber) error

+ func (t *RedisTransport) Close(_ context.Context) (err error)

+ func (t *RedisTransport) Dispatch(ctx context.Context, update *mercure.Update) error

+ func (t *RedisTransport) GetSubscribers(_ context.Context) (string, []*mercure.Subscriber, error)

+ func (t *RedisTransport) RemoveSubscriber(_ context.Context, subscriber *mercure.LocalSubscriber) error