zrpc

package module

v0.1.33 Latest Latest Go to latest Published: Nov 7, 2023 License: Apache-2.0 Imports: 17 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/Zzaniu/zrpc

Links

Open Source Insights

README ¶

zrpc

倍通内部rpc框架，基于gRPC

Documentation ¶

Index ¶

func Block() grpc.DialOption
func Insecure() grpc.DialOption
func MustNewClientConn(rpcClient rpc.Client, serverName string, opts ...COption) *grpc.ClientConn
type COption
- func WithClientInterceptor(clientInterceptor ...grpc.UnaryClientInterceptor) COption
- func WithDialOption(opts ...grpc.DialOption) COption
type Client
- func MustNewClient(rpcClient rpc.Client, serverName string, opts ...COption) *Client
- func (c *Client) Coon() *grpc.ClientConn
- func (c *Client) GetTarget() string
type RegisterServer
type SOption
type Server
- func MustNewServer(ctx context.Context, server rpc.Server, registerServer RegisterServer, ...) *Server

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Block ¶

func Block() grpc.DialOption

func Insecure ¶

func Insecure() grpc.DialOption

func MustNewClientConn ¶ added in v0.1.3

func MustNewClientConn(rpcClient rpc.Client, serverName string, opts ...COption) *grpc.ClientConn

MustNewClientConn 新建一个 Client 实例

Types ¶

type COption ¶

type COption func(*clientOption)

func WithClientInterceptor ¶ added in v0.1.3

func WithClientInterceptor(clientInterceptor ...grpc.UnaryClientInterceptor) COption

func WithDialOption ¶

func WithDialOption(opts ...grpc.DialOption) COption

type Client ¶

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

func MustNewClient ¶

func MustNewClient(rpcClient rpc.Client, serverName string, opts ...COption) *Client

func (*Client) Coon ¶

func (c *Client) Coon() *grpc.ClientConn

func (*Client) GetTarget ¶ added in v0.1.10

func (c *Client) GetTarget() string

type RegisterServer ¶

type RegisterServer func(server *grpc.Server)

type SOption ¶

type SOption func(*serverOption)

func WithServeZero ¶ added in v0.1.24

func WithServeZero() SOption

WithServeZero 设置服务启动运行在 0.0.0.0

func WithServerInterceptor ¶ added in v0.1.3

func WithServerInterceptor(serverInterceptor ...grpc.UnaryServerInterceptor) SOption

WithServerInterceptor 生成服务端拦截器

func WithServerOption ¶

func WithServerOption(opts ...grpc.ServerOption) SOption

WithServerOption 通过 grpc.ServerOption 生成 SOption

type Server ¶

type Server struct {
	ServiceInstance *register.ServiceInstance
	// contains filtered or unexported fields
}

func MustNewServer ¶

func MustNewServer(ctx context.Context, server rpc.Server, registerServer RegisterServer, serverOptions ...SOption) *Server

func (*Server) Serve ¶

func (s *Server) Serve() error

Serve 启动服务

func (*Server) ServerEndpoint ¶ added in v0.1.24

func (s *Server) ServerEndpoint() string

ServerEndpoint 服务真正运行的 endpoint

func (*Server) StopServe ¶

func (s *Server) StopServe()

StopServe 停止服务

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
configure
cache/redis
db/mysql
rpc
example
proto
middleware
balancer
balancer/p2c
breaker
limiter
recovery
register
register/etcd
resolver/etcd
timeout
tracer

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