zrpc

Documentation

Index

• Variables
• type Client
  • func MustNewClient(c RpcClientConf, options ...ClientOption) Client
  • func NewClient(c RpcClientConf, options ...ClientOption) (Client, error)
  • func NewClientNoAuth(c discov.EtcdConf) (Client, error)
  • func NewClientWithTarget(target string, opts ...ClientOption) (Client, error)
• type ClientOption
• type RpcClient
  • func (rc *RpcClient) AddInterceptor(interceptor grpc.UnaryClientInterceptor)
  • func (rc *RpcClient) Conn() *grpc.ClientConn
• type RpcClientConf
  • func NewDirectClientConf(endpoints []string, app, token string) RpcClientConf
  • func NewEtcdClientConf(hosts []string, key, app, token string) RpcClientConf
  • func (cc RpcClientConf) HasCredential() bool
• type RpcProxy
  • func NewProxy(backend string, opts ...internal.ClientOption) *RpcProxy
  • func (p *RpcProxy) TakeConn(ctx context.Context) (*grpc.ClientConn, error)
• type RpcServer
  • 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
  • func (sc RpcServerConf) HasEtcd() bool
  • func (sc RpcServerConf) Validate() error

Variables

var (
	WithDialOption = internal.WithDialOption
	WithTimeout    = internal.WithTimeout
)

Types

type Client

type Client interface {
	AddInterceptor(interceptor grpc.UnaryClientInterceptor)
	Conn() *grpc.ClientConn
}

func MustNewClient

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

func NewClient

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

func NewClientNoAuth

func NewClientNoAuth(c discov.EtcdConf) (Client, error)

func NewClientWithTarget

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

type ClientOption

type ClientOption = internal.ClientOption

type RpcClient

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

func (*RpcClient) AddInterceptor

func (rc *RpcClient) AddInterceptor(interceptor grpc.UnaryClientInterceptor)

func (*RpcClient) Conn

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

type RpcClientConf

type RpcClientConf struct {
	Etcd      discov.EtcdConf `json:",optional"`
	Endpoints []string        `json:",optional=!Etcd"`
	App       string          `json:",optional"`
	Token     string          `json:",optional"`
	Timeout   int64           `json:",optional"`
}

func NewDirectClientConf

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

func NewEtcdClientConf

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

func (RpcClientConf) HasCredential

func (cc RpcClientConf) HasCredential() bool

type RpcProxy

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

func NewProxy

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

func (*RpcProxy) TakeConn

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

type RpcServer

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

func MustNewServer

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

func NewServer

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

func (*RpcServer) AddOptions

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

func (*RpcServer) AddStreamInterceptors

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

func (*RpcServer) AddUnaryInterceptors

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

func (*RpcServer) Start

func (rs *RpcServer) Start()

func (*RpcServer) Stop

func (rs *RpcServer) Stop()

type RpcServerConf

type RpcServerConf struct {
	service.ServiceConf
	ListenOn      string
	Etcd          discov.EtcdConf    `json:",optional"`
	Auth          bool               `json:",optional"`
	Redis         redis.RedisKeyConf `json:",optional"`
	StrictControl bool               `json:",optional"`
	// pending forever is not allowed
	// never set it to 0, if zero, the underlying will set to 2s automatically
	Timeout      int64 `json:",default=2000"`
	CpuThreshold int64 `json:",default=900,range=[0:1000]"`
}

func (RpcServerConf) HasEtcd

func (sc RpcServerConf) HasEtcd() bool

func (RpcServerConf) Validate

func (sc RpcServerConf) Validate() error