grpcserver

Sep 29, 2025

Changes in this version

type LogConfig

+ TimeSlotsThreshold config.TimeDuration

Jul 22, 2025

Changes in this version

+ type Config struct

+ Address string

+ Keepalive KeepaliveConfig

+ Limits LimitsConfig

+ Log LogConfig

+ TLS TLSConfig

+ Timeouts TimeoutsConfig

+ UnixSocketPath string

+ func NewConfig(options ...ConfigOption) *Config

+ func NewDefaultConfig(options ...ConfigOption) *Config

+ func (c *Config) KeyPrefix() string

+ func (c *Config) Set(dp config.DataProvider) error

+ func (c *Config) SetProviderDefaults(dp config.DataProvider)

+ type ConfigOption func(*configOptions)

+ func WithKeyPrefix(keyPrefix string) ConfigOption

+ type GRPCServer struct

+ GRPCServer *grpc.Server

+ Logger log.FieldLogger

+ func New(cfg *Config, logger log.FieldLogger, options ...Option) (*GRPCServer, error)

+ func (s *GRPCServer) Address() string

+ func (s *GRPCServer) MustRegisterMetrics()

+ func (s *GRPCServer) Start(fatalError chan<- error)

+ func (s *GRPCServer) Stop(gracefully bool) error

+ func (s *GRPCServer) UnregisterMetrics()

+ type KeepaliveConfig struct

+ MinTime config.TimeDuration

+ Time config.TimeDuration

+ Timeout config.TimeDuration

+ func (k *KeepaliveConfig) Set(dp config.DataProvider) error

+ type LimitsConfig struct

+ MaxConcurrentStreams uint32

+ MaxRecvMessageSize config.ByteSize

+ MaxSendMessageSize config.ByteSize

+ func (l *LimitsConfig) Set(dp config.DataProvider) error

+ type LogConfig struct

+ CallStart bool

+ ExcludedMethods []string

+ SlowCallThreshold config.TimeDuration

+ func (l *LogConfig) Set(dp config.DataProvider) error

+ type LoggingOptions struct

+ StreamCustomLoggerProvider func(ctx context.Context, info *grpc.StreamServerInfo) log.FieldLogger

+ UnaryCustomLoggerProvider func(ctx context.Context, info *grpc.UnaryServerInfo) log.FieldLogger

+ type MetricsOptions struct

+ ConstLabels prometheus.Labels

+ DurationBuckets []float64

+ Namespace string

+ StreamUserAgentTypeProvider func(ctx context.Context, info *grpc.StreamServerInfo) string

+ UnaryUserAgentTypeProvider func(ctx context.Context, info *grpc.UnaryServerInfo) string

+ type Option func(*serverOptions)

+ func WithLoggingOptions(opts LoggingOptions) Option

+ func WithMetricsOptions(opts MetricsOptions) Option

+ func WithStreamInterceptors(interceptors ...grpc.StreamServerInterceptor) Option

+ func WithUnaryInterceptors(interceptors ...grpc.UnaryServerInterceptor) Option

+ type TLSConfig struct

+ Certificate string

+ Enabled bool

+ Key string

+ func (s *TLSConfig) Set(dp config.DataProvider) error

+ type TimeoutsConfig struct

+ Shutdown config.TimeDuration

+ func (t *TimeoutsConfig) Set(dp config.DataProvider) error