Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

feat: GRPC health #1690

Merged
merged 11 commits into from
Sep 12, 2024
Merged

feat: GRPC health #1690

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
1769d61
grpc_health_v1
amitza Aug 21, 2024
f78b856
consumer health server
amitza Sep 9, 2024
b4fc5ed
Merge remote-tracking branch 'origin/main' into feat/grpc-healthchecks
amitza Sep 11, 2024
27dbd87
Merge remote-tracking branch 'origin/main' into feat/grpc-healthchecks
amitza Sep 11, 2024
659b341
a test commit, can be reverted if nessesary
amitza Sep 11, 2024
6fe2116
rm toolchain
amitza Sep 11, 2024
75bc608
testify
amitza Sep 11, 2024
9086a5c
Revert "grpc_health_v1"
amitza Sep 12, 2024
70753b2
Reapply "grpc_health_v1"
amitza Sep 12, 2024
0529c6f
Revert "a test commit, can be reverted if nessesary"
amitza Sep 12, 2024
2e16857
remove health for provider
amitza Sep 12, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions protocol/chainlib/grpcproxy/grpcproxy.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,8 @@ import (
"golang.org/x/net/http2/h2c"
"google.golang.org/grpc"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/health"
"google.golang.org/grpc/health/grpc_health_v1"
"google.golang.org/grpc/metadata"
"google.golang.org/grpc/status"
)
Expand All @@ -28,6 +30,7 @@ type HealthReporter interface {
func NewGRPCProxy(cb ProxyCallBack, healthCheckPath string, cmdFlags common.ConsumerCmdFlags, healthReporter HealthReporter) (*grpc.Server, *http.Server, error) {
serverReceiveMaxMessageSize := grpc.MaxRecvMsgSize(MaxCallRecvMsgSize) // setting receive size to 32mb instead of 4mb default
s := grpc.NewServer(grpc.UnknownServiceHandler(makeProxyFunc(cb)), grpc.ForceServerCodec(RawBytesCodec{}), serverReceiveMaxMessageSize)
grpc_health_v1.RegisterHealthServer(s, health.NewServer())
wrappedServer := grpcweb.WrapServer(s)
handler := func(resp http.ResponseWriter, req *http.Request) {
// Set CORS headers
Expand Down
1 change: 0 additions & 1 deletion protocol/rpcprovider/provider_listener.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,6 @@ func NewProviderListener(ctx context.Context, networkAddress lavasession.Network
grpc.MaxRecvMsgSize(1024 * 1024 * 32), // setting receive size to 32mb instead of 4mb default
}
grpcServer := grpc.NewServer(opts...)

wrappedServer := grpcweb.WrapServer(grpcServer)
handler := func(resp http.ResponseWriter, req *http.Request) {
// Set CORS headers
Expand Down
Loading