(t *testing.T)
| 194 | } |
| 195 | |
| 196 | func TestStreamStructure_XTrim(t *testing.T) { |
| 197 | stc, _ := initStreamDB() |
| 198 | defer stc.db.Clean() |
| 199 | |
| 200 | ok1, err := stc.XAdd("test", "1", map[string]interface{}{"name1": "flydb1"}) |
| 201 | assert.Nil(t, err) |
| 202 | assert.True(t, ok1) |
| 203 | |
| 204 | ok2, err := stc.XAdd("test", "2", map[string]interface{}{"name2": "flydb2"}) |
| 205 | assert.Nil(t, err) |
| 206 | assert.True(t, ok2) |
| 207 | |
| 208 | ok3, err := stc.XAdd("test", "3", map[string]interface{}{"name3": "flydb3"}) |
| 209 | assert.Nil(t, err) |
| 210 | assert.True(t, ok3) |
| 211 | |
| 212 | ok4, err := stc.XAdd("test1", "1", map[string]interface{}{"name11": "flydb11"}) |
| 213 | assert.Nil(t, err) |
| 214 | assert.True(t, ok4) |
| 215 | |
| 216 | l1, err := stc.XTrim("test", 2) |
| 217 | assert.Nil(t, err) |
| 218 | assert.Equal(t, 2, l1) |
| 219 | |
| 220 | l2, err := stc.XTrim("test1", 1) |
| 221 | assert.Nil(t, err) |
| 222 | assert.Equal(t, 1, l2) |
| 223 | |
| 224 | } |
| 225 | |
| 226 | func TestStreamStructure_XGroup(t *testing.T) { |
| 227 | stc, _ := initStreamDB() |
nothing calls this directly
no test coverage detected