server

Documentation

Overview

Package server - все http сервисы приложения

Index

• Variables
• type GatewayServer
  • func NewGatewayServer() *GatewayServer
  • func (s *GatewayServer) Start()
  • func (s *GatewayServer) Stop(ctx context.Context)
• type GrpcServer
  • func NewGrpcServer(packageService *service.PackageService) *GrpcServer
  • func (s *GrpcServer) Start()
  • func (s *GrpcServer) Stop() error
• type MetricsServer
  • func NewMetricsServer() *MetricsServer
  • func (s *MetricsServer) Start()
  • func (s *MetricsServer) Stop(ctx context.Context)
• type StatusServer
  • func NewStatusServer(isReady *atomic.Value) *StatusServer
  • func (s *StatusServer) Start()
  • func (s *StatusServer) Stop(ctx context.Context)

Variables

var CRUDCounter = promauto.NewCounter(prometheus.CounterOpts{
	Namespace: "logistic",
	Subsystem: "package_api",
	Name:      "crud",
	Help:      "Total CRUD calls",
})

CRUDCounter - счетчик CRUD запросов

var GRPC2 = promauto.NewHistogram(prometheus.HistogramOpts{
	Namespace: "logistic",
	Subsystem: "package_api",
	Name:      "grpc2",
	Help:      "grpc2 calls",
},
)

GRPC2 - гистограмма времени выполнения gRPC запросов

var GRPCNotFoundCounter = promauto.NewCounter(prometheus.CounterOpts{
	Namespace: "logistic",
	Subsystem: "package_api",
	Name:      "grpc_not_found",
	Help:      "Total gRPC not found calls",
})

GRPCNotFoundCounter - счетчик не найденных запросов

var RetranslatorEvents = promauto.NewGauge(prometheus.GaugeOpts{
	Namespace: "logistic",
	Subsystem: "package_api",
	Name:      "retranslator",
	Help:      "Retranslator events in work",
})

RetranslatorEvents - счетчик событий которые сейчас отправляются в кафку

Types

type GatewayServer

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

GatewayServer is HTTP gRPC-gateway server

func NewGatewayServer

func NewGatewayServer() *GatewayServer

NewGatewayServer returns HTTP gRPC-gateway server

func (*GatewayServer) Start

func (s *GatewayServer) Start()

Start - starts the gateway server and Swagger server cancelFunc - функция отмены контекста, вызывается в случае ошибки запуска

func (*GatewayServer) Stop

func (s *GatewayServer) Stop(ctx context.Context)

Stop - stops the gateway server correctly

type GrpcServer

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

GrpcServer is gRPC server

func NewGrpcServer

func NewGrpcServer(packageService *service.PackageService) *GrpcServer

NewGrpcServer returns gRPC server

func (*GrpcServer) Start

func (s *GrpcServer) Start()

Start method runs server

func (*GrpcServer) Stop

func (s *GrpcServer) Stop() error

Stop - stop gRPC server

type MetricsServer

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

MetricsServer - http сервер для метрик

func NewMetricsServer

func NewMetricsServer() *MetricsServer

NewMetricsServer returns http server for metrics

func (*MetricsServer) Start

func (s *MetricsServer) Start()

Start - запуск http сервера

func (*MetricsServer) Stop

func (s *MetricsServer) Stop(ctx context.Context)

Stop - остановка http сервера

type StatusServer

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

StatusServer - http сервер для мониторинга состояния приложения

func NewStatusServer

func NewStatusServer(isReady *atomic.Value) *StatusServer

NewStatusServer - конструктор http сервера для мониторинга состояния приложения

func (*StatusServer) Start

func (s *StatusServer) Start()

Start - запуск http сервера

func (*StatusServer) Stop

func (s *StatusServer) Stop(ctx context.Context)

Stop - остановка http сервера