Feat/release (#93)

* feat: optimize conf

* feat: release 1.2.2

Author: singchia

VERSION

@@ -1 +1 @@
-1.2.1
+1.2.2

examples/iclm/service/service.go

@@ -102,7 +102,7 @@ func main() {
 	methods := pflag.String("methods", "", "method name, support echo")
 	printmessage = pflag.Bool("printmessage", false, "whether print message out")
 	nostdin = pflag.Bool("nostdin", false, "nostdin mode, no stdin will be accepted")
-	buffersize := pflag.Int("buffer", 8192, "buffer size set for service")
+	buffersize := pflag.Int("buffer", 1024, "buffer size set for service")
 	stats := pflag.Bool("stats", false, "print statistics or not")
 
 	pflag.Parse()

go.mod

@@ -12,7 +12,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.2.0
+	github.com/singchia/geminio v1.2.2-rc.2
 	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

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.2.0 h1:Bxi6b2Av9GAvGM+M2VQ8fIR6E6MRL1q9/pumr6FXMKw=
-github.com/singchia/geminio v1.2.0/go.mod h1:b6bld5o0aofg/kuAdc5uAnaTJYvd6YaJxYDtH9b+NzY=
+github.com/singchia/geminio v1.2.2-rc.2 h1:3cAb2GrgxCp1tQwy0ZwLR2b0HsjwY4NfAMO28QEQm+M=
+github.com/singchia/geminio v1.2.2-rc.2/go.mod h1:b6bld5o0aofg/kuAdc5uAnaTJYvd6YaJxYDtH9b+NzY=
 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=

pkg/frontier/edgebound/edge_manager.go

@@ -146,7 +146,7 @@ func (em *edgeManager) handleConn(conn net.Conn) error {
 	// stream handler
 	opt.SetAcceptStreamFunc(em.acceptStream)
 	opt.SetClosedStreamFunc(em.closedStream)
-	opt.SetBufferSize(8192, 8192)
+	opt.SetBufferSize(512, 512)
 	end, err := server.NewEndWithConn(conn, opt)
 	if err != nil {
 		klog.Warningf("edge manager geminio server new end err: %s, addr: %s", err, conn.RemoteAddr())

pkg/frontier/servicebound/service_manager.go

@@ -115,7 +115,7 @@ func (sm *serviceManager) handleConn(conn net.Conn) error {
 	// stream handler
 	opt.SetAcceptStreamFunc(sm.acceptStream)
 	opt.SetClosedStreamFunc(sm.closedStream)
-	opt.SetBufferSize(8192, 8192)
+	opt.SetBufferSize(512, 512)
 	end, err := server.NewEndWithConn(conn, opt)
 	if err != nil {
 		klog.Errorf("service manager geminio server new end err: %s", err)