Documentation
¶
Index ¶
- Variables
- func CloseClientConnection(connection *grpc.ClientConn)
- func GrpcDialWithRetryAndBackoff(serviceName, serviceURL string) (*grpc.ClientConn, error)
- func IsConnectionReady(c *grpc.ClientConn) error
- func NewGRPCServer(opts ...grpc.ServerOption) *grpc.Server
- func PeerInfoInterceptor(logger *zerolog.Logger) grpc.UnaryServerInterceptor
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrConnectionNotReady = errors.New("unhealthy gRPC connection")
Functions ¶
func CloseClientConnection ¶
func CloseClientConnection(connection *grpc.ClientConn)
CloseClientConnection is a wrapper around grpc.ClientConn Close function
func GrpcDialWithRetryAndBackoff ¶
func GrpcDialWithRetryAndBackoff(serviceName, serviceURL string) (*grpc.ClientConn, error)
GrpcDialWithRetryAndBackoff creates an insecure gRPC connection to serviceURL After successfully connected, any RPC calls made from this connection also have a retry policy of ~10 minutes after which an error is returned that it couldn't connect to the service.
func IsConnectionReady ¶
func IsConnectionReady(c *grpc.ClientConn) error
func NewGRPCServer ¶
func NewGRPCServer(opts ...grpc.ServerOption) *grpc.Server
func PeerInfoInterceptor ¶
func PeerInfoInterceptor(logger *zerolog.Logger) grpc.UnaryServerInterceptor
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.