Put saves data to IPFS and return key(internally it is a hash).
(value []byte)
| 70 | |
| 71 | // Put saves data to IPFS and return key(internally it is a hash). |
| 72 | func (db *IpfsDatabase) Put(value []byte) ([]byte, error) { |
| 73 | reader := bytes.NewBuffer(value) |
| 74 | |
| 75 | db.rwlock.Lock() |
| 76 | defer db.rwlock.Unlock() |
| 77 | |
| 78 | // Automatically pin the added data in IPFS. |
| 79 | hash, err := db.adapter.Add(reader) |
| 80 | |
| 81 | if err != nil { |
| 82 | return nil, err |
| 83 | } else { |
| 84 | return []byte(hash), nil |
| 85 | } |
| 86 | } |
| 87 | |
| 88 | // Discard data from IPFS network. |
| 89 | func (db *IpfsDatabase) Discard(key []byte) error { |