Struct Builder 

pub struct Builder { /* private fields */ }

Available on crate features http and http-full only.

A builder to configure an HTTP connection.

After setting options, the builder is used to create a handshake future.

Note: The default values of options are not considered stable. They are subject to change at any time.

Implementations

impl Builder

pub fn new(exec: Executor) -> Builder

Creates a new connection builder.

pub fn with_setting_config(self, config: &SettingsConfig) -> Builder

pub fn set_setting_config(&mut self, config: &SettingsConfig) -> &mut Builder

pub fn with_initial_stream_window_size( self, sz: impl Into<Option<u32>>, ) -> Builder

Sets the SETTINGS_INITIAL_WINDOW_SIZE option for HTTP2 stream-level flow control.

Passing None will do nothing.

If not set, rama_http_core will use a default.

pub fn set_initial_stream_window_size( &mut self, sz: impl Into<Option<u32>>, ) -> &mut Builder

Sets the SETTINGS_INITIAL_WINDOW_SIZE option for HTTP2 stream-level flow control.

Passing None will do nothing.

If not set, rama_http_core will use a default.

pub fn with_initial_connection_window_size(self, sz: u32) -> Builder

Sets the max connection-level flow control for HTTP2

If not set, rama_http_core will use a default.

pub fn set_initial_connection_window_size(&mut self, sz: u32) -> &mut Builder

Sets the max connection-level flow control for HTTP2

If not set, rama_http_core will use a default.

pub fn with_initial_max_send_streams(self, initial: usize) -> Builder

Sets the initial maximum of locally initiated (send) streams.

This value will be overwritten by the value included in the initial SETTINGS frame received from the peer as part of a connection preface.

If not set, rama_http_core will use a default.

pub fn set_initial_max_send_streams(&mut self, initial: usize) -> &mut Builder

Sets the initial maximum of locally initiated (send) streams.

This value will be overwritten by the value included in the initial SETTINGS frame received from the peer as part of a connection preface.

If not set, rama_http_core will use a default.

pub fn with_adaptive_window(self, enabled: bool) -> Builder

Sets whether to use an adaptive flow control.

Enabling this will override the limits set in initial_stream_window_size and initial_connection_window_size.

pub fn set_adaptive_window(&mut self, enabled: bool) -> &mut Builder

Sets whether to use an adaptive flow control.

Enabling this will override the limits set in initial_stream_window_size and initial_connection_window_size.

pub fn with_max_frame_size(self, sz: impl Into<Option<u32>>) -> Builder

Sets the maximum frame size to use for HTTP2.

Default is currently 16KB, but can change.

pub fn set_max_frame_size(&mut self, sz: impl Into<Option<u32>>) -> &mut Builder

Sets the maximum frame size to use for HTTP2.

Default is currently 16KB, but can change.

pub fn with_max_header_list_size(self, max: u32) -> Builder

Sets the max size of received header frames.

Default is currently 16KB, but can change.

pub fn set_max_header_list_size(&mut self, max: u32) -> &mut Builder

Sets the max size of received header frames.

Default is currently 16KB, but can change.

pub fn with_header_table_size(self, size: impl Into<Option<u32>>) -> Builder

Sets the header table size.

This setting informs the peer of the maximum size of the header compression table used to encode header blocks, in octets. The encoder may select any value equal to or less than the header table size specified by the sender.

The default value of crate h2 is 4,096.

pub fn set_header_table_size( &mut self, size: impl Into<Option<u32>>, ) -> &mut Builder

Sets the header table size.

This setting informs the peer of the maximum size of the header compression table used to encode header blocks, in octets. The encoder may select any value equal to or less than the header table size specified by the sender.

The default value of crate h2 is 4,096.

pub fn with_max_concurrent_streams(self, max: impl Into<Option<u32>>) -> Builder

Sets the maximum number of concurrent streams.

The maximum concurrent streams setting only controls the maximum number of streams that can be initiated by the remote peer. In other words, when this setting is set to 100, this does not limit the number of concurrent streams that can be created by the caller.

It is recommended that this value be no smaller than 100, so as to not unnecessarily limit parallelism. However, any value is legal, including 0. If max is set to 0, then the remote will not be permitted to initiate streams.

Note that streams in the reserved state, i.e., push promises that have been reserved but the stream has not started, do not count against this setting.

Also note that if the remote does exceed the value set here, it is not a protocol level error. Instead, the h2 library will immediately reset the stream.

See Section 5.1.2 in the HTTP/2 spec for more details.

pub fn set_max_concurrent_streams( &mut self, max: impl Into<Option<u32>>, ) -> &mut Builder

Sets the maximum number of concurrent streams.

The maximum concurrent streams setting only controls the maximum number of streams that can be initiated by the remote peer. In other words, when this setting is set to 100, this does not limit the number of concurrent streams that can be created by the caller.

It is recommended that this value be no smaller than 100, so as to not unnecessarily limit parallelism. However, any value is legal, including 0. If max is set to 0, then the remote will not be permitted to initiate streams.

Note that streams in the reserved state, i.e., push promises that have been reserved but the stream has not started, do not count against this setting.

