grpc

Documentation

Index

• type Option
  • func WithAddrOption(s string) Option
  • func WithContextOption(c context.Context) Option
  • func WithDomainOption(s string) Option
  • func WithIDOption(s string) Option
  • func WithKeepAliveOption(t time.Duration) Option
  • func WithMaxConcurrentStreamsOption(i int) Option
  • func WithMaxConnectionAgeGraceOption(t time.Duration) Option
  • func WithMaxConnectionAgeOption(t time.Duration) Option
  • func WithMaxMsgSizeOption(i int) Option
  • func WithStreamServerInterceptorsOption(u ...grpc.StreamServerInterceptor) Option
  • func WithTimeoutOption(t time.Duration) Option
  • func WithTlsOption(tls *tls.Config) Option
  • func WithUnaryServerInterceptorsOption(u ...grpc.UnaryServerInterceptor) Option
• type Options
• type Server
  • func New(name string, options ...Option) *Server
  • func (e *Server) Attempt() bool
  • 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)

func WithAddrOption

func WithAddrOption(s string) Option

func WithContextOption

func WithContextOption(c context.Context) Option

func WithDomainOption

func WithDomainOption(s string) Option

func WithIDOption

func WithIDOption(s string) Option

func WithKeepAliveOption

func WithKeepAliveOption(t time.Duration) Option

func WithMaxConcurrentStreamsOption

func WithMaxConcurrentStreamsOption(i int) Option

func WithMaxConnectionAgeGraceOption

func WithMaxConnectionAgeGraceOption(t time.Duration) Option

func WithMaxConnectionAgeOption

func WithMaxConnectionAgeOption(t time.Duration) Option

func WithMaxMsgSizeOption

func WithMaxMsgSizeOption(i int) Option

func WithStreamServerInterceptorsOption

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

func WithTimeoutOption

func WithTimeoutOption(t time.Duration) Option

func WithTlsOption

func WithTlsOption(tls *tls.Config) Option

func WithUnaryServerInterceptorsOption

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

type Options

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

type Server

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

func New

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

New new grpc server

func (*Server) Attempt

func (e *Server) Attempt() bool

func (*Server) NewServer

func (e *Server) NewServer()

func (*Server) Options

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

func (*Server) Register

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

func (*Server) Server

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

func (*Server) Shutdown

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

func (*Server) Start

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

func (*Server) String

func (e *Server) String() string

String string

type Service

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

func (*Service) Dial

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