server

Documentation

Index

• func LoadEnv(envPath ...string) error
• func LoadEnvFromString(env string) error
• type Config
  • func NewConfig(options ...Option) *Config
• type GoApiBoot
  • func NewGoApiBoot(options ...Option) *GoApiBoot
  • func (g *GoApiBoot) Start(grpcPort, webPort string)
  • func (g *GoApiBoot) Stop()
• type Option
  • func AppendHttpHandlers(handlers map[string]func(http.ResponseWriter, *http.Request)) Option
  • func AppendStreamInterceptors(interceptors []grpc.StreamServerInterceptor) Option
  • func AppendUnaryInterceptors(interceptors []grpc.UnaryServerInterceptor) Option
  • func WithCorsConfig(corsConfig *cors.Cors) Option
  • func WithSSL(ssl bool) Option
• type SSLManager
  • func NewSSLManager() *SSLManager
  • func (s *SSLManager) DownloadCertificatesWithRetry()
  • func (s *SSLManager) RunAcmeChallengeListener()
• type WebProxy
  • func GetWebProxy(server *grpc.Server) WebProxy
  • func (w WebProxy) ServeHTTP(resp http.ResponseWriter, req *http.Request)

Functions

func LoadEnv

func LoadEnv(envPath ...string) error

LoadEnv loads environment variables from .env file.

func LoadEnvFromString

func LoadEnvFromString(env string) error

Types

type Config

type Config struct {
	CorsConfig         *cors.Cors
	UnaryInterceptors  []grpc.UnaryServerInterceptor
	StreamInterceptors []grpc.StreamServerInterceptor

	// Additional http handlers. All of the gRpc APIs will be exposed by default on http Rest for web.
	ExtraHttpHandlers map[string]func(http.ResponseWriter, *http.Request)
	SSL               bool
}

func NewConfig

func NewConfig(options ...Option) *Config

type GoApiBoot

type GoApiBoot struct {
	GrpcServer *grpc.Server
	WebServer  *http.Server
	// contains filtered or unexported fields
}

func NewGoApiBoot

func NewGoApiBoot(options ...Option) *GoApiBoot

func (*GoApiBoot) Start

func (g *GoApiBoot) Start(grpcPort, webPort string)

func (*GoApiBoot) Stop

func (g *GoApiBoot) Stop()

type Option

type Option func(*Config)

func AppendHttpHandlers

func AppendHttpHandlers(handlers map[string]func(http.ResponseWriter, *http.Request)) Option

func AppendStreamInterceptors

func AppendStreamInterceptors(interceptors []grpc.StreamServerInterceptor) Option

func AppendUnaryInterceptors

func AppendUnaryInterceptors(interceptors []grpc.UnaryServerInterceptor) Option

func WithCorsConfig

func WithCorsConfig(corsConfig *cors.Cors) Option

func WithSSL

func WithSSL(ssl bool) Option

type SSLManager

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

func NewSSLManager

func NewSSLManager() *SSLManager

func (*SSLManager) DownloadCertificatesWithRetry

func (s *SSLManager) DownloadCertificatesWithRetry()

func (*SSLManager) RunAcmeChallengeListener

func (s *SSLManager) RunAcmeChallengeListener()

type WebProxy

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

func GetWebProxy

func GetWebProxy(server *grpc.Server) WebProxy

func (WebProxy) ServeHTTP

func (w WebProxy) ServeHTTP(resp http.ResponseWriter, req *http.Request)