overflow_server_app/external/grpc/pool.go
crusader 24f1d2c389 ing
2018-03-26 23:47:55 +09:00

62 lines
1.3 KiB
Go

package grpc
import (
"git.loafle.net/commons_go/logging"
ooas "git.loafle.net/overflow/overflow_api_server/golang"
"git.loafle.net/overflow/overflow_server_app/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
// }