package grpc import ( "git.loafle.net/commons_go/logging" ooas "git.loafle.net/overflow/overflow_api_server/golang" "git.loafle.net/overflow/overflow_gateway_websocket/config" "google.golang.org/grpc" ) var grpcClient ooas.OverflowApiServerClient func ExternalInit() { conn, err := grpc.Dial(config.Config.GRPC.Addr, grpc.WithInsecure()) if nil != err { logging.Logger().Panic(err) } grpcClient = ooas.NewOverflowApiServerClient(conn) } func ExternalDestroy() { } // var grpcPool cgp.Pool // func ExternalInit() { // ph := &grpcPoolHandlers{} // ph.MaxCapacity = config.Config.GRPC.Pool.MaxCapacity // ph.MaxIdle = config.Config.GRPC.Pool.MaxIdle // ph.IdleTimeout = config.Config.GRPC.Pool.IdleTimeout // ph.Wait = config.Config.GRPC.Pool.Wait // grpcPool = cgp.New(ph) // if err := grpcPool.Start(); nil != err { // logging.Logger().Panicf("App: %v", err) // return // } // } // func ExternalDestroy() { // if nil != grpcPool { // grpcPool.Stop() // } // } // type grpcPoolHandlers struct { // cgp.PoolHandlers // } // func (h *grpcPoolHandlers) Dial() (*grpc.ClientConn, interface{}, error) { // var err error // conn, err := grpc.Dial(config.Config.GRPC.Addr, grpc.WithInsecure()) // if nil != err { // return nil, nil, err // } // c := ooas.NewOverflowApiServerClient(conn) // return conn, c, nil // }