The database for intelligentresponsivedistributed systems

from kurrentdbclient import KurrentDBClient

client = KurrentDBClient(uri="kurrentdb://localhost:2113?tls=false")

await client.append_to_stream(stream_name="orders-42", events=[
    NewEvent(
        type='OrderPlaced',
        data=b'{"order_id": 42,"total":99.99}'
    )
])

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

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

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

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

settings, err := kurrentdb.ParseConnectionString("kurrentdb://localhost:2113?tls=false")
if err != nil { panic(err) }

client, err := kurrentdb.NewClient(settings)
if err != nil { panic(err) }

data, _ := json.Marshal(map[string]any{"orderId": 42, "total": 99.99})

_, err = client.AppendToStream(context.Background(), "orders-42",
  kurrentdb.AppendToStreamOptions{},
  kurrentdb.EventData{
      EventID:     uuid.New(),
      EventType:   "order-placed",
      ContentType: kurrentdb.ContentTypeJson,
      Data:        data,
  },
)

var client = KurrentDBClient.create(
    KurrentDBConnectionString.parseOrThrow("kurrentdb://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();

let settings = "kurrentdb://localhost:2113?tls=false".parse::<ClientSettings>()?;
let client = Client::new(settings)?;

let event = EventData::json(
  "order-placed",
  &OrderPlaced { order_id: 42, total: 99.99 },
)?
.id(Uuid::new_v4());

let options = AppendToStreamOptions::default().stream_state(StreamState::Any);

client
  .append_to_stream("orders-42", &options, event)
  .await?;