Skip to main content

Quick Start

This is the smallest useful flow: dial the cluster, list databases, and inspect a table.

Connect​

package main

import (
	"context"
	"log"

	"github.com/chiqors/fluss-go-client/client"
)

func main() {
	ctx := context.Background()

	cli, err := client.Dial(ctx, client.Config{
		Endpoints: []string{"127.0.0.1:9123"},
	})
	if err != nil {
		log.Fatal(err)
	}
	defer cli.Close()

	names, summaries, err := cli.Admin().ListDatabases(ctx, true)
	if err != nil {
		log.Fatal(err)
	}

	log.Printf("database names: %v", names)
	log.Printf("database summaries: %v", summaries)
}

Inspect a Table​

table := cli.Table(client.TablePath{
	DatabaseName: "fluss",
	TableName:    "orders",
})

info, err := table.Info(ctx)
if err != nil {
	log.Fatal(err)
}

schema, err := table.Schema(ctx, nil)
if err != nil {
	log.Fatal(err)
}

_, _ = info, schema

What To Explore Next​

For broader examples, start with: