grpcx

Documentation

Index

• func GetPageSize(defaultPageSize int32, maxPageSize int32, req PageSizeRequest) (pageSize int32, err error)
• func InitPrometheusMetrics(server *grpc.Server)
• func LoggingUnaryServerInterceptor(log *zap.Logger) grpc.UnaryServerInterceptor
• func NewClientConnection(addr string, opts ...grpc.DialOption) (*grpc.ClientConn, error)
• func NewServer(log *zap.Logger) *grpc.Server
• type PageSizeRequest
• type ServerController
  • func NewServerController(addr string, server *grpc.Server, log *zap.Logger, ...) *ServerController
  • func (sm *ServerController) Start(ctx context.Context) error
  • func (sm *ServerController) Stop(ctx context.Context) error
  • func (sm *ServerController) Wait() <-chan error
• type ServerControllerOption
  • func ServerControllerWithUnixSocket(path string) ServerControllerOption

Functions

func GetPageSize

func GetPageSize(
	defaultPageSize int32,
	maxPageSize int32,
	req PageSizeRequest,
) (pageSize int32, err error)

func InitPrometheusMetrics

func InitPrometheusMetrics(server *grpc.Server)

func LoggingUnaryServerInterceptor

func LoggingUnaryServerInterceptor(log *zap.Logger) grpc.UnaryServerInterceptor

func NewClientConnection

func NewClientConnection(addr string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

NewClientConnection establishes new gRPC client connection and returns it.

func NewServer

func NewServer(log *zap.Logger) *grpc.Server

Types

type PageSizeRequest

type PageSizeRequest interface {
	GetPageSize() int32
}

PageSizeRequest describes a request with page size parameter.

type ServerController

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

func NewServerController

func NewServerController(
	addr string,
	server *grpc.Server,
	log *zap.Logger,
	opts ...ServerControllerOption,
) *ServerController

func (*ServerController) Start

func (sm *ServerController) Start(ctx context.Context) error

func (*ServerController) Stop

func (sm *ServerController) Stop(ctx context.Context) error

func (*ServerController) Wait

func (sm *ServerController) Wait() <-chan error

type ServerControllerOption

type ServerControllerOption func(*ServerController)

func ServerControllerWithUnixSocket

func ServerControllerWithUnixSocket(path string) ServerControllerOption