Loading pkg/usecases/distributors/telegram/telegram.go +1 −1 Original line number Diff line number Diff line Loading @@ -66,7 +66,7 @@ func (d *TelegramDistributor) GetResources(id int64) []core.Resource { } pool := "new" if id >= d.cfg.MinUserID { if id < d.cfg.MinUserID { pool = "old" oldResources, err := d.oldHashring.GetMany(hashKey, d.cfg.NumBridgesPerRequest) if err != nil { Loading pkg/usecases/distributors/telegram/telegram_test.go +2 −2 Original line number Diff line number Diff line Loading @@ -39,8 +39,8 @@ func initDistributor() *TelegramDistributor { } func TestGetResources(t *testing.T) { newID := int64(10) oldID := int64(101) newID := int64(101) oldID := int64(10) d := initDistributor() defer d.Shutdown() Loading Loading
pkg/usecases/distributors/telegram/telegram.go +1 −1 Original line number Diff line number Diff line Loading @@ -66,7 +66,7 @@ func (d *TelegramDistributor) GetResources(id int64) []core.Resource { } pool := "new" if id >= d.cfg.MinUserID { if id < d.cfg.MinUserID { pool = "old" oldResources, err := d.oldHashring.GetMany(hashKey, d.cfg.NumBridgesPerRequest) if err != nil { Loading
pkg/usecases/distributors/telegram/telegram_test.go +2 −2 Original line number Diff line number Diff line Loading @@ -39,8 +39,8 @@ func initDistributor() *TelegramDistributor { } func TestGetResources(t *testing.T) { newID := int64(10) oldID := int64(101) newID := int64(101) oldID := int64(10) d := initDistributor() defer d.Shutdown() Loading