redis

Documentation

Index

• func ConnectPool(addr string) (*redis.Pool, error)
• type Repository
  • func NewRepository(pool *redis.Pool) *Repository
  • func (r Repository) CacheResponse(_ context.Context, response schema.CachedResponse) error
  • func (r Repository) GetCachedResponse(_ context.Context, key string) (schema.CachedResponse, error)
  • func (r Repository) Lock(_ context.Context, key string) error

Functions

func ConnectPool

func ConnectPool(addr string) (*redis.Pool, error)

Types

type Repository

type Repository struct {
	// contains filtered or unexported fields
}

func NewRepository

func NewRepository(pool *redis.Pool) *Repository

func (Repository) CacheResponse

func (r Repository) CacheResponse(_ context.Context, response schema.CachedResponse) error

func (Repository) GetCachedResponse

func (r Repository) GetCachedResponse(_ context.Context, key string) (schema.CachedResponse, error)

func (Repository) Lock

func (r Repository) Lock(_ context.Context, key string) error