Go Agent v0.1.14

2022年12月14日

Fixed UDPサーバーが停止した状態でCPU使用率が増加する現象を修正

UDPサーバーが停止した状態(whatap-agentサービスが停止)で、Goモニタリングを適用するとアプリケーションのCPU負荷が増加します。UDPサーバーへの接続と終了の処理が繰り返されることで、UDP接続が複数維持され、CPU使用量が増加します。

New k8s.io/client-go/kubernetesライブラリに対応

golang
import (
  "k8s.io/client-go/rest"
)

func main() {
  // Init whatap trace
  config := make(map[string]string)
  trace.Init(config)
  defer trace.Shutdown()

  ...

  config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
  if err != nil {
    return nil, err
  }

  // whatap roundTripper関数を設定します。 
  config.WrapTransport = wRT.WrapRoundTripper()

  clientset, err := kubernetes.NewForConfig(config)
  if err != nil {
    return nil, err
  }

  deploymentsClient := clientset.AppsV1().Deployments(conf.Server.Namespace)

  ...
}

New github.com/gofiber/fiber/v2ライブラリに対応

参考例

golang
import (
  "github.com/whatap/go-api/instrumentation/github.com/gofiber/fiber/v2/whatapfiber"
)

func main() {
  // Init whatap trace
  config := make(map[string]string)
  trace.Init(config)
  defer trace.Shutdown()

  ...

  r := fiber.New(fiber.Config{
    StrictRouting: true,
    Views:         engine,
  })

  r.Use(recover.New())

  // whatapfiberのmiddlewareを登録します。
  r.Use(whatapfiber.Middleware())
  
  ...
}

New github.com/valyala/fasthttpライブラリに対応

参考例

golang
import (
  "github.com/whatap/go-api/instrumentation/github.com/valyala/fasthttp/whatapfasthttp"
)

func main() {
  // Init whatap trace
  config := make(map[string]string)
  trace.Init(config)
  defer trace.Shutdown()

  ...
    
  r := fiber.New(fiber.Config{
    StrictRouting: true,
    Views:         engine,
  })

  r.Use(recover.New())

  // ラッパー（Wrapper）関数whatapfasthtp.Funcを使用します。 
  r.GET("/", whatapfasthttp.Func(func(ctx *fasthttp.RequestCtx) {
    ...
  }))
  r.GET("/hello/{name}", whatapfasthttp.Func(func(ctx *fasthttp.RequestCtx) {
    fmt.Fprintf(ctx, "Hello, %s!\n", ctx.UserValue("name"))
    ctx.SetContentType("text/html;charset=utf8")
  }))
}

2022年12月14日​

2022年12月14日