()
| 467 | } |
| 468 | |
| 469 | func (sm *StoreManager) FindTenantList() (tenants []string, err error) { |
| 470 | tenantKey := "dtleUser" |
| 471 | storeUsers, err := sm.consulStore.List(tenantKey) |
| 472 | if nil != err && err != store.ErrKeyNotFound { |
| 473 | return tenants, fmt.Errorf("get %v value from consul failed: %v", tenantKey, err) |
| 474 | } |
| 475 | tenantMap := make(map[string]struct{}, 0) |
| 476 | for _, storeUser := range storeUsers { |
| 477 | user := new(User) |
| 478 | err = json.Unmarshal(storeUser.Value, user) |
| 479 | if err != nil { |
| 480 | return tenants, fmt.Errorf("get %v from consul, unmarshal err : %v", storeUser, err) |
| 481 | } |
| 482 | tenantMap[user.Tenant] = struct{}{} |
| 483 | } |
| 484 | for tenant := range tenantMap { |
| 485 | tenants = append(tenants, tenant) |
| 486 | } |
| 487 | return |
| 488 | } |
| 489 | |
| 490 | func (sm *StoreManager) DeleteUser(tenant, user string) error { |
| 491 | key := fmt.Sprintf("dtleUser/%v/%v", tenant, user) |
no test coverage detected