I will ask you about the issue of pin-point interworking with Golang.

[hoonyplus]

Is there a sample integration for an application without an API that only performs database queries and API calls based on Kafka events?

Most of the samples on GitHub operate based on HTTP API calls. Therefore, a sample where a transaction starts with a Kafka event is needed.

[dwkang]

We are providing plug-in to trace the sarama package, kfaka library. Please refer to the link below.

• https://github.com/pinpoint-apm/pinpoint-go-agent/tree/main/plugin/sarama
• https://github.com/pinpoint-apm/pinpoint-go-agent/tree/main/plugin/sarama-IBM

Also, plugins are also prepared in the database or other packages, so please refer to the link below.

• https://github.com/pinpoint-apm/pinpoint-go-agent/blob/main/doc/plugin_guide.md
• https://github.com/pinpoint-apm/pinpoint-go-agent/tree/main/plugin

[hoonyplus]

Thank you for your response.
Below is a reproduction of a case where there is a DB call without an HTTP request. I want to find a way to make such a call.

package main

import (
"context"
"database/sql"
"github.com/pinpoint-apm/pinpoint-go-agent"
_ "github.com/pinpoint-apm/pinpoint-go-agent/plugin/pgsql"
"log"
"testing"
"time"
)

func TestTableCountWithoutRequest(t *testing.T) {

// Pinpoint Agent 설정
opts := []pinpoint.ConfigOption{
	pinpoint.WithAppName("...."),
	pinpoint.WithAgentId("..."),
	pinpoint.WithCollectorHost("..."),
	pinpoint.WithLogLevel("debug"),
}
cfg, _ := pinpoint.NewConfig(opts...)
agent, err := pinpoint.NewAgent(cfg)
if err != nil {
	log.Fatalf("Pinpoint agent start fail: %v", err)
}

defer func() {
	// 에이전트가 데이터를 전송할 수 있도록 약간의 대기 시간 추가
	time.Sleep(30 * time.Second)
	agent.Shutdown()
}()

// Pinpoint Tracer 생성
tracer := agent.NewSpanTracer("tableCountWithoutRequest", "/example/path")
defer tracer.EndSpan()

// 데이터베이스 연결
db, err := sql.Open("pq-pinpoint", "...")
if err != nil {
	t.Fatalf("DB connection error: %v", err)
}
defer db.Close()

// 테스트용 컨텍스트 생성
ctx := context.Background()

// 쿼리 실행
row := db.QueryRowContext(ctx, "SELECT count(*) FROM ...")

var count int
err = row.Scan(&count)
if err != nil {
	t.Fatalf("SQL error: %v", err)
}

// 결과 검증
if count < 0 {
	t.Errorf("Invalid count: %d", count)
} else {
	t.Logf("Number of entries: %d", count)
}

}

[dwkang]

The tracer should be propagated to database calls using context.
Refer to link below.

• https://github.com/pinpoint-apm/pinpoint-go-agent/blob/main/doc/instrument.md#context-propagation
• https://github.com/pinpoint-apm/pinpoint-go-agent/blob/main/example/stand_alone.go