Skip to content

Commit 1b90a91

Browse files
committed
reduce diff
1 parent b342389 commit 1b90a91

9 files changed

Lines changed: 122 additions & 122 deletions

File tree

execution/grpc/client.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,8 +15,8 @@ import (
1515
"google.golang.org/protobuf/types/known/timestamppb"
1616

1717
"github.com/evstack/ev-node/core/execution"
18-
pb "github.com/evstack/ev-node/execution/grpc/types/pb"
19-
"github.com/evstack/ev-node/execution/grpc/types/pb/pbconnect"
18+
pb "github.com/evstack/ev-node/execution/grpc/types/pb/evnode/v1"
19+
"github.com/evstack/ev-node/execution/grpc/types/pb/evnode/v1/v1connect"
2020
)
2121

2222
// Ensure Client implements the execution.Executor interface
@@ -25,7 +25,7 @@ var _ execution.Executor = (*Client)(nil)
2525
// Client is a gRPC client that implements the execution.Executor interface.
2626
// It communicates with a remote execution service via gRPC using Connect-RPC.
2727
type Client struct {
28-
client pbconnect.ExecutorServiceClient
28+
client v1connect.ExecutorServiceClient
2929
}
3030

3131
const (
@@ -99,7 +99,7 @@ func NewClient(url string, opts ...connect.ClientOption) (*Client, error) {
9999
return nil, err
100100
}
101101
return &Client{
102-
client: pbconnect.NewExecutorServiceClient(
102+
client: v1connect.NewExecutorServiceClient(
103103
httpClient,
104104
targetURL,
105105
opts...,

execution/grpc/handler.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ import (
1010
"golang.org/x/net/http2/h2c"
1111

1212
"github.com/evstack/ev-node/core/execution"
13-
"github.com/evstack/ev-node/execution/grpc/types/pb/pbconnect"
13+
"github.com/evstack/ev-node/execution/grpc/types/pb/evnode/v1/v1connect"
1414
)
1515

1616
// NewExecutorServiceHandler creates a new HTTP handler for the ExecutorService.
@@ -33,13 +33,13 @@ func NewExecutorServiceHandler(executor execution.Executor, opts ...connect.Hand
3333

3434
// Set up gRPC reflection for debugging and discovery
3535
reflector := grpcreflect.NewStaticReflector(
36-
pbconnect.ExecutorServiceName,
36+
v1connect.ExecutorServiceName,
3737
)
3838
mux.Handle(grpcreflect.NewHandlerV1(reflector, compress1KB))
3939
mux.Handle(grpcreflect.NewHandlerV1Alpha(reflector, compress1KB))
4040

4141
// Register the ExecutorService
42-
path, handler := pbconnect.NewExecutorServiceHandler(server, append(opts, compress1KB)...)
42+
path, handler := v1connect.NewExecutorServiceHandler(server, append(opts, compress1KB)...)
4343
mux.Handle(path, handler)
4444

4545
// Use h2c to support HTTP/2 without TLS

execution/grpc/proto/execution.proto renamed to execution/grpc/proto/evnode/v1/execution.proto

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ package evnode.v1;
33

44
import "google/protobuf/timestamp.proto";
55

6-
option go_package = "github.com/evstack/ev-node/execution/grpc/types/pb";
6+
option go_package = "github.com/evstack/ev-node/execution/grpc/types/pb/evnode/v1";
77

88
// ExecutorService defines the execution layer interface for execution/grpc
99
service ExecutorService {

execution/grpc/server.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ import (
88
"connectrpc.com/connect"
99

1010
"github.com/evstack/ev-node/core/execution"
11-
pb "github.com/evstack/ev-node/execution/grpc/types/pb"
11+
pb "github.com/evstack/ev-node/execution/grpc/types/pb/evnode/v1"
1212
)
1313

1414
// Server is a gRPC server that wraps an execution.Executor implementation.

execution/grpc/server_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ import (
1010
"google.golang.org/protobuf/types/known/timestamppb"
1111

1212
"github.com/evstack/ev-node/core/execution"
13-
pb "github.com/evstack/ev-node/execution/grpc/types/pb"
13+
pb "github.com/evstack/ev-node/execution/grpc/types/pb/evnode/v1"
1414
)
1515

1616
func TestServer_InitChain(t *testing.T) {

execution/grpc/tx_batch.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ package grpc
33
import (
44
"fmt"
55

6-
pb "github.com/evstack/ev-node/execution/grpc/types/pb"
6+
pb "github.com/evstack/ev-node/execution/grpc/types/pb/evnode/v1"
77
)
88

99
// maxTxBatchTxSize is the largest transaction length representable in TxBatch.TxSizes:

execution/grpc/tx_batch_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ import (
44
"bytes"
55
"testing"
66

7-
pb "github.com/evstack/ev-node/execution/grpc/types/pb"
7+
pb "github.com/evstack/ev-node/execution/grpc/types/pb/evnode/v1"
88
)
99

1010
func mustEncodeTxBatch(t *testing.T, txs [][]byte) *pb.TxBatch {

0 commit comments

Comments
 (0)