Struct StatelessHttpConnection 

pub struct StatelessHttpConnection<C: HttpClient> { /* private fields */ }

A live smart-HTTP connection backed by HttpClient stateless RPC.

A receive-pack request body larger than Git’s default http.postBuffer (1 MiB) is not held in memory: after a small probe request settles authentication, it streams to the server through HttpClient::post_streaming while the caller is still writing it.

Implementations

impl<C: HttpClient + 'static> StatelessHttpConnection<C>

pub fn new( client: C, service: Service, repo_url: String, protocol_version: u8, adv_refs: Vec<(String, ObjectId)>, caps: Vec<String>, head_symref: Option<String>, object_format: String, git_protocol: Option<String>, ) -> Self

Build a connection after info/refs discovery.

pub fn repo_url(&self) -> &str

Repository URL used for subsequent POSTs.

pub fn object_format(&self) -> &str

The server’s advertised object format (sha1 or sha256).

Trait Implementations

impl<C: HttpClient + 'static> Connection for StatelessHttpConnection<C>

fn reader(&mut self) -> &mut dyn Read

The readable half of the pkt-line stream (server -> client).

fn writer(&mut self) -> &mut dyn Write

The writable half of the pkt-line stream (client -> server).

fn advertised_refs(&self) -> &[(String, ObjectId)]

The refs the server advertised on connect (excluding HEAD, the capabilities^{} carrier, and peeled ^{} lines). Empty for a protocol v2 connection, whose refs are obtained later via ls-refs.

fn capabilities(&self) -> &[String]

The capability tokens advertised by the server (from the first ref line in v0/v1, or the v2 capability block).

fn head_symref(&self) -> Option<&str>

The target of the server’s HEAD symref (e.g. refs/heads/main), if it advertised one.

fn protocol_version(&self) -> u8

The negotiated protocol version (0, 1, or 2).

fn stateless_rpc(&self) -> bool

Smart HTTP stateless RPC (gitprotocol-http): each POST carries a full command body rather than appending to one duplex stream.

fn finish_send(&mut self)

Half-close the write side of the stream, signalling end-of-input to the server (the wire equivalent of the CLI’s drop(stdin)).

fn wait_for_response(&mut self, cancel: &dyn Cancel) -> Result<()>

Send whatever request is still buffered and wait until the server’s response can be read from Self::reader, giving up once cancel fires.

fn advertised_tag_peel(&self) -> Option<&HashMap<String, ObjectId>>

Peeled object ids for annotated tags from the v0/v1 ref advertisement (refs/tags/name → commit oid), when captured on connect.

fn finish(&mut self) -> Result<()>

End the session and report how the server side ended, for transports whose server runs in this process.

impl<C: HttpClient + 'static> Write for StatelessHttpConnection<C>

fn write(&mut self, buf: &[u8]) -> Result<usize>

Writes a buffer into this writer, returning how many bytes were written.

fn flush(&mut self) -> Result<()>

Flushes this output stream, ensuring that all intermediately buffered contents reach their destination.

fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> Result<usize, Error>

Like write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

🔬This is a nightly-only experimental API. (can_vector)

Determines if this Writer has an efficient write_vectored implementation.

fn write_all(&mut self, buf: &[u8]) -> Result<(), Error>

Attempts to write an entire buffer into this writer.

fn write_all_vectored(&mut self, bufs: &mut [IoSlice<'_>]) -> Result<(), Error>

🔬This is a nightly-only experimental API. (write_all_vectored)

Attempts to write multiple buffers into this writer.

fn write_fmt(&mut self, args: Arguments<'_>) -> Result<(), Error>

Writes a formatted string into this writer, returning any error encountered.

fn by_ref(&mut self) -> &mut Self

where Self: Sized,

Creates a “by reference” adapter for this instance of Write.