mirror of
https://github.com/yunionio/cloudpods.git
synced 2026-09-01 15:07:17 +08:00
fix(cloudevent): options changed with etcd (#23432)
This commit is contained in:
@@ -17,7 +17,8 @@ package cloudevent
|
||||
import "yunion.io/x/onecloud/pkg/apis"
|
||||
|
||||
const (
|
||||
SERVICE_TYPE = apis.SERVICE_TYPE_CLOUDEVENT
|
||||
SERVICE_TYPE = apis.SERVICE_TYPE_CLOUDEVENT
|
||||
SERVICE_VERSION = ""
|
||||
|
||||
CLOUD_EVENT_SERVICE_COMPUTE = "compute"
|
||||
CLOUD_EVENT_SERVICE_UNKNOWN = "unknown"
|
||||
|
||||
@@ -32,3 +32,14 @@ type CloudeventOptions struct {
|
||||
var (
|
||||
Options CloudeventOptions
|
||||
)
|
||||
|
||||
func OnOptionsChange(oldO, newO interface{}) bool {
|
||||
oldOpts := oldO.(*CloudeventOptions)
|
||||
newOpts := newO.(*CloudeventOptions)
|
||||
|
||||
changed := false
|
||||
if common_options.OnCommonOptionsChange(&oldOpts.CommonOptions, &newOpts.CommonOptions) {
|
||||
changed = true
|
||||
}
|
||||
return changed
|
||||
}
|
||||
|
||||
@@ -45,6 +45,8 @@ func StartService() {
|
||||
log.Infof("Auth complete")
|
||||
})
|
||||
|
||||
common_options.StartOptionManager(opts, opts.ConfigSyncPeriodSeconds, api.SERVICE_TYPE, api.SERVICE_VERSION, options.OnOptionsChange)
|
||||
|
||||
dbOpts := &opts.DBOptions
|
||||
baseOpts := &opts.BaseOptions
|
||||
|
||||
|
||||
Reference in New Issue
Block a user