Documentation
¶
Index ¶
- Constants
- type ClientAuthType
- type Config
- type 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
- type Plugin
- 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
Constants ¶
View Source
const (
RrMode string = "RR_MODE"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClientAuthType ¶
type ClientAuthType string
const ( NoClientCert ClientAuthType = "no_client_cert" RequestClientCert ClientAuthType = "request_client_cert" RequireAnyClientCert ClientAuthType = "require_any_client_cert" VerifyClientCertIfGiven ClientAuthType = "verify_client_cert_if_given" RequireAndVerifyClientCert ClientAuthType = "require_and_verify_client_cert" )
type Config ¶
type Config struct { Listen string `mapstructure:"listen"` EnableReflectionServer bool `mapstructure:"enable_reflection_server"` Proto []string `mapstructure:"proto"` TLS *TLS `mapstructure:"tls"` // Env is environment variables passed to the http pool Env map[string]string `mapstructure:"env"` GrpcPool *pool.Config `mapstructure:"pool"` MaxSendMsgSize int64 `mapstructure:"max_send_msg_size"` MaxRecvMsgSize int64 `mapstructure:"max_recv_msg_size"` MaxConnectionIdle time.Duration `mapstructure:"max_connection_idle"` MaxConnectionAge time.Duration `mapstructure:"max_connection_age"` MaxConnectionAgeGrace time.Duration `mapstructure:"max_connection_age_grace"` MaxConcurrentStreams int64 `mapstructure:"max_concurrent_streams"` PingTime time.Duration `mapstructure:"ping_time"` Timeout time.Duration `mapstructure:"timeout"` }
func (*Config) InitDefaults ¶
type HealthCheckServer ¶ added in v2.10.0
type HealthCheckServer struct { grpc_health_v1.HealthCheckRequest // contains filtered or unexported fields }
func NewHeathServer ¶ added in v2.10.0
func NewHeathServer(p *Plugin, log *zap.Logger) *HealthCheckServer
func (*HealthCheckServer) Check ¶ added in v2.10.0
func (h *HealthCheckServer) Check(_ context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
func (*HealthCheckServer) RegisterServer ¶ added in v2.10.0
func (h *HealthCheckServer) RegisterServer(serv *grpc.Server)
func (*HealthCheckServer) SetServingStatus ¶ added in v2.10.0
func (h *HealthCheckServer) SetServingStatus(servingStatus grpc_health_v1.HealthCheckResponse_ServingStatus)
func (*HealthCheckServer) Shutdown ¶ added in v2.10.0
func (h *HealthCheckServer) Shutdown()
func (*HealthCheckServer) Watch ¶ added in v2.10.0
func (h *HealthCheckServer) Watch(_ *grpc_health_v1.HealthCheckRequest, stream grpc_health_v1.Health_WatchServer) error
type Plugin ¶
type Plugin struct {
// contains filtered or unexported fields
}
func (*Plugin) MetricsCollector ¶
func (p *Plugin) MetricsCollector() []prometheus.Collector
Click to show internal directories.
Click to hide internal directories.