Closed bryoco closed 5 years ago
In src/session/redisstore.go
src/session/redisstore.go
func (rs *RedisStore) SetQueue(sid SessionID, sessionState interface{}) error { pipeline := rs.Client.Pipeline() // do not expire queue pipe := pipeline.Set(string(sid), sessionState, 0) if _, err := pipeline.Exec(); err != nil { // TODO: redis: can't marshal []string <---------------------------------------------------- log.Println("redis cannot exec command") return err } if s, err := pipe.Result(); err != nil { return err } else { // TODO: remove me log.Println("pipeline.Result:",s) if err = json.Unmarshal([]byte(s), sessionState); err != nil { // cannot unmarshal return err } else { return nil } } }
TODO: Is this a pipeline issue?
In
src/session/redisstore.go