server

Documentation

Index

• Constants
• func CheckNetErrClosing(err error) error
• func PanicServerInterceptor(panicHandler func(ctx context.Context, err error, params ...interface{}) error, ...) grpc.UnaryServerInterceptor
• func SetGrpcServerOptions(conf configs.Configs, lg logr.Logger, ...) ([]grpc.ServerOption, error)
• type ProviderServer
  • func NewProviderServer(conf *configs.Configs, logger logr.Logger, grpcSrv *server.Server, ...) *ProviderServer
  • func (ps ProviderServer) GetMetrics(ctx context.Context, req *pb.ReqGetMetrics) (res *pb.ResGetMetrics, err error)
  • func (ps ProviderServer) Ping(ctx context.Context, req *pb.ReqPing) (*pb.ResPong, error)
  • func (ps *ProviderServer) Start() <-chan error
  • func (ps *ProviderServer) Stop() error
• type Server

Constants

const (
	KeepaliveTimeoutCanceledErr = "keepalive timeout is canceled"

	ReqGetMetricsCastErr         = `protobuf "ReqGetMetrics" type cast error`
	PeriodOrMetricsFieldEmptyErr = `period or metrics slice is empty`
)

const (
	DefaultMaxMsgSize = 2 << 20 // 2Mb
)

Functions

func CheckNetErrClosing

func CheckNetErrClosing(err error) error

func PanicServerInterceptor

func PanicServerInterceptor(panicHandler func(ctx context.Context, err error, params ...interface{}) error, params ...interface{}) grpc.UnaryServerInterceptor

func SetGrpcServerOptions

func SetGrpcServerOptions(conf configs.Configs, lg logr.Logger,
	internalInterceptors ...grpc.UnaryServerInterceptor) ([]grpc.ServerOption, error)

Types

type ProviderServer

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

func NewProviderServer

func NewProviderServer(conf *configs.Configs, logger logr.Logger, grpcSrv *server.Server, listener ...net.Listener) *ProviderServer

func (ProviderServer) GetMetrics

func (ps ProviderServer) GetMetrics(ctx context.Context, req *pb.ReqGetMetrics) (res *pb.ResGetMetrics, err error)

func (ProviderServer) Ping

func (ps ProviderServer) Ping(ctx context.Context, req *pb.ReqPing) (*pb.ResPong, error)

func (*ProviderServer) Start

func (ps *ProviderServer) Start() <-chan error

func (*ProviderServer) Stop

func (ps *ProviderServer) Stop() error

type Server

type Server interface {
	Start() <-chan error
	Stop() error
}