serve

type Config struct {
	GRPC ServerConfig `mapstructure:"server"`
	HTTP ServerConfig `mapstructure:"monitoring"`
	// ServiceStartupTimeout is the maximum time to wait for a service
	// to become ready before startup fails.
	ServiceStartupTimeout time.Duration `mapstructure:"startup-timeout"`
}

type DynamicTLSUpdater struct {
	// contains filtered or unexported fields
}

type RateLimitConfig struct {
	// RequestsPerSecond is the maximum number of requests per second allowed.
	// Set to 0 or negative to disable rate limiting.
	RequestsPerSecond int `mapstructure:"requests-per-second"`
	// Burst is the maximum number of requests allowed in a single burst.
	// This allows handling sudden spikes of concurrent requests from multiple clients.
	// Must be greater than 0 and less than or equal to RequestsPerSecond when rate limiting is enabled.
	Burst int `mapstructure:"burst"`
}

type Registerer interface {
	RegisterService(Servers)
}

type ServerConfig struct {
	Endpoint             connection.Endpoint    `mapstructure:"endpoint"`
	TLS                  connection.TLSConfig   `mapstructure:"tls"`
	KeepAlive            *ServerKeepAliveConfig `mapstructure:"keep-alive"`
	RateLimit            RateLimitConfig        `mapstructure:"rate-limit"`
	MaxConcurrentStreams int                    `mapstructure:"max-concurrent-streams" validate:"gte=0"`
	// contains filtered or unexported fields
}

type ServerKeepAliveConfig struct {
	Params            *ServerKeepAliveParamsConfig            `mapstructure:"params"`
	EnforcementPolicy *ServerKeepAliveEnforcementPolicyConfig `mapstructure:"enforcement-policy"`
}

type ServerKeepAliveEnforcementPolicyConfig struct {
	MinTime             time.Duration `mapstructure:"min-time"`
	PermitWithoutStream bool          `mapstructure:"permit-without-stream"`
}

type ServerKeepAliveParamsConfig struct {
	MaxConnectionIdle     time.Duration `mapstructure:"max-connection-idle"`
	MaxConnectionAge      time.Duration `mapstructure:"max-connection-age"`
	MaxConnectionAgeGrace time.Duration `mapstructure:"max-connection-age-grace"`
	Time                  time.Duration `mapstructure:"time"`
	Timeout               time.Duration `mapstructure:"timeout"`
}

type Servers struct {
	GRPC            *grpc.Server
	HTTP            *http.ServeMux
	GrpcTLSProvider *TLSProvider
	// contains filtered or unexported fields
}

type Service interface {
	Registerer
	// Run executes the service until the context is done.
	Run(ctx context.Context) error
	// WaitForReady waits for the service resources to initialize.
	// If the context ended before the service is ready, returns false.
	WaitForReady(ctx context.Context) bool
}

type TLSProvider struct {
	// contains filtered or unexported fields
}