* func (db *DB) Get(key []byte) ([]byte, error) { if v, ok := db.cache.Get(key); ok { return v.([]byte), nil } v, err := db.db.Get(key, nil) if err == leveldb.ErrNotFound { v, err = db.S3Get(key) if err != nil{ return nil, nil }else { return nil, nil } } db.cache.Set(key, v, 0
(key []byte)
| 259 | */ |
| 260 | |
| 261 | func (db *DB) Get(key []byte) ([]byte, error) { |
| 262 | v, err := db.S3Get(key) |
| 263 | if err != nil { |
| 264 | //fmt.Println(" s3 get ", err) |
| 265 | return nil, nil |
| 266 | } |
| 267 | |
| 268 | return v, nil |
| 269 | } |
| 270 | |
| 271 | func (db *DB) S3Delete(key []byte) error { |
| 272 |