Skip to content

Commit 1c1d2e1

Browse files
louyutinglouyuting
authored
Add basic abstraction for data-source extension (alibaba#73)
1 parent 270e7e0 commit 1c1d2e1

File tree

9 files changed

+238
-15
lines changed

9 files changed

+238
-15
lines changed

‎core/base/property.go

-15
This file was deleted.

‎ext/datasource/datasource.go

+21
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
package datasource
2+
3+
import (
4+
"io"
5+
)
6+
7+
// The generic interface to describe the datasource
8+
// Each DataSource instance listen in one property type.
9+
type DataSource interface {
10+
// Add specified property handler in current datasource
11+
AddPropertyHandler(h PropertyHandler)
12+
// Remove specified property handler in current datasource
13+
RemovePropertyHandler(h PropertyHandler)
14+
// Read original data from the data source.
15+
ReadSource() []byte
16+
// Initialize, init datasource and load initial rules
17+
// start listener
18+
Initialize()
19+
// Close the data source.
20+
io.Closer
21+
}

‎ext/datasource/property.go

+67
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,67 @@
1+
package datasource
2+
3+
import (
4+
"github.com/alibaba/sentinel-golang/logging"
5+
"github.com/pkg/errors"
6+
"reflect"
7+
)
8+
9+
var logger = logging.GetDefaultLogger()
10+
11+
// PropertyConverter func is to converter source message bytes to the specific property.
12+
type PropertyConverter func(src []byte) interface{}
13+
14+
// PropertyUpdater func is to update the specific properties to downstream.
15+
type PropertyUpdater func(data interface{}) error
16+
17+
// abstract interface to
18+
type PropertyHandler interface {
19+
// check whether the current src is consistent with last update property
20+
isPropertyConsistent(src interface{}) bool
21+
// handle the current property
22+
Handle(src []byte) error
23+
}
24+
25+
// DefaultPropertyHandler encapsulate the Converter and updater of property.
26+
// One DefaultPropertyHandler instance is to handle one property type.
27+
// DefaultPropertyHandler should check whether current property is consistent with last update property
28+
// converter convert the message to the specific property
29+
// updater update the specific property to downstream.
30+
type DefaultPropertyHandler struct {
31+
lastUpdateProperty interface{}
32+
33+
converter PropertyConverter
34+
updater PropertyUpdater
35+
}
36+
37+
func (h *DefaultPropertyHandler) isPropertyConsistent(src interface{}) bool {
38+
isConsistent := reflect.DeepEqual(src, h.lastUpdateProperty)
39+
if isConsistent {
40+
return true
41+
} else {
42+
h.lastUpdateProperty = src
43+
return false
44+
}
45+
}
46+
47+
func (h *DefaultPropertyHandler) Handle(src []byte) error {
48+
defer func() {
49+
if err := recover(); err != nil && logger != nil {
50+
logger.Panicf("Unexpected panic: %+v", errors.Errorf("%+v", err))
51+
}
52+
}()
53+
// converter to target property
54+
realProperty := h.converter(src)
55+
isConsistent := h.isPropertyConsistent(realProperty)
56+
if isConsistent {
57+
return nil
58+
}
59+
return h.updater(realProperty)
60+
}
61+
62+
func NewSinglePropertyHandler(converter PropertyConverter, updater PropertyUpdater) *DefaultPropertyHandler {
63+
return &DefaultPropertyHandler{
64+
converter: converter,
65+
updater: updater,
66+
}
67+
}

‎ext/datasource/property_test.go

+74
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,74 @@
1+
package datasource
2+
3+
import (
4+
"encoding/json"
5+
"errors"
6+
"github.com/alibaba/sentinel-golang/core/system"
7+
"github.com/stretchr/testify/assert"
8+
"io/ioutil"
9+
"testing"
10+
)
11+
12+
func MockSystemRulesConverter(src []byte) interface{} {
13+
ret := make([]system.SystemRule, 0)
14+
_ = json.Unmarshal(src, &ret)
15+
return ret
16+
}
17+
func MockSystemRulesConverterReturnNil(src []byte) interface{} {
18+
return nil
19+
}
20+
func MockSystemRulesUpdaterReturnNil(data interface{}) error {
21+
return nil
22+
}
23+
func MockSystemRulesUpdaterReturnError(data interface{}) error {
24+
return errors.New("MockSystemRulesUpdaterReturnError")
25+
}
26+
27+
func TestNewSinglePropertyHandler(t *testing.T) {
28+
got := NewSinglePropertyHandler(MockSystemRulesConverter, MockSystemRulesUpdaterReturnNil)
29+
assert.Truef(t, got.lastUpdateProperty == nil, "lastUpdateProperty:%d, expect nil", got.lastUpdateProperty)
30+
}
31+
32+
func TestSinglePropertyHandler_Handle(t *testing.T) {
33+
h1 := NewSinglePropertyHandler(MockSystemRulesConverterReturnNil, MockSystemRulesUpdaterReturnNil)
34+
r1 := h1.Handle(nil)
35+
assert.True(t, r1 == nil, "Fail to execute Handle func.")
36+
37+
h2 := NewSinglePropertyHandler(MockSystemRulesConverter, MockSystemRulesUpdaterReturnError)
38+
src, err := ioutil.ReadFile("../../tests/testdata/extension/SystemRule.json")
39+
if err != nil {
40+
t.Errorf("Fail to get source file, err:%+v", err)
41+
}
42+
r2 := h2.Handle(src)
43+
assert.True(t, r2 != nil && r2.Error() == "MockSystemRulesUpdaterReturnError", "Fail to execute Handle func.")
44+
}
45+
46+
func TestSinglePropertyHandler_isPropertyConsistent(t *testing.T) {
47+
h := NewSinglePropertyHandler(MockSystemRulesConverter, MockSystemRulesUpdaterReturnNil)
48+
src, err := ioutil.ReadFile("../../tests/testdata/extension/SystemRule.json")
49+
if err != nil {
50+
t.Errorf("Fail to get source file, err:%+v", err)
51+
}
52+
ret1 := make([]system.SystemRule, 0)
53+
_ = json.Unmarshal(src, &ret1)
54+
isConsistent := h.isPropertyConsistent(ret1)
55+
assert.True(t, isConsistent == false, "Fail to execute isPropertyConsistent.")
56+
57+
src2, err := ioutil.ReadFile("../../tests/testdata/extension/SystemRule2.json")
58+
if err != nil {
59+
t.Errorf("Fail to get source file, err:%+v", err)
60+
}
61+
ret2 := make([]system.SystemRule, 0)
62+
_ = json.Unmarshal(src2, &ret2)
63+
isConsistent = h.isPropertyConsistent(ret2)
64+
assert.True(t, isConsistent == true, "Fail to execute isPropertyConsistent.")
65+
66+
src3, err := ioutil.ReadFile("../../tests/testdata/extension/SystemRule3.json")
67+
if err != nil {
68+
t.Errorf("Fail to get source file, err:%+v", err)
69+
}
70+
ret3 := make([]system.SystemRule, 0)
71+
_ = json.Unmarshal(src3, &ret3)
72+
isConsistent = h.isPropertyConsistent(ret3)
73+
assert.True(t, isConsistent == false, "Fail to execute isPropertyConsistent.")
74+
}

‎go.mod

+3
Original file line numberDiff line numberDiff line change
@@ -6,9 +6,12 @@ require (
66
github.com/StackExchange/wmi v0.0.0-20190523213315-cbe66965904d // indirect
77
github.com/apache/dubbo-go v0.1.2-0.20200224151332-dd1a3c24d656
88
github.com/go-ole/go-ole v1.2.4 // indirect
9+
github.com/google/uuid v1.1.1
910
github.com/pkg/errors v0.8.1
1011
github.com/shirou/gopsutil v2.19.12+incompatible
1112
github.com/stretchr/testify v1.4.0
13+
github.com/tidwall/gjson v1.5.0
1214
golang.org/x/sys v0.0.0-20200107162124-548cf772de50 // indirect
1315
gopkg.in/yaml.v2 v2.2.2
16+
go.uber.org/multierr v1.5.0
1417
)

‎go.sum

+27
Original file line numberDiff line numberDiff line change
@@ -113,6 +113,9 @@ github.com/google/go-github v17.0.0+incompatible/go.mod h1:zLgOLi98H3fifZn+44m+u
113113
github.com/google/go-querystring v0.0.0-20170111101155-53e6ce116135/go.mod h1:odCYkC5MyYFN7vkCjXpyrEuKhc/BUO6wN/zVPAxq5ck=
114114
github.com/google/gofuzz v0.0.0-20170612174753-24818f796faf/go.mod h1:HP5RmnzzSNb993RKQDq4+1A4ia9nllfqcQFTQJedwGI=
115115
github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
116+
github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI=
117+
github.com/google/uuid v1.1.1 h1:Gkbcsh/GbpXz7lPftLA3P6TYMwjCLYm83jiFQZF/3gY=
118+
github.com/google/uuid v1.1.1/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
116119
github.com/googleapis/gnostic v0.2.0/go.mod h1:sJBsCZ4ayReDTBIg8b9dl28c5xFWyhBTVRp3pOg5EKY=
117120
github.com/gophercloud/gophercloud v0.0.0-20180828235145-f29afc2cceca/go.mod h1:3WdhXV3rUYy9p6AUW8d94kr+HS62Y4VL9mBnFxsD8q4=
118121
github.com/gopherjs/gopherjs v0.0.0-20180825215210-0210a2f0f73c/go.mod h1:wJfORRmW1u3UXTncJ5qlYoELFm8eSnnEO6hX4iZ3EWY=
@@ -256,6 +259,7 @@ github.com/prometheus/procfs v0.0.2/go.mod h1:TjEm7ze935MbeOT/UhFTIMYKhuLP4wbCsT
256259
github.com/prometheus/procfs v0.0.3/go.mod h1:4A/X28fw3Fc593LaREMrKMqOKvUAntwMDaekg4FpcdQ=
257260
github.com/renier/xmlrpc v0.0.0-20170708154548-ce4a1a486c03/go.mod h1:gRAiPF5C5Nd0eyyRdqIu9qTiFSoZzpTq727b5B8fkkU=
258261
github.com/rogpeppe/fastuuid v0.0.0-20150106093220-6724a57986af/go.mod h1:XWv6SoW27p1b0cqNHllgS5HIMJraePCO15w5zCzIWYg=
262+
github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
259263
github.com/ryanuber/columnize v0.0.0-20160712163229-9b3edd62028f/go.mod h1:sm1tb6uqfes/u+d4ooFouqFdy9/2g9QGwK3SQygK0Ts=
260264
github.com/ryanuber/go-glob v0.0.0-20170128012129-256dc444b735/go.mod h1:807d1WSdnB0XRJzKNil9Om6lcp/3a0v4qIHxIXzX/Yc=
261265
github.com/satori/go.uuid v1.2.0 h1:0uYX9dsZ2yD7q2RtLRtPSdGDWzjeM3TbMJP9utgA0ww=
@@ -287,6 +291,12 @@ github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81P
287291
github.com/tebeka/strftime v0.1.3/go.mod h1:7wJm3dZlpr4l/oVK0t1HYIc4rMzQ2XJlOMIUJUJH6XQ=
288292
github.com/tent/http-link-go v0.0.0-20130702225549-ac974c61c2f9/go.mod h1:RHkNRtSLfOK7qBTHaeSX1D6BNpI3qw7NTxsmNr4RvN8=
289293
github.com/tevid/gohamcrest v1.1.1/go.mod h1:3UvtWlqm8j5JbwYZh80D/PVBt0mJ1eJiYgZMibh0H/k=
294+
github.com/tidwall/gjson v1.5.0 h1:QCssIUI7J0RStkzIcI4A7O6P8rDA5wi5IPf70uqKSxg=
295+
github.com/tidwall/gjson v1.5.0/go.mod h1:P256ACg0Mn+j1RXIDXoss50DeIABTYK1PULOJHhxOls=
296+
github.com/tidwall/match v1.0.1 h1:PnKP62LPNxHKTwvHHZZzdOAOCtsJTjo6dZLCwpKm5xc=
297+
github.com/tidwall/match v1.0.1/go.mod h1:LujAq0jyVjBy028G1WhWfIzbpQfMO8bBZ6Tyb0+pL9E=
298+
github.com/tidwall/pretty v1.0.0 h1:HsD+QiTn7sK6flMKIvNmpqz1qrpP3Ps6jOKIKMooyg4=
299+
github.com/tidwall/pretty v1.0.0/go.mod h1:XNkn88O1ChpSDQmQeStsy+sBenx6DDtFZJxhVysOjyk=
290300
github.com/tmc/grpc-websocket-proxy v0.0.0-20190109142713-0ad062ec5ee5/go.mod h1:ncp9v5uamzpCO7NfCPTXjqaC+bZgJeR0sMTm6dMHP7U=
291301
github.com/toolkits/concurrent v0.0.0-20150624120057-a4371d70e3e3/go.mod h1:QDlpd3qS71vYtakd2hmdpqhJ9nwv6mD6A30bQ1BPBFE=
292302
github.com/tv42/httpunix v0.0.0-20150427012821-b75d8614f926/go.mod h1:9ESjWnEqriFuLhtthL60Sar/7RFoluCcXsuvEwTV5KM=
@@ -297,16 +307,24 @@ go.etcd.io/bbolt v1.3.3/go.mod h1:IbVyRI1SCnLcuJnV2u8VeU0CEYM7e686BmAb1XKL+uU=
297307
go.etcd.io/etcd v3.3.13+incompatible/go.mod h1:yaeTdrJi5lOmYerz05bd8+V7KubZs8YSFZfzsF9A6aI=
298308
go.uber.org/atomic v1.4.0 h1:cxzIVoETapQEqDhQu3QfnvXAV4AlzcvUCxkVUFw3+EU=
299309
go.uber.org/atomic v1.4.0/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE=
310+
go.uber.org/atomic v1.6.0 h1:Ezj3JGmsOnG1MoRWQkPBsKLe9DwWD9QeXzTRzzldNVk=
311+
go.uber.org/atomic v1.6.0/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ=
300312
go.uber.org/multierr v1.1.0 h1:HoEmRHQPVSqub6w2z2d2EOVs2fjyFRGyofhKuyDq0QI=
301313
go.uber.org/multierr v1.1.0/go.mod h1:wR5kodmAFQ0UK8QlbwjlSNy0Z68gJhDJUG5sjR94q/0=
314+
go.uber.org/multierr v1.5.0 h1:KCa4XfM8CWFCpxXRGok+Q0SS/0XBhMDbHHGABQLvD2A=
315+
go.uber.org/multierr v1.5.0/go.mod h1:FeouvMocqHpRaaGuG9EjoKcStLC43Zu/fmqdUMPcKYU=
316+
go.uber.org/tools v0.0.0-20190618225709-2cfd321de3ee/go.mod h1:vJERXedbb3MVM5f9Ejo0C68/HhF8uaILCdgjnY+goOA=
302317
go.uber.org/zap v1.10.0 h1:ORx85nbTijNz8ljznvCMR1ZBIPKFn3jQrag10X2AsuM=
303318
go.uber.org/zap v1.10.0/go.mod h1:vwi/ZaCAaUcBkycHslxD9B2zi4UTXhF60s6SWpuDF0Q=
304319
golang.org/x/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
305320
golang.org/x/crypto v0.0.0-20181029021203-45a5f77698d3/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
306321
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
307322
golang.org/x/crypto v0.0.0-20190325154230-a5d413f7728c/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
323+
golang.org/x/crypto v0.0.0-20190510104115-cbcb75029529/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
308324
golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
309325
golang.org/x/lint v0.0.0-20190313153728-d0100b6bd8b3/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
326+
golang.org/x/lint v0.0.0-20190930215403-16217165b5de/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
327+
golang.org/x/mod v0.0.0-20190513183733-4bf6d317e70e/go.mod h1:mXi4GBBbnImb6dmsKGUJ2LatrhH/nqhxcFungHvyanc=
310328
golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
311329
golang.org/x/net v0.0.0-20180906233101-161cd47e91fd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
312330
golang.org/x/net v0.0.0-20181023162649-9b4f9f5ad519/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
@@ -315,9 +333,11 @@ golang.org/x/net v0.0.0-20181201002055-351d144fa1fc/go.mod h1:mL1N/T3taQHkDXs73r
315333
golang.org/x/net v0.0.0-20181220203305-927f97764cc3/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
316334
golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
317335
golang.org/x/net v0.0.0-20190320064053-1272bf9dcd53/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
336+
golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
318337
golang.org/x/net v0.0.0-20190503192946-f4e77d36d62c/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
319338
golang.org/x/net v0.0.0-20190613194153-d28f0bde5980 h1:dfGZHvZk057jK2MCeWus/TowKpJ8y4AmooUzdBSR9GU=
320339
golang.org/x/net v0.0.0-20190613194153-d28f0bde5980/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
340+
golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
321341
golang.org/x/oauth2 v0.0.0-20170807180024-9a379c6b3e95/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
322342
golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
323343
golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
@@ -332,6 +352,7 @@ golang.org/x/sys v0.0.0-20181026203630-95b1ffbd15a5/go.mod h1:STP8DvDyc/dI5b8T5h
332352
golang.org/x/sys v0.0.0-20181107165924-66b7b1311ac8/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
333353
golang.org/x/sys v0.0.0-20181116152217-5ac8a444bdc5/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
334354
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
355+
golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
335356
golang.org/x/sys v0.0.0-20190508220229-2d0786266e9c/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
336357
golang.org/x/sys v0.0.0-20190523142557-0e01d883c5c5/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
337358
golang.org/x/sys v0.0.0-20190801041406-cbf593c0f2f3/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
@@ -348,6 +369,10 @@ golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod h1:LCzVGOaR6xXOjkQ3
348369
golang.org/x/tools v0.0.0-20190328211700-ab21143f2384/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
349370
golang.org/x/tools v0.0.0-20190425150028-36563e24a262/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q=
350371
golang.org/x/tools v0.0.0-20190524140312-2c0ae7006135/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q=
372+
golang.org/x/tools v0.0.0-20190621195816-6e04913cbbac/go.mod h1:/rFqwRUd4F7ZHNgwSSTFct+R/Kf4OFW1sUzUTQQTgfc=
373+
golang.org/x/tools v0.0.0-20191029041327-9cc4af7d6b2c/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
374+
golang.org/x/tools v0.0.0-20191029190741-b9c20aec41a5/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
375+
golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
351376
google.golang.org/api v0.0.0-20180829000535-087779f1d2c9/go.mod h1:4mhQ8q/RsB7i+udVvVy5NUi08OU8ZlA0gRVgrF7VFY0=
352377
google.golang.org/appengine v1.1.0/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM=
353378
google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc=
@@ -361,6 +386,7 @@ gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+
361386
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
362387
gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127 h1:qIbj1fsPNlZgppZ+VLlY7N33q108Sa+fhmuc+sWQYwY=
363388
gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
389+
gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI=
364390
gopkg.in/fsnotify.v1 v1.4.7/go.mod h1:Tz8NjZHkW78fSQdbUxIjBTcgA1z1m8ZHf0WmKUhAMys=
365391
gopkg.in/gemnasium/logrus-airbrake-hook.v2 v2.1.2/go.mod h1:Xk6kEKp8OKb+X14hQBKWaSkCsqBpgog8nAV2xsGOxlo=
366392
gopkg.in/inf.v0 v0.9.1/go.mod h1:cWUDdTG/fYaXco+Dcufb5Vnc6Gp2YChqWtbxRZE0mXw=
@@ -377,6 +403,7 @@ gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
377403
gotest.tools v2.2.0+incompatible/go.mod h1:DsYFclhRJ6vuDpmuTbkuFWG+y2sxOXAzmJt81HFBacw=
378404
honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
379405
honnef.co/go/tools v0.0.0-20190523083050-ea95bdfd59fc/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
406+
honnef.co/go/tools v0.0.1-2019.2.3/go.mod h1:a3bituU0lyd329TUQxRnasdCoJDkEUEAqEt0JzvZhAg=
380407
istio.io/gogo-genproto v0.0.0-20190124151557-6d926a6e6feb/go.mod h1:eIDJ6jNk/IeJz6ODSksHl5Aiczy5JUq6vFhJWI5OtiI=
381408
k8s.io/api v0.0.0-20180806132203-61b11ee65332/go.mod h1:iuAfoD4hCxJ8Onx9kaTIt30j7jUFS00AXQi6QMi99vA=
382409
k8s.io/api v0.0.0-20190325185214-7544f9db76f6/go.mod h1:iuAfoD4hCxJ8Onx9kaTIt30j7jUFS00AXQi6QMi99vA=

‎tests/testdata/extension/SystemRule.json

+17
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
[
2+
{
3+
"id": 0,
4+
"metricType": 0,
5+
"adaptiveStrategy": 0
6+
},
7+
{
8+
"id": 1,
9+
"metricType": 0,
10+
"adaptiveStrategy": 0
11+
},
12+
{
13+
"id": 2,
14+
"metricType": 0,
15+
"adaptiveStrategy": 0
16+
}
17+
]

‎tests/testdata/extension/SystemRule2.json

+17
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
[
2+
{
3+
"id": 0,
4+
"metricType": 0,
5+
"adaptiveStrategy": 0
6+
},
7+
{
8+
"id": 1,
9+
"metricType": 0,
10+
"adaptiveStrategy": 0
11+
},
12+
{
13+
"id": 2,
14+
"metricType": 0,
15+
"adaptiveStrategy": 0
16+
}
17+
]

‎tests/testdata/extension/SystemRule3.json

+12
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
[
2+
{
3+
"id": 0,
4+
"metricType": 0,
5+
"adaptiveStrategy": 0
6+
},
7+
{
8+
"id": 1,
9+
"metricType": 0,
10+
"adaptiveStrategy": 0
11+
}
12+
]

0 commit comments

Comments
 (0)