gmicro

Jun 19, 2021

Changes in this version

type Service

+ func (s *Service) ServeFile(w http.ResponseWriter, r *http.Request, _ map[string]string)

Dec 19, 2020

Changes in this version

type Option

+ func WithStaticAccess(b bool) Option

Oct 8, 2020

Changes in this version

+ var ErrInvokeGRPCClientIP = errors.New("invoke from context failed")

+ var ErrPeerAddressNil = errors.New("peer address is nil")

Oct 3, 2020

Changes in this version

type Option

+ func WithGRPCNetwork(network string) Option

Jul 18, 2020

Changes in this version

+ var InterruptSignals = []os.Signal

+ func AllPattern() runtime.Pattern

+ func DefaultHTTPHandler(mux *runtime.ServeMux) http.Handler

+ func GRPCHandlerFunc(grpcServer *grpc.Server, otherHandler http.Handler) http.Handler

+ func GetGRPCClientIP(ctx context.Context) (string, error)

+ func Md5(str string) string

+ func PathPattern(path string) runtime.Pattern

+ func RandInt64(min, max int64) int64

+ func RndUUID() string

+ func RndUUIDMd5() string

+ func WithRateLimit(limiter Limiter) grpc.UnaryServerInterceptor

+ type AnnotatorFunc func(context.Context, *http.Request) metadata.MD

+ type CtxKey string

+ const GRPCClientIP

+ const RequestMethod

+ const RequestURI

+ const XRequestID

+ type HTTPHandlerFunc func(*runtime.ServeMux) http.Handler

+ type HandlerFromEndpoint func(ctx context.Context, mux *runtime.ServeMux, grpcAddressAndPort string, ...) error

+ type Limiter interface

+ Limit func() bool

+ type Logger interface

+ Printf func(string, ...interface{})

+ type LoggerFunc func(string, ...interface{})

+ func (f LoggerFunc) Printf(msg string, args ...interface{})

+ type Option func(s *Service)

+ func WithAnnotator(annotator ...AnnotatorFunc) Option

+ func WithErrorHandler(errorHandler runtime.ProtoErrorHandlerFunc) Option

+ func WithGRPCDialOption(dialOption ...grpc.DialOption) Option

+ func WithGRPCServerOption(serverOption ...grpc.ServerOption) Option

+ func WithHTTPHandler(h HTTPHandlerFunc) Option

+ func WithHTTPServer(server *http.Server) Option

+ func WithHandlerFromEndpoint(reverseProxyFunc ...HandlerFromEndpoint) Option

+ func WithInterruptSignal(signal os.Signal) Option

+ func WithLogger(logger Logger) Option

+ func WithMuxOption(muxOption ...runtime.ServeMuxOption) Option

+ func WithPreShutdownDelay(timeout time.Duration) Option

+ func WithPrometheus(b bool) Option

+ func WithRecovery(f func()) Option

+ func WithRequestAccess(b bool) Option

+ func WithRouteOpt(routes ...Route) Option

+ func WithShutdownFunc(f func()) Option

+ func WithShutdownTimeout(timeout time.Duration) Option

+ func WithStaticDir(dir string) Option

+ func WithStreamInterceptor(streamInterceptor ...grpc.StreamServerInterceptor) Option

+ func WithUnaryInterceptor(unaryInterceptor ...grpc.UnaryServerInterceptor) Option

+ type Route struct

+ Handler runtime.HandlerFunc

+ Method string

+ Pattern runtime.Pattern

+ type Service struct

+ GRPCServer *grpc.Server

+ HTTPServer *http.Server

+ func NewService(opts ...Option) *Service

+ func NewServiceWithoutGateway(opts ...Option) *Service

+ func (s *Service) AddHandlerFromEndpoint(h ...HandlerFromEndpoint)

+ func (s *Service) AddRoute(routes ...Route)

+ func (s *Service) GetPid() int

+ func (s *Service) RequestInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (res interface{}, err error)

+ func (s *Service) Start(httpPort int, grpcPort int) error

+ func (s *Service) StartGRPCAndHTTPServer(port int) error

+ func (s *Service) StartGRPCWithoutGateway(grpcPort int) error

+ func (s *Service) Stop()

+ func (s *Service) StopGRPCWithoutGateway()