grpc

func NewServer ¶

func NewServer(fs ...ServerOpt) (*Server, error)

func WithAdmin ¶

func WithAdmin(a admin.AdminService) ServerOpt

func WithAdminV1 ¶

func WithAdminV1(a adminv1.AdminService) ServerOpt

func WithAlerter ¶

func WithAlerter(a hatcheterrors.Alerter) ServerOpt

func WithAnalytics ¶

func WithAnalytics(a analytics.Analytics) ServerOpt

func WithBindAddress ¶

func WithBindAddress(bindAddress string) ServerOpt

func WithConfig ¶

func WithConfig(config *server.ServerConfig) ServerOpt

func WithDispatcher ¶

func WithDispatcher(d dispatcher.Dispatcher) ServerOpt

func WithDispatcherV1 ¶

func WithDispatcherV1(d v1connect.V1DispatcherHandler) ServerOpt

func WithIngestor ¶

func WithIngestor(i ingestor.Ingestor) ServerOpt

func WithInsecure ¶

func WithInsecure() ServerOpt

func WithLogger ¶

func WithLogger(l *zerolog.Logger) ServerOpt

func WithOTelCollector ¶ added in v0.77.32

func WithOTelCollector(oc otelcol.OTelCollector) ServerOpt

func WithOperatorService ¶ added in v0.109.0

func WithOperatorService(o v1connect.OperatorServiceHandler) ServerOpt

WithOperatorService registers the v1.OperatorService for out-of-process operators. When it is not set the service is not registered and callers receive Unimplemented.

func WithPort ¶

func WithPort(port int) ServerOpt

func WithShutdownTimeout ¶ added in v0.89.2

func WithShutdownTimeout(timeout time.Duration) ServerOpt

WithShutdownTimeout bounds how long the server waits for in-flight RPCs and streams to drain on graceful shutdown before forcing a hard stop. Non-positive values are ignored.

func WithTLSConfig ¶

func WithTLSConfig(tls *tls.Config) ServerOpt