Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- // addCacheData creates CacheDataInterface
- func addCacheData(factoryMap map[string]interface{}, gc *configs.GrpcConfig) (dataservice.CacheDataInterface, error) {
- conn, err := grpc.Dial(gc.Target, grpc.WithInsecure())
- if err != nil {
- return nil, errors.Wrap(err, "")
- }
- cdg := cacheclient.CacheDataGrpc{*conn}
- key := gc.Target
- factoryMap[key] = &cdg
- return &cdg, err
- }
- // retrieveCache retrieves CacheDataInterface from factory map. If it is not in map yet, it created one and put it
- // into map.
- // CacheDataInterface is a singleton
- func retrieveCache(factoryMap map[string]interface{}, gc *configs.GrpcConfig) (dataservice.CacheDataInterface, error){
- key := gc.Code
- value, found := registry.GetFromRegistry(factoryMap, key)
- if found {
- logger.Log.Debug("find RetrieveCache key=%v \n",key)
- return value.(dataservice.CacheDataInterface), nil
- }
- //not in map, need to create one
- return addCacheData(factoryMap, gc)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement