go-client

pegasus-go-client

Requirement

• Go1.18+
• thrift 0.13

Development

Build the pegasus-go-client:

make build

Format the code:

make fmt

It requires the Pegasus onebox has been started.

Then run tests:

make ci

Logging

By default, pegasus-go-client logs to "./pegasus.log" on where your application runs. You can customize the logging rules as follows:

    // customize where the pegasus-go-client's logs reside.
    pegalog.SetLogger(pegalog.NewLogrusLogger(&pegalog.LogrusConfig{
        // rotation rules
        MaxSize:    500, // megabytes
        MaxAge:     5,   // days
        MaxBackups: 100,
        // log files location
        Filename:   "/home/work/myapp/log/pegasus.log",
    }))

To print the logs on screen:

pegalog.SetLogger(pegalog.StderrLogger)

We highly recommend you to enable client logging for debugging purpose. If you want support for other log destinations or log formats, please submit an issue for that.

Example

    import (
        "context"

        "github.com/apache/incubator-pegasus/go-client/pegasus"
    )

    cfg := Config{
        MetaServers: []string{"0.0.0.0:34601", "0.0.0.0:34602", "0.0.0.0:34603"},
    }

    client := NewClient(cfg)
    defer client.Close()

    tb, err := client.OpenTable(context.Background(), "temp")
    err = tb.Set(context.Background(), []byte("h1"), []byte("s1"), []byte("v1"))

For more examples please refer to example/.

TroubleShooting

Before using pegasus-go-client, it's recommended to configure GOBACKTRACE so as to generate coredump while program unexpectedly corrupts.

ulimit -c unlimited
export GOBACTRACE=crash