Skip to content

Commit

Permalink
fix createIngress conditions
Browse files Browse the repository at this point in the history
  • Loading branch information
cw-sakamoto committed Nov 24, 2023
1 parent e030d1b commit 86cec22
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion cmd/ingress/ingressCheck.go
Original file line number Diff line number Diff line change
Expand Up @@ -134,7 +134,7 @@ func (i *Ingress) createResources() error {
i.Chatwork.AddMessage(fmt.Sprintf("Error Create Service: %s", err))
return err
}
if err := k.CreateIngress(i.createIngressObject(), i.NoDnsCheck); err != nil {
if err := k.CreateIngress(i.createIngressObject()); err != nil {
i.Chatwork.AddMessage(fmt.Sprintf("Error Create Ingress: %s", err))
return err
}
Expand Down
4 changes: 2 additions & 2 deletions util/k8s/resources.go
Original file line number Diff line number Diff line change
Expand Up @@ -151,7 +151,7 @@ func (k *K8s) DeleteService(serviceName string) error {
return nil
}

func (k *K8s) CreateIngress(ingress *networkingv1.Ingress, NoAddressCheck bool) error {
func (k *K8s) CreateIngress(ingress *networkingv1.Ingress) error {
ingressClient := k.clientset.NetworkingV1().Ingresses(k.namespace)

k.logger().Infof("Creating ingress: %s", ingress.Name)
Expand All @@ -168,7 +168,7 @@ func (k *K8s) CreateIngress(ingress *networkingv1.Ingress, NoAddressCheck bool)
return err
}

if !NoAddressCheck {
if *ingress.Spec.IngressClassName == "alb" {
err = wait.PollUntilContextTimeout(context.Background(), 5*time.Second, 5*time.Minute, false, func(ctx context.Context) (bool, error) {
ingress, err := ingressClient.Get(ctx, ingress.Name, metav1.GetOptions{})
if err != nil {
Expand Down

0 comments on commit 86cec22

Please sign in to comment.