Also note that if the remote does exceed the value set here, it is not a protocol level error. Instead, the h2 library will immediately reset the stream.

See Section 5.1.2 in the HTTP/2 spec for more details.

pub fn with_keep_alive_interval( self, interval: impl Into<Option<Duration>>, ) -> Builder

Sets an interval for HTTP2 Ping frames should be sent to keep a connection alive.

Pass None to disable HTTP2 keep-alive.

Default is currently disabled.

pub fn set_keep_alive_interval( &mut self, interval: impl Into<Option<Duration>>, ) -> &mut Builder

Sets an interval for HTTP2 Ping frames should be sent to keep a connection alive.

Pass None to disable HTTP2 keep-alive.

Default is currently disabled.

pub fn with_keep_alive_timeout(self, timeout: Duration) -> Builder

Sets a timeout for receiving an acknowledgement of the keep-alive ping.

If the ping is not acknowledged within the timeout, the connection will be closed. Does nothing if keep_alive_interval is disabled.

Default is 20 seconds.

pub fn set_keep_alive_timeout(&mut self, timeout: Duration) -> &mut Builder

Sets a timeout for receiving an acknowledgement of the keep-alive ping.

If the ping is not acknowledged within the timeout, the connection will be closed. Does nothing if keep_alive_interval is disabled.

Default is 20 seconds.

pub fn with_keep_alive_while_idle(self, enabled: bool) -> Builder

Sets whether HTTP2 keep-alive should apply while the connection is idle.

If disabled, keep-alive pings are only sent while there are open request/responses streams. If enabled, pings are also sent when no streams are active. Does nothing if keep_alive_interval is disabled.

Default is false.

pub fn set_keep_alive_while_idle(&mut self, enabled: bool) -> &mut Builder

Sets whether HTTP2 keep-alive should apply while the connection is idle.

If disabled, keep-alive pings are only sent while there are open request/responses streams. If enabled, pings are also sent when no streams are active. Does nothing if keep_alive_interval is disabled.

Default is false.

pub fn with_max_concurrent_reset_streams(self, max: usize) -> Builder

Sets the maximum number of HTTP2 concurrent locally reset streams.

See the documentation of h2::client::Builder::max_concurrent_reset_streams for more details.

The default value is determined by the h2 crate.

pub fn set_max_concurrent_reset_streams(&mut self, max: usize) -> &mut Builder

Sets the maximum number of HTTP2 concurrent locally reset streams.

See the documentation of h2::client::Builder::max_concurrent_reset_streams for more details.

The default value is determined by the h2 crate.

pub fn with_max_send_buf_size(self, max: u32) -> Builder

Set the maximum write buffer size for each HTTP/2 stream.

Default is currently 1MB, but may change.

pub fn set_max_send_buf_size(&mut self, max: u32) -> &mut Builder

Set the maximum write buffer size for each HTTP/2 stream.

Default is currently 1MB, but may change.

pub fn with_max_pending_accept_reset_streams( self, max: impl Into<Option<usize>>, ) -> Builder

Configures the maximum number of pending reset streams allowed before a GOAWAY will be sent.

This will default to the default value set by the h2 module. For now this is 20.

pub fn set_max_pending_accept_reset_streams( &mut self, max: impl Into<Option<usize>>, ) -> &mut Builder

Configures the maximum number of pending reset streams allowed before a GOAWAY will be sent.

This will default to the default value set by the h2 module. For now this is 20.

pub fn with_enable_push(self, enable: bool) -> Builder

pub fn set_enable_push(&mut self, enable: bool) -> &mut Builder

pub fn with_enable_connect_protocol(self, value: u32) -> Builder

pub fn set_enable_connect_protocol(&mut self, value: u32) -> &mut Builder

pub fn with_no_rfc7540_priorities(self, value: u32) -> Builder

pub fn set_no_rfc7540_priorities(&mut self, value: u32) -> &mut Builder

pub fn with_setting_order(self, order: SettingOrder) -> Builder

pub fn set_setting_order(&mut self, order: SettingOrder) -> &mut Builder

pub fn with_headers_pseudo_order(self, order: PseudoHeaderOrder) -> Builder

pub fn set_headers_pseudo_order( &mut self, order: PseudoHeaderOrder, ) -> &mut Builder

pub fn with_early_frames(self, frames: Vec<EarlyFrame>) -> Builder

pub fn set_early_frames(&mut self, frames: Vec<EarlyFrame>) -> &mut Builder

pub fn handshake<T, B>( &self, io: T, ) -> impl Future<Output = Result<(SendRequest<B>, Connection<T, B>), Error>>

where T: AsyncRead + AsyncWrite + Send + Unpin + ExtensionsMut + 'static, B: Body + Send + 'static + Unpin, <B as Body>::Data: Send + 'static, <B as Body>::Error: Into<Box<dyn Error + Send + Sync>>,

Constructs a connection with the configured options and IO. See client::conn for more.

Note, if Connection is not await-ed, SendRequest will do nothing.

Trait Implementations

impl Clone for Builder

fn clone(&self) -> Builder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Builder

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

Formats the value using the given formatter.