Crate krabka_app_sdk 

Krabka application SDK for Rust.

This crate implements the cross-language application SDK contract used by serverless app code. It deliberately sits beside, not above, the native Kafka-shaped krabka-client-* crates: use this SDK for the portable app surface, and use the native crates for Kafka protocol administration, producing, consuming, and stream-processing internals.

Re-exports

pub use self::client::KrabkaClient;

pub use self::client::KrabkaClientBuilder;

pub use self::error::KrabkaError;

pub use self::messaging::CloudEvent;

pub use self::messaging::Filter;

pub use self::messaging::Inbound;

pub use self::messaging::MessageStream;

pub use self::messaging::MessagingClient;

pub use self::messaging::PublishOptions;

pub use self::messaging::RecordResult;

pub use self::stubs::AcquireOptions;

pub use self::stubs::AuthClient;

pub use self::stubs::BlobClient;

pub use self::stubs::DatabaseClient;

pub use self::stubs::QueueAckEntry;

pub use self::stubs::QueueAckResult;

pub use self::stubs::QueueAckType;

pub use self::stubs::QueueAcquireResult;

pub use self::stubs::QueueMessage;

pub use self::stubs::QueueRenewEntry;

pub use self::stubs::QueuesClient;

Modules

client

Client construction and module accessors.

connect_client

Minimal Connect client pieces used by the Rust app SDK.

error

Public SDK error taxonomy.

messaging

Messaging module for publish, CloudEvents publish, and subscribe.

pb

Generated gateway protobuf messages.

stubs

Queue client plus gated stubs for modules not implemented in v1.