A11 (C++ runtime)
Native C++ implementation of the A11 streaming action runtime
Loading...
Searching...
No Matches
a11::net::HttpSseClientWireStream::ClientState Struct Referenceabstract

Public Member Functions

 ClientState (ParsedUrl value_url, std::string value_connect_path, std::string value_message_endpoint, std::shared_ptr< Http2Client > value_client)
 
std::shared_ptr< Http2Client > client ABSL_GUARDED_BY (mu)
 
std::shared_ptr< Http2ResponseStream > response ABSL_GUARDED_BY (mu)
 
SseOutboundDelivery outbound ABSL_GUARDED_BY (mu)
 The delivery method in force, which is the requested one unless a kStream request met a server that does not advertise it.
 
std::shared_ptr< Http2DuplexStream > upload ABSL_GUARDED_BY (mu)
 The streamed outbound request body, and the connection opened for it when the connect connection could not carry a second request (HTTP/1.1).
 
std::shared_ptr< Http2Client > upload_client ABSL_GUARDED_BY (mu)
 
bool upload_finished ABSL_GUARDED_BY (mu)
 
size_t posts_in_flight ABSL_GUARDED_BY (mu)=0
 Outbound POSTs handed over and not yet answered, and the maximum.
 
size_t max_posts_in_flight ABSL_GUARDED_BY (mu)
 

Public Attributes

thread::Mutex mu
 
const ParsedUrl url
 
const std::string connect_path
 
const std::string message_endpoint
 
thread::CondVar posts_changed
 

Constructor & Destructor Documentation

◆ ClientState()

a11::net::HttpSseClientWireStream::ClientState::ClientState ( ParsedUrl  value_url,
std::string  value_connect_path,
std::string  value_message_endpoint,
std::shared_ptr< Http2Client >  value_client 
)
inline

Member Function Documentation

◆ ABSL_GUARDED_BY() [1/8]

std::shared_ptr< Http2Client > client a11::net::HttpSseClientWireStream::ClientState::ABSL_GUARDED_BY ( mu  )

◆ ABSL_GUARDED_BY() [2/8]

std::shared_ptr< Http2ResponseStream > response a11::net::HttpSseClientWireStream::ClientState::ABSL_GUARDED_BY ( mu  )

◆ ABSL_GUARDED_BY() [3/8]

SseOutboundDelivery outbound a11::net::HttpSseClientWireStream::ClientState::ABSL_GUARDED_BY ( mu  )

The delivery method in force, which is the requested one unless a kStream request met a server that does not advertise it.

◆ ABSL_GUARDED_BY() [4/8]

std::shared_ptr< Http2DuplexStream > upload a11::net::HttpSseClientWireStream::ClientState::ABSL_GUARDED_BY ( mu  )

The streamed outbound request body, and the connection opened for it when the connect connection could not carry a second request (HTTP/1.1).

◆ ABSL_GUARDED_BY() [5/8]

std::shared_ptr< Http2Client > upload_client a11::net::HttpSseClientWireStream::ClientState::ABSL_GUARDED_BY ( mu  )

◆ ABSL_GUARDED_BY() [6/8]

bool upload_finished a11::net::HttpSseClientWireStream::ClientState::ABSL_GUARDED_BY ( mu  )

◆ ABSL_GUARDED_BY() [7/8]

size_t max_posts_in_flight a11::net::HttpSseClientWireStream::ClientState::ABSL_GUARDED_BY ( mu  )

◆ ABSL_GUARDED_BY() [8/8]

size_t posts_in_flight a11::net::HttpSseClientWireStream::ClientState::ABSL_GUARDED_BY ( mu  )
pure virtual

Outbound POSTs handed over and not yet answered, and the maximum.

Member Data Documentation

◆ connect_path

const std::string a11::net::HttpSseClientWireStream::ClientState::connect_path

◆ message_endpoint

const std::string a11::net::HttpSseClientWireStream::ClientState::message_endpoint

◆ mu

thread::Mutex a11::net::HttpSseClientWireStream::ClientState::mu
mutable

◆ posts_changed

thread::CondVar a11::net::HttpSseClientWireStream::ClientState::posts_changed

◆ url

const ParsedUrl a11::net::HttpSseClientWireStream::ClientState::url

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