Versions in this module Expand all Collapse all v1 v1.0.0 Mar 7, 2026 Changes in this version + func StreamServerInterceptor(engine *Engine, cfg *Config) grpc.StreamServerInterceptor + type Config struct + AdmissionLimiter *admission.Limiter + AdmissionMode core.AdmissionMode + MetricsSink metrics.Sink + Name string + Shutdown core.ShutdownCoordinator + SupervisorPolicy supervisor.SupervisorPolicy + func BuildConfig(opts ...Option) *Config + func (c *Config) String() string + type Engine struct + func New(opts ...Option) *Engine + func NewEngine(cfg *Config) *Engine + func (e *Engine) Run(ctx context.Context, stream *Stream, mode core.AdmissionMode, ...) error + type Option func(*Config) + func WithAdmissionLimit(n int) Option + func WithAdmissionLimiter(l *admission.Limiter) Option + func WithAdmissionMode(m core.AdmissionMode) Option + func WithMetricsSink(s metrics.Sink) Option + func WithName(name string) Option + func WithShutdown(s core.ShutdownCoordinator) Option + func WithSupervisorPolicy(p supervisor.SupervisorPolicy) Option + type Stream struct + func NewStream(ctx context.Context, ss grpc.ServerStream) *Stream + func (s *Stream) Close() + func (s *Stream) Context() context.Context + func (s *Stream) Send(msg any) error
Go to main page