Argthtjtr

var es = elastigo.NewConn()

var indexer = es.NewBulkIndexer(50)



// Create a custom Sender Func, so that we can check what the error is

indexer.Sender = func(buf *bytes.Buffer) error {



    resp, err := c_es.DoCommand("POST", "/_bulk", nil, buf)

    if err != nil {



        fmt.Println("Error", string(resp)) 

        fmt.Println("Error", err)

    }



    if err == nil {

        fmt.Println("Succeed")

    }

    return err

}

// Connect to elasticsearch 

olivere_es, err = elastic.NewClient(elastic.SetURL("http:144.00.0.34:9400"))



//Replace the code for the var indexer = es.NewBulkIndexer(50)

var oliveIndexer = elastic.NewBulkService(olivere_es)

var es = elastigo.NewConn()

var indexer = es.NewBulkIndexer(50)



// Create a custom Sender Func, so that we can check what the error is

indexer.Sender = func(buf *bytes.Buffer) error {



    resp, err := c_es.DoCommand("POST", "/_bulk", nil, buf)

    if err != nil {



        fmt.Println("Error", string(resp)) 

        fmt.Println("Error", err)

    }



    if err == nil {

        fmt.Println("Succeed")

    }

    return err

}

// Connect to elasticsearch 

olivere_es, err = elastic.NewClient(elastic.SetURL("http:144.00.0.34:9400"))



//Replace the code for the var indexer = es.NewBulkIndexer(50)

var oliveIndexer = elastic.NewBulkService(olivere_es)

var es = elastigo.NewConn()

var indexer = es.NewBulkIndexer(50)



// Create a custom Sender Func, so that we can check what the error is

indexer.Sender = func(buf *bytes.Buffer) error {



    resp, err := c_es.DoCommand("POST", "/_bulk", nil, buf)

    if err != nil {



        fmt.Println("Error", string(resp)) 

        fmt.Println("Error", err)

    }



    if err == nil {

        fmt.Println("Succeed")

    }

    return err

}

// Connect to elasticsearch 

olivere_es, err = elastic.NewClient(elastic.SetURL("http:144.00.0.34:9400"))



//Replace the code for the var indexer = es.NewBulkIndexer(50)

var oliveIndexer = elastic.NewBulkService(olivere_es)

var es = elastigo.NewConn()

var indexer = es.NewBulkIndexer(50)



// Create a custom Sender Func, so that we can check what the error is

indexer.Sender = func(buf *bytes.Buffer) error {



    resp, err := c_es.DoCommand("POST", "/_bulk", nil, buf)

    if err != nil {



        fmt.Println("Error", string(resp)) 

        fmt.Println("Error", err)

    }



    if err == nil {

        fmt.Println("Succeed")

    }

    return err

}

// Connect to elasticsearch 

olivere_es, err = elastic.NewClient(elastic.SetURL("http:144.00.0.34:9400"))



//Replace the code for the var indexer = es.NewBulkIndexer(50)

var oliveIndexer = elastic.NewBulkService(olivere_es)

Your Answer

StackExchange.ifUsing("editor", function () {
StackExchange.using("externalEditor", function () {
StackExchange.using("snippets", function () {
StackExchange.snippets.init();
});
});
}, "code-snippets");

StackExchange.ready(function() {
var channelOptions = {
tags: "".split(" "),
id: "1"
};
initTagRenderer("".split(" "), "".split(" "), channelOptions);

StackExchange.using("externalEditor", function() {
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled) {
StackExchange.using("snippets", function() {
createEditor();
});
}
else {
createEditor();
}
});

function createEditor() {
StackExchange.prepareEditor({
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader: {
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
},
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
});


}
});