MCPcopy Create free account
hub / github.com/IceFireDB/IceFireDB / Put

Method Put

driver/hybriddb/db.go:171–188  ·  view source on GitHub ↗
(key, value []byte)

Source from the content-addressed store, hash-verified

169}
170
171func (db *DB) Put(key, value []byte) error {
172 db.mu.Lock()
173 defer db.mu.Unlock()
174
175 if db.closed {
176 return fmt.Errorf("database is closed")
177 }
178
179 if err := db.validateKeyValue(key, value); err != nil {
180 db.stats.Errors++
181 return err
182 }
183
184 db.stats.WriteOps++
185 db.stats.BytesWritten += int64(len(key) + len(value))
186
187 return db.db.Put(key, value, nil)
188}
189
190func (db *DB) Get(key []byte) ([]byte, error) {
191 db.mu.RLock()

Callers 13

TestIteratorFunction · 0.45
SyncPutMethod · 0.45
TestDB_PutGetFunction · 0.45
TestDB_DeleteFunction · 0.45
TestDB_IteratorFunction · 0.45
TestDB_SnapshotFunction · 0.45
TestDB_ConcurrentAccessFunction · 0.45
TestDB_RepairFunction · 0.45
TestDB_EdgeCasesFunction · 0.45
TestSnapshotFunction · 0.45
TestSnapshot_IteratorFunction · 0.45

Calls 1

validateKeyValueMethod · 0.95

Tested by 12

TestIteratorFunction · 0.36
TestDB_PutGetFunction · 0.36
TestDB_DeleteFunction · 0.36
TestDB_IteratorFunction · 0.36
TestDB_SnapshotFunction · 0.36
TestDB_ConcurrentAccessFunction · 0.36
TestDB_RepairFunction · 0.36
TestDB_EdgeCasesFunction · 0.36
TestSnapshotFunction · 0.36
TestSnapshot_IteratorFunction · 0.36
TestSnapshot_ConcurrentFunction · 0.36