Documentation ¶
Index ¶
- Variables
- func NewClient(ctx context.Context, host string, opts ...ClientOption) (*grpc.ClientConn, error)
- func NewDialOptions(opts ...ClientOption) ([]grpc.DialOption, error)
- func StreamServerInterceptor() []grpc.StreamServerInterceptor
- func UnaryClientInterceptors(opts ...ClientOption) ([]grpc.UnaryClientInterceptor, error)
- func UnaryServerInterceptor() []grpc.UnaryServerInterceptor
- type ClientOption
- func WithClientBreaker() ClientOption
- func WithClientDialOption(opts ...grpc.DialOption) ClientOption
- func WithClientLogger(logger *zap.Logger) ClientOption
- func WithClientMetrics(meter metric.Meter) ClientOption
- func WithClientRetry(cfg *retry.Config) ClientOption
- func WithClientSecure(sec security.Config) (ClientOption, error)
- func WithClientStreamInterceptors(stream ...grpc.StreamClientInterceptor) ClientOption
- func WithClientTracer(tracer gtracer.Tracer) ClientOption
- func WithClientUnaryInterceptors(unary ...grpc.UnaryClientInterceptor) ClientOption
- func WithClientUserAgent(userAgent string) ClientOption
- type Config
- type Server
- type ServerParams
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrInvalidPort = errors.New("invalid port")
ErrInvalidPort for gRPC.
Functions ¶
func NewClient ¶
func NewClient(ctx context.Context, host string, opts ...ClientOption) (*grpc.ClientConn, error)
NewClient to host for gRPC.
func NewDialOptions ¶ added in v1.105.0
func NewDialOptions(opts ...ClientOption) ([]grpc.DialOption, error)
NewDialOptions for gRPC.
func StreamServerInterceptor ¶
func StreamServerInterceptor() []grpc.StreamServerInterceptor
StreamServerInterceptor for gRPC.
func UnaryClientInterceptors ¶ added in v1.134.0
func UnaryClientInterceptors(opts ...ClientOption) ([]grpc.UnaryClientInterceptor, error)
UnaryClientInterceptors 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(meter metric.Meter) ClientOption
WithClientMetrics for gRPC.
func WithClientRetry ¶ added in v1.50.0
func WithClientRetry(cfg *retry.Config) ClientOption
WithClientRetry for gRPC.
func WithClientSecure ¶ added in v1.50.0
func WithClientSecure(sec security.Config) (ClientOption, error)
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 gtracer.Tracer) ClientOption
WithClientTracer for gRPC.
func WithClientUnaryInterceptors ¶ added in v1.50.0
func WithClientUnaryInterceptors(unary ...grpc.UnaryClientInterceptor) ClientOption
WithClientUnaryInterceptors for gRPC.
func WithClientUserAgent ¶ added in v1.121.0
func WithClientUserAgent(userAgent string) ClientOption
WithUserAgent for gRPC.
type Config ¶
type Config struct { Enabled bool `yaml:"enabled" json:"enabled" toml:"enabled"` Security security.Config `yaml:"security" json:"security" toml:"security"` Port string `yaml:"port" json:"port" toml:"port"` Retry retry.Config `yaml:"retry" json:"retry" toml:"retry"` UserAgent string `yaml:"user_agent" json:"user_agent" toml:"user_agent"` }
Config for gRPC.
type ServerParams ¶
type ServerParams struct { fx.In Shutdowner fx.Shutdowner Config *Config Logger *zap.Logger Tracer tracer.Tracer Meter metric.Meter Unary []grpc.UnaryServerInterceptor Stream []grpc.StreamServerInterceptor }
ServerParams for gRPC.
Click to show internal directories.
Click to hide internal directories.