Callback - APMPlus

go get github.com/cloudwego/eino-ext/callbacks/apmplus

package main

import (
    "context"
    "log"
    
    "github.com/cloudwego/eino-ext/callbacks/apmplus"
    "github.com/cloudwego/eino/callbacks"
)

func main() {
    ctx := context.Background()
    // 创建apmplus handler
    cbh, showdown, err := apmplus.NewApmplusHandler(&apmplus.Config{
       Host: "apmplus-cn-beijing.volces.com:4317",
       AppKey:      "appkey-xxx",
       ServiceName: "eino-app",
       Release:     "release/v0.0.1",
    })
    if err != nil {
       log.Fatal(err)
    }

    // 设置apmplus为全局callback
    callbacks.AppendGlobalHandlers(cbh)

    g := NewGraph[string,string]()
    /*
     * compose and run graph
     */
    runner, _ := g.Compile(ctx)
    runner.Run(ctx)

    // 如想设置会话信息, 可通过 apmplus.SetSession 方法
	ctx = apmplus.SetSession(ctx, apmplus.WithSessionID("your_session_id"), apmplus.WithUserID("your_user_id"))

    // 执行 runner
	result, _ := runner.Invoke(ctx, "input")
	/*
	 * 处理结果
    */

    // 等待所有trace和metrics上报完成后退出
    showdown(ctx)
}