feat: initial commit
All checks were successful
Cadoles/bouncer/pipeline/head This commit looks good
All checks were successful
Cadoles/bouncer/pipeline/head This commit looks good
This commit is contained in:
35
internal/queue/redis/repository.go
Normal file
35
internal/queue/redis/repository.go
Normal file
@ -0,0 +1,35 @@
|
||||
package redis
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"forge.cadoles.com/cadoles/bouncer/internal/queue"
|
||||
"github.com/redis/go-redis/v9"
|
||||
)
|
||||
|
||||
type Repository struct {
|
||||
client redis.UniversalClient
|
||||
}
|
||||
|
||||
// AddToQueue implements queue.Repository
|
||||
func (*Repository) AddToQueue(ctx context.Context, queueName string, sessionId string) (uint, error) {
|
||||
panic("unimplemented")
|
||||
}
|
||||
|
||||
// IsInQueue implements queue.Repository
|
||||
func (*Repository) IsInQueue(ctx context.Context, queueName string, sessionId string) (bool, uint, error) {
|
||||
panic("unimplemented")
|
||||
}
|
||||
|
||||
// RemoveFromQueue implements queue.Repository
|
||||
func (*Repository) RemoveFromQueue(ctx context.Context, queueName string, sessionId string) error {
|
||||
panic("unimplemented")
|
||||
}
|
||||
|
||||
func NewRepository(client redis.UniversalClient) *Repository {
|
||||
return &Repository{
|
||||
client: client,
|
||||
}
|
||||
}
|
||||
|
||||
var _ queue.Repository = &Repository{}
|
Reference in New Issue
Block a user