diff --git a/pkg/output/xatu/exporter.go b/pkg/output/xatu/exporter.go index 5be16236..a2229dd9 100644 --- a/pkg/output/xatu/exporter.go +++ b/pkg/output/xatu/exporter.go @@ -4,6 +4,7 @@ import ( "context" "fmt" "net" + "time" "github.com/ethpandaops/xatu/pkg/observability" pb "github.com/ethpandaops/xatu/pkg/proto/xatu" @@ -18,6 +19,7 @@ import ( "google.golang.org/grpc/credentials" "google.golang.org/grpc/credentials/insecure" "google.golang.org/grpc/encoding/gzip" + "google.golang.org/grpc/keepalive" "google.golang.org/grpc/metadata" ) @@ -33,7 +35,11 @@ func NewItemExporter(name string, config *Config, log logrus.FieldLogger) (ItemE opts := []grpc.DialOption{ grpc.WithChainUnaryInterceptor(grpc_prometheus.UnaryClientInterceptor, retry.UnaryClientInterceptor()), grpc.WithChainStreamInterceptor(grpc_prometheus.StreamClientInterceptor, retry.StreamClientInterceptor()), - grpc.WithTimeout(config.ExportTimeout), + grpc.WithKeepaliveParams(keepalive.ClientParameters{ + Time: 10 * time.Second, + Timeout: 30 * time.Second, + PermitWithoutStream: true, + }), } if config.TLS {