(key, value string)
| 102 | } |
| 103 | |
| 104 | func (b *batchTx) Set(key, value string) { |
| 105 | if b.err != nil { |
| 106 | return |
| 107 | } |
| 108 | if err := sorted.CheckSizes(key, value); err != nil { |
| 109 | log.Printf("Skipping storing (%q:%q): %v", key, value, err) |
| 110 | return |
| 111 | } |
| 112 | if b.kv.BatchSetFunc != nil { |
| 113 | b.err = b.kv.BatchSetFunc(b.tx, key, value) |
| 114 | return |
| 115 | } |
| 116 | _, b.err = b.tx.Exec(b.kv.sql("REPLACE INTO /*TPRE*/rows (k, v) VALUES (?, ?)"), key, value) |
| 117 | } |
| 118 | |
| 119 | func (b *batchTx) Delete(key string) { |
| 120 | if b.err != nil { |
nothing calls this directly
no test coverage detected