rpc: Accept interface in place of ClientConn #98
2 changed files with 10 additions and 2 deletions
|
@ -2,8 +2,16 @@ package client
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"io"
|
"io"
|
||||||
|
|
||||||
|
"google.golang.org/grpc"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
// Conn is an interface for grpc client connection.
|
||||||
|
type Conn interface {
|
||||||
|
grpc.ClientConnInterface
|
||||||
|
io.Closer
|
||||||
|
}
|
||||||
|
|
||||||
// Conn returns underlying connection.
|
// Conn returns underlying connection.
|
||||||
//
|
//
|
||||||
// Returns non-nil result after the first Init() call
|
// Returns non-nil result after the first Init() call
|
||||||
|
|
|
@ -25,7 +25,7 @@ type cfg struct {
|
||||||
tlsCfg *tls.Config
|
tlsCfg *tls.Config
|
||||||
grpcDialOpts []grpc.DialOption
|
grpcDialOpts []grpc.DialOption
|
||||||
|
|
||||||
conn *grpc.ClientConn
|
conn Conn
|
||||||
}
|
}
|
||||||
|
|
||||||
const (
|
const (
|
||||||
|
@ -114,7 +114,7 @@ func WithTLSCfg(v *tls.Config) Option {
|
||||||
|
|
||||||
// WithGRPCConn returns option to specify
|
// WithGRPCConn returns option to specify
|
||||||
// gRPC virtual connection.
|
// gRPC virtual connection.
|
||||||
func WithGRPCConn(v *grpc.ClientConn) Option {
|
func WithGRPCConn(v Conn) Option {
|
||||||
return func(c *cfg) {
|
return func(c *cfg) {
|
||||||
if v != nil {
|
if v != nil {
|
||||||
c.conn = v
|
c.conn = v
|
||||||
|
|
Loading…
Add table
Reference in a new issue