()
| 757 | } |
| 758 | |
| 759 | func (t *Cortex) initAlertManager() (serv services.Service, err error) { |
| 760 | t.Cfg.Alertmanager.ShardingRing.ListenPort = t.Cfg.Server.GRPCListenPort |
| 761 | |
| 762 | var featureControlMode string |
| 763 | switch t.Cfg.NameValidationScheme { |
| 764 | case model.LegacyValidation: |
| 765 | featureControlMode = featurecontrol.FeatureClassicMode |
| 766 | case model.UTF8Validation: |
| 767 | featureControlMode = featurecontrol.FeatureUTF8StrictMode |
| 768 | default: |
| 769 | return nil, fmt.Errorf("invalid validation scheme: %s", t.Cfg.NameValidationScheme) |
| 770 | } |
| 771 | |
| 772 | features, err := featurecontrol.NewFlags(util_log.SLogger, featureControlMode) |
| 773 | if err != nil { |
| 774 | return |
| 775 | } |
| 776 | compat.InitFromFlags(util_log.SLogger, features) |
| 777 | |
| 778 | // Initialise the store. |
| 779 | store, err := alertstore.NewAlertStore(context.Background(), t.Cfg.AlertmanagerStorage, t.OverridesConfig, util_log.Logger, prometheus.DefaultRegisterer) |
| 780 | if err != nil { |
| 781 | return |
| 782 | } |
| 783 | |
| 784 | t.Alertmanager, err = alertmanager.NewMultitenantAlertmanager(&t.Cfg.Alertmanager, store, t.OverridesConfig, util_log.Logger, prometheus.DefaultRegisterer) |
| 785 | if err != nil { |
| 786 | return |
| 787 | } |
| 788 | |
| 789 | t.API.RegisterAlertmanager(t.Alertmanager, t.Cfg.isModuleEnabled(AlertManager), t.Cfg.Alertmanager.EnableAPI) |
| 790 | return t.Alertmanager, nil |
| 791 | } |
| 792 | |
| 793 | func (t *Cortex) initParquetConverter() (serv services.Service, err error) { |
| 794 | t.Cfg.ParquetConverter.Ring.ListenPort = t.Cfg.Server.GRPCListenPort |
nothing calls this directly
no test coverage detected