overflow_gateway_websocket/external/grpc/pool.go

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
// }