Documentation
¶
Index ¶
- func NewClient(params ClientParams, opts ...ClientOption) (*grpc.ClientConn, error)
- func StreamServerInterceptor() []grpc.StreamServerInterceptor
- func UnaryServerInterceptor() []grpc.UnaryServerInterceptor
- type ClientOption
- func WithClientBreaker() ClientOption
- func WithClientDialOption(opts ...grpc.DialOption) ClientOption
- func WithClientLogger(logger *zap.Logger) ClientOption
- func WithClientMetrics(metrics *prometheus.ClientCollector) ClientOption
- func WithClientRetry() ClientOption
- func WithClientSecure() ClientOption
- func WithClientStreamInterceptors(stream ...grpc.StreamClientInterceptor) ClientOption
- func WithClientTracer(tracer gotel.Tracer) ClientOption
- func WithClientUnaryInterceptors(unary ...grpc.UnaryClientInterceptor) ClientOption
- type ClientParams
- type Config
- type Server
- type ServerParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewClient ¶
func NewClient(params ClientParams, opts ...ClientOption) (*grpc.ClientConn, error)
NewClient to host for gRPC.
func StreamServerInterceptor ¶
func StreamServerInterceptor() []grpc.StreamServerInterceptor
StreamServerInterceptor for gRPC.
func UnaryServerInterceptor ¶
func UnaryServerInterceptor() []grpc.UnaryServerInterceptor
UnaryServerInterceptor for gRPC.
Types ¶
type ClientOption ¶ added in v1.50.0
type ClientOption interface {
// contains filtered or unexported methods
}
ClientOption for HTTP.
func WithClientBreaker ¶ added in v1.50.0
func WithClientBreaker() ClientOption
WithClientBreaker for gRPC.
func WithClientDialOption ¶ added in v1.50.0
func WithClientDialOption(opts ...grpc.DialOption) ClientOption
WithClientDialOption for gRPC.
func WithClientLogger ¶ added in v1.52.0
func WithClientLogger(logger *zap.Logger) ClientOption
WithClientLogger for gRPC.
func WithClientMetrics ¶ added in v1.65.0
func WithClientMetrics(metrics *prometheus.ClientCollector) ClientOption
WithClientConfig for gRPC.
func WithClientRetry ¶ added in v1.50.0
func WithClientRetry() ClientOption
WithClientRetry for gRPC.
func WithClientSecure ¶ added in v1.50.0
func WithClientSecure() ClientOption
WithClientSecure for gRPC.
func WithClientStreamInterceptors ¶ added in v1.50.0
func WithClientStreamInterceptors(stream ...grpc.StreamClientInterceptor) ClientOption
WithClientUnaryInterceptors for gRPC.
func WithClientTracer ¶ added in v1.52.0
func WithClientTracer(tracer gotel.Tracer) ClientOption
WithClientConfig for gRPC.
func WithClientUnaryInterceptors ¶ added in v1.50.0
func WithClientUnaryInterceptors(unary ...grpc.UnaryClientInterceptor) ClientOption
WithClientUnaryInterceptors for gRPC.
type ClientParams ¶
ClientParams for gRPC.
type Config ¶
type Config struct { Retry retry.Config `yaml:"retry" json:"retry" toml:"retry"` UserAgent string `yaml:"user_agent" json:"user_agent" toml:"user_agent"` }
Config for gRPC.
type Server ¶ added in v1.70.0
Server for gRPC.
type ServerParams ¶
type ServerParams struct { fx.In Shutdowner fx.Shutdowner Config *Config Logger *zap.Logger Tracer otel.Tracer Metrics *prometheus.ServerCollector Unary []grpc.UnaryServerInterceptor Stream []grpc.StreamServerInterceptor }
ServerParams for gRPC.
Click to show internal directories.
Click to hide internal directories.