| 412 | } |
| 413 | |
| 414 | func TestDeltaFIFO_KeyOf(t *testing.T) { |
| 415 | f := DeltaFIFO{keyFunc: testFifoObjectKeyFunc} |
| 416 | |
| 417 | table := []struct { |
| 418 | obj interface{} |
| 419 | key string |
| 420 | }{ |
| 421 | {obj: testFifoObject{name: "A"}, key: "A"}, |
| 422 | {obj: DeletedFinalStateUnknown{Key: "B", Obj: nil}, key: "B"}, |
| 423 | {obj: Deltas{{Object: testFifoObject{name: "C"}}}, key: "C"}, |
| 424 | {obj: Deltas{{Object: DeletedFinalStateUnknown{Key: "D", Obj: nil}}}, key: "D"}, |
| 425 | } |
| 426 | |
| 427 | for _, item := range table { |
| 428 | got, err := f.KeyOf(item.obj) |
| 429 | if err != nil { |
| 430 | t.Errorf("Unexpected error for %q: %v", item.obj, err) |
| 431 | continue |
| 432 | } |
| 433 | if e, a := item.key, got; e != a { |
| 434 | t.Errorf("Expected %v, got %v", e, a) |
| 435 | } |
| 436 | } |
| 437 | } |
| 438 | |
| 439 | func TestDeltaFIFO_HasSynced(t *testing.T) { |
| 440 | tests := []struct { |