rpc

Documentation

Index

• type ByteText
  • func (b ByteText) Value() int
• type Config
• type LoggerConfig
• type Server
  • func New(c Config) *Server
  • func (s *Server) Router(router func(server *grpc.Server))
  • func (s *Server) Run(ctx context.Context) error
  • func (s *Server) Shutdown()
  • func (s *Server) WithGRPCOption(options ...grpc.ServerOption)
  • func (s *Server) WithRegistry(r registry.Registry)
  • func (s *Server) WithStatsHandler(handlers ...stats.Handler)
  • func (s *Server) WithStreamServerInterceptor(interceptors ...grpc.StreamServerInterceptor)
  • func (s *Server) WithUnaryServerInterceptor(interceptors ...grpc.UnaryServerInterceptor)

Types

type ByteText

type ByteText string

func (ByteText) Value

func (b ByteText) Value() int

type Config

type Config struct {
	basic.Config
	Timeout        string
	MaxRecvMsgSize ByteText
	MaxSendMsgSize ByteText
	Logger         LoggerConfig
}

type LoggerConfig

type LoggerConfig struct {
	Enable bool
}

type Server

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

func New

func New(c Config) *Server

func (*Server) Router

func (s *Server) Router(router func(server *grpc.Server))

func (*Server) Run

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

func (*Server) Shutdown

func (s *Server) Shutdown()

func (*Server) WithGRPCOption

func (s *Server) WithGRPCOption(options ...grpc.ServerOption)

func (*Server) WithRegistry

func (s *Server) WithRegistry(r registry.Registry)

func (*Server) WithStatsHandler

func (s *Server) WithStatsHandler(handlers ...stats.Handler)

func (*Server) WithStreamServerInterceptor

func (s *Server) WithStreamServerInterceptor(interceptors ...grpc.StreamServerInterceptor)

func (*Server) WithUnaryServerInterceptor

func (s *Server) WithUnaryServerInterceptor(interceptors ...grpc.UnaryServerInterceptor)