ppgohbase

ppgohbase

This package instruments the tsuna/gohbase package.

Installation

$ go get github.com/pinpoint-apm/pinpoint-go-agent/plugin/gohbase

import "github.com/pinpoint-apm/pinpoint-go-agent/plugin/gohbase"

Usage

This package instruments the gohbase calls. Use the NewClient as the gohbase.NewClient.

client := ppgohbase.NewClient("localhost")

It is necessary to pass the context containing the pinpoint.Tracer to gohbase.Client.

ctx := pinpoint.NewContext(context.Background(), tracer)
putRequest, _ := hrpc.NewPutStr(ctx, "table", "key", values)
client.Put(putRequest)

import (
    "github.com/tsuna/gohbase/hrpc"
    "github.com/pinpoint-apm/pinpoint-go-agent"
    "github.com/pinpoint-apm/pinpoint-go-agent/plugin/gohbase"
)

func doHbase(w http.ResponseWriter, r *http.Request) {
    client := ppgohbase.NewClient("localhost")

    values := map[string]map[string][]byte{"cf": {"a": []byte{0}}}
    putRequest, err := hrpc.NewPutStr(r.Context(), "table", "key", values)
    _, err = client.Put(putRequest)
	
    ...
}

Full Example Source