grpc_dialer

package

v0.2.23 Latest Latest Go to latest Published: Mar 14, 2024 License: MIT Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/no-mole/neptune

Links

Open Source Insights

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 ¶

View Source

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

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

Variables ¶

View Source

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

View Source

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 ¶ added in v0.2.9

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

func DialContextConnection ¶ added in v0.2.15

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

DialContextConnection 根据metadata构建单个链接

func DialContextEndpoint ¶ added in v0.2.5

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

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

func DialContextEndpointConnection ¶ added in v0.2.15

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

DialContextEndpointConnection 使用固定端点构建链接

Types ¶

type GrpcDialer ¶ added in v0.2.9

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

func NewGrpcDialer ¶ added in v0.2.9

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

func (*GrpcDialer) Run ¶ added in v0.2.9

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL