Documentation
¶
Index ¶
- Constants
- func LogStreamInterceptor() grpc.StreamServerInterceptor
- func LogUnaryInterceptor() grpc.UnaryServerInterceptor
- func PassMetadataUnaryClientInterceptor() grpc.UnaryClientInterceptor
- func RecoverStreamInterceptor() grpc.StreamServerInterceptor
- func RecoverUnaryInterceptor() grpc.UnaryServerInterceptor
- func ReturnToVTPoolUnaryServerInterceptor() grpc.UnaryServerInterceptor
- func StopGRPCServer(ctx context.Context, grpcServer *grpc.Server)
- func StoreProtocolHeaderStreamServerInterceptor(protocolVersion config.StoreProtocolVersion) grpc.StreamServerInterceptor
- func StoreProtocolHeaderUnaryServerInterceptor(protocolVersion config.StoreProtocolVersion) grpc.UnaryServerInterceptor
- func TraceUnaryInterceptor() grpc.UnaryServerInterceptor
- type VTProtoCodec
- type VTProtoMessage
Constants ¶
const CodecName = encodingproto.Name
CodecName uses default codec name to override default codec.
Variables ¶
This section is empty.
Functions ¶
func LogStreamInterceptor ¶
func LogStreamInterceptor() grpc.StreamServerInterceptor
func LogUnaryInterceptor ¶
func LogUnaryInterceptor() grpc.UnaryServerInterceptor
func PassMetadataUnaryClientInterceptor ¶
func PassMetadataUnaryClientInterceptor() grpc.UnaryClientInterceptor
PassMetadataUnaryClientInterceptor passes metadata from incoming context to outgoing context.
func RecoverStreamInterceptor ¶
func RecoverStreamInterceptor() grpc.StreamServerInterceptor
func RecoverUnaryInterceptor ¶
func RecoverUnaryInterceptor() grpc.UnaryServerInterceptor
func ReturnToVTPoolUnaryServerInterceptor ¶
func ReturnToVTPoolUnaryServerInterceptor() grpc.UnaryServerInterceptor
ReturnToVTPoolUnaryServerInterceptor calls ReturnToVTPool for each request that implements this method. It is necessary because vtproto does not return objects to the pool.
func StopGRPCServer ¶
StopGRPCServer tries to gracefully stop the given gRPC server. If the context is canceled before graceful stop is finished, applies force stop.
func StoreProtocolHeaderStreamServerInterceptor ¶ added in v0.63.0
func StoreProtocolHeaderStreamServerInterceptor(protocolVersion config.StoreProtocolVersion) grpc.StreamServerInterceptor
StoreProtocolHeaderStreamServerInterceptor sets the store protocol version header for all streaming responses.
func StoreProtocolHeaderUnaryServerInterceptor ¶ added in v0.63.0
func StoreProtocolHeaderUnaryServerInterceptor(protocolVersion config.StoreProtocolVersion) grpc.UnaryServerInterceptor
StoreProtocolHeaderUnaryServerInterceptor sets the store protocol version header for all unary responses.
func TraceUnaryInterceptor ¶
func TraceUnaryInterceptor() grpc.UnaryServerInterceptor
Types ¶
type VTProtoCodec ¶
type VTProtoCodec struct{}
VTProtoCodec implements the Codec interface. It will use the codec vtproto, if possible, otherwise falls on the standard codec. This is necessary since not all structures implement vtproto codec (for example emptypb.Empty).
func (VTProtoCodec) Name ¶
func (VTProtoCodec) Name() string
Source Files