builder

Nov 25, 2024

Changes in this version

+ var DefaultGatewayAllowedHeaders = []string

+ var DefaultGatewayAllowedMethods = []string

+ var DefaultGatewayAllowedOrigins = []string

+ type API struct

+ GRPC struct{ ... }

+ Gateway struct{ ... }

+ Needs []string

+ type GRPCOptions struct

+ Registrations GRPCRegistrations

+ ServerOptions []grpc.ServerOption

+ type GRPCRegistrations func(server *grpc.Server)

+ type Gateway struct

+ Certs *aserto.TLSConfig

+ Mux *http.ServeMux

+ Server *http.Server

+ func (g *Gateway) AddHandler(pattern string, handler http.HandlerFunc)

+ type GatewayOptions struct

+ ErrorHandler runtime.ErrorHandlerFunc

+ HandlerRegistrations HandlerRegistrations

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

+ type Health struct

+ Address string

+ GRPCServer *grpc.Server

+ Server *health.Server

+ func (h *Health) SetServiceStatus(service string, status healthpb.HealthCheckResponse_ServingStatus)

+ type Service struct

+ Cleanup []func()

+ Config *API

+ Gateway Gateway

+ Listener net.Listener

+ Server *grpc.Server

+ Started chan bool

+ type ServiceFactory struct

+ func NewServiceFactory() *ServiceFactory

+ func (f *ServiceFactory) CreateService(config *API, grpcOpts *GRPCOptions, gatewayOpts *GatewayOptions, ...) (*Service, error)

+ type ServiceInterface interface

+ Start func(context.Context) error

+ Stop func(context.Context) error

+ type ServiceManager struct

+ Context context.Context

+ DependencyMap map[string][]string

+ HealthServer *Health

+ MetricServer *http.Server

+ Servers map[string]*Service

+ func NewServiceManager(logger *zerolog.Logger) *ServiceManager

+ func (s *ServiceManager) AddGRPCServer(server *Service) error

+ func (s *ServiceManager) SetupHealthServer(address string, certCfg *aserto.TLSConfig) error

+ func (s *ServiceManager) SetupMetricsServer(address string, certCfg *aserto.TLSConfig, enableZpages bool) ([]grpc.ServerOption, error)

+ func (s *ServiceManager) StartServers(ctx context.Context) error

+ func (s *ServiceManager) StopServers(ctx context.Context)

+ func (s *ServiceManager) WithShutdownTimeout(seconds int) *ServiceManager