axw

version: "2.1"
services:
  apm-server:
    image: docker.elastic.co/apm/apm-server:${STACK_VERSION:-6.5.0}
    ports:
      - "127.0.0.1:${APM_SERVER_PORT:-8200}:8200"
      - "127.0.0.1:${APM_SERVER_MONITOR_PORT:-6060}:6060"
    command: >
      apm-server -e
        -E apm-server.rum.enabled=true

axw

The proposal provides a means of printing an error, including the source location.
In the proposal, this is the _only_ way of accessing the source location.

In the Elastic APM Go agent (https://github.com/elastic/apm-agent-go), we provide
users with a means of reporting unexpected errors, along with the source location,
in a structured format. As the proposal is, we would need to print and then parse;
and then the format is not well defined anyway.

It would be ideal if we could access the error's frame directly, and then given
a frame, access the source location directly (say, by providing a method to convert

axw

package main                                                                            
                                                                                        
import (                                                                                
        "fmt"                                                                           
        "net/http"                                                                      
                                                                                        
        "github.com/zenazn/goji"                                                        
        "github.com/zenazn/goji/web"                                                    
        "go.elastic.co/apm/module/apmhttp"                                              
)                                                                                       

axw

const apm = require('elastic-apm-node').start({
        serviceName: 'geoip-node-client'
});

var grpc = require('grpc');
var interceptor = function(options, nextCall) {
        return new grpc.InterceptingCall(nextCall(options), {
                start: function(metadata, listener, next) {
                        var span = apm.startSpan('grpc');
                        var traceparent = span._context.toString();

axw

package main

import (
	"fmt"

	"go.elastic.co/apm"
)

type node struct {
	tracer *apm.Tracer

axw

version: '2.2'
services:
  apm-server:
    image: docker.elastic.co/apm/apm-server:7.5.1
    depends_on:
      elasticsearch:
        condition: service_healthy
      kibana:
        condition: service_healthy
    cap_add: ["CHOWN", "DAC_OVERRIDE", "SETGID", "SETUID"]

axw

diff --git a/elasticsearch/client.go b/elasticsearch/client.go
index e7df0cde..712a1ba3 100644
--- a/elasticsearch/client.go
+++ b/elasticsearch/client.go
@@ -18,15 +18,9 @@
 package elasticsearch
 
 import (
-	"bytes"
 	"context"

axw

package main

import (
	"context"
	"fmt"
	"io"
	"log"
	"net/http"
	"time"

axw

package main                                                                                                                
                                                                                                                            
import (                                                                                                                    
        "context"                                                                                                           
        "log"                                                                                                               
        "time"                                                                                                              
                                                                                                                            
        "github.com/elastic/beats/v7/libbeat/logp"