(t *testing.T)
| 164 | } |
| 165 | |
| 166 | func TestStreamStructure_XRevRange(t *testing.T) { |
| 167 | stc, _ := initStreamDB() |
| 168 | defer stc.db.Clean() |
| 169 | |
| 170 | ok1, err := stc.XAdd("test", "1", map[string]interface{}{"name1": "flydb1"}) |
| 171 | assert.Nil(t, err) |
| 172 | assert.True(t, ok1) |
| 173 | |
| 174 | ok2, err := stc.XAdd("test", "2", map[string]interface{}{"name2": "flydb2"}) |
| 175 | assert.Nil(t, err) |
| 176 | assert.True(t, ok2) |
| 177 | |
| 178 | ok3, err := stc.XAdd("test", "3", map[string]interface{}{"name3": "flydb3"}) |
| 179 | assert.Nil(t, err) |
| 180 | assert.True(t, ok3) |
| 181 | |
| 182 | ok4, err := stc.XAdd("test1", "1", map[string]interface{}{"name11": "flydb11"}) |
| 183 | assert.Nil(t, err) |
| 184 | assert.True(t, ok4) |
| 185 | |
| 186 | items, err := stc.XRevRange("test", 1, 3) |
| 187 | assert.Nil(t, err) |
| 188 | assert.Equal(t, 2, len(items)) |
| 189 | |
| 190 | items, err = stc.XRevRange("test1", 1, 3) |
| 191 | assert.NotNil(t, err) |
| 192 | assert.Equal(t, 0, len(items)) |
| 193 | |
| 194 | } |
| 195 | |
| 196 | func TestStreamStructure_XTrim(t *testing.T) { |
| 197 | stc, _ := initStreamDB() |
nothing calls this directly
no test coverage detected