From 92dc12b7c67a3f9c05528e189e0d79a4eac928b9 Mon Sep 17 00:00:00 2001 From: Austin Zhai Date: Thu, 25 Sep 2025 08:49:30 +0800 Subject: [PATCH] Feat/update geminio (#88) * feat: bump up buffer size * feat: update geminio --- api/dataplane/v1/service/cluster_service_end.go | 3 ++- go.mod | 2 +- go.sum | 4 ++-- pkg/frontier/edgebound/edge_manager.go | 1 + 4 files changed, 6 insertions(+), 4 deletions(-) diff --git a/api/dataplane/v1/service/cluster_service_end.go b/api/dataplane/v1/service/cluster_service_end.go index c6dad70..3077aec 100644 --- a/api/dataplane/v1/service/cluster_service_end.go +++ b/api/dataplane/v1/service/cluster_service_end.go @@ -247,7 +247,8 @@ func (end *clusterServiceEnd) newServiceEnd(addr string) (*serviceEnd, error) { OptionServiceName(end.serviceOption.service), OptionServiceReceiveTopics(end.serviceOption.topics), OptionServiceTimer(end.serviceOption.tmr), - OptionServiceID(end.serviceOption.serviceID)) + OptionServiceID(end.serviceOption.serviceID), + OptionServiceBufferSize(end.serviceOption.readBufferSize, end.serviceOption.writeBufferSize)) if err != nil { return nil, err } diff --git a/go.mod b/go.mod index 1a329cc..80427a0 100644 --- a/go.mod +++ b/go.mod @@ -14,7 +14,7 @@ require ( github.com/nats-io/nats.go v1.33.1 github.com/nsqio/go-nsq v1.1.0 github.com/rabbitmq/amqp091-go v1.9.0 - github.com/singchia/geminio v1.1.7-rc.1 + github.com/singchia/geminio v1.1.8 github.com/singchia/go-timer/v2 v2.2.1 github.com/singchia/joy4 v0.0.0-20240621074108-53a2b0132ec6 github.com/soheilhy/cmux v0.1.5 diff --git a/go.sum b/go.sum index 9377d0b..2293dee 100644 --- a/go.sum +++ b/go.sum @@ -146,8 +146,8 @@ github.com/redis/go-redis/v9 v9.5.5 h1:51VEyMF8eOO+NUHFm8fpg+IOc1xFuFOhxs3R+kPu1 github.com/redis/go-redis/v9 v9.5.5/go.mod h1:hdY0cQFCN4fnSYT6TkisLufl/4W5UIXyv0b/CLO2V2M= github.com/rogpeppe/go-internal v1.10.0 h1:TMyTOH3F/DB16zRVcYyreMH6GnZZrwQVAoYjRBZyWFQ= github.com/rogpeppe/go-internal v1.10.0/go.mod h1:UQnix2H7Ngw/k4C5ijL5+65zddjncjaFoBhdsK/akog= -github.com/singchia/geminio v1.1.7-rc.1 h1:JZxEOHqN1oUt/RnJtzff37Iap8pOmgr1zXM7B5ZUHLo= -github.com/singchia/geminio v1.1.7-rc.1/go.mod h1:LkgZj4Ddja97vP7NWQk7TffFLZAosHe/PZtyW8vnFBQ= +github.com/singchia/geminio v1.1.8 h1:jsPgJSWoQpzupGVziFtqdDKLBs6lPv8i0SBzmGcr4ZA= +github.com/singchia/geminio v1.1.8/go.mod h1:LkgZj4Ddja97vP7NWQk7TffFLZAosHe/PZtyW8vnFBQ= github.com/singchia/go-timer/v2 v2.0.3/go.mod h1:PgkEQc6io8slCUiT5rHzWKU4/P2HXHWk3WWfijZXAf4= github.com/singchia/go-timer/v2 v2.2.1 h1:gJucmL99fkuNzGk2AfNPFpa1X3/4+aGO21KkjFAG624= github.com/singchia/go-timer/v2 v2.2.1/go.mod h1:PgkEQc6io8slCUiT5rHzWKU4/P2HXHWk3WWfijZXAf4= diff --git a/pkg/frontier/edgebound/edge_manager.go b/pkg/frontier/edgebound/edge_manager.go index 86ab468..9ecda26 100644 --- a/pkg/frontier/edgebound/edge_manager.go +++ b/pkg/frontier/edgebound/edge_manager.go @@ -146,6 +146,7 @@ func (em *edgeManager) handleConn(conn net.Conn) error { // stream handler opt.SetAcceptStreamFunc(em.acceptStream) opt.SetClosedStreamFunc(em.closedStream) + opt.SetBufferSize(8192, 8192) end, err := server.NewEndWithConn(conn, opt) if err != nil { klog.Warningf("edge manager geminio server new end err: %s, addr: %s", err, conn.RemoteAddr())