redis sessions
This commit is contained in:
@@ -51,7 +51,7 @@ func (m *RedisStore) Create(sessionID string, session *SessionData) (err error)
|
|||||||
return ErrSessionBackend
|
return ErrSessionBackend
|
||||||
}
|
}
|
||||||
|
|
||||||
created, err := m.client.SetNX(m.ctx, hashedSession, data, 0).Result()
|
created, err := m.client.SetNX(m.ctx, hashedSession, data, time.Hour).Result()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logging.Error(err.Error())
|
logging.Error(err.Error())
|
||||||
return ErrSessionBackend
|
return ErrSessionBackend
|
||||||
@@ -94,7 +94,7 @@ func (m *RedisStore) Update(sessionID string, session *SessionData) error {
|
|||||||
return ErrSessionBackend
|
return ErrSessionBackend
|
||||||
}
|
}
|
||||||
|
|
||||||
updated, err := m.client.SetXX(m.ctx, hashedSession, data, 0).Result()
|
updated, err := m.client.SetXX(m.ctx, hashedSession, data, time.Hour).Result()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logging.Error(err.Error())
|
logging.Error(err.Error())
|
||||||
return ErrSessionBackend
|
return ErrSessionBackend
|
||||||
@@ -106,9 +106,12 @@ func (m *RedisStore) Update(sessionID string, session *SessionData) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *RedisStore) cleanup() {
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *RedisStore) Delete(sessionID string) error {
|
func (m *RedisStore) Delete(sessionID string) error {
|
||||||
|
hashedSession := hashSession(sessionID)
|
||||||
|
err := m.client.Del(m.ctx, hashedSession).Err()
|
||||||
|
if err != nil {
|
||||||
|
logging.Error(err.Error())
|
||||||
|
return ErrSessionBackend
|
||||||
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user