(ctx context.Context, memBuffer kv.MemBuffer, snap kv.Snapshot, key kv.Key)
| 391 | } |
| 392 | |
| 393 | func (fkc *FKCheckExec) checkPrefixKey(ctx context.Context, memBuffer kv.MemBuffer, snap kv.Snapshot, key kv.Key) error { |
| 394 | key, value, err := fkc.getIndexKeyValueInTable(ctx, memBuffer, snap, key) |
| 395 | if err != nil { |
| 396 | return err |
| 397 | } |
| 398 | if fkc.CheckExist { |
| 399 | return fkc.checkPrefixKeyExist(key, value) |
| 400 | } |
| 401 | if len(value) > 0 { |
| 402 | // If check not exist, but the key is exist, return failedErr. |
| 403 | return fkc.FailedErr |
| 404 | } |
| 405 | return nil |
| 406 | } |
| 407 | |
| 408 | func (fkc *FKCheckExec) checkPrefixKeyExist(key kv.Key, value []byte) error { |
| 409 | exist := len(value) > 0 |
no test coverage detected