server

Documentation

Index

• Constants
• Variables
• func AddGracefulStop(fn func())
• func GinLoggerHandler() gin.HandlerFunc
• func GinRecoverHandler() gin.HandlerFunc
• func NewGinAPIHandler(initRoute func(r *gin.Engine)) http.Handler
• type GrpcConfig
• type GrpcServer
  • func NewGrpcServer(conf GrpcConfig, registerServerFunc func(*grpc.Server), ...) (*GrpcServer, error)
  • func (s *GrpcServer) Start()
  • func (s *GrpcServer) Stop()
• type HTTPConfig
• type HTTPService
  • func NewHTTPServer(conf HTTPConfig, handler http.Handler) (*HTTPService, error)
  • func (s *HTTPService) Start()
  • func (s *HTTPService) Stop()
• type Server
• type Servers
  • func (s *Servers) Add(server Server)
  • func (s *Servers) Start()
  • func (s *Servers) Stop()

Constants

const (
	HTTPTimeoutReadDefault  = 10
	HTTPTimeoutWriteDefault = 10
)

Variables

var ErrGrpcExecPanic = errors.New("grpc exec panic")

Functions

func AddGracefulStop

func AddGracefulStop(fn func())

func GinLoggerHandler

func GinLoggerHandler() gin.HandlerFunc

func GinRecoverHandler

func GinRecoverHandler() gin.HandlerFunc

func NewGinAPIHandler

func NewGinAPIHandler(initRoute func(r *gin.Engine)) http.Handler

Types

type GrpcConfig

type GrpcConfig struct {
	Addr    string
	Timeout int64
}

type GrpcServer

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

func NewGrpcServer

func NewGrpcServer(conf GrpcConfig, registerServerFunc func(*grpc.Server), interceptors ...grpc.UnaryServerInterceptor) (*GrpcServer, error)

func (*GrpcServer) Start

func (s *GrpcServer) Start()

func (*GrpcServer) Stop

func (s *GrpcServer) Stop()

type HTTPConfig

type HTTPConfig struct {
	Addr         string
	TimeoutRead  int64
	TimeoutWrite int64
}

type HTTPService

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

func NewHTTPServer

func NewHTTPServer(conf HTTPConfig, handler http.Handler) (*HTTPService, error)

func (*HTTPService) Start

func (s *HTTPService) Start()

func (*HTTPService) Stop

func (s *HTTPService) Stop()

type Server

type Server interface {
	Start()
	Stop()
}

type Servers

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

func (*Servers) Add

func (s *Servers) Add(server Server)

func (*Servers) Start

func (s *Servers) Start()

func (*Servers) Stop

func (s *Servers) Stop()