refactor: isolate filter with appid (#233)

Author: dk-lockdown

cmd/cmd.go

@@ -91,7 +91,7 @@ var (
 					if err != nil {
 						log.Fatal(errors.Wrapf(err, "failed to create filter: %s", filterConf.Name))
 					}
-					filter.RegisterFilter(filterConf.Name, f)
+					filter.RegisterFilter(appid, filterConf.Name, f)
 				}
 
 				resource.RegisterDBManager(appid, dbpackConf.DataSources, func(dbName, dsn string) pools.Factory {

pkg/executor/read_write_splitting.go

@@ -98,7 +98,7 @@ func NewReadWriteSplittingExecutor(conf *config.Executor) (proto.Executor, error
 
 	for i := 0; i < len(conf.Filters); i++ {
 		filterName := conf.Filters[i]
-		f := filter.GetFilter(filterName)
+		f := filter.GetFilter(conf.AppID, filterName)
 		if f != nil {
 			preFilter, ok := f.(proto.DBPreFilter)
 			if ok {

pkg/executor/sharding.go

@@ -86,7 +86,7 @@ func NewShardingExecutor(conf *config.Executor) (proto.Executor, error) {
 
 	for i := 0; i < len(conf.Filters); i++ {
 		filterName := conf.Filters[i]
-		f := filter.GetFilter(filterName)
+		f := filter.GetFilter(conf.AppID, filterName)
 		if f != nil {
 			preFilter, ok := f.(proto.DBPreFilter)
 			if ok {

pkg/executor/single_db.go

@@ -73,7 +73,7 @@ func NewSingleDBExecutor(conf *config.Executor) (proto.Executor, error) {
 
 	for i := 0; i < len(conf.Filters); i++ {
 		filterName := conf.Filters[i]
-		f := filter.GetFilter(filterName)
+		f := filter.GetFilter(conf.AppID, filterName)
 		if f != nil {
 			preFilter, ok := f.(proto.DBPreFilter)
 			if ok {

pkg/filter/filters.go

@@ -16,7 +16,11 @@
 
 package filter
 
-import "github.com/cectc/dbpack/pkg/proto"
+import (
+	"strings"
+
+	"github.com/cectc/dbpack/pkg/proto"
+)
 
 var (
 	filterFactories = make(map[string]proto.FilterFactory)
@@ -31,10 +35,12 @@ func GetFilterFactory(kind string) proto.FilterFactory {
 	return filterFactories[kind]
 }
 
-func RegisterFilter(name string, filter proto.Filter) {
-	filters[name] = filter
+func RegisterFilter(appid, name string, filter proto.Filter) {
+	key := strings.Join([]string{appid, name}, "-")
+	filters[key] = filter
 }
 
-func GetFilter(name string) proto.Filter {
-	return filters[name]
+func GetFilter(appid, name string) proto.Filter {
+	key := strings.Join([]string{appid, name}, "-")
+	return filters[key]
 }

pkg/listener/http.go

@@ -86,7 +86,7 @@ func NewHttpListener(conf *config.Listener) (proto.Listener, error) {
 
 	for i := 0; i < len(conf.Filters); i++ {
 		filterName := conf.Filters[i]
-		f := filter.GetFilter(filterName)
+		f := filter.GetFilter(conf.AppID, filterName)
 		if f != nil {
 			preFilter, ok := f.(proto.HttpPreFilter)
 			if ok {

pkg/resource/data_source.go

@@ -56,7 +56,7 @@ func RegisterDBManager(appid string, dataSources []*config.DataSource, factory f
 		db := sql.NewDB(dataSource.Name, dataSource.PingInterval, dataSource.PingTimesForChangeStatus, resourcePool)
 		for j := 0; j < len(dataSource.Filters); j++ {
 			filterName := dataSource.Filters[j]
-			f := filter.GetFilter(filterName)
+			f := filter.GetFilter(appid, filterName)
 			if f != nil {
 				preFilter, ok := f.(proto.DBConnectionPreFilter)
 				if ok {