a11::net::WireStreamOptions Struct Reference

Buffering, sizing, and deadline limits for a WireStream endpoint. More...

#include <cpp/a11/net/wire_stream.h>

Public Member Functions
absl::Status	Validate () const
	Validate the option values, returning a non-OK status if inconsistent.

Public Attributes
size_t	max_buffered_incoming_messages = 100
	Maximum inbound messages buffered before backpressure is applied.
size_t	max_single_message_size = kMaxSingleMessageSize
	Reject any single reassembled message larger than this.
size_t	max_buffered_incoming_bytes = 32 * 1024 * 1024
	Maximum total bytes of buffered inbound messages.
absl::Duration	message_timeout = absl::InfiniteDuration()
	Fail a message that cannot be delivered within this duration (infinite = no per-message timeout).
absl::Time	deadline = absl::InfiniteFuture()
	Absolute deadline after which the stream is aborted.

Detailed Description

Buffering, sizing, and deadline limits for a WireStream endpoint.

These bound how much inbound data the stream will hold before applying backpressure or failing, and when it gives up. Concrete transports validate and apply them at construction.

Member Function Documentation

Validate()

absl::Status a11::net::WireStreamOptions::Validate

(

)

const

Validate the option values, returning a non-OK status if inconsistent.

Member Data Documentation

deadline

absl::Time a11::net::WireStreamOptions::deadline = absl::InfiniteFuture()

Absolute deadline after which the stream is aborted.

max_buffered_incoming_bytes

size_t a11::net::WireStreamOptions::max_buffered_incoming_bytes = 32 * 1024 * 1024

Maximum total bytes of buffered inbound messages.

max_buffered_incoming_messages

size_t a11::net::WireStreamOptions::max_buffered_incoming_messages = 100

Maximum inbound messages buffered before backpressure is applied.

max_single_message_size

size_t a11::net::WireStreamOptions::max_single_message_size = kMaxSingleMessageSize

Reject any single reassembled message larger than this.

message_timeout

absl::Duration a11::net::WireStreamOptions::message_timeout = absl::InfiniteDuration()

Fail a message that cannot be delivered within this duration (infinite = no per-message timeout).

---

The documentation for this struct was generated from the following files:

• cpp/a11/net/wire_stream.h
• cpp/a11/net/wire_stream.cc