(t *testing.T)
| 593 | } |
| 594 | |
| 595 | func TestClusterClient_Put_PXAT(t *testing.T) { |
| 596 | cluster := newTestOlricCluster(t) |
| 597 | db := cluster.addMember(t) |
| 598 | |
| 599 | ctx := context.Background() |
| 600 | c, err := NewClusterClient([]string{db.name}) |
| 601 | require.NoError(t, err) |
| 602 | defer func() { |
| 603 | require.NoError(t, c.Close(ctx)) |
| 604 | }() |
| 605 | |
| 606 | dm, err := c.NewDMap("mydmap") |
| 607 | require.NoError(t, err) |
| 608 | |
| 609 | err = dm.Put(ctx, "mykey", "myvalue", PXAT(time.Duration(time.Now().Add(time.Millisecond).UnixNano()))) |
| 610 | require.NoError(t, err) |
| 611 | |
| 612 | <-time.After(time.Millisecond) |
| 613 | |
| 614 | _, err = dm.Get(ctx, "mykey") |
| 615 | require.ErrorIs(t, err, ErrKeyNotFound) |
| 616 | } |
| 617 | |
| 618 | func TestClusterClient_Put_NX(t *testing.T) { |
| 619 | cluster := newTestOlricCluster(t) |
nothing calls this directly
no test coverage detected