github-mirrors/kibana
1
0
Fork 0
mirror of https://github.com/elastic/kibana.git synced 2025-04-23 09:19:04 -04:00
Code Issues Projects Releases Packages Wiki Activity

[Courier - Mapper] only request the client once it is needed

Browse source
This commit is contained in:
Spencer Alger 2014-02-24 12:37:39 -07:00
parent 1316104364
commit e8b3bff1f5
1 changed files with 6 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/courier/mapper.js
View file

@ -12,8 +12,6 @@ define(function (require) {
*/
function Mapper(courier, config) {
var client = courier._getClient();
// Exclude anything wirh empty mapping except these
var reservedFields = {
'_id': { type: 'string' },
@ -104,6 +102,7 @@ define(function (require) {
* @param {Function} callback A function to be executed with the results.
*/
this.getFieldsFromCache = function (dataSource, callback) {
var client = courier._getClient();
var params = {
index: config.cacheIndex,
type: config.cacheType,
@ -119,6 +118,7 @@ define(function (require) {
* @param {Function} callback A function to be executed with the results.
*/
this.getFieldsFromMapping = function (dataSource, callback) {
var client = courier._getClient();
var params = {
// TODO: Change index to be newest resolved index. Change _state.index to id().
index: dataSource._state.index,
@ -156,6 +156,8 @@ define(function (require) {
* @param {Function} callback A function to be executed with the results.
*/
var cacheFieldsToElasticsearch = function (config, index, fields, callback) {
var client = courier._getClient();
client.index({
index: config.cacheIndex,
type: config.cacheType,
@ -180,6 +182,8 @@ define(function (require) {
* @param {Function} callback A function to be executed with the results.
*/
this.clearCache = function (dataSource, callback) {
var client = courier._getClient();
if (!_.isUndefined(mappings[dataSource._state.index])) {
delete mappings[dataSource._state.index];
}