Struct WireTransport 

pub struct WireTransport { /* private fields */ }

gunnar-wire, wired to the SSH listener.

Implementations

impl WireTransport

pub fn new(stores: Arc<ServerStores>) -> Self

Serve repositories out of stores.

pub fn with_wire_config(self, wire: WireConfig) -> Self

Serve under wire rather than gunnar-wire’s defaults.

The whole of what makes WireConfig reachable. Without a call to this, every knob on it is a comment.

pub fn with_metrics(self, metrics: Arc<ServerMetrics>) -> Self

Count into the server’s counters rather than into a private set.

gunnar serve mints one ServerMetrics and hands the same Arc here and to the SSH listener, so connections_refused and pushes_rejected are two readings of one server. A transport built without this still counts, into a set only it can see, which is what a unit test wants.

pub fn with_bus(self, bus: Arc<EventBus>) -> Self

Publish RefUpdated / RefDeleted / PushRejected / PushAttestation to the event bus.

The bus is optional; the attestation log is not. A server started with --no-grpc has nobody to notify, but the attestation’s durable record is not a notification. It is the thing the event stream explicitly does not promise to keep (see EventBus::publish), so the log is written either way and only the publish is conditional.

pub fn attestation_log(&self) -> &AttestationLog

Where the attestation’s JSON lines land.

Trait Implementations

impl GitTransport for WireTransport

fn serve<'a>( &'a self, request: ServiceRequest, stream: Box<dyn DuplexStream>, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'a>>

Serve one request to completion.

impl LfsTransport for WireTransport

The LFS object store, opened the one way — for the SSH session and for the HTTP batch API alike (one implementation).

The two surfaces used to be one call apart from having two answers to where does this repository keep its LFS objects: serve_blocking reached for stores.repo_store(...).git_dir() and anything else would have had to re-derive it. It is <git_dir>/lfs/, the symlink check in ServerStores::repo_dir is not optional on either path, and the handle the store lock lives on is the same handle, so a repack and an LFS transfer exclude each other the same way on both transports.

fn open_lfs( &self, request: &ServiceRequest, ) -> Result<LfsAccess, TransportError>

The object store for request’s repository.