grpcutils

Feb 21, 2023

Changes in this version

+ func NewServer(opts ...ServerOption) *grpc.Server

+ type DialOption func(*DialOptions)

+ func WithChainStreamInterceptor(interceptors ...grpc.StreamClientInterceptor) DialOption

+ func WithChainUnaryInterceptor(interceptors ...grpc.UnaryClientInterceptor) DialOption

+ type DialOptions struct

+ type ServerOption func(*ServerOptions)

+ func WithStreamInterceptor(streamInterceptor grpc.StreamServerInterceptor) ServerOption

+ func WithUnaryInterceptor(unaryInterceptor grpc.UnaryServerInterceptor) ServerOption

+ type ServerOptions struct

Jul 21, 2022

Changes in this version

+ func DialOptsWithMetrics(clientMetrics *grpc_prometheus.ClientMetrics) []grpc.DialOption

May 25, 2022

Changes in this version

+ func EnsureValidResponseCode(code int) int

+ func TimestampAsTime(ts *tspb.Timestamp) (time.Time, error)

+ func TimestampFromTime(time time.Time) *tspb.Timestamp

Apr 13, 2022

Changes in this version

+ var DefaultDialOptions = []grpc.DialOption

+ var DefaultServerOptions = []grpc.ServerOption

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

+ func NewDefaultServer(opts []grpc.ServerOption) *grpc.Server

+ func NewListener() (net.Listener, error)

+ func Serve(listener net.Listener, grpcServerFunc func([]grpc.ServerOption) *grpc.Server)

Mar 10, 2022

Changes in this version

+ func Errorf(code int, tmpl string, args ...interface{}) error

+ func GetGRPCErrorFromHTTPResponse(resp *ghttpproto.HandleSimpleHTTPResponse) error

+ func GetHTTPHeader(hs http.Header) []*ghttpproto.Element

+ func GetHTTPResponseFromError(err error) (*ghttpproto.HandleSimpleHTTPResponse, bool)

+ func MergeHTTPHeader(hs []*ghttpproto.Element, header http.Header)

Feb 5, 2021

Changes in this version

type ServerCloser

+ func (s *ServerCloser) GracefulStop()