Struct StandaloneConfig 

pub struct StandaloneConfig {
    pub consumer_id: String,
    pub topic_id: u32,
    pub topic_name: Option<String>,
    pub max_fetch_bytes: u32,
    pub start_position: SeekPosition,
    pub offset_dir: Option<PathBuf>,
    pub auto_commit_interval: Option<Duration>,
    pub connect_timeout: Duration,
    pub poll_timeout: Duration,
}

Configuration for standalone consumer mode

There are three ways to specify which topic to consume:

1. Name-based (recommended) — pass only the topic name via StandaloneConfig::with_topic_name. The consumer resolves the name to a numeric ID automatically by calling create_topic (which is idempotent) on connect.

2. ID + name — use StandaloneConfig::new_with_id when you already hold a resolved TopicInfo and want to skip the extra round-trip.

3. ID-only (legacy) — use StandaloneConfig::new with a numeric ID directly. This preserves backward compatibility with existing callers.

Fields

consumer_id: String

Identifier for this consumer (used for offset storage)

topic_id: u32

Topic ID to consume from.

When this is 0 and topic_name is Some, the consumer will resolve the name to an ID on the first call to StandaloneConsumer::connect.

topic_name: Option<String>

Human-readable topic name.

When set and topic_id == 0, StandaloneConsumer::connect resolves the name to an ID via create_topic (idempotent).

max_fetch_bytes: u32

Maximum bytes to fetch per poll

start_position: SeekPosition

Starting position if no stored offset exists

offset_dir: Option<PathBuf>

Directory for offset persistence (None = in-memory only)

auto_commit_interval: Option<Duration>

Auto-commit interval (None = manual commit only)

connect_timeout: Duration

Connection timeout

poll_timeout: Duration

Poll timeout for blocking operations

Implementations

impl StandaloneConfig

pub fn new(consumer_id: impl Into<String>, topic_id: u32) -> Self

Create a standalone config using a numeric topic ID.

This is the legacy constructor and is kept for backward compatibility. Prefer StandaloneConfig::with_topic_name for new code — it lets the client resolve the name automatically and avoids coupling call sites to numeric IDs.

pub fn with_topic_name( consumer_id: impl Into<String>, topic_name: impl Into<String>, ) -> Self

Create a standalone config using only the topic name.

When this config is passed to StandaloneConsumer::connect, the consumer calls create_topic (idempotent) to resolve the name to a numeric ID before subscribing. No extra setup code is required on the call site.

The name must match [a-zA-Z0-9-]+; an error is returned at connect time if validation fails.

Examples

use lnc_client::{StandaloneConsumer, StandaloneConfig};

let mut consumer = StandaloneConsumer::connect(
    "127.0.0.1:1992",
    StandaloneConfig::with_topic_name("my-consumer", "rithmic-actions"),
).await?;

pub fn new_with_id( consumer_id: impl Into<String>, topic_name: impl Into<String>, topic_id: u32, ) -> Self

Create a standalone config with both a topic name and a pre-resolved numeric ID.

Use this when you already have a TopicInfo from a prior create_topic call and want to avoid the extra round-trip that StandaloneConfig::with_topic_name performs on connect.

Examples

use lnc_client::{ClientConfig, LanceClient, StandaloneConsumer, StandaloneConfig};

let mut mgmt = LanceClient::connect(ClientConfig::new("127.0.0.1:1992")).await?;
let info = mgmt.create_topic("rithmic-actions").await?;

let mut consumer = StandaloneConsumer::connect(
    "127.0.0.1:1992",
    StandaloneConfig::new_with_id("my-consumer", &info.name, info.id),
).await?;

pub fn with_consumer_id(self, id: impl Into<String>) -> Self

Set the consumer ID for offset tracking

pub fn with_max_fetch_bytes(self, bytes: u32) -> Self

Set the maximum bytes to fetch per poll

pub fn with_start_position(self, position: SeekPosition) -> Self

Set the starting position when no stored offset exists

pub fn with_offset_dir(self, dir: &Path) -> Self

Set the directory for offset persistence If not set, offsets are stored in memory only (lost on restart)

pub fn with_auto_commit_interval(self, interval: Option<Duration>) -> Self

Set auto-commit interval (None to disable auto-commit)

pub fn with_manual_commit(self) -> Self

Disable auto-commit (manual commit only)

pub fn with_connect_timeout(self, timeout: Duration) -> Self

Set connection timeout

pub fn with_poll_timeout(self, timeout: Duration) -> Self

Set poll timeout

Trait Implementations

impl Clone for StandaloneConfig

fn clone(&self) -> StandaloneConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StandaloneConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.