package main import ( "context" "fmt" "log" "time" "github.com/robotomize/go-ratelimiter" ) func main() { // set a limit of 10 request per 1 seconds per api key redisStore, err := ratelimiter.DefaultRedisStore(context.Background(), ":6379", 1*time.Second, 10) if err != nil { log.Fatal(err)	} // Retrieve data by the api key in the datastore limit, remaining, resetTime, ok, err := redisStore.Take(context.Background(), "apikey-1") if err != nil { log.Fatal(err)	} if !ok { fmt.Println("limit exceeded")	} // Print the constraints from the datastore fmt.Printf( "resource: maximum %d, remaining %d, reset time %s", limit, remaining, time.Unix(0, int64(resetTime)).UTC().Format(time.RFC1123),	) }

package main import ( "context" "errors" "fmt" "log" "net/http" "os" "time" "github.com/robotomize/go-ratelimiter" ) func main() { // set a limit of 5 request per 1 seconds per api key redisStore, err := ratelimiter.DefaultRedisStore(context.Background(), ":6379", 1*time.Second, 5) if err != nil { log.Fatal(err)	} mx := http.NewServeMux() // Let's create a test handler healthHandler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { w.Header().Set("Content-Type", "application/json") w.WriteHeader(http.StatusOK) w.Write([]byte(`{"status": "ok"}`))	}) mx.Handle( "/health", ratelimiter.LimiterMiddleware( redisStore, func(r *http.Request) (string, error) { // Example key func ctx := r.Context() // Get key value out of context ctxValue := ctx.Value("apikey") if key, ok := ctxValue.(string); ok { return key, nil	} return "", errors.New("get api key from ctx")	}, ratelimiter.WithSkipper(func() bool { // set a skipper, skip ratelimiter if DEBUG == 1 return os.Getenv("DEBUG") == "1"	}, ),	)(healthHandler),	) // start listener if err = http.ListenAndServe(":8888", mx); err != nil { log.Fatal(err)	} }