Go API Reference

Go SDK for Kimberlite.

Package: github.com/kimberlitedb/kimberlite-go Go: 1.21+

Installation

go get github.com/kimberlitedb/kimberlite-go

Client

package main

import (
    "context"
    "log"
    kmb "github.com/kimberlitedb/kimberlite-go"
)

func main() {
    // Connect
    client, err := kmb.Connect("localhost:3000")
    if err != nil {
        log.Fatal(err)
    }
    defer client.Close()

    // Append
    position, err := client.Append(
        context.Background(),
        kmb.TenantID(1),
        kmb.StreamID{TenantID: 1, StreamNumber: 100},
        []byte("event data"),
    )
    if err != nil {
        log.Fatal(err)
    }

    // Read
    events, err := client.ReadStream(
        context.Background(),
        kmb.TenantID(1),
        kmb.StreamID{TenantID: 1, StreamNumber: 100},
    )
    if err != nil {
        log.Fatal(err)
    }

    for _, event := range events {
        log.Printf("Position: %d, Data: %s", event.Position, event.Data)
    }
}

Examples

See Go Quickstart for complete examples.