(t *testing.T)
| 16 | } |
| 17 | |
| 18 | func TestStreamStructure_XRead(t *testing.T) { |
| 19 | stc, _ := initStreamDB() |
| 20 | defer stc.db.Clean() |
| 21 | |
| 22 | ok1, err := stc.XAdd("test", "1", map[string]interface{}{"name1": "flydb1"}) |
| 23 | assert.Nil(t, err) |
| 24 | assert.True(t, ok1) |
| 25 | |
| 26 | ok2, err := stc.XAdd("test", "2", map[string]interface{}{"name2": "flydb2"}) |
| 27 | assert.Nil(t, err) |
| 28 | assert.True(t, ok2) |
| 29 | |
| 30 | ok3, err := stc.XAdd("test", "3", map[string]interface{}{"name3": "flydb3"}) |
| 31 | assert.Nil(t, err) |
| 32 | assert.True(t, ok3) |
| 33 | |
| 34 | ok4, err := stc.XAdd("test1", "1", map[string]interface{}{"name11": "flydb11"}) |
| 35 | assert.Nil(t, err) |
| 36 | assert.True(t, ok4) |
| 37 | |
| 38 | item, err := stc.XRead("test", 1) |
| 39 | assert.NotNil(t, item) |
| 40 | assert.Nil(t, err) |
| 41 | |
| 42 | item1, err := stc.XRead("test1", 1) |
| 43 | assert.NotNil(t, item1) |
| 44 | assert.Nil(t, err) |
| 45 | |
| 46 | } |
| 47 | |
| 48 | func TestStreamStructure_XDel(t *testing.T) { |
| 49 | stc, _ := initStreamDB() |
nothing calls this directly
no test coverage detected