Versions in this module Expand all Collapse all v0 v0.1.0 Nov 19, 2024 Changes in this version + var ErrConnectionPoolClosed = errors.New("connection pool is closed") + var ErrPortRequired = errors.New("port is required") + var NewTokenSource = idtoken.NewTokenSource + var SystemCertPool = x509.SystemCertPool + func CloseServer(listener net.Listener, server *grpc.Server) + func NewHealthServer(depsCheck *DepsCheck, watchInterval time.Duration) healthpb.HealthServer + func StartServer(port int) (net.Listener, *grpc.Server, error) + type ConnPool interface + Close func() + Open func(ctx context.Context, host string, port int, protocol Protocol) (*grpc.ClientConn, error) + func NewConnPool(release bool) ConnPool + type DepCheckCallbacks map[string]func() error + type DepCheckServices map[string][]string + type DepsCheck struct + Dependencies DepCheckCallbacks + Services DepCheckServices + type ErrorHandler interface + As func(target interface{}, code codes.Code) ErrorHandler + AsW func(target interface{}, code codes.Code, wrap error) ErrorHandler + AsWF func(target interface{}, code codes.Code, format string, args ...interface{}) ErrorHandler + Handle func(err error) error + Is func(target error, code codes.Code) ErrorHandler + IsW func(target error, code codes.Code, wrap error) ErrorHandler + IsWF func(target error, code codes.Code, format string, args ...interface{}) ErrorHandler + Test func(caseFn func(initialErr error) (err error, ok bool)) ErrorHandler + func HandleError(defaultCode codes.Code) ErrorHandler + type ExecService interface + Exec func(ctx context.Context, data In) (Out, error) + func WithReport[In any, Out any](name string, service ExecService[In, Out], logger quicklog.Logger) ExecService[In, Out] + type GRPCCallback func(ctx context.Context, in In) (Out, error) + type Protocol string + const ProtocolHTTP + const ProtocolHTTPS + func (p *Protocol) WithAddr(host string) string
Go to main page