Struct GoRegistry 

pub struct GoRegistry { /* private fields */ }

Client for interacting with proxy.golang.org.

Uses the Go module proxy protocol for version lookups and metadata. All requests are cached via the provided HttpCache.

Implementations

impl GoRegistry

pub fn new(cache: Arc<HttpCache>) -> GoRegistry

Creates a new Go registry client with the given HTTP cache.

pub fn register_chain(root: &Arc<GoRegistry>, chain: &GoProxyChain)

Builds the full hop chain for one GoProxyChain and inserts the head into root.alternates under chain.key. Idempotent per key (a repeat registration for the same key is a no-op), capacity-capped at MAX_ALTERNATE_REGISTRIES. Mirrors deps_pypi::PypiRegistry::register_chain exactly in shape.

pub fn alternate_client(&self, index: &str) -> Option<Arc<GoRegistry>>

The registered client for index (a GoProxyChain::key or crate::config::GOPRIVATE_CHAIN_KEY), if any — read-only, performs no registration, no validation.

Only ever meaningful on the root: a chain-hop leaf’s own alternates map is always empty by construction (Self::with_base/Self::terminal never populate it).

pub async fn get_versions( &self, module_path: &str, ) -> Result<Vec<GoVersion>, DepsError>

Fetches all versions for a module from the /@v/list endpoint.

Returns versions in registry order (not sorted). Includes pseudo-versions.

Errors

Returns an error if:

• HTTP request fails
• Response body is invalid UTF-8
• Module does not exist (404)
• Module path is invalid or too long

Examples

let cache = Arc::new(HttpCache::new());
let registry = GoRegistry::new(cache);

let versions = registry.get_versions("github.com/gin-gonic/gin").await.unwrap();
assert!(!versions.is_empty());

pub async fn get_version_info( &self, module_path: &str, version: &str, ) -> Result<GoVersion, DepsError>

Fetches version metadata from the /@v/{version}.info endpoint.

Returns version with timestamp information.

Errors

Returns an error if:

• HTTP request fails
• JSON parsing fails
• Module path or version string is invalid

Examples

let cache = Arc::new(HttpCache::new());
let registry = GoRegistry::new(cache);

let info = registry.get_version_info("github.com/gin-gonic/gin", "v1.9.1").await.unwrap();
assert_eq!(info.version, "v1.9.1");

pub async fn get_latest( &self, module_path: &str, ) -> Result<GoVersion, DepsError>

Fetches latest version using the /@latest endpoint.

Returns the latest stable version (non-pseudo).

Errors

Returns an error if:

• HTTP request fails
• JSON parsing fails
• Module path is invalid

Examples

let cache = Arc::new(HttpCache::new());
let registry = GoRegistry::new(cache);

let latest = registry.get_latest("github.com/gin-gonic/gin").await.unwrap();
assert!(!latest.is_pseudo);

pub async fn get_go_mod( &self, module_path: &str, version: &str, ) -> Result<String, DepsError>

Fetches the go.mod file for a specific version.

Returns the raw content of the go.mod file.

Errors

Returns an error if:

• HTTP request fails
• Response body is invalid UTF-8
• Module path or version string is invalid

Examples

let cache = Arc::new(HttpCache::new());
let registry = GoRegistry::new(cache);

let go_mod = registry.get_go_mod("github.com/gin-gonic/gin", "v1.9.1").await.unwrap();
assert!(go_mod.contains("module github.com/gin-gonic/gin"));

Trait Implementations

impl Clone for GoRegistry

fn clone(&self) -> GoRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Registry for GoRegistry

fn get_versions_from<'a>( &'a self, name: &'a PackageName, source: &'a DependencySource, freshness: FreshnessSettings, ) -> Pin<Box<dyn Future<Output = Result<Vec<Box<dyn Version>>, DepsError>> + Send + 'a>>

Dispatches by source (spec 034 FR-013): an AlternateRegistry whose index has a registered client routes through GoRegistry::get_versions_chained (FR-005’s chain walk); one with no registered client is PackageNotFound, never a fall back to proxy.golang.org (Go always sets mirrors_crates_io: false, so Cargo’s mirror-degradation arm is dead here and must not be written — falling back would send a private module path to the public proxy, the exact class of leak FR-008/FR-009 close). Every other source keeps today’s public-registry path unchanged.

fn get_latest_matching_from<'a>( &'a self, name: &'a PackageName, source: &'a DependencySource, req: &'a VersionReq, _minimum_stability: Option<&'a str>, ) -> Pin<Box<dyn Future<Output = Result<Option<Box<dyn Version>>, DepsError>> + Send + 'a>>

get_versions_from’s get_latest_matching-shaped counterpart — same dispatch, same “never fall back to proxy.golang.org for an unregistered AlternateRegistry” invariant. Derived from GoRegistry::get_versions_chained + deps_core::Registry::select_latest_matching (mirrors deps-pypi’s identical derivation) rather than an independent per-hop matching walk — the winning hop (first hop with a non-empty version list) is selected once, and matching happens only within that single hop’s list. No /@latest fast path for a chain hop (unlike the plain public-registry path below): phase 1 keeps this simple and correct rather than optimizing an extra request off the private-proxy path.

fn get_versions<'a>( &'a self, name: &'a PackageName, ) -> Pin<Box<dyn Future<Output = Result<Vec<Box<dyn Version>>, DepsError>> + Send + 'a>>

Fetches all available versions for a package.

fn get_latest_matching<'a>( &'a self, name: &'a PackageName, _req: &'a VersionReq, ) -> Pin<Box<dyn Future<Output = Result<Option<Box<dyn Version>>, DepsError>> + Send + 'a>>

Finds the latest version matching a version requirement.

fn search<'a>( &'a self, _query: &'a str, _limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Box<dyn Metadata>>, DepsError>> + Send + 'a>>

Searches for packages by name or keywords.

fn select_latest_matching( &self, versions: &[Box<dyn Version>], _req: &VersionReq, ) -> Option<usize>

Index of the latest version in versions satisfying req, with no I/O.

fn reports_yanked(&self) -> bool

Whether get_versions results carry meaningful per-version yank/deprecation data via Version::removal_status.

fn as_any(&self) -> &(dyn Any + 'static)

Downcast to concrete registry type for ecosystem-specific operations

fn get_versions_with<'a>( &'a self, name: &'a PackageName, freshness: FreshnessSettings, ) -> Pin<Box<dyn Future<Output = Result<Vec<Box<dyn Version>>, DepsError>> + Send + 'a>>

Like get_versions, but lets a registry that can obtain Version::published_at only through an extra request gate that request behind freshness.enabled instead of always paying for it.

fn get_latest_matching_with_context<'a>( &'a self, name: &'a PackageName, req: &'a VersionReq, minimum_stability: Option<&'a str>, ) -> Pin<Box<dyn Future<Output = Result<Option<Box<dyn Version>>, DepsError>> + Send + 'a>>

Like get_latest_matching, but lets a registry whose “latest matching” selection can be refined by ecosystem-specific manifest state (e.g. Composer’s minimum-stability field, #424) read it, alongside req.

fn select_latest_matching_with_context( &self, versions: &[Box<dyn Version>], req: &VersionReq, minimum_stability: Option<&str>, ) -> Option<usize>

Like select_latest_matching, but lets a registry whose selection can be refined by ecosystem-specific manifest state (e.g. Composer’s minimum-stability field, #424) read it, alongside versions and req. See get_latest_matching_with_context for why minimum_stability is an opaque per-ecosystem string rather than a shared type.