Struct Topic 

pub struct Topic { /* private fields */ }

One topic within a stream: the Log primitive’s data handle. Build it with Stream::topic or, against the default stream, Laser::topic. Verbs resolve the producer through the client’s shared cache, so handles are free to construct and clone.

Implementations

impl Topic

pub fn publish(&self) -> PublishRequest<'_>

Open the fluent publish builder (payload via .payload() / .json() / .record(), then .send()). The raw payload path compiles to the same bytes as the low-level send, nothing is linked unless a typed form is used. Feature streaming.

pub fn publish_batch(&self) -> BatchPublishRequest<'_>

Open the fluent record-batch builder (add records, then .send()), the typed sibling of batch. Feature streaming.

pub async fn send( &self, payload: impl Into<Vec<u8>>, headers: BTreeMap<HeaderKey, HeaderValue>, partition_key: Option<&str>, ) -> Result<SendMessagesResponse, LaserError>

One raw message with explicit user headers, the zero-overhead path. Keyed partitioning preserves per-key ordering, None lets the producer balance across partitions.

pub async fn batch( &self, messages: Vec<IggyMessage>, partition_key: Option<&str>, ) -> Result<SendMessagesResponse, LaserError>

One Iggy send_messages call covering many pre-built messages, all sharing the same partitioning. An empty batch is a cheap no-op.

pub fn batching(&self) -> Result<BatchingProducerBuilder, LaserError>

A size-and-time batching publisher over this topic: .batching(), tune .max_records/.max_bytes/.linger/.partition_key, then .build(). Opt-in: the unbatched verbs compile to exactly the same calls as before. Feature agent (the linger timer rides tokio).

pub fn replay(&self) -> Result<Cursor, LaserError>

The positional replay handle over this topic: a resumable Cursor reading from explicit offsets. The bounded-read rung below the reliable consumer.

pub async fn ensure(&self, partitions: u32) -> Result<(), LaserError>

Idempotently create this topic with partitions, creating the stream first if needed.

pub async fn ensure_consumer_group(&self, name: &str) -> Result<(), LaserError>

Idempotently create the consumer group name on this topic without joining it or giving it a filter policy, so an operator can address it before any member connects. ConsumerGroup::create configures a policy in the same step.

pub fn iggy_producer(&self) -> Result<IggyProducerBuilder, LaserError>

The Iggy producer builder for this topic, the substrate front door: Iggy’s own options (batching, partitioning, retries, encryption) with nothing wrapped. Independent of the fluent path’s cached producer.

pub fn iggy_consumer( &self, name: &str, partition: u32, ) -> Result<IggyConsumerBuilder, LaserError>

The Iggy consumer builder named name over one partition of this topic. The built IggyConsumer implements futures::Stream.

pub fn iggy_consumer_group( &self, group: &str, ) -> Result<IggyConsumerBuilder, LaserError>

The Iggy consumer-group builder over this topic: the balanced group, offsets committed under group.

pub fn producer(&self) -> ProducerBuilder

Build a Laser streaming producer with direct batching, linger, retries, routing, and optional stream/topic creation. build().await initializes it before returning.

pub fn consumer( &self, name: impl Into<String>, partition: u32, ) -> ConsumerBuilder

Build a live Laser consumer for one partition. The built consumer implements futures::Stream and exposes server-backed offset control.

pub fn consumer_group(&self, group: impl Into<String>) -> ConsumerGroup

The consumer group group of this topic: the handle that owns the group’s filter policy and builds its consumers and readers. Free and synchronous, IO happens at the verbs.

pub fn consumer_group_id(&self, id: u64) -> ConsumerGroup

consumer_group by the group’s native numeric id. The id names a group inside this topic incarnation only.

pub fn name(&self) -> &str

This topic’s name.

impl Topic

pub fn json<T>(&self) -> TypedTopic<T>

The typed handle over this topic in the JSON serde form: no registry, the body type’s Serialize/Deserialize is the contract. Publishes stamp agdx.ct=json, records decodes each payload back into T.

pub fn cbor<T>(&self) -> TypedTopic<T>

The typed handle in the CBOR serde form: same contract as json with a binary self-describing body and agdx.ct=cbor.

pub async fn schema<T>( &self, schema_id: u32, ) -> Result<TypedTopic<T>, LaserError>

The typed handle bound to a registered writer schema: resolves the definition from LaserData Cloud’s registry and compiles it ONCE for the handle’s lifetime, so every publish validates against it client-side before any byte leaves the process and stamps agdx.ct + agdx.sid. A body that stops matching the schema fails at the producer with the schema’s error, not downstream in the projector. Feature schema-codecs, and the registry is managed, so this form needs LaserData Cloud.

Trait Implementations

impl Clone for Topic

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.