(t *testing.T)
| 134 | } |
| 135 | |
| 136 | func TestStreamStructure_XRange(t *testing.T) { |
| 137 | stc, _ := initStreamDB() |
| 138 | defer stc.db.Clean() |
| 139 | |
| 140 | ok1, err := stc.XAdd("test", "1", map[string]interface{}{"name1": "flydb1"}) |
| 141 | assert.Nil(t, err) |
| 142 | assert.True(t, ok1) |
| 143 | |
| 144 | ok2, err := stc.XAdd("test", "2", map[string]interface{}{"name2": "flydb2"}) |
| 145 | assert.Nil(t, err) |
| 146 | assert.True(t, ok2) |
| 147 | |
| 148 | ok3, err := stc.XAdd("test", "3", map[string]interface{}{"name3": "flydb3"}) |
| 149 | assert.Nil(t, err) |
| 150 | assert.True(t, ok3) |
| 151 | |
| 152 | ok4, err := stc.XAdd("test1", "1", map[string]interface{}{"name11": "flydb11"}) |
| 153 | assert.Nil(t, err) |
| 154 | assert.True(t, ok4) |
| 155 | |
| 156 | items, err := stc.XRange("test", 1, 3) |
| 157 | assert.Nil(t, err) |
| 158 | assert.Equal(t, 2, len(items)) |
| 159 | |
| 160 | items, err = stc.XRange("test1", 1, 3) |
| 161 | assert.NotNil(t, err) |
| 162 | assert.Equal(t, 0, len(items)) |
| 163 | |
| 164 | } |
| 165 | |
| 166 | func TestStreamStructure_XRevRange(t *testing.T) { |
| 167 | stc, _ := initStreamDB() |
nothing calls this directly
no test coverage detected