Skip to content

Commit d16d167

Browse files
committed
fix: bugfix on rc16
1 parent 41517a2 commit d16d167

3 files changed

Lines changed: 9 additions & 1 deletion

File tree

internal/monetizeapi/types.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -64,6 +64,7 @@ var (
6464
NamespaceGVR = schema.GroupVersionResource{Group: "", Version: "v1", Resource: "namespaces"}
6565
ServiceAccountGVR = schema.GroupVersionResource{Group: "", Version: "v1", Resource: "serviceaccounts"}
6666
PVCGVR = schema.GroupVersionResource{Group: "", Version: "v1", Resource: "persistentvolumeclaims"}
67+
NetworkPolicyGVR = schema.GroupVersionResource{Group: "networking.k8s.io", Version: "v1", Resource: "networkpolicies"}
6768
)
6869

6970
// ── ServiceOffer ────────────────────────────────────────────────────────────

internal/serviceoffercontroller/agent.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -522,6 +522,8 @@ func (c *Controller) resourceFor(u *unstructured.Unstructured) dynamic.ResourceI
522522
return c.client.Resource(monetizeapi.PVCGVR).Namespace(u.GetNamespace())
523523
case "Deployment":
524524
return c.deployments.Namespace(u.GetNamespace())
525+
case "NetworkPolicy":
526+
return c.client.Resource(monetizeapi.NetworkPolicyGVR).Namespace(u.GetNamespace())
525527
default:
526528
// Unknown kinds shouldn't reach this path — agentManifests is
527529
// closed-set. Fall through to a sensible default so the eventual

internal/serviceoffercontroller/agent_test.go

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -202,6 +202,7 @@ func TestReconcileAgent_HappyPath_ProvisionsAndPins(t *testing.T) {
202202
{"secrets", "agent-quant", "hermes-api-server"},
203203
{"deployments", "agent-quant", "hermes"},
204204
{"services", "agent-quant", "hermes"},
205+
{"networkpolicies", "agent-quant", "agent-isolation"},
205206
} {
206207
if !resourceExists(t, c, kind.gvr, kind.ns, kind.name) {
207208
t.Errorf("%s/%s/%s not applied", kind.gvr, kind.ns, kind.name)
@@ -426,6 +427,7 @@ func newProvisioningTestController(t *testing.T, agent *monetizeapi.Agent, seedO
426427
monetizeapi.SecretGVR: "SecretList",
427428
monetizeapi.DeploymentGVR: "DeploymentList",
428429
monetizeapi.ServiceGVR: "ServiceList",
430+
monetizeapi.NetworkPolicyGVR: "NetworkPolicyList",
429431
},
430432
objects...,
431433
)
@@ -469,8 +471,11 @@ func litellmSecretObject(t *testing.T, masterKey string) *unstructured.Unstructu
469471
func resourceExists(t *testing.T, c *Controller, resource, namespace, name string) bool {
470472
t.Helper()
471473
gvr := schema.GroupVersionResource{Group: "", Version: "v1", Resource: resource}
472-
if resource == "deployments" {
474+
switch resource {
475+
case "deployments":
473476
gvr = schema.GroupVersionResource{Group: "apps", Version: "v1", Resource: resource}
477+
case "networkpolicies":
478+
gvr = schema.GroupVersionResource{Group: "networking.k8s.io", Version: "v1", Resource: resource}
474479
}
475480
dyn := c.dynClient.Resource(gvr)
476481
if namespace != "" {

0 commit comments

Comments
 (0)