Callback - Langfuse

package main

import (
    "github.com/cloudwego/eino-ext/callbacks/langfuse"
    "github.com/cloudwego/eino/callbacks"
)

func main() {
    cbh, flusher := langfuse.NewLangfuseHandler(&langfuse.Config{
        Host: "https://cloud.langfuse.com",
        PublicKey: "pk-xxx",
        SecretKey: "sk-xxx",
    })
    defer flusher() // 等待所有trace上报完成后退出

    callbacks.AppendGlobalHandlers(cbh) // 设置langfuse为全局callback
    
    g := NewGraph[string,string]()
    /*
    * compose and run graph
    */
}