From 8b30620a2f21523f9afa48827eb1a0c44917397b Mon Sep 17 00:00:00 2001 From: Joonas Bergius Date: Wed, 24 Apr 2024 19:48:25 -0500 Subject: [PATCH] Add conditions to Endpoints part of the EndpointSlices reflecting wadm application Service entries --- src/services.rs | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/services.rs b/src/services.rs index 441e41a..4cafd0b 100644 --- a/src/services.rs +++ b/src/services.rs @@ -15,7 +15,7 @@ use async_nats::{ use cloudevents::{AttributesReader, Event as CloudEvent}; use futures::StreamExt; use k8s_openapi::api::core::v1::{Pod, Service, ServicePort, ServiceSpec}; -use k8s_openapi::api::discovery::v1::{Endpoint, EndpointPort, EndpointSlice}; +use k8s_openapi::api::discovery::v1::{Endpoint, EndpointConditions, EndpointPort, EndpointSlice}; use k8s_openapi::apimachinery::pkg::apis::meta::v1::OwnerReference; use kube::{ api::{Api, DeleteParams, ListParams, Patch, PatchParams}, @@ -522,6 +522,11 @@ pub async fn create_or_update_service( .filter_map(|ip| { ip.ip.as_ref().map(|i| Endpoint { addresses: vec![i.clone()], + conditions: Some(EndpointConditions { + ready: Some(true), + serving: Some(true), + terminating: None, + }), hostname: None, target_ref: None, ..Default::default()