rpc

Documentation

Index

• type Client
  • func NewGrpcClient(opts ...ClientOption) *Client
  • func (c *Client) Dial() (*grpc.ClientConn, error)
  • func (c *Client) DialWithConsul() (*grpc.ClientConn, error)
• type ClientOption
  • func WithDiscoverAddr(addr string) ClientOption
  • func WithServiceName(serviceName string) ClientOption
• type Option
  • func WithServerHost(host string) Option
  • func WithServerPort(port int) Option
• type Server
  • func NewGrpcServer(logger *log.Logger, opts ...Option) *Server
  • func (s *Server) Start(ctx context.Context) error
  • func (s *Server) Stop(ctx context.Context) error

Types

type Client

type Client struct {
	DiscoverAddr string //获取服务信息的地址
	ServiceName  string
}

func NewGrpcClient

func NewGrpcClient(opts ...ClientOption) *Client

func (*Client) Dial

func (c *Client) Dial() (*grpc.ClientConn, error)

func (*Client) DialWithConsul

func (c *Client) DialWithConsul() (*grpc.ClientConn, error)

type ClientOption

type ClientOption func(s *Client)

func WithDiscoverAddr

func WithDiscoverAddr(addr string) ClientOption

func WithServiceName

func WithServiceName(serviceName string) ClientOption

type Option

type Option func(s *Server)

func WithServerHost

func WithServerHost(host string) Option

func WithServerPort

func WithServerPort(port int) Option

type Server

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

func NewGrpcServer

func NewGrpcServer(logger *log.Logger, opts ...Option) *Server

func (*Server) Start

func (s *Server) Start(ctx context.Context) error

func (*Server) Stop

func (s *Server) Stop(ctx context.Context) error