grpc

Aug 10, 2022

Changes in this version

type Config

+ ReflectionServer *ReflectionServer

+ type ReflectionServer struct

+ Include []string

Jul 12, 2022

Changes in this version

type Config

+ EnableReflectionServer bool

Feb 16, 2022

Changes in this version

+ 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) 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

Feb 12, 2022

Changes in this version

+ const NoClientCert

+ const RequestClientCert

+ const RequireAndVerifyClientCert

+ const RequireAnyClientCert

+ const RrMode

+ const VerifyClientCertIfGiven

+ type ClientAuthType string

+ 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 Plugin struct

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

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

+ func (p *Plugin) Name() string

+ func (p *Plugin) Reset() error

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

+ func (p *Plugin) Stop() error

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

+ type TLS struct

+ AuthType string

+ Cert string

+ Key string

+ RootCA string