grpc

Documentation

Index

• Variables
• type Client
  • func NewClient(o *ClientOptions, tracer opentracing.Tracer) (*Client, error)
  • func (c *Client) Dial(service string, options ...ClientOptional) (*grpc.ClientConn, error)
• type ClientOptional
  • func WithConsulConfig(consul *consulApi.Config) ClientOptional
  • func WithGrpcDialOptions(options ...grpc.DialOption) ClientOptional
  • func WithTag(tag string) ClientOptional
  • func WithTarget(t string) ClientOptional
  • func WithTimeout(d time.Duration) ClientOptional
• type ClientOptions
  • func NewClientOptions(v *viper.Viper) (*ClientOptions, error)
• type InitServers
• type Server
  • func NewServer(o *ServerOption, logger *zap.Logger, tracer opentracing.Tracer, ...) (*Server, error)
  • func (s *Server) AppName(name string)
  • func (s *Server) ConsulClient(cli *consulApi.Client)
  • func (s *Server) Start(opts ...options.ServerOptional) error
  • func (s *Server) Stop() error
• type ServerOption
  • func NewOptions(v *viper.Viper) (*ServerOption, error)

Variables

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

Provider

Types

type Client

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

Client

func NewClient

func NewClient(o *ClientOptions, tracer opentracing.Tracer) (*Client, error)

NewClient

func (*Client) Dial

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

Dial

type ClientOptional

type ClientOptional func(o *ClientOptions)

ClientOptional

func WithConsulConfig

func WithConsulConfig(consul *consulApi.Config) ClientOptional

WithConsulConfig

func WithGrpcDialOptions

func WithGrpcDialOptions(options ...grpc.DialOption) ClientOptional

WithGrpcDialOptions

func WithTag

func WithTag(tag string) ClientOptional

WithTag

func WithTarget

func WithTarget(t string) ClientOptional

WithTarget "consul://xxx" or ip+port "xx.xx.xx.xx:xxxx"

func WithTimeout

func WithTimeout(d time.Duration) ClientOptional

WithTimeout

type ClientOptions

type ClientOptions struct {
	Target string // "consul://xxx" or ip+port "xx.xx.xx.xx:xxxx"
	Wait   time.Duration
	Tag    string
	// contains filtered or unexported fields
}

ClientOptions

func NewClientOptions

func NewClientOptions(v *viper.Viper) (*ClientOptions, error)

NewClientOptions

type InitServers

type InitServers func(s *grpc.Server)

InitServers

type Server

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

Server

func NewServer

func NewServer(o *ServerOption, logger *zap.Logger, tracer opentracing.Tracer, init InitServers) (*Server, error)

NewServer

func (*Server) AppName

func (s *Server) AppName(name string)

AppName

func (*Server) ConsulClient

func (s *Server) ConsulClient(cli *consulApi.Client)

ConsulClient

func (*Server) Start

func (s *Server) Start(opts ...options.ServerOptional) error

Start

func (*Server) Stop

func (s *Server) Stop() error

Stop

type ServerOption

type ServerOption struct {
	options.ServerOption
}

ServerOption

func NewOptions

func NewOptions(v *viper.Viper) (*ServerOption, error)

NewOptions