Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

zrpc

package

Go to main page

Versions in this module

v1

v1.3.0

Jan 6, 2022

v1.3.0-rc2

Jan 6, 2022

v1.2.7

Jan 4, 2022

v1.2.6

Dec 26, 2021

v1.2.5

Dec 23, 2021

Changes in this version

+ var WithNonBlock = internal.WithNonBlock

+ var WithTransportCredentials = internal.WithTransportCredentials

+ func SetClientSlowThreshold(threshold time.Duration)

+ func SetServerSlowThreshold(threshold time.Duration)

type RpcClientConf

+ NonBlock bool

+ func (cc RpcClientConf) BuildTarget() (string, error)

v1.2.3

Oct 14, 2021

v1.2.2

Oct 9, 2021

Changes in this version

+ var WithDialOption = internal.WithDialOption

+ var WithTimeout = internal.WithTimeout

+ var WithUnaryClientInterceptor = internal.WithUnaryClientInterceptor

+ type Client = internal.Client

+ func MustNewClient(c RpcClientConf, options ...ClientOption) Client

+ func NewClient(c RpcClientConf, options ...ClientOption) (Client, error)

+ func NewClientNoAuth(c discov.EtcdConf, opts ...ClientOption) (Client, error)

+ func NewClientWithTarget(target string, opts ...ClientOption) (Client, error)

+ type ClientOption = internal.ClientOption

+ type RpcClient struct

+ func (rc *RpcClient) Conn() *grpc.ClientConn

+ type RpcClientConf struct

+ App string

+ Endpoints []string

+ Etcd discov.EtcdConf

+ Target string

+ Timeout int64

+ Token string

+ func NewDirectClientConf(endpoints []string, app, token string) RpcClientConf

+ func NewEtcdClientConf(hosts []string, key, app, token string) RpcClientConf

+ func (cc RpcClientConf) HasCredential() bool

+ type RpcProxy struct

+ func NewProxy(backend string, opts ...internal.ClientOption) *RpcProxy

+ func (p *RpcProxy) TakeConn(ctx context.Context) (*grpc.ClientConn, error)

+ type RpcServer struct

+ func MustNewServer(c RpcServerConf, register internal.RegisterFn) *RpcServer

+ func NewServer(c RpcServerConf, register internal.RegisterFn) (*RpcServer, error)

+ func (rs *RpcServer) AddOptions(options ...grpc.ServerOption)

+ func (rs *RpcServer) AddStreamInterceptors(interceptors ...grpc.StreamServerInterceptor)

+ func (rs *RpcServer) AddUnaryInterceptors(interceptors ...grpc.UnaryServerInterceptor)

+ func (rs *RpcServer) Start()

+ func (rs *RpcServer) Stop()

+ type RpcServerConf struct

+ Auth bool

+ CpuThreshold int64

+ Etcd discov.EtcdConf

+ ListenOn string

+ Redis redis.RedisKeyConf

+ StrictControl bool

+ Timeout int64

+ func (sc RpcServerConf) HasEtcd() bool

+ func (sc RpcServerConf) Validate() error