mirror of
https://github.com/SagerNet/sing-box.git
synced 2024-11-16 14:22:21 +08:00
65 lines
1.1 KiB
Go
65 lines
1.1 KiB
Go
package adapter
|
|
|
|
import E "github.com/sagernet/sing/common/exceptions"
|
|
|
|
type StartStage uint8
|
|
|
|
const (
|
|
StartStateInitialize StartStage = iota
|
|
StartStateStart
|
|
StartStatePostStart
|
|
StartStateStarted
|
|
)
|
|
|
|
var ListStartStages = []StartStage{
|
|
StartStateInitialize,
|
|
StartStateStart,
|
|
StartStatePostStart,
|
|
StartStateStarted,
|
|
}
|
|
|
|
func (s StartStage) String() string {
|
|
switch s {
|
|
case StartStateInitialize:
|
|
return "initialize"
|
|
case StartStateStart:
|
|
return "start"
|
|
case StartStatePostStart:
|
|
return "post-start"
|
|
case StartStateStarted:
|
|
return "finish-start"
|
|
default:
|
|
panic("unknown stage")
|
|
}
|
|
}
|
|
|
|
type Lifecycle interface {
|
|
Start(stage StartStage) error
|
|
Close() error
|
|
}
|
|
|
|
type LifecycleService interface {
|
|
Name() string
|
|
Lifecycle
|
|
}
|
|
|
|
func Start(stage StartStage, services ...Lifecycle) error {
|
|
for _, service := range services {
|
|
err := service.Start(stage)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func StartNamed(stage StartStage, services []LifecycleService) error {
|
|
for _, service := range services {
|
|
err := service.Start(stage)
|
|
if err != nil {
|
|
return E.Cause(err, stage.String(), " ", service.Name())
|
|
}
|
|
}
|
|
return nil
|
|
}
|