Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GatewayServer ¶
type GatewayServer struct {
// contains filtered or unexported fields
}
GatewayServer - represents simple http server wrapper for gateway to gRPC service
func NewGatewayServer ¶
func NewGatewayServer(gatewayConfiguration, grpcEndpointConfiguration *config.EndpointConfiguration, errChan chan<- error) *GatewayServer
NewGatewayServer - creates new GatewayServer with configuration parameters
and output channel to signalize about critical errors
func (*GatewayServer) Stop ¶
func (s *GatewayServer) Stop()
Stop - graceful stop GatewayServer with waiting of http server is stopped
type GrpcServer ¶
type GrpcServer struct {
// contains filtered or unexported fields
}
GrpcServer - represents simple gRPC server wrapper
func NewGrpcServer ¶
func NewGrpcServer(configuration *config.EndpointConfiguration, producer kafka.Producer, db *sqlx.DB, metric metrics.Metrics, chunkSize int, errChan chan<- error) *GrpcServer
NewGrpcServer - creates new GrpcServer with configuration endpoint
and output channel to signalize about critical errors
type HealthServer ¶
type HealthServer struct {
// contains filtered or unexported fields
}
HealthServer - represents simple http server for checking health
func NewHealthServer ¶
func NewHealthServer(healthcheckConfiguration *config.HealthCheckConfiguration, producer kafka.Producer, db *sqlx.DB) *HealthServer
NewHealthServer - creates new HealthServer with configuration parameters
func (*HealthServer) Stop ¶
func (s *HealthServer) Stop()
Stop - graceful stop HealthServer with waiting of http server is stopped
type MetricsServer ¶
type MetricsServer struct {
// contains filtered or unexported fields
}
MetricsServer - represents simple http server wrapper for prometheus metrics
func NewMetricsServer ¶
func NewMetricsServer(prometheusConfiguration *config.PrometheusConfiguration) *MetricsServer
NewMetricsServer - creates new MetricsServer with configuration parameters
func (*MetricsServer) Stop ¶
func (s *MetricsServer) Stop()
Stop - graceful stop MetricsServer with waiting of http server is stopped
Source Files