The database for intelligentresponsivedistributed systems

from kurrent.client import KurrentClient

client = KurrentClient.create("esdb://localhost:2113?tls=false")

events = [
    NewEvent(
        type="order-placed",
        data={"order_id": 42, "total": 99.99},
    )
]

await client.append_to_stream("orders-42", events=events)

import { KurrentDBClient, jsonEvent } from "@kurrent/kurrentdb-client";

const client = KurrentDBClient.connectionString(
  "esdb://localhost:2113?tls=false"
);

const event = jsonEvent({
  type: "order-placed",
  data: { orderId: 42, total: 99.99 },
});

await client.appendToStream("orders-42", event);

client, err := kurrentdb.NewClient(kurrentdb.Configuration{
    Address: "localhost:2113",
})

data, _ := json.Marshal(map[string]any{"orderId": 42, "total": 99.99})
events := []kurrentdb.EventData{
    kurrentdb.CreateEventData(uuid.New(), "order-placed", data, nil),
}

_, err = client.AppendToStream(
    context.Background(), "orders-42",
    kurrentdb.AppendToStreamOptions{},
    events...,
)

var client = EventStoreDBClient.create(
    EventStoreDBConnectionString.parseOrThrow("esdb://localhost:2113?tls=false")
);

var data = new ObjectMapper().writeValueAsBytes(
    Map.of("orderId", 42, "total", 99.99)
);

var event = EventData.builderAsJson("order-placed", data).build();

client.appendToStream("orders-42", event).get();