grpc

Nov 6, 2025

Changes in this version

type ReflectionConfig

+ ImportPaths []string

Oct 30, 2025

Changes in this version

type Config

+ Reflection *ReflectionConfig

+ func (c *Config) EnableReflection() bool

+ func (c *Config) GetDescriptorSets() []string

+ type ReflectionConfig struct

+ DescriptorSets []string

+ Enabled bool

Oct 30, 2025

Changes in this version

type Config

+ DescriptorSets []string

Oct 28, 2025

Changes in this version

+ const RrMode

+ type ClientAuthType string

+ const NoClientCert

+ const RequestClientCert

+ const RequireAndVerifyClientCert

+ const RequireAnyClientCert

+ const VerifyClientCertIfGiven

+ type Config struct

+ Env map[string]string

+ GrpcPool *pool.Config

+ Listen string

+ MaxConcurrentStreams int64

+ MaxConnectionAge time.Duration

+ MaxConnectionAgeGrace time.Duration

+ MaxConnectionIdle time.Duration

+ MaxRecvMsgSize int64

+ MaxSendMsgSize int64

+ PingTime time.Duration

+ Proto []string

+ TLS *TLS

+ Timeout time.Duration

+ func (c *Config) EnableTLS() bool

+ func (c *Config) InitDefaults() error

+ type HealthCheckServer struct

+ func NewHeathServer(p *Plugin, log *zap.Logger) *HealthCheckServer

+ func (h *HealthCheckServer) Check(_ context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

+ func (h *HealthCheckServer) List(context.Context, *grpc_health_v1.HealthListRequest) (*grpc_health_v1.HealthListResponse, error)

+ func (h *HealthCheckServer) RegisterServer(serv *grpc.Server)

+ func (h *HealthCheckServer) SetServingStatus(servingStatus grpc_health_v1.HealthCheckResponse_ServingStatus)

+ func (h *HealthCheckServer) Shutdown()

+ func (h *HealthCheckServer) Watch(_ *grpc_health_v1.HealthCheckRequest, stream grpc_health_v1.Health_WatchServer) error

+ type Informer interface

+ Workers func() []*process.State

+ type Plugin struct

+ func (p *Plugin) AddWorker() error

+ func (p *Plugin) Collects() []*dep.In

+ func (p *Plugin) Init(cfg api.Configurer, log api.Logger, server api.Server) error

+ func (p *Plugin) MetricsCollector() []prometheus.Collector

+ func (p *Plugin) Name() string

+ func (p *Plugin) Ready() (*status.Status, error)

+ func (p *Plugin) RemoveWorker(ctx context.Context) error

+ func (p *Plugin) Reset() error

+ func (p *Plugin) Serve() chan error

+ func (p *Plugin) Status() (*status.Status, error)

+ func (p *Plugin) Stop(ctx context.Context) error

+ func (p *Plugin) Workers() []*process.State

+ type StatsExporter struct

+ StateDesc *prometheus.Desc

+ TotalMemoryDesc *prometheus.Desc

+ TotalWorkersDesc *prometheus.Desc

+ WorkerMemoryDesc *prometheus.Desc

+ Workers Informer

+ WorkersInvalid *prometheus.Desc

+ WorkersReady *prometheus.Desc

+ WorkersWorking *prometheus.Desc

+ func (s *StatsExporter) Collect(ch chan<- prometheus.Metric)

+ func (s *StatsExporter) Describe(d chan<- *prometheus.Desc)

+ type TLS struct

+ AuthType ClientAuthType

+ Cert string

+ Key string

+ RootCA string

+ type Tracer interface

+ Tracer func() *sdktrace.TracerProvider