rpc

Jun 29, 2021

Changes in this version

+ var ProviderSet = wire.NewSet(NewServer, NewClient, NewClientOptions)

+ type Client struct

+ func NewClient(o *ClientOptions, consul *api.Client, logger *logger.Logger) (*Client, error)

+ func (c *Client) Dial(service string, options ...ClientOptional) (*grpc.ClientConn, error)

+ type ClientOptional func(o *ClientOptions)

+ func WithTag(tag string) ClientOptional

+ func WithTimeout(d time.Duration) ClientOptional

+ type ClientOptions struct

+ GrpcDialOptions []grpc.DialOption

+ Tag string

+ Wait time.Duration

+ func NewClientOptions(tracer opentracing.Tracer) (*ClientOptions, error)

+ type InitServer func(s *grpc.Server)

+ type Server struct

+ func NewServer(opt *config.AppConfig, logger *logger.Logger, init InitServer, ...) (*Server, error)

+ func (s *Server) Register(f func(gs *grpc.Server) error) error

+ func (s *Server) Start() error

+ func (s *Server) Stop() error