(t *testing.T)
| 224 | } |
| 225 | |
| 226 | func TestStreamStructure_XGroup(t *testing.T) { |
| 227 | stc, _ := initStreamDB() |
| 228 | defer stc.db.Clean() |
| 229 | |
| 230 | ok1, err := stc.XAdd("test", "1", map[string]interface{}{"name1": "flydb1"}) |
| 231 | assert.Nil(t, err) |
| 232 | assert.True(t, ok1) |
| 233 | |
| 234 | ok2, err := stc.XAdd("test", "2", map[string]interface{}{"name2": "flydb2"}) |
| 235 | assert.Nil(t, err) |
| 236 | assert.True(t, ok2) |
| 237 | |
| 238 | ok3, err := stc.XAdd("test", "3", map[string]interface{}{"name3": "flydb3"}) |
| 239 | assert.Nil(t, err) |
| 240 | assert.True(t, ok3) |
| 241 | |
| 242 | ok4, err := stc.XAdd("test1", "1", map[string]interface{}{"name11": "flydb11"}) |
| 243 | assert.Nil(t, err) |
| 244 | assert.True(t, ok4) |
| 245 | |
| 246 | ok5, err := stc.XGroup("test", "testGroup", "$") |
| 247 | assert.Nil(t, err) |
| 248 | assert.True(t, ok5) |
| 249 | |
| 250 | ok6, err := stc.XGroup("test1", "testGroup", "$") |
| 251 | assert.Nil(t, err) |
| 252 | assert.True(t, ok6) |
| 253 | |
| 254 | } |
nothing calls this directly
no test coverage detected