Documentation
¶
Index ¶
Constants ¶
const ( DefaultShutdownTimeout = 30 * time.Second DefaultHealthCheckInterval = 30 * time.Second DefaultCircuitBreakerThreshold = 5 DefaultCircuitBreakerTimeout = 60 * time.Second )
Default configuration constants
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Application ¶ added in v1.2.3
type Application struct {
// contains filtered or unexported fields
}
Application represents the main bootstrap structure for Lynx applications, responsible for managing application initialization, configuration loading, and lifecycle
func NewApplication ¶ added in v1.2.3
func NewApplication(wire wireApp, plugins ...plugins.Plugin) *Application
NewApplication creates a new Lynx microservice bootstrap instance Parameters:
- wire: Function used to initialize Kratos application
- plugins: Optional plugin list to initialize with the application
Returns:
- *Application: Initialized Application instance
func (*Application) GetHost ¶ added in v1.2.3
func (app *Application) GetHost() string
GetHost gets application host
func (*Application) GetName ¶ added in v1.2.3
func (app *Application) GetName() string
GetName gets application name
func (*Application) GetVersion ¶ added in v1.2.3
func (app *Application) GetVersion() string
GetVersion gets application version
func (*Application) LoadBootstrapConfig ¶ added in v1.2.3
func (app *Application) LoadBootstrapConfig() error
LoadBootstrapConfig loads bootstrap configuration from local files or directories. It reads configuration from the path specified by the configuration manager and initializes the application's configuration state.
Returns:
- error: Any error that occurs during configuration loading
func (*Application) Run ¶ added in v1.2.3
func (app *Application) Run() error
Run starts the Lynx application and manages its lifecycle with enhanced production features
type CircuitBreaker ¶ added in v1.2.3
type CircuitBreaker struct {
// contains filtered or unexported fields
}
CircuitBreaker provides error handling and recovery
func (*CircuitBreaker) CanExecute ¶ added in v1.2.3
func (cb *CircuitBreaker) CanExecute() bool
CanExecute checks if the circuit breaker allows execution
func (*CircuitBreaker) GetState ¶ added in v1.2.3
func (cb *CircuitBreaker) GetState() CircuitState
GetState returns the current circuit breaker state
func (*CircuitBreaker) RecordResult ¶ added in v1.2.3
func (cb *CircuitBreaker) RecordResult(err error)
RecordResult records the result of an operation
type CircuitState ¶ added in v1.2.3
type CircuitState int
CircuitState represents the state of circuit breaker
const ( CircuitStateClosed CircuitState = iota CircuitStateOpen CircuitStateHalfOpen )
type ConfigManager ¶ added in v1.2.3
type ConfigManager struct {
// contains filtered or unexported fields
}
ConfigManager manages application configuration paths
func GetConfigManager ¶ added in v1.2.3
func GetConfigManager() *ConfigManager
GetConfigManager returns singleton configuration manager instance
func (*ConfigManager) GetConfigPath ¶ added in v1.2.3
func (cm *ConfigManager) GetConfigPath() string
GetConfigPath gets configuration path
func (*ConfigManager) GetDefaultConfigPath ¶ added in v1.2.3
func (cm *ConfigManager) GetDefaultConfigPath() string
GetDefaultConfigPath gets default configuration path
func (*ConfigManager) IsConfigPathSet ¶ added in v1.2.3
func (cm *ConfigManager) IsConfigPathSet() bool
IsConfigPathSet checks if configuration path is set
func (*ConfigManager) SetConfigPath ¶ added in v1.2.3
func (cm *ConfigManager) SetConfigPath(path string)
SetConfigPath sets configuration path
type HealthChecker ¶ added in v1.2.3
type HealthChecker struct {
// contains filtered or unexported fields
}
HealthChecker provides application health monitoring
func (*HealthChecker) IsHealthy ¶ added in v1.2.3
func (hc *HealthChecker) IsHealthy() bool
IsHealthy returns the current health status
func (*HealthChecker) Run ¶ added in v1.2.3
func (hc *HealthChecker) Run()
Run starts the health checker
func (*HealthChecker) Stop ¶ added in v1.2.3
func (hc *HealthChecker) Stop()
Stop stops the health checker