grpc

Documentation

Index

• type Option
  • func WithAddr(s string) Option
  • func WithContext(c context.Context) Option
  • func WithDomain(s string) Option
  • func WithID(s string) Option
  • func WithKeepAlive(t time.Duration) Option
  • func WithMaxConcurrentStreamsOption(i int) Option
  • func WithMaxConnectionAge(t time.Duration) Option
  • func WithMaxConnectionAgeGrace(t time.Duration) Option
  • func WithMaxMsgSizeOption(i int) Option
  • func WithStreamServerInterceptors(u ...grpc.StreamServerInterceptor) Option
  • func WithTLS(tls *tls.Config) Option
  • func WithTimeout(t time.Duration) Option
  • func WithUnaryServerInterceptors(u ...grpc.UnaryServerInterceptor) Option
• type Options
• type Server
  • func New(name string, options ...Option) *Server
  • func (e *Server) NewServer()
  • func (e *Server) Options(options ...Option)
  • func (e *Server) Register(do func(server *Server))
  • func (e *Server) Server() *grpc.Server
  • func (e *Server) Shutdown(ctx context.Context) error
  • func (e *Server) Start(ctx context.Context) error
  • func (e *Server) String() string
• type Service
  • func (e *Service) Dial(endpoint string, callTimeout time.Duration, ...) (err error)

Types

type Option

type Option func(*Options)

Option set options

func WithAddr

func WithAddr(s string) Option

WithAddr set AddrOption

func WithContext

func WithContext(c context.Context) Option

WithContext set ContextOption

func WithDomain

func WithDomain(s string) Option

WithDomain set DomainOption

func WithID

func WithID(s string) Option

WithID set IDOption

func WithKeepAlive

func WithKeepAlive(t time.Duration) Option

WithKeepAlive set KeepAliveOption

func WithMaxConcurrentStreamsOption

func WithMaxConcurrentStreamsOption(i int) Option

WithMaxConcurrentStreamsOption set MaxConcurrentStreamsOption

func WithMaxConnectionAge

func WithMaxConnectionAge(t time.Duration) Option

WithMaxConnectionAge set MaxConnectionAgeOption

func WithMaxConnectionAgeGrace

func WithMaxConnectionAgeGrace(t time.Duration) Option

WithMaxConnectionAgeGrace set MaxConnectionAgeGraceOption

func WithMaxMsgSizeOption

func WithMaxMsgSizeOption(i int) Option

WithMaxMsgSizeOption set MaxMsgSizeOption

func WithStreamServerInterceptors

func WithStreamServerInterceptors(u ...grpc.StreamServerInterceptor) Option

WithStreamServerInterceptors set StreamServerInterceptorsOption

func WithTLS

func WithTLS(tls *tls.Config) Option

WithTLS set TlsOption

func WithTimeout

func WithTimeout(t time.Duration) Option

WithTimeout set TimeoutOption

func WithUnaryServerInterceptors

func WithUnaryServerInterceptors(u ...grpc.UnaryServerInterceptor) Option

WithUnaryServerInterceptors set UnaryServerInterceptorsOption

type Options

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

Options options

type Server

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

Server server

func New

func New(name string, options ...Option) *Server

New new grpc server

func (*Server) NewServer

func (e *Server) NewServer()

NewServer new a server

func (*Server) Options

func (e *Server) Options(options ...Option)

Options set options

func (*Server) Register

func (e *Server) Register(do func(server *Server))

Register register

func (*Server) Server

func (e *Server) Server() *grpc.Server

Server return server

func (*Server) Shutdown

func (e *Server) Shutdown(ctx context.Context) error

Shutdown shutdown

func (*Server) Start

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

Start start

func (*Server) String

func (e *Server) String() string

String string

type Service

type Service struct {
	Connection  *grpc.ClientConn
	CallTimeout time.Duration
}

Service service client

func (*Service) Dial

func (e *Service) Dial(
	endpoint string,
	callTimeout time.Duration,
	unary ...grpc.UnaryClientInterceptor) (err error)

Dial dial