add logic of mixed rule_type which is used to adapt to shared mode of OpensergoClient.

Author: jnan806

Diff for: pkg/datasource/opensergo/demo/datasource_opensergo_example.go

@@ -47,7 +47,7 @@ type Counter struct {
 
 func main() {
 
-	handler := datasource.NewFlowRulesHandler(datasource.FlowRuleJsonArrayParser)
+	handler := datasource.NewDefaultPropertyHandler(opensergo.MixedPropertyJsonArrayParser, opensergo.MixedPropertyUpdater)
 	openSergoDataSource, _ := opensergo.NewOpenSergoDataSource(host, port, namespace, app, handler)
 	openSergoDataSource.Initialize()
 	openSergoDataSource.Start()

Diff for: pkg/datasource/opensergo/mixed_property_adaptor.go

@@ -0,0 +1,71 @@
+package opensergo
+
+import (
+	"encoding/json"
+	"fmt"
+	"github.com/alibaba/sentinel-golang/ext/datasource"
+)
+
+// MixedPropertyJsonArrayParser provide JSON  as the default serialization for MixedRule
+func MixedPropertyJsonArrayParser(src []byte) (interface{}, error) {
+	mixedRules := new(MixedRule)
+	if err := json.Unmarshal(src, mixedRules); err != nil {
+		desc := fmt.Sprintf("Fail to convert source bytes to []*opensergo.MixedRule, err: %s", err.Error())
+		return nil, datasource.NewError(datasource.ConvertSourceError, desc)
+	}
+	return mixedRules, nil
+}
+
+// MixedPropertyUpdater load the newest MixedRule to downstream flow component.
+func MixedPropertyUpdater(data interface{}) error {
+	mixedRule := data.(*MixedRule)
+
+	var errSlice []error
+	flowRules := mixedRule.FlowRule
+	if flowRules != nil {
+		if err := datasource.FlowRulesUpdater(flowRules); err != nil {
+			errSlice = append(errSlice, err)
+		}
+	}
+
+	hotSpotParamFlowRule := mixedRule.HotSpotParamFlowRule
+	if hotSpotParamFlowRule != nil {
+		if err := datasource.HotSpotParamRulesUpdater(hotSpotParamFlowRule); err != nil {
+			errSlice = append(errSlice, err)
+		}
+	}
+
+	circuitBreakerRule := mixedRule.CircuitBreakerRule
+	if circuitBreakerRule != nil {
+		if err := datasource.CircuitBreakerRulesUpdater(circuitBreakerRule); err != nil {
+			errSlice = append(errSlice, err)
+		}
+	}
+
+	systemRules := mixedRule.SystemRule
+	if systemRules != nil {
+		if err := datasource.SystemRulesUpdater(systemRules); err != nil {
+			errSlice = append(errSlice, err)
+		}
+	}
+
+	isolationRule := mixedRule.IsolationRule
+	if isolationRule != nil {
+		if err := datasource.IsolationRulesUpdater(isolationRule); err != nil {
+			errSlice = append(errSlice, err)
+		}
+	}
+
+	if errSlice == nil || len(errSlice) == 0 {
+		return nil
+	}
+
+	var errStr string
+	for _, err := range errSlice {
+		errStr = fmt.Sprintf(" | ") + fmt.Sprintf("%+v", err)
+	}
+	return datasource.NewError(
+		datasource.UpdatePropertyError,
+		fmt.Sprintf(errStr),
+	)
+}

Diff for: pkg/datasource/opensergo/mixed_rule.go

@@ -0,0 +1,17 @@
+package opensergo
+
+import (
+	"github.com/alibaba/sentinel-golang/core/circuitbreaker"
+	"github.com/alibaba/sentinel-golang/core/flow"
+	"github.com/alibaba/sentinel-golang/core/hotspot"
+	"github.com/alibaba/sentinel-golang/core/isolation"
+	"github.com/alibaba/sentinel-golang/core/system"
+)
+
+type MixedRule struct {
+	FlowRule             []flow.Rule
+	HotSpotParamFlowRule []hotspot.Rule
+	CircuitBreakerRule   []circuitbreaker.Rule
+	SystemRule           []system.Rule
+	IsolationRule        []isolation.Rule
+}

Diff for: pkg/datasource/opensergo/opensergo.go

@@ -86,7 +86,7 @@ func (ds OpenSergoDataSource) doUpdate() {
 func (ds OpenSergoDataSource) ReadSource() ([]byte, error) {
 	dataMap := ds.opensergoRuleAggregator.dataMap
 	logging.Info("[OpenSergo] Succeed to read source", "namespace", ds.namespace, "app", ds.app, "content", dataMap)
-	bytes, err := json.Marshal(dataMap[RuleType_FlowRule])
+	bytes, err := json.Marshal(dataMap)
 	if err != nil {
 		return nil, err
 	}

Diff for: pkg/datasource/opensergo/opensergo_const.go

@@ -15,8 +15,9 @@
 package opensergo
 
 const (
-	RuleType_FlowRule           string = "FlowRule"
-	RuleType_CircuitBreakerRule string = "DegradeRule"
-	RuleType_SystemAdaptiveRule string = "SystemRule"
-	RuleType_ParamFlowRule      string = "ParamFlowRule"
+	RuleType_FlowRule             string = "FlowRule"
+	RuleType_CircuitBreakerRule   string = "CircuitBreakerRule"
+	RuleType_SystemAdaptiveRule   string = "SystemRule"
+	RuleType_HotSpotParamFlowRule string = "HotSpotParamFlowRule"
+	RuleType_IsolationRule        string = "IsolationRule"
 )