package cmprocess
import (
"clusterd/pkg/application/faultmanager/cmprocess/custom"
"clusterd/pkg/application/faultmanager/cmprocess/incrementfault"
"clusterd/pkg/application/faultmanager/cmprocess/manualfault"
"clusterd/pkg/application/faultmanager/cmprocess/preseparate"
"clusterd/pkg/application/faultmanager/cmprocess/publicfault"
"clusterd/pkg/application/faultmanager/cmprocess/recoverinplace"
"clusterd/pkg/application/faultmanager/cmprocess/retry"
"clusterd/pkg/application/faultmanager/cmprocess/stresstest"
"clusterd/pkg/application/faultmanager/cmprocess/uceaccompany"
"clusterd/pkg/common/constant"
"clusterd/pkg/domain/faultdomain/cmmanager"
)
var DeviceCenter *deviceFaultProcessCenter
type deviceFaultProcessCenter struct {
baseFaultCenter[*constant.AdvanceDeviceFaultCm]
}
func init() {
manager := cmmanager.DeviceCenterCmManager
DeviceCenter = &deviceFaultProcessCenter{
baseFaultCenter: newBaseFaultCenter(manager, constant.DeviceProcessType),
}
DeviceCenter.addProcessors([]constant.FaultProcessor{
publicfault.PubFaultProcessor,
custom.CustomProcessor,
uceaccompany.UceAccompanyProcessor,
retry.RetryProcessor,
recoverinplace.RecoverInplaceProcessor,
stresstest.StressTestProcessor,
preseparate.PreSeparateFaultProcessor,
incrementfault.IncrementFaultProcessor,
manualfault.ManualFaultProcessor,
})
}