rediskit

NewStorage adapts a go-redis client to fiber.Storage, e.g. for a multi-instance rate limiter. miniredis stands in for real Redis here.

package main

import (
	"fmt"
	"time"

	"github.com/alicebob/miniredis/v2"
	"github.com/rahmadafandi/fibr/v2/rediskit"

	goredis "github.com/redis/go-redis/v9"
)

func main() {
	mr, _ := miniredis.Run()
	defer mr.Close()

	client := goredis.NewClient(&goredis.Options{Addr: mr.Addr()})
	store := rediskit.NewStorage(client, rediskit.WithPrefix("ratelimit:"))

	_ = store.Set("1.2.3.4", []byte("1"), time.Minute)
	v, _ := store.Get("1.2.3.4")

	fmt.Println(string(v))
}

Output:
1

Publish an event on one instance; every instance subscribed to the channel runs its handler with the decoded payload (e.g. to bust a local cache).

package main

import (
	"context"

	"github.com/rahmadafandi/fibr/v2/rediskit"
	goredis "github.com/redis/go-redis/v9"
)

func main() {
	r := rediskit.New(goredis.NewClient(&goredis.Options{Addr: "localhost:6379"}))
	ctx := context.Background()

	type invalidate struct {
		Key string `json:"key"`
	}

	sub, err := rediskit.Subscribe[invalidate](ctx, r, "cache:invalidate", func(_ context.Context, e invalidate) error {
		// drop e.Key from a local cache here
		return nil
	})
	if err != nil {
		return
	}
	defer sub.Close()

	_ = r.Publish(ctx, "cache:invalidate", invalidate{Key: "user:1"})
}

Output: