Go SDK

go get gitlab.com/westyx/nexus/sdk/go

package main

import (
    "context"
    "log"
    nexus "gitlab.com/westyx/nexus/sdk/go"
)

func main() {
    ctx, cancel := context.WithCancel(context.Background())
    defer cancel()

    client, err := nexus.NewClient(ctx, nexus.Config{
        BaseURL: "https://your-service.nexus.westyx.dev",
        APIKey:  "sk_live_...",
    })
    if err != nil {
        log.Fatal(err) // initial sync failed - do not ignore
    }

    go client.RunStream(ctx) // SSE live updates

    dbURL, _ := client.GetConfig("database.url")
    stripe, _ := client.GetSecret("stripe.key")
    newUI     := client.GetFlag("new.ui", false)
    log.Printf("db=%s stripe=%d-bytes newUI=%v", dbURL, len(stripe), newUI)
}

nexus.Config{
    BaseURL:    "https://your-service.nexus.westyx.dev", // required
    APIKey:     "sk_live_...",                           // required unless WIF
    TTL:        5 * time.Minute,                         // default: 5m
    HTTPClient: &http.Client{Timeout: 10 * time.Second},
    WIF:        &nexus.WIFConfig{...},                   // see WIF section
    Observer:   &nexus.StreamObserver{...},              // optional hooks
}

client, err := nexus.NewClient(ctx, nexus.Config{
    BaseURL: "https://your-service.nexus.westyx.dev",
    WIF: &nexus.WIFConfig{
        Enabled:  true,
        Provider: nexus.WIFProviderAuto, // "kubernetes" | "aws" | "gcp" | "azure" | "auto"
    },
})

WIF: &nexus.WIFConfig{
    Enabled: true,
    TokenSource: func(ctx context.Context) (string, error) {
        return fetchMyOIDCToken(), nil
    },
}

nexus.Config{
    Observer: &nexus.StreamObserver{
        OnConnected:       func() { log.Println("stream connected") },
        OnEvent:           func(e nexus.StreamEvent) { log.Printf("event: %s", e.Type) },
        OnReconnectAttempt: func(n int, err error) { log.Printf("reconnect #%d: %v", n, err) },
        OnFallback:        func(reason string) { log.Printf("fallback: %s", reason) },
    },
}