warden

Nov 6, 2019

Changes in this version

type Server

+ func (s *Server) StartWithAddr() (*Server, net.Addr, error)

Aug 19, 2019

Changes in this version

+ type TimeoutCallOption struct

+ Timeout time.Duration

Jul 19, 2019

Changes in this version

+ const LogFlagDisable

+ const LogFlagDisableArgs

+ const LogFlagDisableInfo

+ func WithDialLogFlag(flag int8) grpc.DialOption

+ func WithLogFlag(flag int8) grpc.CallOption

type ClientConfig

+ KeepAliveInterval xtime.Duration

+ KeepAliveTimeout xtime.Duration

+ KeepAliveWithoutStream bool

type ServerConfig

+ LogFlag int8

+ type TimeOutCallOption struct

+ Timeout time.Duration

+ func WithTimeoutCallOption(timeout time.Duration) *TimeOutCallOption

Jun 11, 2019

Changes in this version

+ func NewConn(target string, opt ...grpc.DialOption) (*grpc.ClientConn, error)

+ type Client struct

+ func DefaultClient() *Client

+ func NewClient(conf *ClientConfig, opt ...grpc.DialOption) *Client

+ func (c *Client) Dial(ctx context.Context, target string, opt ...grpc.DialOption) (conn *grpc.ClientConn, err error)

+ func (c *Client) DialTLS(ctx context.Context, target string, file string, name string) (conn *grpc.ClientConn, err error)

+ func (c *Client) SetConfig(conf *ClientConfig) (err error)

+ func (c *Client) Use(handlers ...grpc.UnaryClientInterceptor) *Client

+ func (c *Client) UseOpt(opt ...grpc.DialOption) *Client

+ type ClientConfig struct

+ Breaker *breaker.Config

+ Clusters []string

+ Dial xtime.Duration

+ Method map[string]*ClientConfig

+ NonBlock bool

+ Subset int

+ Timeout xtime.Duration

+ Zone string

+ type Server struct

+ func NewServer(conf *ServerConfig, opt ...grpc.ServerOption) (s *Server)

+ func (s *Server) RegisterValidation(key string, fn validator.Func) error

+ func (s *Server) Run(addr string) error

+ func (s *Server) RunUnix(file string) error

+ func (s *Server) Serve(lis net.Listener) error

+ func (s *Server) Server() *grpc.Server

+ func (s *Server) SetConfig(conf *ServerConfig) (err error)

+ func (s *Server) Shutdown(ctx context.Context) (err error)

+ func (s *Server) Start() (*Server, error)

+ func (s *Server) Use(handlers ...grpc.UnaryServerInterceptor) *Server

+ type ServerConfig struct

+ Addr string

+ ForceCloseWait xtime.Duration

+ IdleTimeout xtime.Duration

+ KeepAliveInterval xtime.Duration

+ KeepAliveTimeout xtime.Duration

+ MaxLifeTime xtime.Duration

+ Network string

+ Timeout xtime.Duration