Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ErrGRPCConnectionNotReady = errors.New("gRPC connection is not ready")
ErrGRPCConnectionNotReady is returned when the gRPC connection is not in a ready state.
Functions ¶
Types ¶
type GRPCConnection ¶
type GRPCConnection struct {
Addr string
Conn *grpc.ClientConn
Logger libLog.Logger
}
GRPCConnection is a struct which deal with gRPC connections.
func (*GRPCConnection) CheckHealth ¶ added in v3.4.8
func (c *GRPCConnection) CheckHealth(ctx context.Context) error
CheckHealth verifies that the gRPC connection is healthy and ready to accept requests. It checks the connection state and returns an error if the connection is not ready. The check uses a configurable timeout from GRPC_HEALTH_CHECK_TIMEOUT environment variable (default: 5 seconds).
func (*GRPCConnection) Connect ¶
func (c *GRPCConnection) Connect() error
Connect keeps a singleton connection with gRPC.
func (*GRPCConnection) ContextMetadataInjection ¶
func (c *GRPCConnection) ContextMetadataInjection(ctx context.Context, token string) context.Context
ContextMetadataInjection injects OpenTelemetry trace context and optional authorization into the outgoing gRPC context. It preserves existing metadata and appends: - traceparent/tracestate (W3C propagated via OpenTelemetry) - authorization (JWT), when provided
func (*GRPCConnection) GetNewClient ¶
func (c *GRPCConnection) GetNewClient() (*grpc.ClientConn, error)
GetNewClient returns a connection to gRPC, reconnect it if necessary.
Source Files
Directories