in api/internal/core/store/storehub.go [50:83]
func InitStore(key HubKey, opt GenericStoreOption) error {
hubsNeedCheck := map[HubKey]bool{
HubKeyConsumer: true,
HubKeyRoute: true,
HubKeySsl: true,
HubKeyService: true,
HubKeyUpstream: true,
HubKeyGlobalRule: true,
HubKeyStreamRoute: true,
HubKeySystemConfig: true,
}
if _, ok := hubsNeedCheck[key]; ok {
validator, err := NewAPISIXJsonSchemaValidator("main." + string(key))
if err != nil {
return err
}
opt.Validator = validator
}
opt.HubKey = key
s, err := NewGenericStore(opt)
if err != nil {
log.Errorf("NewGenericStore error: %s", err)
return err
}
if err := s.Init(); err != nil {
log.Errorf("GenericStore init error: %s", err)
return err
}
utils.AppendToClosers(s.Close)
storeHub[key] = s
return nil
}