rpc

Sep 27, 2019

Changes in this version

+ const ConfigNameEnableRPCLogging

type ClientParams

+ Address string

+ EnableRPCPayloadLogging bool

+ type ListenerHolder struct

+ func MustListen() *ListenerHolder

+ func (lh *ListenerHolder) AddrString() string

+ func (lh *ListenerHolder) Close() error

+ func (lh *ListenerHolder) Number() int

+ func (lh *ListenerHolder) Obtain() (net.Listener, error)

Aug 2, 2019

Changes in this version

+ func GRPCClientFromConfig(cfg config.View, prefix string) (*grpc.ClientConn, error)

+ func GRPCClientFromEndpoint(cfg config.View, address string) (*grpc.ClientConn, error)

+ func GRPCClientFromParams(params *ClientParams) (*grpc.ClientConn, error)

+ func HTTPClientFromConfig(cfg config.View, prefix string) (*http.Client, string, error)

+ func HTTPClientFromEndpoint(cfg config.View, address string) (*http.Client, string, error)

+ func HTTPClientFromParams(params *ClientParams) (*http.Client, string, error)

+ func MustServeForever(params *ServerParams)

+ type ClientCache struct

+ func NewClientCache(cfg config.View) *ClientCache

+ func (cc *ClientCache) GetGRPC(address string) (*grpc.ClientConn, error)

+ func (cc *ClientCache) GetHTTP(address string) (*http.Client, string, error)

+ type ClientParams struct

+ EnableMetrics bool

+ EnableRPCLogging bool

+ Hostname string

+ Port int

+ TrustedCertificate []byte

+ type GrpcHandler func(*grpc.Server)

+ type GrpcProxyHandler func(context.Context, *runtime.ServeMux, string, []grpc.DialOption) error

+ type Server struct

+ func (s *Server) Start(p *ServerParams) (func(), error)

+ func (s *Server) Stop()

+ type ServerParams struct

+ ServeMux *http.ServeMux

+ func NewServerParamsFromConfig(cfg config.View, prefix string) (*ServerParams, error)

+ func NewServerParamsFromListeners(grpcLh *netlistener.ListenerHolder, proxyLh *netlistener.ListenerHolder) *ServerParams

+ func (p *ServerParams) AddHandleFunc(handlerFunc GrpcHandler, grpcProxyHandler GrpcProxyHandler)

+ func (p *ServerParams) AddHealthCheckFunc(handlerFunc func(context.Context) error)

+ func (p *ServerParams) SetTLSConfiguration(rootCaPublicCertificateFileData []byte, publicCertificateFileData []byte, ...) *ServerParams