Skip to content

Commit 8a15e21

Browse files
committed
Iter
1 parent 18955c3 commit 8a15e21

File tree

3 files changed

+22
-5
lines changed

3 files changed

+22
-5
lines changed

CHANGELOG.md

+1
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
## [master](https://github.com/arangodb/kube-arangodb/tree/master) (N/A)
44
- (Bugfix) Use Profile Annotations
55
- (Bugfix) Improve Wait Procedure on AF
6+
- (Feature) (Platform) Generate GRPC Gateway Code
67

78
## [1.2.46](https://github.com/arangodb/kube-arangodb/tree/1.2.46) (2025-02-24)
89
- (Bugfix) Clean Phase change properly during upgrade

pkg/util/errors/errors.go

+17
Original file line numberDiff line numberDiff line change
@@ -98,6 +98,23 @@ func WithMessagef(err error, format string, args ...interface{}) error {
9898
return errors.WithMessagef(err, format, args...)
9999
}
100100

101+
func AnyOf(err error, targets ...error) bool {
102+
if err == nil {
103+
return false
104+
}
105+
for _, target := range targets {
106+
if target == nil {
107+
continue
108+
}
109+
110+
if Is(err, target) {
111+
return true
112+
}
113+
}
114+
115+
return false
116+
}
117+
101118
func Is(err, target error) bool { return errors.Is(err, target) }
102119

103120
func As(err error, target interface{}) bool { return errors.As(err, target) }

pkg/util/svc/starter.go

+4-5
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@ import (
2424
"context"
2525
"fmt"
2626
"net"
27+
goHttp "net/http"
2728
"sync"
2829
"time"
2930

@@ -86,7 +87,7 @@ func (s *serviceStarter) runE(ctx context.Context, health Health, ln, http net.L
8687
s.service.server.GracefulStop()
8788
}()
8889

89-
if err := s.service.server.Serve(ln); err != nil && !errors.Is(err, grpc.ErrServerStopped) {
90+
if err := s.service.server.Serve(ln); !errors.AnyOf(err, grpc.ErrServerStopped) {
9091
serveError = err
9192
}
9293
}()
@@ -107,10 +108,8 @@ func (s *serviceStarter) runE(ctx context.Context, health Health, ln, http net.L
107108
s.service.http.Close()
108109
}()
109110

110-
if err := s.service.http.Serve(http); err != nil {
111-
if !errors.Is(err, grpc.ErrServerStopped) {
112-
serveError = err
113-
}
111+
if err := s.service.http.Serve(http); !errors.AnyOf(err, goHttp.ErrServerClosed) {
112+
serveError = err
114113
}
115114
}()
116115

0 commit comments

Comments
 (0)