arch/dref
1
0
Fork 0
Code Issues 3 Pull requests Actions Packages Activity

Support for insecure registries

Browse source 
I personally run my registry in the same Kubernetes cluster as my dref
deployment so it makes sense to have them talk directly.
This commit is contained in:
Gabriel Simmer 2022-12-13 09:17:46 +00:00
parent 782e19e49a
commit 527d6f8fbf
Signed by: arch
GPG key ID: C81B106D46C5B875
1 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/main.rs
View file

@ -89,8 +89,9 @@ async fn root() -> Markup {
async fn get_images() -> Result<Vec<Image>, boxed::Box<dyn error::Error>> { async fn get_images() -> Result<Vec<Image>, boxed::Box<dyn error::Error>> {
let host = env::var("DREF_REGISTRY").unwrap(); let host = env::var("DREF_REGISTRY").unwrap();
let insecure_registry = env::var("DREF_REGISTRY_USE_SSL").unwrap() == "false";
let dclient = Client::configure() let dclient = Client::configure()
.insecure_registry(false) .insecure_registry(insecure_registry)
.registry(&host) .registry(&host)
.build()?; .build()?;
let catalog = dclient.get_catalog(None).collect::<Vec<_>>().await let catalog = dclient.get_catalog(None).collect::<Vec<_>>().await
@ -104,8 +105,9 @@ async fn get_images() -> Result<Vec<Image>, boxed::Box<dyn error::Error>> {
async fn get_tags(image: String) -> Result<Vec<Tag>, boxed::Box<dyn error::Error>> { async fn get_tags(image: String) -> Result<Vec<Tag>, boxed::Box<dyn error::Error>> {
let host = env::var("DREF_REGISTRY").unwrap(); let host = env::var("DREF_REGISTRY").unwrap();
let insecure_registry = env::var("DREF_REGISTRY_USE_SSL").unwrap() == "false";
let dclient = Client::configure() let dclient = Client::configure()
.insecure_registry(false) .insecure_registry(insecure_registry)
.registry(&host) .registry(&host)
.build()?; .build()?;
let tags = dclient.get_tags(image.as_str(), None).collect::<Vec<_>>().await let tags = dclient.get_tags(image.as_str(), None).collect::<Vec<_>>().await
@ -116,9 +118,10 @@ async fn get_tags(image: String) -> Result<Vec<Tag>, boxed::Box<dyn error::Error
} }
async fn get_platforms(image: &String, tag: String) -> Result<Vec<String>, boxed::Box<dyn error::Error>> { async fn get_platforms(image: &String, tag: String) -> Result<Vec<String>, boxed::Box<dyn error::Error>> {
let host = env::var("DREF_REGISTRY").unwrap(); let host = env::var("DREF_REGISTRY").unwrap();
let insecure_registry = env::var("DREF_REGISTRY_USE_SSL").unwrap() == "false";
let dclient = Client::configure() let dclient = Client::configure()
.insecure_registry(false) .insecure_registry(insecure_registry)
.registry(&host) .registry(&host)
.build()?; .build()?;
let manifest = dclient.get_manifest(image.as_str(), tag.as_str()).await.unwrap(); let manifest = dclient.get_manifest(image.as_str(), tag.as_str()).await.unwrap();