grpc

Dec 14, 2023

Changes in this version

+ type Tracer interface

+ Tracer func() *sdktrace.TracerProvider

Nov 29, 2023

Changes in this version

type Plugin

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

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

Sep 24, 2023

Changes in this version

type Plugin

+ func (p *Plugin) AddWorker() error

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

Feb 6, 2023

Changes in this version

type Plugin

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

Jan 9, 2023

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 Configurer interface

+ Has func(name string) bool

+ UnmarshalKey func(name string, out any) 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) 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 Logger interface

+ NamedLogger func(name string) *zap.Logger

+ type Plugin struct

+ func (p *Plugin) Init(cfg Configurer, log Logger, 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(ctx context.Context) error

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

+ type Pool interface

+ Destroy func(ctx context.Context)

+ Exec func(ctx context.Context, p *payload.Payload) (*payload.Payload, error)

+ Reset func(ctx context.Context) error

+ Workers func() (workers []*worker.Process)

+ type Server interface

+ NewPool func(ctx context.Context, cfg *pool.Config, env map[string]string, _ *zap.Logger) (*staticPool.Pool, error)

+ type TLS struct

+ AuthType ClientAuthType

+ Cert string

+ Key string

+ RootCA string