Advertisement
Guest User

Untitled

a guest
Jul 16th, 2019
70
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.91 KB | None | 0 0
  1. // addCacheData creates CacheDataInterface
  2. func addCacheData(factoryMap map[string]interface{}, gc *configs.GrpcConfig) (dataservice.CacheDataInterface, error) {
  3. conn, err := grpc.Dial(gc.Target, grpc.WithInsecure())
  4. if err != nil {
  5. return nil, errors.Wrap(err, "")
  6. }
  7.  
  8. cdg := cacheclient.CacheDataGrpc{*conn}
  9. key := gc.Target
  10. factoryMap[key] = &cdg
  11. return &cdg, err
  12. }
  13.  
  14. // retrieveCache retrieves CacheDataInterface from factory map. If it is not in map yet, it created one and put it
  15. // into map.
  16. // CacheDataInterface is a singleton
  17. func retrieveCache(factoryMap map[string]interface{}, gc *configs.GrpcConfig) (dataservice.CacheDataInterface, error){
  18. key := gc.Code
  19. value, found := registry.GetFromRegistry(factoryMap, key)
  20. if found {
  21. logger.Log.Debug("find RetrieveCache key=%v \n",key)
  22. return value.(dataservice.CacheDataInterface), nil
  23. }
  24. //not in map, need to create one
  25. return addCacheData(factoryMap, gc)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement