Skip to content

Commit 4d7738a

Browse files
authored
minor changes in few places (kubernetes-sigs#702)
* minor changes in few places Signed-off-by: Nir Rozenbaum <[email protected]> * removed empty labels field Signed-off-by: Nir Rozenbaum <[email protected]> --------- Signed-off-by: Nir Rozenbaum <[email protected]>
1 parent 944d63c commit 4d7738a

File tree

6 files changed

+11
-14
lines changed

6 files changed

+11
-14
lines changed

config/manifests/inferencepool-resources.yaml

+2-1
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@
44
apiVersion: inference.networking.x-k8s.io/v1alpha2
55
kind: InferencePool
66
metadata:
7-
labels:
87
name: vllm-llama3-8b-instruct
98
spec:
109
targetPortNumber: 8000
@@ -54,6 +53,8 @@ spec:
5453
args:
5554
- -poolName
5655
- "vllm-llama3-8b-instruct"
56+
- "-poolNamespace"
57+
- "default"
5758
- -v
5859
- "4"
5960
- --zap-encoder

pkg/epp/controller/inferencepool_reconciler.go

+2-4
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@ import (
2121
"reflect"
2222

2323
"k8s.io/apimachinery/pkg/api/errors"
24-
"k8s.io/apimachinery/pkg/types"
2524
"k8s.io/client-go/tools/record"
2625
ctrl "sigs.k8s.io/controller-runtime"
2726
"sigs.k8s.io/controller-runtime/pkg/client"
@@ -36,9 +35,8 @@ import (
3635
// will have the proper controller that will create/manage objects on behalf of the server pool.
3736
type InferencePoolReconciler struct {
3837
client.Client
39-
Record record.EventRecorder
40-
PoolNamespacedName types.NamespacedName
41-
Datastore datastore.Datastore
38+
Record record.EventRecorder
39+
Datastore datastore.Datastore
4240
}
4341

4442
func (c *InferencePoolReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {

pkg/epp/controller/inferencepool_reconciler_test.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ func TestInferencePoolReconciler(t *testing.T) {
9696

9797
pmf := backendmetrics.NewPodMetricsFactory(&backendmetrics.FakePodMetricsClient{}, time.Second)
9898
datastore := datastore.NewDatastore(ctx, pmf)
99-
inferencePoolReconciler := &InferencePoolReconciler{PoolNamespacedName: namespacedName, Client: fakeClient, Datastore: datastore}
99+
inferencePoolReconciler := &InferencePoolReconciler{Client: fakeClient, Datastore: datastore}
100100

101101
// Step 1: Inception, only ready pods matching pool1 are added to the store.
102102
if _, err := inferencePoolReconciler.Reconcile(ctx, req); err != nil {

pkg/epp/server/controller_manager.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -39,8 +39,8 @@ func init() {
3939
utilruntime.Must(v1alpha2.Install(scheme))
4040
}
4141

42-
// DefaultManagerOptions returns the default options used to create the manager.
43-
func DefaultManagerOptions(namespace, name string) ctrl.Options {
42+
// defaultManagerOptions returns the default options used to create the manager.
43+
func defaultManagerOptions(namespace string, name string) ctrl.Options {
4444
return ctrl.Options{
4545
Scheme: scheme,
4646
Cache: cache.Options{
@@ -71,7 +71,7 @@ func DefaultManagerOptions(namespace, name string) ctrl.Options {
7171

7272
// NewDefaultManager creates a new controller manager with default configuration.
7373
func NewDefaultManager(namespace, name string, restConfig *rest.Config) (ctrl.Manager, error) {
74-
manager, err := ctrl.NewManager(restConfig, DefaultManagerOptions(namespace, name))
74+
manager, err := ctrl.NewManager(restConfig, defaultManagerOptions(namespace, name))
7575
if err != nil {
7676
return nil, fmt.Errorf("failed to create controller manager: %v", err)
7777
}

pkg/epp/server/runserver.go

+1-5
Original file line numberDiff line numberDiff line change
@@ -87,11 +87,7 @@ func (r *ExtProcServerRunner) SetupWithManager(ctx context.Context, mgr ctrl.Man
8787
if err := (&controller.InferencePoolReconciler{
8888
Datastore: r.Datastore,
8989
Client: mgr.GetClient(),
90-
PoolNamespacedName: types.NamespacedName{
91-
Name: r.PoolName,
92-
Namespace: r.PoolNamespace,
93-
},
94-
Record: mgr.GetEventRecorderFor("InferencePool"),
90+
Record: mgr.GetEventRecorderFor("InferencePool"),
9591
}).SetupWithManager(mgr); err != nil {
9692
return fmt.Errorf("failed setting up InferencePoolReconciler: %w", err)
9793
}

site-src/implementations/gateways.md

+2
Original file line numberDiff line numberDiff line change
@@ -5,10 +5,12 @@ This project has several implementations that are planned or in progress:
55
* [Envoy AI Gateway][1]
66
* [Kgateway][2]
77
* [Google Kubernetes Engine][3]
8+
* [Istio][4]
89

910
[1]:#envoy-gateway
1011
[2]:#kgateway
1112
[3]:#google-kubernetes-engine
13+
[4]:#istio
1214

1315
## Envoy AI Gateway
1416

0 commit comments

Comments
 (0)