services

package

v0.0.1 Latest Latest Go to latest Published: Oct 26, 2021 License: BSD-3-Clause Imports: 6 Imported by: 0

Details

This section is empty.

View Source

var ENV_MEMCACHED_ADDRESS = os.Getenv("ENV_MEMCACHED_ADDRESS")

View Source

var ENV_REDIS_ADDRESS = os.Getenv("ENV_REDIS_ADDRESS")

This section is empty.

type MemcachedService struct {
	Cache *memcache.Client
}

func NewMemcachedService() *MemcachedService

func (ms *MemcachedService) Acquire(lock *lib.Lock) (*lib.Lock, error)

func (ms *MemcachedService) Release(lock *lib.Lock) (*lib.Lock, error)

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

RedisService:

// A service for creating distributed locks in Redis

func NewRedisService() *RedisService

NewRedisService:

Creates a new Redis Service to allow redis locks.

Returns:

*RedisService

func (rs *RedisService) Acquire(lock *lib.Lock) (*lib.Lock, error)

Acquire a distributed lock in Redis

Parameters:

func (rs *RedisService) Release(lock *lib.Lock) (*lib.Lock, error)

Release a distributed lock in Redis

Parameters: