diff --git a/module/application-authorization/auth-driver/aksk/aksk.go b/module/application-authorization/auth-driver/aksk/aksk.go index 083b9ffa..274ae372 100644 --- a/module/application-authorization/auth-driver/aksk/aksk.go +++ b/module/application-authorization/auth-driver/aksk/aksk.go @@ -3,9 +3,9 @@ package aksk import ( "encoding/json" "fmt" - + auth_driver "github.com/APIParkLab/APIPark/module/application-authorization/auth-driver" - + application_authorization_dto "github.com/APIParkLab/APIPark/module/application-authorization/dto" ) @@ -26,8 +26,7 @@ type Config struct { } func (a *Config) ID() string { - //TODO implement me - panic("implement me") + return a.Ak } func (a *Config) Valid() ([]byte, error) { diff --git a/module/log/iml.go b/module/log/iml.go index 6f21b7cb..a6426e7a 100644 --- a/module/log/iml.go +++ b/module/log/iml.go @@ -165,29 +165,7 @@ func (i *imlLogModule) Get(ctx context.Context, driver string) (*log_dto.LogSour } func (i *imlLogModule) OnComplete() { - drivers := log_driver.Drivers() - if len(drivers) < 1 { - return - } - ctx := context.Background() - for _, driver := range drivers { - factory, has := log_driver.GetFactory(driver) - if !has { - log_print.Errorf("driver %s not found", driver) - continue - } - info, err := i.service.GetLogSource(ctx, driver) - if err != nil { - log_print.Errorf("get log source %s error: %s", driver, err) - continue - } - d, _, err := factory.Create(info.Config) - if err != nil { - log_print.Errorf("create driver %s error: %s,config: %s", driver, err, info.Config) - continue - } - log_driver.SetDriver(driver, d) - } + } func (i *imlLogModule) initGateway(ctx context.Context, clusterId string, clientDriver gateway.IClientDriver) error { diff --git a/service/log/iml.go b/service/log/iml.go index 9943a15a..f514dc31 100644 --- a/service/log/iml.go +++ b/service/log/iml.go @@ -5,6 +5,8 @@ import ( "errors" "time" + log_print "github.com/eolinker/eosc/log" + "github.com/google/uuid" log_driver "github.com/APIParkLab/APIPark/log-driver" @@ -25,7 +27,29 @@ type imlLogService struct { } func (i *imlLogService) OnComplete() { - + drivers := log_driver.Drivers() + if len(drivers) < 1 { + return + } + ctx := context.Background() + for _, driver := range drivers { + factory, has := log_driver.GetFactory(driver) + if !has { + log_print.Errorf("driver %s not found", driver) + continue + } + info, err := i.GetLogSource(ctx, driver) + if err != nil { + log_print.Errorf("get log source %s error: %s", driver, err) + continue + } + d, _, err := factory.Create(info.Config) + if err != nil { + log_print.Errorf("create driver %s error: %s,config: %s", driver, err, info.Config) + continue + } + log_driver.SetDriver(driver, d) + } } func (i *imlLogService) UpdateLogSource(ctx context.Context, driver string, input *Save) error {