Pulsar

BindingsCollection.Pulsar registers server and channel levels.

using ByteBard.AsyncAPI.Bindings.Pulsar;
using ByteBard.AsyncAPI.Models;
using ByteBard.AsyncAPI.Models.Bindings.Pulsar;

var channel = new AsyncApiChannel();
channel.Bindings.Add(new PulsarChannelBinding
{
    Namespace = "sales",
    Persistence = Persistence.Persistent,
    Deduplication = true,
    Retention = new RetentionDefinition { Time = 7, Size = 1000 },
});

var server = new AsyncApiServer();
server.Bindings.Add(new PulsarServerBinding { Tenant = "contoso" });

Bindings.Add(binding) uses each instance's BindingKey (pulsar) for both channel and server bindings.

Server binding fields: Tenant. Channel binding fields: Namespace, required Persistence, nullable Compaction, GeoReplication, Retention, nullable TTL, and nullable Deduplication. RetentionDefinition contains integer Time and Size (time in minutes; size in megabytes).

Write

For example, attach a PulsarChannelBinding to its channel and serialize the enclosing document:

using ByteBard.AsyncAPI;
using ByteBard.AsyncAPI.Bindings.Pulsar;
using ByteBard.AsyncAPI.Models;
using ByteBard.AsyncAPI.Models.Bindings.Pulsar;
using System.Collections.Generic;

var document = new AsyncApiDocument
{
    Info = new AsyncApiInfo { Title = "Orders", Version = "1.0.0" },
    Channels = new Dictionary<string, AsyncApiChannel>
    {
        ["orders"] = new AsyncApiChannel { Address = "orders" },
    },
};
document.Channels["orders"].Bindings.Add(new PulsarChannelBinding
{
    Namespace = "sales",
    Persistence = Persistence.Persistent,
    Retention = new RetentionDefinition { Time = 7, Size = 1000 },
    Deduplication = true,
});

var yaml = document.SerializeAsYaml(AsyncApiVersion.AsyncApi3_0);

Read and use

Continuing from the Write example above, this snippet uses its yaml variable.

using System;
using ByteBard.AsyncAPI;
using ByteBard.AsyncAPI.Bindings;
using ByteBard.AsyncAPI.Bindings.Pulsar;
using ByteBard.AsyncAPI.Models;
using ByteBard.AsyncAPI.Readers;

var settings = new AsyncApiReaderSettings { Bindings = BindingsCollection.Pulsar };
var parsed = new AsyncApiStringReader(settings).Read(yaml, out var diagnostics);
if (parsed.Channels["orders"].Bindings.TryGetValue<PulsarChannelBinding>(out var pulsar))
{
    Console.WriteLine($"{pulsar.Namespace}: {pulsar.Persistence}, retention={pulsar.Retention.Time}m/{pulsar.Retention.Size}MB");
}

var parsedServer = new AsyncApiStringReader(settings).ReadFragment<AsyncApiServer>("""
    bindings:
      pulsar:
        tenant: contoso
    """, AsyncApiVersion.AsyncApi3_0, out diagnostics);
if (parsedServer.Bindings.TryGetValue<PulsarServerBinding>(out var pulsarServer))
{
    Console.WriteLine(pulsarServer.Tenant);
}

Each typed lookup returns false when the corresponding server or channel binding is absent.

The same collection supports PulsarServerBinding on a server. These examples target AsyncAPI 3.1.0; when writing 2.x, AsyncAPI.NET converts the surrounding document layout. The model does not enforce Pulsar's deployment-specific retention or namespace constraints. For reader setup see the shared guide.