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 const fn new(cache: Arc<HttpCache>) -> GoRegistry

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

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

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, GoError>

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, GoError>

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, GoError>

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<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Box<dyn Version>>, DepsError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, GoRegistry: 'async_trait,

Fetches all available versions for a package.

fn get_latest_matching<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, name: &'life1 str, _req: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Box<dyn Version>>, DepsError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, GoRegistry: 'async_trait,

Finds the latest version matching a version requirement.

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

where 'life0: 'async_trait, 'life1: 'async_trait, GoRegistry: 'async_trait,

Searches for packages by name or keywords.

fn package_url(&self, name: &str) -> String

Package URL for ecosystem (e.g., https://crates.io/crates/serde)

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

Downcast to concrete registry type for ecosystem-specific operations