@@ -19,13 +19,15 @@ package e2e
19
19
import (
20
20
"testing"
21
21
22
+ "github.com/onsi/gomega"
22
23
. "github.com/onsi/gomega"
23
24
. "github.com/project-codeflare/codeflare-common/support"
24
25
mcadv1beta1 "github.com/project-codeflare/multi-cluster-app-dispatcher/pkg/apis/controller/v1beta1"
25
26
rayv1 "github.com/ray-project/kuberay/ray-operator/apis/ray/v1"
26
27
27
28
batchv1 "k8s.io/api/batch/v1"
28
29
corev1 "k8s.io/api/core/v1"
30
+ networkingv1 "k8s.io/api/networking/v1"
29
31
rbacv1 "k8s.io/api/rbac/v1"
30
32
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
31
33
)
@@ -138,6 +140,43 @@ func TestMNISTRayClusterSDK(t *testing.T) {
138
140
_ , err = test .Client ().Core ().RbacV1 ().RoleBindings (namespace .Name ).Create (test .Ctx (), roleBinding , metav1.CreateOptions {})
139
141
test .Expect (err ).NotTo (HaveOccurred ())
140
142
143
+ ingress := & networkingv1.Ingress {
144
+ ObjectMeta : metav1.ObjectMeta {
145
+ Name : "ray-ingress" ,
146
+ Namespace : namespace .Name ,
147
+ },
148
+ Spec : networkingv1.IngressSpec {
149
+ Rules : []networkingv1.IngressRule {
150
+ {
151
+ Host : "ray-dashboard-mnist-test.com" ,
152
+ IngressRuleValue : networkingv1.IngressRuleValue {
153
+ HTTP : & networkingv1.HTTPIngressRuleValue {
154
+ Paths : []networkingv1.HTTPIngressPath {
155
+ {
156
+ PathType : func (s networkingv1.PathType ) * networkingv1.PathType { return & s }(networkingv1 .PathTypePrefix ),
157
+ Path : "/" ,
158
+ Backend : networkingv1.IngressBackend {
159
+ Service : & networkingv1.IngressServiceBackend {
160
+ Name : "raycluster-head-svc" ,
161
+ Port : networkingv1.ServiceBackendPort {
162
+ Number : 80 ,
163
+ },
164
+ },
165
+ },
166
+ },
167
+ },
168
+ },
169
+ },
170
+ },
171
+ },
172
+ },
173
+ }
174
+
175
+ // Create the Ingress
176
+ createdIngress , err := test .Client ().Core ().NetworkingV1 ().Ingresses (namespace .Name ).Create (test .Ctx (), ingress , metav1.CreateOptions {})
177
+ test .Expect (err ).NotTo (gomega .HaveOccurred ())
178
+ test .T ().Logf ("Created Ingress %s/%s successfully" , createdIngress .Namespace , createdIngress .Name )
179
+
141
180
job := & batchv1.Job {
142
181
TypeMeta : metav1.TypeMeta {
143
182
APIVersion : batchv1 .SchemeGroupVersion .String (),
0 commit comments