From 1c5ad5f20ba67459900f3ed75d43c6f4bd1346bc Mon Sep 17 00:00:00 2001 From: "dc.To" Date: Tue, 29 Apr 2025 18:27:54 +0800 Subject: [PATCH] add bss client --- grpcx/grpcx.go | 15 +++++++++------ 1 file changed, 9 insertions(+), 6 deletions(-) diff --git a/grpcx/grpcx.go b/grpcx/grpcx.go index ed35235..d692c5b 100644 --- a/grpcx/grpcx.go +++ b/grpcx/grpcx.go @@ -4,6 +4,7 @@ import ( "os" "git.linkiio.cn/linkpay/invoke/chain" + "git.linkiio.cn/linkpay/protobuf" "github.com/gogf/gf/contrib/registry/etcd/v2" "github.com/gogf/gf/contrib/rpc/grpcx/v2" "google.golang.org/grpc" @@ -67,9 +68,11 @@ func Reflect(s reflection.GRPCServer, f ...func()) { } } -// func Resolve[T any](value T, f func(T) T) T { -// if f == nil { -// return value -// } -// return f(value) -// } +/** + * BSS 双向通信流 + * @author dc.To + * @version 20250410 + */ +func BssClient() protobuf.BssClient { + return protobuf.NewBssClient(grpcx.Client.MustNewGrpcClientConn("api")) +}