Callback - Langfuse

package main

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

func main() {
    cbh, flusher := NewLangfuseHandler(&_Config_{
        Host: "https://cloud.langfuse.com",
        PublicKey: "pk-xxx",
        SecretKey: "sk-xxx",
    })
    
    **callbacks**.InitCallbackHandlers([]**callbacks**._Handler_{cbh}) // 设置langfuse为全局callback
    
    g := NewGraph[string,string]()
    /*
    * compose and run graph
    */
    
    flusher() // 等待所有trace上报完成后退出
}