(meta metadata.Meta, expectedUser string)
| 152 | } |
| 153 | |
| 154 | func convertMetadata(meta metadata.Meta, expectedUser string) (metadata.Meta, []string) { |
| 155 | var changesRequired []string |
| 156 | |
| 157 | org, ok := meta.Thanos.Labels[cortex_tsdb.TenantIDExternalLabel] |
| 158 | if !ok { |
| 159 | changesRequired = append(changesRequired, "add __org_id__ label") |
| 160 | } else if org != expectedUser { |
| 161 | changesRequired = append(changesRequired, fmt.Sprintf("change __org_id__ from %s to %s", org, expectedUser)) |
| 162 | } |
| 163 | |
| 164 | // remove __org_id__ so that we can see if there are any other labels |
| 165 | delete(meta.Thanos.Labels, cortex_tsdb.TenantIDExternalLabel) |
| 166 | if len(meta.Thanos.Labels) > 0 { |
| 167 | changesRequired = append(changesRequired, "remove extra Thanos labels") |
| 168 | } |
| 169 | |
| 170 | meta.Thanos.Labels = map[string]string{ |
| 171 | cortex_tsdb.TenantIDExternalLabel: expectedUser, |
| 172 | } |
| 173 | |
| 174 | return meta, changesRequired |
| 175 | } |
no outgoing calls