grpc_dialer

Documentation

Index

• Constants
• Variables
• func Call(md grpc_service.Metadata, cb func(*grpc.ClientConn) error) error
• func DialContext(ctx context.Context, opts []grpc.DialOption, scheme string, ...) error
• func DialContextConn(conn *grpc.ClientConn, mds ...grpc_service.Metadata) error
• func DialContextConnection(ctx context.Context, opts []grpc.DialOption, scheme string, ...) (*grpc.ClientConn, error)
• func DialContextEndpoint(ctx context.Context, opts []grpc.DialOption, endpoint string, ...) error
• func DialContextEndpointConnection(ctx context.Context, opts []grpc.DialOption, endpoint string) (*grpc.ClientConn, error)
• type GrpcDialer
  • func NewGrpcDialer(endpoints map[string]string, metadataInfo map[string][]grpc_service.Metadata, ...) *GrpcDialer
  • func (g *GrpcDialer) Run(ctx context.Context) error

Constants

const (
	// KeepAliveTime 在此时间后客户端没看到任何活动，将ping服务器
	KeepAliveTime = time.Duration(30) * time.Minute

	// KeepAliveTimeout 客户端在ping以后等待的时间
	KeepAliveTimeout = time.Duration(20) * time.Second
)

Variables

var Conn = map[string]*grpc.ClientConn{}

var DefaultDialOptions = []grpc.DialOption{
	grpc.WithKeepaliveParams(keepalive.ClientParameters{
		Time:                KeepAliveTime,
		Timeout:             KeepAliveTimeout,
		PermitWithoutStream: true,
	}),
}

Functions

func Call

func Call(md grpc_service.Metadata, cb func(*grpc.ClientConn) error) error

func DialContext

func DialContext(ctx context.Context, opts []grpc.DialOption, scheme string, mds ...grpc_service.Metadata) error

DialContext 根据metadata构建链接池

func DialContextConn

func DialContextConn(conn *grpc.ClientConn, mds ...grpc_service.Metadata) error

func DialContextConnection

func DialContextConnection(ctx context.Context, opts []grpc.DialOption, scheme string, md grpc_service.Metadata) (*grpc.ClientConn, error)

DialContextConnection 根据metadata构建单个链接

func DialContextEndpoint

func DialContextEndpoint(ctx context.Context, opts []grpc.DialOption, endpoint string, mds ...grpc_service.Metadata) error

DialContextEndpoint 使用固定端点构建链接池

func DialContextEndpointConnection

func DialContextEndpointConnection(ctx context.Context, opts []grpc.DialOption, endpoint string) (*grpc.ClientConn, error)

DialContextEndpointConnection 使用固定端点构建链接

Types

type GrpcDialer

type GrpcDialer struct {
	// contains filtered or unexported fields
}

func NewGrpcDialer

func NewGrpcDialer(
	endpoints map[string]string,
	metadataInfo map[string][]grpc_service.Metadata,
	opt []grpc.DialOption) *GrpcDialer

func (*GrpcDialer) Run

func (g *GrpcDialer) Run(ctx context.Context) error